黑马程序员技术交流社区

标题: 解析如何正确使用SqlConnection的实现方法 [打印本页]
作者: 蒋元龙    时间: 2013-9-23 16:57
标题: 解析如何正确使用SqlConnection的实现方法
以前曾见过有人这样写代码：

  2. public class Service1 : IService1
  3.     {
  4.         private SqlConnection conn = new SqlConnection();
  5.         public void Method1()
  6.         {
  7.             //do something with conn;
  8.         }
  9.         public void Method2()
  10.         {
  11.             //do something with conn;
  12.         }
  13.         public void Method3()
  14.         {
  15.             //do something with conn;
  16.         }
  17.         public void Method4()
  18.         {
  19.             //do something with conn;
  20.         }
  21.     }
复制代码
在服务类中，新建一个全局的conn对象，然后使用conn对象来操作数据库。
当然，还有一些不同的版本，比如：

  2. private SqlConnection conn = new SqlConnection();
  3. private static SqlConnection sconn = new SqlConnection();
  4. private SqlConnection Conn
  5. {
  6.     get { return new SqlConnection(); }
  7. }
复制代码
如果有人问你哪种方式比较好，你会怎么回答？

首先验证下在多线程环境下使用一个Connection的方式：
创建控制台程序:
Main代码如下：

  2. public static void Main()
  3. {
  4.     string connectionString = @"Data Source=.\SQLEXPRESS;
  5.                                 AttachDbFilename=""E:\DB\NORTHWND.mdf"";
  6.                                 Integrated Security=True;
  7.                                 Connect Timeout=30;User Instance=True";
  8.     string connectionStringNoPooling = connectionString + " ;Pooling='false' ";
  9.     SqlConnection conn = new SqlConnection(connectionString);
  10.     new Thread(() => { ExecuteCommand(conn); }) { Name = "t1" }.Start();
  11.     new Thread(() => { ExecuteCommand(conn); }) { Name = "t2" }.Start();
  12. }
  13. public static void ExecuteCommand(SqlConnection conn)
  14. {
  15.     Console.WriteLine("Thread:{0},{1}", Thread.CurrentThread.Name, DateTime.Now);

  17.     conn.Open();

  19.     SqlCommand command = new SqlCommand("select * from customers", conn);
  20.     command.ExecuteNonQuery();
  21.     command.Dispose();
  22.     Thread.Sleep(5000); //模拟耗时的查询
  23.     conn.Close();
  24.     Console.WriteLine("Thread:{0} 执行完毕,{1}", Thread.CurrentThread.Name, DateTime.Now);
  25. }
复制代码
代码很简单，模拟两个线程同时执行ExecuteCommand.方法。结果如下：




可以知道在多线程环境下使用一个Connection来执行Sql语句是不安全的，

修改Main函数如下：将一个Connection，改为多个Connection

  2. public static void Main()
  3. {
  4.     string connectionString = @"Data Source=.\SQLEXPRESS;
  5.                                 AttachDbFilename=""E:\DB\NORTHWND.mdf"";
  6.                                 Integrated Security=True;
  7.                                 Connect Timeout=30;User Instance=True";
  8.     string connectionStringNoPooling = connectionString + " ;Pooling='false' ";
  9.     //SqlConnection conn = new SqlConnection(connectionString);
  10.     //new Thread(() => { ExecuteCommand(conn); }) { Name = "t1" }.Start();
  11.     //new Thread(() => { ExecuteCommand(conn); }) { Name = "t2" }.Start();
  12.     SqlConnection conn1 = new SqlConnection(connectionString);
  13.     SqlConnection conn2 = new SqlConnection(connectionString);
  14.     new Thread(() => { ExecuteCommand(conn1); }) { Name = "t1" }.Start();
  15.     new Thread(() => { ExecuteCommand(conn2); }) { Name = "t2" }.Start();
  16.     Console.ReadLine();
  17. }
复制代码
运行结果如下：



既然多个Connection比一个Connection要好，

为什么还是有人使用上面的那种写法来创建Connection呢？

我认为他们可能会认为创建多个Connection比较耗时，而且多个Connection会占用内存，影响性能等等。。

在这一点上可以使用测试数据来说明：

测试数据来自：Connection-Pooling vs. Reusing one connection


Run #：1代表1000次查询，2代表2000次查询

NCP ：Not Connection Pool ,未启用数据库连接池

CP ：Connection Pool，启用数据库连接池

OC ：One Connection,一个连接对象

从图表可以发现启用了连接池的方式并不比重用一个连接慢多少。

但是从稳定性，程序的健壮性来说，CP的方式明显的好于OC。

所以下次实现服务，或者是查询的时候完全可以使用

  2. public SqlConnection Connection
  3. {
  4.     get
  5.     {
  6.         return new SqlConnection(@"...");
  7.     }
  8. }
复制代码
而不要
private SqlConnection conn = new SqlConnection(connectionString);







欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2