zoukankan      html  css  js  c++  java
  • 蛙蛙推荐:改进了一个DBAccess类,顺便说说啥是线程安全

    改进了一个DBAccess类,顺便说说啥是线程安全
    原文:
    我的DbHelper数据操作类
    http://www.cnblogs.com/fanrong/archive/2007/04/25/726526.html
    源码下载地址
    https://files.cnblogs.com/onlytiancai/WawaDbAccess.rar
    修改如下
    加了一个参数帮助类,如下,从旧版petshop拆出来的,功能是缓存每个命令的参数。
    经测试,代码一行也不用改,只改配置文件,在access和sqlserver2005下都能通过。
    public class DbParametersHelper
    {
        
    private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable());
        
    public static void CacheParameters(string cacheKey, params DbParameter[] cmdParms)
        {
            parmCache[cacheKey] 
    = cmdParms;
        }

        
    public static DbParameter[] GetCachedParameters(string cacheKey)
        {
            DbParameter[] cachedParms 
    = (DbParameter[])parmCache[cacheKey];

            
    if (cachedParms == null)
                
    return null;

            DbParameter[] clonedParms 
    = new DbParameter[cachedParms.Length];

            
    for (int i = 0, j = cachedParms.Length; i < j; i++)
                clonedParms[i] 
    = (DbParameter)((ICloneable)cachedParms[i]).Clone();

            
    return clonedParms;
        }
    }

    DbHelper类里加了两个方法,如下,功能分别是把参数缓存起来和从缓存里初始化参数
    public void CachedParameters(DbCommand cmd)
    {
        DbParameterCollection paramColl 
    = cmd.Parameters;
        DbParameter[] parms 
    = new DbParameter[paramColl.Count];
        
    for (int i = 0; i < paramColl.Count; i++)
        {
            parms[i] 
    = paramColl[i];
        }

        DbParametersHelper.CacheParameters(
            
    string.Format("{0}{1}", cmd.Connection.ConnectionString, cmd.CommandText),
            parms);
    }

    public bool initParametersFromCache(DbCommand cmd)
    {
        DbParameter[] parms 
    = DbParametersHelper.GetCachedParameters(
            
    string.Format("{0}{1}", cmd.Connection.ConnectionString, cmd.CommandText));
        
    if (parms == null)
            
    return false;
        
    for (int i = 0; i < parms.Length; i++)
        {
            cmd.Parameters.Add(parms[i]);
        }
        
    return true;
    }

    使用如下
    class Program
    {
        
    const string ADD_USER_SQL = "insert into U_Users([userid],[username],[nickname],[password],[hashpassword],[createdate],[createdip],[status])" +
            
    "values(@userid,@username,@nickname,@password,@hashpassword " +
            
    ",@createdate,@createip,0)";
        
    public static void AddUser(string username, string password, string nickname, string createip)
        {
            DbHelper db 
    = new DbHelper();
            DbCommand cmd 
    = db.GetSqlStringCommond(ADD_USER_SQL);
            
    if (db.initParametersFromCache(cmd))
            {
                cmd.Parameters[
    0].Value = 1;
                cmd.Parameters[
    1].Value = username;
                cmd.Parameters[
    2].Value = nickname;
                cmd.Parameters[
    3].Value = password;
                cmd.Parameters[
    4].Value = password;
                cmd.Parameters[
    5].Value = DateTime.UtcNow;
                cmd.Parameters[
    6].Value = createip;
            }
            
    else
            {
                db.AddInParameter(cmd, 
    "@userid", DbType.Int32, 1);
                db.AddInParameter(cmd, 
    "@username", DbType.String, username);
                db.AddInParameter(cmd, 
    "@nickname", DbType.String, nickname);
                db.AddInParameter(cmd, 
    "@password", DbType.String, password);
                db.AddInParameter(cmd, 
    "@hashpassword", DbType.String, password);
                db.AddInParameter(cmd, 
    "@createdate", DbType.Date, DateTime.UtcNow);
                db.AddInParameter(cmd, 
    "@createip", DbType.String, createip);
                db.CachedParameters(cmd);
            }
            db.ExecuteNonQuery(cmd);
        }

        
    static void Main(string[] args)
        {
            
    try
            {
                AddUser(
    "onlytiancai""##$%&SDF""蛙蛙王子""192.168.0.1");
                AddUser(
    "tiancai""3234234""水然枫林醉""192.168.0.23");
                Console.WriteLine(
    "ok");
            }
            
    catch (Exception ex)
            {
                Console.WriteLine(ex);
            }
            Console.Read();
        }
    }

    sqlserver的配置
      <appSettings>
        
    <add key="DbHelperProvider" value="System.Data.SqlClient"/>
        
    <add key="DbHelperConnectionString" value="Data Source=."SQLEXPRESS;AttachDbFilename=H:"KM_SVN"sync"src"db"KM.mdf;Integrated Security=True;Connect Timeout=30;User Instance=True"/>
      
    </appSettings>

    access的配置
    <appSettings>
      
    <add key="DbHelperProvider" value="System.Data.OleDb"/>
      
    <add key="DbHelperConnectionString" value="Provider=Microsoft.Jet.OLEDB.4.0;Data Source=H:"KM_SVN"sync"src"db"km.mdb;Persist Security Info=False"/>
    </appSettings>

    sqlserver的建表脚本
    CREATE TABLE [dbo].[U_Users](
        
    [UserID] [int] NOT [UserID] [int] NOT NULL,
    NULL,
        
    [Username] [varchar](16) COLLATE Chinese_PRC_CI_AS NOT NULL,
        
    [Nickname] [nvarchar](16) COLLATE Chinese_PRC_CI_AS NOT NULL,
        
    [Password] [varchar](16) COLLATE Chinese_PRC_CI_AS NOT NULL,
        
    [HashPassword] [varchar](50) COLLATE Chinese_PRC_CI_AS NOT NULL,
        
    [CreateDate] [datetime] NOT NULL CONSTRAINT [DF_U_Users_CreateDate]  DEFAULT (getdate()),
        
    [CreatedIP] [varchar](32) COLLATE Chinese_PRC_CI_AS NOT NULL,
        
    [LastLoginIp] [varchar](32) COLLATE Chinese_PRC_CI_AS NULL,
        
    [LastLoginTime] [datetime] NULL CONSTRAINT [DF_U_Users_LastLoginTime]  DEFAULT (getdate()),
        
    [Status] [tinyint] NOT NULL CONSTRAINT [DF_U_Users_Status]  DEFAULT ((0))
    ON [PRIMARY]

    access的表结构
    [Username]    数字
    [Nickname] 文本
    [Password] 文本
    [HashPassword]    文本
    [CreateDate]    日期
    /时间
    [CreatedIP]    文本
    [LastLoginIp]    文本
    [LastLoginTime]    日期
    /时间
    [Status]    数字

    原文的链接里有个朋友说DbHelper类每个方法都没有考虑线程安全性,我想了半天也没看出哪儿有问题来,不知道如何改进那个类在多线程下的表现。如frankroast所说:
    【我们说一个方法是否是线程安全的,判断的标准只有一个,这个方法是否访问了 可以写的“成员变量”。(所谓的state)
    注意,只有两个条件:(1)可以改变的 (2)成员变量
    如果访问了可以写的“成员变量”,那么这个方法不是 线程安全的。
    如果没有访问 可以写的“成员变量”,那么这个方法是 线程安全的。】

    dbhelper的类只有3个变量,dbProviderName,dbConnectionString和connection都可以声明为readonly,它本身的方法,无论静态的还是非静态的都没有访问可写的静态变量和全局变量,我觉得多线程下也应该是安全的。

    另如lithium所说:
    【1.静态方法如果会更改静态的成员变量,为了线程安全,同样需要同步,只不过这时获得的不是对象实例的锁,而是该类的class对象的锁
    2.如果实例方法不会更改对象的状态,静态方法不更改静态的成员变量,那么方法就是可重入方法,也就是线程安全的。】


    dbhelper也没有违反这两条,还是不需要加锁。

    david又说了一下原理
    【关于线程安全:
    如果某函数是不可重入的,则它不是线程安全的!
    至于是否可重入,就可以根据这个函数是否使用了静态存储的数据判断了!

    从语意上说,静态存储数据包括全局变量和局部静态变量,它们都是存储在堆上的.而线程间是共享同一进程空间的,所以它们共享相同的静态存储数据, 所以...
    对于可重入函数来说,如果下一次函数调用对上一次调用产生影响的话,那么该函数就是不可重入函数了.

    他这里说的下一次函数调用对上一次调用产生影响是什么意思呀,也没举个例子。我理解的是一个方法第一次调用还没有结束的时候,另一个线程也调用了这个方法,并且改变了第一次调用所访问的类成员(无论静态成员还是实例成员),如果第一次调用里已经认为全局成员A的值为1,并进入一个if语句,而另一个线程里却把全局成员A的值改成0了,这样第一次调用里的逻辑就不对了,或者第一次的if语句里把全局成员A的值改成3了,那另一个线程里把A的值改成1的操作就丢失了。这里没写代码来做示例,也没画图说明一下,但大家应该能理解,有点像sqlserver的事务。
    最后我得出的结论如下,不知道对不对:
    1、把一个类里的所有非readonly的成员,都为其声明一个object的锁对象,锁对象的可访问性和非readonly成员的可访问性一样,成员是public,锁也是public,成员是private,锁也是private,成员是static,锁也是static。然后凡是有需要访问该成员的方法,无论是读取还是修改,无论是本类自己的方法,还是外面的类的方法,都在访问成员的代码外层用lock括起来,lock的对象就是为该成员单独创建的那个object的锁。这样多线程就不会出问题了。

    msdn里明确说过,不要lock(this),lock(值类型),lock(字符串),lock(typeof(this))等,所以最好就是为每个非readonly的成员分配一个锁。大家对此解决方案有啥不同意见,给指正一下,比如说锁太大,有些没必要等,说一下理由。
    忘了贴参考链接了,不好意思
    在多线程中使用静态方法是否有线程安全问题
    http://blog.csdn.net/scucj/archive/2006/11/18/1394523.aspx
    这种静态方法有线程安全问题吗? 
    http://www.javaeye.com/t/14315.html
    方法的线程安全(静态方法调用问题2)
    http://blog.csdn.net/frankroast/archive/2005/03/25/330379.aspx
    锁住局部静态变量确保线程安全
    http://blog.joycode.com/ninputer/archive/2004/08/26/31633.aspx
    .NET中静态变量的使用需要注意线程安全问题
    http://www.cnblogs.com/hhh/archive/2007/01/31/636299.html
    线程,同步与锁————Lock你到底锁住了谁
    http://www.cnblogs.com/city22/archive/2007/01/30/634948.html
    再论线程安全,关键字(C#,.Net,Cache,线程安全)
    http://www.lukiya.com/Blogs/2007/07/27/Post-561.html
    HashTable的线程安全性
    http://www.cnblogs.com/idior/archive/2005/04/01/130095.html
  • 相关阅读:
    Linux autojump命令
    Linux rpmbuild命令
    RPM包制作教程
    LSP(分层服务提供程序)
    WPAD 的原理及实现
    在OpenSSL中添加自定义加密算法
    Openssl sess_id命令
    hdu1878欧拉回路(DFS+欧拉回路)
    好代码的伪科学定义
    MySQL安装过程中出现“APPLY security settings错误”的解决方式
  • 原文地址:https://www.cnblogs.com/onlytiancai/p/895029.html
Copyright © 2011-2022 走看看