日期:2014-05-18  浏览次数:20929 次

多线程操纵数据库 希望大家给一些意见
想用多线程来控制数据库的操作,但思路不是很清析,不知道多线程是否会提高效率,在网上找例子又几乎没有。针对下面几个问题,希望大家给出意见,并希望大家给出更好的思路。
多线程操纵数据库有没有必要?
我是否应该有四个线程就够了,一个SELECT,一个DROP,一个UPDATE,一个INSERT?或者更多个,当进程过多时我是否需要控制数量。
连接用完是关闭还是一直打开?
方法用不用加锁?
还应该注意什么?
希望大家多给宝贵意见
我用的是.NET2.0 SQL2000/2005


------解决方案--------------------
有必要?
------解决方案--------------------
我个人认为:

1.有必要用多线程,毕竟会提高程序运行效率,特别是在数据较大时,用线程不会让用户感觉到程序正在处理数据,而不能响应用户的操作.

2.我认为有一个线程就够了,如果线程过多,那数据的一至性和并发处理将会是一大难点.

3.连接一直开着,至到所有的程序都不再用连接时再关闭.如果是用完就关闭,那样将会给程序的性能带来比较大的影响.

4.应该加锁,那样出现并发的机率又降低了.

另外,我觉得应多用事务和存储过程,事务具有(完整性,一至性,持久性)这都是优点,有优点为什么我们不用.存储过程是数据库预编译好了的,用起来速度将会比用sql语句好得多.由其是在有数据计算时.
------解决方案--------------------
如果这四个东西互相不会LOCK的话 而且你的数据库够强的话 应该会提高效率吧
------解决方案--------------------
个人觉得:
1.如果只是查询,如果你的程序并发访问量很大,我觉得有必要用多线程,但如果通过现有的一些优化的方法可以解决问题,建议不用多线程,毕竟并发访问需要控制的东西很多,一个小失误都会成为瓶颈,反而得不偿失。
2.如果是事务要求严格的应用,不建议多线程,大并发量的处理将浪费过多的服务器资源,而程序如果这方面做的不好,所有的连接都会出于等待状态,占着茅坑不拉屎,没意义,况且现在都有连接池技术,控制好就可以,没必要自己重新造轮子,搞好了就什么都不说了,搞不好了别想奥运门票事件就不好了。
3.对于DML不建议多线程,死锁问题,并发的时候很难搞的很难搞。
4.说下对3楼的存储过程想法的不同见解,如果你的程序不大,创建的视图,索引,存储过程不多,无所谓,但你的程序很大,创建了N多以上说的预编译的什么的东西,如果你公司负责数据维护的人比较忠诚还好,一旦跳槽现象很频繁,接手交接问题,以及对新手培训的费用将大大增加,而且连带问题多多。所以我的建议是:能SQL语句搞定的,尽量SQL语句搞。
------解决方案--------------------
要注意一下几点
1.多线程访问数据库有必要
2多线程访问数据库线程的数量要受到控制
3每个线程都可以做SELECT,DROP,UPDATE,INSERT
4 数据库数据写入要用事务
5 数据库数据写入表的顺序要保持一致
完成这样要求的具体代码是:
C# code

using System;
using Server;
using PublicControl.Run;
using PublicControl.DataBas;
using System.Data;
using System.Data.SqlClient;

namespace Server.RUN
{
    /// <summary>
    /// RunApp 服务器执行的虚拟类
    /// </summary>
    public abstract class RunApp
    {
        /// <summary>
        /// 使用本服务的用户
        /// </summary>
        protected OnlineUser onlineUser=new OnlineUser();
        /// <summary>
        /// 运行参数
        /// </summary>
        protected RunParam runParam;
        /// <summary>
        /// 共享服务提供类
        /// </summary>
        protected PublicServer publicServer;    
        /// <summary>
        /// 数据库应用对象
        /// </summary>
        protected DataBasAPP dataBasAPP;
        /// <summary>
        /// 是否继续运行
        /// </summary>
        protected bool fContinueRUN=true;
        
        /// <summary>
        /// 挑选需要处理的数据
        /// </summary>
        protected virtual void SecurityCheck()
        {
            OnlineUserCache temp=(OnlineUserCache)this.publicServer[onlineUser.GetType().FullName];    
            OnlineUser user=temp.GetData(runParam.UserID,null);
            if(user==null)
            {
                runParam.Error=true;
                runParam.ErrorInfo="您没有登陆系统请登陆后在做操作.";    
                return;
            }
            if(user.SecurityPassword!=runParam.SecurityCheck)
            {
                runParam.Error=true;
                runParam.ErrorInfo="信任关系校验失败,请重新登陆.\n很有可能是您又在其它地方登陆了.";    
                return;
            }
            onlineUser=user;
            user.UserWorkTime=DateTime.Now;
        }
        /// <summary>
        /// 挑选需要处理的数据
        /// </summary>
        protected abstract void SelectDataList();
        /// <summary>
        /// 开始预处理
        /// </summary>
        protected abstract void BeginRUNList();
        /// <summary>
        /// 处理结束收尾.
        /// </summary>
        protected abstract void EndRUNList();
        /// <summary>
        /// 更新数据库
        /// </summary>
        protected abstract void UpDataList();
        /// <summary>
        /// 是否继续运行
        /// </summary>
        protected bool Continue