1. 使用SqlConnection对象连接SQL Server数据库
2. 打开和关闭数据库连接
3. 连接池
4. ASP.NET 2.0中连接字符串的设置
本文将详细介绍如何使用Connection对象连接数据库。对于不同的.NET数据提供者,ADO.NET采用不同的Connection对象连接数据库。这些Connection对象为我们屏蔽了具体的实现细节,并提供了一种统一的实现方法。
Connection类有四种:SqlConnection,OleDbConnection,OdbcConnection和OracleConnection。
SqlConnection类的对象连接SQL Server数据库;OracleConnection 类的对象连接Oracle数据库;
OleDbConnection类的对象连接支持OLE DB的数据库,如Access;而OdbcConnection类的对象连接任何支持ODBC的数据库。与数据库的所有通讯最终都是通过Connection对象来完成的。
SqlConnection类
Connection 用于与数据库“对话”,并由特定提供程序的类(如 SqlConnection)表示。尽管SqlConnection类是针对Sql Server的,但是这个类的许多属性、方法与事件和OleDbConnection及OdbcConnection等类相似。本章将重点讲解SqlConnection特定的属性与方法,其他的Connection类你可以参考相应的帮助文档。
注意:使用不同的Connection对象需要导入不同的命名空间。OleDbConnection的命名空间为System.Data.OleDb。SqlConnection的命名空间为System.Data.SqlClient。OdbcConnection的命名空间为System.Data.Odbc。OracleConnection的命名空间为System.Data.OracleClinet。
SqlConnection属性:
| 属性 | 说明 |
| ConnectionString | 其返回类型为string,获取或设置用于打开 SQL Server 数据库的字符串。 |
| ConnectionTimeOut | 其返回类型为int,获取在尝试建立连接时终止尝试并生成错误之前所等待的时间。 |
| Database | 其返回类型为string,获取当前数据库或连接打开后要使用的数据库的名称。 |
| DataSource | 其返回类型为string,获取要连接的 SQL Server 实例的名称。 |
| State | 其返回类型为ConnectionState,取得当前的连接状态:Broken、Closed、Connecting、Fetching或Open。 |
| ServerVersion | 其返回类型为string,获取包含客户端连接的 SQL Server 实例的版本的字符串。 |
| PacketSize | 获取用来与 SQL Server 的实例通信的网络数据包的大小(以字节为单位)。这个属性只适用于SqlConnection类型 |
SqlConnection方法:
| 方法 | 说明 |
| Close() | 其返回类型为void,关闭与数据库的连接。 |
| CreateCommand() | 其返回类型为SqlCommand,创建并返回一个与 SqlConnection 关联的 SqlCommand 对象。 |
| Open() | 其返回类型为void,用连接字符串属性指定的属性打开数据库连接 |
| 事件 | 说明 |
| StateChange | 当事件状态更改时发生。 (从 DbConnection 继承。) |
| InfoMessage | 当 SQL Server 返回一个警告或信息性消息时发生。 |
提示:可以用事件让一个对象以某种方式通知另一对象产生某些事情。例如我们在Windows系统中选择“开始”菜单,一旦单击鼠标时,就发生了一个事件,通知操作系统将“开始”菜单显示出来。
使用SqlConnection对象连接SQL Server数据库
我们可以用SqlConnection()构造函数生成一个新的SqlConnection对象。这个函数是重载的,即我们可以调用构造函数的不同版本。SqlConnection()的构造函数如下表所示:
| 构造函数 | 说明 |
| SqlConnection () | 初始化 SqlConnection 类的新实例。 |
| SqlConnection (String) | 如果给定包含连接字符串的字符串,则初始化 SqlConnection 类的新实例。 |
| SqlConnection mySqlConnection = new SqlConnection(); |
| string connectionString="server=localhost;database=Northwind; integrated security=SSPI"; |

| string connectionString = "server=localhost;database=Northwind;uid=sa;pwd=sa"; |

| string connectionString = "data source=localhost;initial catalog=Sales; use id=sa;password=;provider=MSDAORA"; |
| string connectionString = "provider=Microsoft.Jet.OLEDB.4.0; @”data source=c:\DataSource\Northwind.mdb”; |
| string connectionString = "server=localhost;database=Northwind;uid=sa;pwd=sa"; SqlConnection mySqlConnection = new SqlConnection(connectionString); |
| SqlConnection mySqlConnection =new SqlConnection( "server=localhost;database=Northwind;uid=sa;pwd=sa"); |
| SqlConnection mySqlConnection = new SqlConnection(); mySqlConnection.ConnectionString = "server=localhost;database=Northwind;uid=sa;pwd=sa"; |
打开和关闭数据库连接
生成Connection对象并将其设置ConnectionString属性设置为数据库连接的相应细节之后,就可以打开数据库连接。为此可以调用Connection对象的Open()方法。其方法如下:
| mySqlConnection.Open(); |
| mySqlConnection.Close(); |
| 01 public partial class _Default : System.Web.UI.Page 02 { 03 protected void Page_Load(object sender, EventArgs e) 04 { 05 //建立数据库连接字符串 06 string connectionString = "server=localhost;database=Northwind; 07 integrated security=SSPI"; 08 //将连接字符串传入SqlConnection对象的构造函数中 09 SqlConnection mySqlConnection = new SqlConnection(connectionString); 10 try 11 { 12 //打开连接 13 mySqlConnection.Open(); 14 //利用label控件显示mySqlConnection对象的ConnectionString属性 15 lblInfo.Text = "<b>mySqlConnection对象的ConnectionString属性为:<b>" + 16 mySqlConnection.ConnectionString + "<br>"; 17 lblInfo.Text += "<b>mySqlConnection对象的ConnectionTimeout属性为<b>" + 18 mySqlConnection.ConnectionTimeout + "<br>"; 19 lblInfo.Text += "<b>mySqlConnection对象的Database属性为<b>" + 20 mySqlConnection.Database + "<br>"; 21 lblInfo.Text += "<b>mySqlConnection对象的DataSource属性为<b>" + 22 mySqlConnection.DataSource + "<br>"; 23 lblInfo.Text += "<b>mySqlConnection对象的PacketSize属性为<b>" + 24 mySqlConnection.PacketSize + "<br>"; 25 lblInfo.Text += "<b>mySqlConnection对象的ServerVersion属性为<b>" + 26 mySqlConnection.ServerVersion + "<br>"; 27 lblInfo.Text += "<b>mySqlConnection对象的当前状态为<b>" + 28 mySqlConnection.State + "<br>"; 29 } 30 catch (Exception err) 31 { 32 lblInfo.Text = "读取数据库出错"; 33 lblInfo.Text += err.Message; 34 } 35 finally 36 { 37 //关闭与数据库的连接 38 mySqlConnection.Close(); 39 lblInfo.Text += "<br><b>关闭连接后的mySqlConnection对象的状态为:</b>"; 40 lblInfo.Text += mySqlConnection.State.ToString(); 41 } 42 } 43 } |
| 01 public partial class _Default : System.Web.UI.Page 02 { 03 protected void Page_Load(object sender, EventArgs e) 04 { 05 string connectionString = "server=localhost;database=Northwind; 06 integrated security=SSPI"; 07 SqlConnection mySqlConnection = new SqlConnection(connectionString); 08 using (mySqlConnection) 09 { 10 mySqlConnection.Open(); 11 lblInfo.Text = "<b>mySqlConnection对象的ConnectionString属性为:<b>" + 12 mySqlConnection.ConnectionString + "<br>"; 13 lblInfo.Text += "<b>mySqlConnection对象的ConnectionTimeout属性为<b>" + 14 mySqlConnection.ConnectionTimeout + "<br>"; 15 lblInfo.Text += "<b>mySqlConnection对象的Database属性为<b>" + 16 mySqlConnection.Database + "<br>"; 17 lblInfo.Text += "<b>mySqlConnection对象的DataSource属性为<b>" + 18 mySqlConnection.DataSource + "<br>"; 19 lblInfo.Text += "<b>mySqlConnection对象的PacketSize属性为<b>" + 20 mySqlConnection.PacketSize + "<br>"; 21 lblInfo.Text += "<b>mySqlConnection对象的ServerVersion属性为<b>" + 22 mySqlConnection.ServerVersion + "<br>"; 23 lblInfo.Text += "<b>mySqlConnection对象的当前状态为<b>"+ 24 mySqlConnection.State + "<br>"; 25 } 26 lblInfo.Text += "<br><b>关闭连接后的mySqlConnection对象的状态为:</b>"; 27 lblInfo.Text += mySqlConnection.State.ToString(); 28 } 29 } |
连接池
打开与关闭数据库都是比较耗时的。为此,ADO.NET自动将数据库连接存放在连接池中。连接池可以大幅度提高程序的性能和效率,因为我们不必等待建立全新的数据库连接过程,而是直接利用现成的数据库连接。注意,利用Close()方法关闭连接时,并不是实际关闭连接,而是将连接标为未用,放在连接池中,准备下一次复用。
如果在连接字符串中提供相同的细节,即相同的数据库,用户名,密码等等,则可以直接取得并返回池中的连接。然后可以用这个连接访问数据库。
使用SqlConnection对象时,可以在连接字符串中指定max pool size,表示连接池允许的最大连接数(默认为100),也可以指定min pool size表示连接池允许的最小连接数(默认为0)。下面的代码指定了SqlConnection对象的max pool size为10,min pool size为5。
| SqlConnection mySqlConnection = new SqlConnection("server=localhost;database=Northwind; integrated security=SSPI;"+"max pool size=10;min pool size=5"); |
| 01 public partial class _Default : System.Web.UI.Page 02 { 03 protected void Page_Load(object sender, EventArgs e) 04 { 05 //设置连接池的最大连接数为5,最小为1 06 SqlConnection mySqlConnection =new SqlConnection( 07 "server=localhost;database=Northwind;integrated security=SSPI;"+ 08 "max pool size=5;min pool size=1"); 09 //新建一个StringBuilder对象 10 StringBuilder htmStr = new StringBuilder(""); 11 for (int count = 1; count <= 5; count++) 12 { 13 //使用Append()方法追加字符串到StringBuilder对象的结尾处 14 htmStr.Append("连接对象 "+count); 15 htmStr.Append("<br>"); 16 //设置一个连接的开始时间 17 DateTime start = DateTime.Now; 18 mySqlConnection.Open(); 19 //连接所用的时间 20 TimeSpan timeTaken = DateTime.Now - start; 21 htmStr.Append("连接时间为 "+timeTaken.Milliseconds+"毫秒"); 22 htmStr.Append("<br>"); 23 htmStr.Append("mySqlConnection对象的状态为" + mySqlConnection.State); 24 htmStr.Append("<br>"); 25 mySqlConnection.Close(); 26 } 27 //将StringBuilder对象的包含的字符串在label控件中显示出来 28 lblInfo.Text = htmStr.ToString(); 29 } 30 } |
ASP.NET 2.0中连接字符串的设置
在ASP.NET 2.0中,使用了一种在运行时解析为连接字符串值的新的声明性表达式语法,按名称引用数据库连接字符串。连接字符串本身存储在 Web.config 文件中的 <connectionStrings> 配置节下面,以便易于在单个位置为应用程序中的所有页进行维护。
范例程序代码如下:
| <?xml version="1.0"?> <configuration> <connectionStrings> <add name="Pubs" connectionString="Server=localhost; Integrated Security=True;Database=pubs;Persist Security Info=True" providerName="System.Data.SqlClient" /> <add name="Northwind" connectionString="Server=localhost; Integrated Security=True;Database=Northwind;Persist Security Info=True" providerName="System.Data.SqlClient" /> </connectionStrings> <system.web> <pages styleSheetTheme="Default"/> </system.web> </configuration> |
| string connectionString =ConfigurationManager.ConnectionStrings["Northwind"].ConnectionString; |