一、简单介绍ADO.NET

System.Data：DataTable,DataSet,DataRow,DataColumn,DataRelation,Constraint

System.Data.Common（各种数据访问类的基类和接口）：DataColumnMapping,DataTableMapping

System.Data.SqlClient（对Sql Server进行操作的数据访问类）：

1)SqlConnection：数据库连接器

2)SqlCommand：数据库命名对象

3)SqlCommandBuilder：生存SQL命令

4)SqlDataReader：数据读取器

5)SqlDataAdapter：数据适配器，填充DataSet

6)SqlParameter：为存储过程定义参数

7)SqlTransaction：数据库事务

二、SqlConnection（连接对象） 

1、连接字符串

基本语法：数据源（Data Source）+数据库名称（Initial Catalog）+用户名（User ID）+密码（Password）。

说明：

（1）必须指定Sql Server支持的两种身份验证方法（即Windows身份验证和Sql Server身份验证）中的一种。要想使用Windows身份验证，必须在连接字符串中包括 Integrated Security 属性:Data Source=ServerName;Integrated Security=True;默认情况下，Integrated Security属性为False。

（2）连接字符串中可用的选项：

Application Name（应用程序名称）：应用程序的名称。如果没有被指定的话，它的值为.NET SqlClient Data Provider（数据提供程序）。

AttachDBFileName/extended properties（扩展属性）/Initial File Name（初始文件名）： 可连接数据库的主要文件的名称，包括完整路径名称。数据库名称必须用关键字数据库指定。

Connect Timeout（连接超时）/Connection Timeout（连接超时）：一个到服务器的连接在终止之前等待的时间长度（以秒计），缺省值为15。

Connection Lifetime（连接生存时间）： 当一个连接被返回到连接池时，它的创建时间会与当前时间进行对比。如果这个时间跨度超过了连接的有效期的话，连接就被取消。其缺省值为0。

Connection Reset（连接重置）： 表示一个连接在从连接池中被移除时是否被重置。缺少值为真。

Current Language（当前语言）： SQL Server语言记录的名称。

Data Source（数据源）/Server（服务器）/Address（地址）/Addr（地址）/Network Address（网络地址）：SQL Server实例的名称或网络地址。

Encrypt（加密）：当值为真时，如果服务器安装了授权证书，SQL Server就会对所有在客户和服务器之间传输的数据使用SSL加密。被接受的值有true（真）、false（伪）、yes（是）和no（否）。

Enlist（登记）：表示连接池程序是否会自动登记创建线程的当前事务语境中的连接，其缺省值为真。

Database（数据库）/Initial Catalog（初始编目）：数据库的名称。

Integrated Security（集成安全）/Trusted Connection（受信连接）：表示Windows认证是否被用来连接数据库。它可以被设置成真、伪或者是和真对等的sspi，其缺省值为伪。

Max Pool Size（连接池的最大容量）： 连接池允许的连接数的最大值，其缺省值为100。

Min Pool Size（连接池的最小容量）： 连接池允许的连接数的最小值，其缺省值为0。

Network Library（网络库）/Net（网络）：用来建立到一个SQL Server实例的连接的网络库。支持的值包括： dbnmpntw (Named Pipes)、dbmsrpcn (Multiprotocol／RPC)、dbmsvinn(Banyan Vines)、dbmsspxn (IPX／SPX)和dbmssocn (TCP／IP)。协议的动态链接库必须被安装到适当的连接，其缺省值为TCP／IP。

Packet Size（数据包大小）：用来和数据库通信的网络数据包的大小。其缺省值为8192。

Password（密码）/Pwd：与帐户名相对应的密码。

Persist Security Info（保持安全信息）：用来确定一旦连接建立了以后安全信息是否可用。如果值为真的话，说明像用户名和密码这样对安全性比较敏感的数据可用，而如果值为伪则不可用。重置连接字符串将重新配置包括密码在内的所有连接字符串的值。其缺省值为伪。

Pooling（池）：确定是否使用连接池。如果值为真的话，连接就要从适当的连接池中获得，或者，如果需要的话，连接将被创建，然后被加入合适的连接池中。其缺省值为真。

User ID（用户ID）：用来登陆数据库的帐户名。

Workstation ID（工作站ID）：连接到SQL Server的工作站的名称。其缺省值为本地计算机的名称。

（3）例举典型连接字符串

1>SQL Server连接字符串

标准安全连接： 

Data Source=myServerAddress;Initial Catalog=myDataBase;User Id=myUsername;Password=myPassword;或者

Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;Trusted_Connection=False;

可信连接：

Data Source=myServerAddress;Initial Catalog=myDataBase;Integrated Security=SSPI;或者

Server=myServerAddress;Database=myDatabase;Trusted_Connection=True; 

2> Access连接字符串

Provider=Microsoft.Jet.OLEDB.4.0;Data Source=C:\myDatabase.mdb;User Id=admin;Password=;

3>MySQL连接字符串

Server=myServerAddress;Database=myDatabase;Uid=myUsername;Pwd=myPassword;

4>DB2连接字符串

Server=myAddress:myPortNumber;Database=myDatabase;UID=myUsername;PWD=myPassword;

5>Oracle连接字符串

Data Source=TORCL;User Id=myUsername;Password=myPassword; 

2、创建连接对象

SqlConnectionStringBuilder connectionStringBuilder = new SqlConnectionStringBuilder()
{
    DataSource = "",
    InitialCatalog = "",
    UserID = "",
    Password = ""
};
SqlConnection connection = new SqlConnection(connectionStringBuilder.ToString()); 

3、打开和关闭连接对象

using(SqlConnection connection = new SqlConnection(connectionStringBuilder.ToString()))
{
     connection.Open();
     connection.Close();
} 

4、连接池

（1）建立一个数据库连接是非常消耗时间和消耗资源的事情。ADO.NET提供了名为连接池的优化方法。连接池就是一个容器，它存放了一定数量的与数据库服务器的物理连接。因此，当我们需要连接数据库服务器的时候，只需去池（容器）中取出一条空闲的连接，而不是新建一条连接。这样的话，我们就可以大大减少连接数据库的开销，从而提高了应用程序的性能。

（2）连接池具有类别区分，同一个时刻同一应用程序域可以有多个不同类型的连接池。细致的讲，连接池是由进程、应用程序域、连接字符串以及windows标识（在使用集成的安全性时）共同组成签名来标识区分的。但对于同一应用程序域来说，一般只由连接字符串来标识区分。当打开一条连接时，如果该条连接的类型签名与现有的连接池类型不匹配，则创建一个新的连接池。反之，则不创建新的连接池。

例如：

//创建连接对象1
using (SqlConnection conn1 = new SqlConnection("DataSource=(local);Integrated Security=SSPI;Initial Catalog=Northwind"))    
{        
    conn1.Open();       
}


//创建连接对象2
using (SqlConnection conn2 = new SqlConnection("DataSource=(local);Integrated Security=SSPI;Initial Catalog=pubs"))   
{       
    conn2.Open();      
}


//创建连接对象3
using (SqlConnection conn3 = new SqlConnection("DataSource=(local);Integrated Security=SSPI;Initial Catalog=Northwind"))  
{        
    conn3.Open();      
} 

创建了三个SqlConnection对象，但是管理时只需要两个连接池。因为conn1与conn2的连接字符串相同，所有可以共享一个连接池。conn2与conn1,conn3不同，所以需要创建新的连接池。

（3）连接池行为可以通过连接字符串控制：

Connection Timeout：连接请求等待超时时间。默认为15秒。

Max Pool Size：连接池中最大连接数。默认为100。

Min Pool Size：连接池中最小连接数。默认为0。

Pooling：是否启用连接池。ADO.NET默认是启动的。

（4）使用T-SQL语句监视连接状态：exec sp_who

（5）高效使用连接池的基本原则：

     ● 在最晚的时刻申请连接，在最早的时刻释放连接。

     ● 关闭连接时先关闭相关用户定义的事务。

     ● 确保并维持连接池中至少有一个打开的连接。

三、SqlCommand（命令对象）

1、实例化的时候默认初始化的四个属性：

CommandText：空字符串（""） 

CommandTimeout：30

CommandType：CommandType.Text

Connection：Null

2、创建命令对象：

SqlCommand command=new SqlCommand(); 

3、几个重要的属性：

（1）CommandText：获取或设置要对数据源执行的 Transact-SQL 语句、表名或存储过程！

（2）CommandType：设置你执行的SQL语句是存储过程还是T-SQL(是一个枚举)！

● Text：SQL文本命令（默认）

  ● TableDirect：表的名称

（3）Parameters：设置你T-SQL中你需要用到的参数。

4、几个重要的方法：

（1）ExecuteNonQuery：返回是影响的行数(int)，主要执行更新，添加，删除等操作！

（2）ExecuteReader：执行SQL或存储过程，返回的是SqlDataReader类型，主要用来查询！

注意这个方法的重载CommandBehavior枚举，成员如下：

● Default：此查询可能返回多个结果集。执行查询可能会影响数据库状态。当不设置CommandBehavior标志时默认为Default。

● SingleResult：查询返回个结果集。

● SchemaOnly：查询仅返回列信息。当使用SchemaOnly时，用于SQL Server的.NET Framework数据提供程序将在要执行的语句前加上SET FMTONLY ON。

● KeyInfo：此查询返回列和主键信息。

● SingleRow： 查询应返回一行。

● SequentialAccess：提供一种方法，以便DataReader处理包含带有大量二进制值的列的行。SequentialAccess不是加载整行，而是使DataReader将数据作为流来加载。然后可以使用GetBytes或GetChars方法来指定开始读取操作的字节位置以及正在返回的数据的有限的缓冲区大小。

● CloseConnection：在执行该命令时，如果关闭关联的DataReader对象，则关联的Connection对象也将关闭。

（3）ExecuteScalar：返回执行结果集中的第一行第一列，如果没有数据，则返回NULL！

可能返回NULL值，需要对结果进行判断，如下：

object my = cmd.ExecuteScalar();
if (object.Equals(my,null))  //可以使用Equals进行Null值的判断，易读性强
  Console.WriteLine("Not Data");
else
  Console.WriteLine("Yes"); 

（4）CreateParameter：创建SqlParameter实例。 

5、异步执行命令：执行Command对象命令时，需要等待命令完成才能执行其他操作。比如，执行ExcuteNonQuery()方法，应用程序将会保持阻塞，直到数据操作成功完成或者异常终止以及连接超时。异步执行的根本思想是，在执行命令操作时，无需等待命令操作完成，可以并发的处理其他操作。ADO.NET提供了丰富的方法来处理异步操作，BeginExecuteNonQuery和EndExcuteNonQuery就是一对典型的为异步操作服务的方法。BeginExecuteNonQuery方法返回System.IAsyncResult接口对象。我们可以根据IAsyncResult的IsCompleted属性来轮询（检测）命令是否执行完成。

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Text;
 5 using System.Data;//必须引入
 6 using System.Data.SqlClient;//必须引入
 7 namespace Command
 8 {
 9     class Program
10     {
11         static void Main(string[] args)
12         {
13             SqlConnectionStringBuilder connStr = new SqlConnectionStringBuilder();
14             connStr.DataSource = @".\SQLEXPRESS";
15             connStr.IntegratedSecurity = true;
16             connStr.InitialCatalog = "db_MyDemo";
17             connStr.AsynchronousProcessing = true;//必须显示说明异步操作
18             StringBuilder strSQL = new StringBuilder();
19             //插入100个测试客户
20             for (int i = 1; i <= 500; ++i)
21             {
22                 strSQL.Append("insert into tb_SelCustomer ");
23                 strSQL.Append("values(‘");
24                 string name = "测试客户" + i.ToString();
25                 strSQL.Append(name);
26                 strSQL.Append("‘,‘0‘,‘0‘,‘13822223333‘,‘liuhaorain@163.com‘,‘广东省深圳市宝安区‘,12.234556,34.222234,‘422900‘,‘备注信息‘); ");
27             }
28             using (SqlConnection conn = new SqlConnection(connStr.ConnectionString))
29             {
30                 conn.Open();
31                 SqlCommand cmd = new SqlCommand(strSQL.ToString(), conn);
32                 IAsyncResult pending = cmd.BeginExecuteNonQuery();//开始执行异步操作
33                 double time = 0;
34                 //检查异步处理状态
35                 while (pending.IsCompleted == false)
36                 {
37                     System.Threading.Thread.Sleep(1);
38                     time++;
39                     Console.WriteLine("{0}s", time * 0.001);
40                 }
41                 if (pending.IsCompleted == true)
42                 {
43                     Console.WriteLine("Data is inserted completely...\nTotal coast {0}s", time * 0.001);
44                 }
45                 cmd.EndExecuteNonQuery(pending);//结束异步操作
46             }
47             Console.Read();
48         }
49     }
50 } 

View Code

6、如何获取插入行的ID

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Text;
 5 using System.Data;
 6 using System.Data.SqlClient;
 7 namespace Command2
 8 {
 9     class Program
10     {
11         static void Main(string[] args)
12         {
13             //构造连接字符串
14             SqlConnectionStringBuilder connStr = new SqlConnectionStringBuilder();
15             connStr.DataSource = @".\SQLEXPRESS";
16             connStr.IntegratedSecurity = true;
17             connStr.InitialCatalog = "db_MyDemo";
18             //拼接SQL语句
19             StringBuilder strSQL = new StringBuilder();
20             strSQL.Append("insert tb_SelCustomer(Name) ");
21             strSQL.Append("OUTPUT inserted.ID values(@Name)");
22             using (SqlConnection conn = new SqlConnection(connStr.ConnectionString))
23             {
24                 SqlCommand cmd = new SqlCommand(strSQL.ToString(), conn);
25                 SqlParameter para = new SqlParameter("@Name", SqlDbType.VarChar, 20);
26                 para.Value = http://www.mamicode.com/"Kemi";
27                 cmd.Parameters.Add(para);
28                 try
29                 {
30                     conn.Open();
31                     int insertedID = (int)cmd.ExecuteScalar();//获取单个值
32                     Console.WriteLine("Inserted ID:{0}", insertedID);
33                 }
34                 catch (Exception ex)
35                 {
36                     Console.WriteLine("{0}", ex.Message);
37                 }
38             }
39             Console.Read();
40         }
41     }
42 } 

View Code

四、SqlParameter（Sql参数） 

1、几个重要的属性

ParameterName：设置参数名

Value：给参数设置值

Size：设置参数字节最大大小

SqlDbType：参数在SQL中的类型

2、命令对象添加参数集合的几种方法

（1）AddWithValue

（2）Add

（3）AddRange

using (SqlConnection connection = new SqlConnection(""))
  {
      SqlCommand command = connection.CreateCommand();
      command.CommandText = "";
 
      //可以使用这种方式添加多个参数，不过方式不够好
      command.Parameters.Add("@name", SqlDbType.NVarChar).Value = "http://www.mamicode.com/yang"; //第一种方式
      command.Parameters.Add("@age", SqlDbType.Int).Value = http://www.mamicode.com/888;"@address", SqlDbType.NVarChar, 100).Value = "http://www.mamicode.com/Jiang Su";
 
      //这种方式直接给定参数名和参数就可以了，可操作性比较差
      command.Parameters.AddWithValue("@name", "yang");
      command.Parameters.AddWithValue("@age", 888).SqlDbType = SqlDbType.Int;
      command.Parameters.AddWithValue("@address", "Jiang su").SqlDbType = SqlDbType.NVarChar;
 
      //直接使用参数集合添加你需要的参数，推荐这种写法
      SqlParameter[] parameters = new SqlParameter[]
      {
          new SqlParameter("@name",SqlDbType.NVarChar,100){Value = "http://www.mamicode.com/yang"},
          new SqlParameter("@age",SqlDbType.Int,2){Value = http://www.mamicode.com/888},"@address",SqlDbType.NVarChar,20){Value = "http://www.mamicode.com/Jiang Su"}, 
      };
      command.Parameters.AddRange(parameters);  //参数也可以是一个Array数组，如果采用数组参数代码的可读性和扩展性就不是那么好了
 
      //当我们把参数都添加好之后，会生成一个“SqlParameterCollection”集合类型，相当于参数的集合
      //那么我们就可以对这些参数进行修改和移除了
      //说穿了“SqlParameterCollection”内部其实是一个List<SqlParameter>的集合，只是它里面的复杂度比较高，考虑的很全面
      command.Parameters[0].Value = "http://www.mamicode.com/hot girl";
      command.Parameters[0].Size = 200;
  } 

五、SqlDataReader（数据流读取器）

1、基本用法 

 1 using (SqlConnection conn = new SqlConnection(ConnectionString()))
 2 {
 3     conn.Open();
 4     //构建查询语句，也可以指定SqlCommand，其中变换的方法有很多
 5     SqlDataAdapter da = new SqlDataAdapter("select LastName,FirstName from dbo.Employees", conn);
 6     DataSet ds = new DataSet();
 7     da.Fill(ds);
 8     //这句话很重要，它会把你在DataSet增加的数据转化为SQL语句用来更新数据库
 9     SqlCommandBuilder cmdBuilder = new SqlCommandBuilder(da);
10     //添加行，实例化一个行对象，注意是用NewRow来创建行
11     DataRow row = ds.Tables[0].NewRow();
12     row[0] = "Yang";
13     row[1] = "鬼头";
14     ds.Tables[0].Rows.Add(row);  //添加到表中
15     da.Update(ds);             //把DataSet中表和数据库进行对比，更新
16 }