第一段码很简洁,但是很多人包括我自己忍不住都会有几个重大疑问:
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();
}
据我的本地机器测试,上面改进后的两种写法数据库连接对象使用正常,线程安全,而且在性能上比加锁操作数据库提高显著,有兴趣的你也不妨一试。