一聚教程网:一个值得你收藏的教程网站

热门教程

SqlConnection对象及数据库连接池

时间:2022-06-25 06:03:48 编辑:袖梨 来源:一聚教程网

第一段码很简洁,但是很多人包括我自己忍不住都会有几个重大疑问:

1、怎么并行操作n多次数据库教程只共用一个连接对象呢?

2、并行处理的地方加了锁,每次进行数据库操作都要Lock一下(我感觉这根本没有发挥多线程并行处理的优势,个人认为还不如单线程执行的快呢),这个真的有这个必要吗?

3、同一个数据库连接字符串,使用数据库连接对象SqlConnection怎么还要传参呢,显式Open和Close不是更好吗?通常不都是using一下完事吗?
下面我们先看代码
string sqlConnString = @"Data Source=.SQLEXPRESS;
     AttachDbFilename=""E:DBNORTHWND.mdf"";
     Integrated Security=True;Connect Timeout=30;User Instance=True";
 SqlConnection conn = new SqlConnection(sqlConnString);
 conn.Open();
 Parallel.For(1, Int32.MaxValue, (id) =>
 {
     ExecuteCommand(conn, id);
 });
其中,ExecuteCommand的具体实现如下:

private static object syncObj = new object();
private static void ExecuteCommand(SqlConnection conn, int id)
{
    lock (syncObj)
    {
        if (conn.State != ConnectionState.Open)
        {
            conn.Open();
        }
        Console.WriteLine("正在执行." + id);

        Thread.Sleep(100);

        SqlCommand cmd = new SqlCommand(
            string.Format("Insert into Nums values('{0}') ", id), conn);

        cmd.ExecuteNonQuery();
    }
}

 

经过简单思考之后,在本地机器上改进了一下实现代码进行测试,如下:

Parallel.For(1, Int32.MaxValue, (id) =>
  {
      ExecuteCommand(id);
  });
ExecuteCommand方法不再接受SqlConnection对象作为参数,去掉Lock,数据库操作看上去就像是操作一次数据库,打开一次数据库连接,保证线程安全:

private static void ExecuteCommand(int id)
{
    using (SqlConnection conn = new SqlConnection(sqlConnString))
    {
        conn.Open();
        Console.WriteLine("正在执行." + id);
        Thread.Sleep(100);
        SqlCommand cmd = new SqlCommand(
            string.Format("Insert into Nums values('{0}') ", id), conn);
        cmd.ExecuteNonQuery();
    }
}
当然ExecuteCommand也可以通过显式Open和Close处理:

private static void ExecuteCommand(int id)
{
    SqlConnection conn = new SqlConnection(sqlConnString);
    conn.Open();
    Console.WriteLine("正在执行." + id);
    Thread.Sleep(100);
    SqlCommand cmd = new SqlCommand(
        string.Format("Insert into Nums values('{0}') ", id), conn);
    cmd.ExecuteNonQuery();
    conn.Close();
}

据我的本地机器测试,上面改进后的两种写法数据库连接对象使用正常,线程安全,而且在性能上比加锁操作数据库提高显著,有兴趣的你也不妨一试。

 

热门栏目