ADO.NET 全面整理

 1 ①System.Data  → DataTable，DataSet，DataRow，DataColumn，DataRelation，Constraint，DataColumnMapping，DataTableMapping
 2 ②System.Data.Coummon     → 各种数据访问类的基类和接口
 3 ③System.Data.SqlClient   → 对Sql Server进行操作的数据访问类
 4   主要有：   a) SqlConnection            → 数据库连接器
 5             b) SqlCommand               → 数据库命名对象
 6             c) SqlCommandBuilder        → 生存SQL命令
 7             d) SqlDataReader            → 数据读取器
 8             e) SqlDataAdapter           → 数据适配器，填充DataSet
 9             f) SqlParameter             → 为存储过程定义参数
10             g) SqlTransaction           → 数据库事物

1 SqlCommand command = connection.CreateCommand(); //这种方式比较好，也可以自己实例化一个对象！

1 command.ExecuteReader(CommandBehavior.CloseConnection); //在执行读取之后会自动关闭连接对象

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

1 SqlParameter para = cmd.CreateParameter() //此方法适合SQL语句中只有一个参数的情况！

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

1 int name = dr.GetOrdinal("name"); //通过列名来获取当前列的索引号，这样如果下次你列名顺序发生变化也没有关系

1 string columnName = dr.GetName(name); //通过列名所处的索引号来获取列名名称 

1   dr.IsDBNull(coContactID) ? "NULL" : dr.GetInt32(coContactID).ToString() //相信大家都会使用的

1 //select * from Employee;select * from County，这样的话就可以采用这种方式
2 dr.NextResult(); //记住这个要放在while(dr.Read())之后，因为读取一个数据集之后才能读取下一个数据集 

1     SqlDataReader读取方法：
2     1. DataReader     索引   + 基于 [序列号] → dr[0].ToString        | Index-based access
3     2. DataReader     索引   + 基于 [列名]  → dr["Name"].ToString     | 性能最差
4     3. Get            开头的 + 基于 [序列号] → dr.GetString(0)      | type-access
5     4. GetSql         开头的 + 基于 [序列号] → dr.GetSqlString(0)   | Provider-specific typed accessor
6     5. GetOrdinal()   通过列名获取这个列的序列号                      | 这个方法在提高性能上面有作用
7     6. 性能(4) --> (3) --> (1) --> (2)

 1     using (SqlConnection conn = new SqlConnection(str))
 2     {
 3          conn.Open();
 4          SqlTransaction transaction = conn.BeginTransaction();
 5          SqlCommand cmd = conn.CreateCommand();
 6          cmd.CommandText = "";
 7          cmd.Transaction = transaction;
 8          //使用命名存储点
 9          transaction.Save("this is point");  //定义命名存储点，使用Save方法先保存存储点，定义回滚数据的开始位置
10                 
11          //这边是你要回滚的操作代码，TO DO...
12 
13          //把从命名存储点到这里的操作进行回滚
14          transaction.Rollback("this is point");  //回滚命名存储点              
15      }

1 BEGIN TRANSACTION
2 
3     --你需要执行的更新，删除，插入的语句
4     
5 IF(@@ERROR > 0) //这是系统变量，存储你在执行更新，删除，插入操作时发生错误的记录编号
6     ROLLBACK
7 ELSE
8     COMMIT

 1 using (TransactionScope transactionScope = new TransactionScope())
 2 {
 3     try
 4     {
 5         using (SqlConnection connection = new SqlConnection())
 6         {
 7             // TO DO
 8             //提交事务，如果有异常，他会自动回滚的
 9             transactionScope.Complete();
10         }
11     }
12     catch (Exception)
13     {
14         //捕获异常
15         throw;
16     }
17 }

1 四个重载：    
2   1. 无参
3   2. SqlDataAdapter(SqlCommand)  → 执行命令对象实例
4   3. SqlDataAdapter(String, SqlConnection) → ①只能指定查询语句 ②连接对象实例
5   4. SqlDataAdapter(String, ConnectionString) → 用 SelectCommand 和一个连接字符串初始化 SqlDataAdapter 类的一个新实例
6   Note：第四个重载就把连接对象和命令对象都包含进去了！

1 DataSet dataSet = new DataSet();
2 using (SqlConnection conn = new SqlConnection(""))
3 {
4     conn.Open();
5     SqlCommand command = conn.CreateCommand();
6     command.CommandText = "select name,age,address from MyInformation";
7     SqlDataAdapter dataAdapter = new SqlDataAdapter(command);
8     dataAdapter.Fill(dataSet);  //填充数据
9 }

 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  }

 1 using (SqlConnection conn = new SqlConnection(""))
 2 {
 3     SqlDataAdapter da = new SqlDataAdapter("SQL语句或你自己定义的命令对象", conn);
 4     DataSet ds = new DataSet();
 5     da.Fill(ds);
 6     //很重要的一句话
 7     SqlCommandBuilder cmdBuilder = new SqlCommandBuilder(da);
 8     ds.Tables[0].Rows[12][1] = ""; //修改数据
 9     da.Update(ds);
10     //调用Update方法其中隐式的调用了AcceptChanges方法，更新数据集中的数据
11     //如果你继续使用这个数据集而没有调用这个方法，在后面的使用会出现异常
12     ds.AcceptChanges();  //这句话可以不写的
13 }

 2  {
 3      SqlDataAdapter da = new SqlDataAdapter("SQL语句或你自己定义的命令对象", conn);
 4      DataSet ds = new DataSet();
 5      da.Fill(ds);
 6      SqlCommandBuilder cmdBuilder = new SqlCommandBuilder(da);
 7      //删除数据
 8      ds.Tables[0].Rows[12].Delete();
 9      da.Update(ds);  //这边会隐式调用DataTable的AcceptChanges方法
10  }

1 ★指定填充数据的数量，如：
2 //从第五行到第十行数据填充DataSet   
3 //上面的定义错了
4 //应该是从第六行开始，后面的十条记录
5 da.Fill(ds,5,10,”MyTable”) 

 1 dt.Columns.Add(new DataColumn("Age", typeof(Int32)));
 2 dt.Columns.Add(new DataColumn()
 3 {
 4     ColumnName = "Address",
 5     DataType = typeof(string),
 6     DefaultValue = "江苏海安"
 7 });
 8 //我们这边使用Add的方法的第二个重载
 9 dt.Rows.Add(new object[] {"11", 44, "222", "yang cao gui"});
10 //我们也可以对添加好的行和列进行读取和修改
11 dt.Columns[0].ColumnName = "wang wei";
12 dt.Rows[0]["wang wei"] = "我把这行这列的值修改了，哈哈";

1     Added          → 添加
2     Deleted        → 删除
3     Detached       → 分离
4     Modified       → 修改
5     Unchanged      → 为改变

1     Current     → 最近的行，主要针对Deleted操作之前的行，行状态的Deleted
2     Default     → 行的默认状态
3     Original    → 行的原始值 Added，Modified，Unchanged    
4     Proposed    → 行的建议值