C# SQL Server的封装(SQLDataAdapter等)之二(共二)

本文章仅是本人学习后总结，如有错误之处，请大家指正。 既然你看到这篇文章，说明最少懂，如果看完了还不懂。。。。。你怎么不上天呢。。。 以下Demo均以SQL Server为例说明。 七个DEMO分别说明以下情况 1.connection字符串 2.Command的常用的三个方法。 3.SqlDataApater的Fill方法。 4.SqlDataAdapter的Update和SqlDataBuilder之间的协作。 5.如何执行存储。 6.如何执行事务。 7.简单的扩展，针对三层架构，表对应类，封装快速获取数据。

Demo4： 说明：SqlDataAdapter的Update和SqlDataBuilder 第一个方法:说明AcceptChanges和GetChanges() 第二个方法:说明Update() 必须理解的内容： 1.当FIll调用后DataTable中的Row的RowState均为Unchanged。 2.对行进行修改后，会改变RowState,具体RowState的请看枚举(enum)DataRowState。 3.当需要将内存数据库更新到本地数据库中,需要判断是否有RowState进行了改变,调用GetChanges()进行判断。 4.当调用完GetChanges()后，为了保持数据库一致需要进行 需要懂的DataRow中的RowState和Delete()方法，因为AcceptChanges()。 5.如果不进行调用，那么不能在进行SqlDataAdapt的Udpate操作。

//使用SqlDataAdapter的Update进行数据更新 //内存数据库操作完成后，对应的RowState都会进行变化 //此处的dTable参数就是你操作完后的，也就是Fill获取后操作完的 public static bool SQLAdapterUpdate(string comStr, DataTable dTable) { //记住comStr最好与获取数据Fill使用的字符串一致，且必须有SQL语句中必须有主键！！！ using (SqlDataAdapter adapter = new SqlDataAdapter(comStr, SQLHelper.ConStr)) { using (SqlCommandBuilder builder = new SqlCommandBuilder(adapter)) { try { int updateRows=adapter.Update(dTable); if (updateRows == 0) return false; else return true; } catch (Exception ex) { adapter.SelectCommand.Connection.Close(); throw ex; } } } }

Demo5： 说明：如何执行存储过程，且可能存在带出(output)参数。

//怎么带出？！创建SqlParameter[]的时候，进行指定方法output即可 //说实话。。。使用Adapter没有执行过存储过程，都是使用connection后创建Command，但个人认为应该是一样的 public static DataSet SQLProcedure(string tranName, params SqlParameter[] paramters) { DataSet dSet = new DataSet(); using (SqlDataAdapter adapter = new SqlDataAdapter(tranName, SQLHelper.ConStr)) { try { if (paramters != null) { adapter.SelectCommand.Parameters.AddRange(paramters); } //加这么一句即可 adapter.SelectCommand.CommandType = CommandType.StoredProcedure; adapter.Fill(dSet); return dSet; } catch (Exception ex) { adapter.SelectCommand.Connection.Close(); throw ex; } } }

Demo6： 说明：执行事务

public static bool SQLTransaction(List<string> commandStrList) { using (SqlConnection connection = new SqlConnection(SQLHelper.ConStr)) { using (SqlCommand command = connection.CreateCommand()) { try { //必须先将连接打开 connection.Open(); SqlTransaction tran=connection.BeginTransaction(); command.Transaction = tran; for (int i = 0; i < commandStrList.Count; i++) { command.CommandText = commandStrList[i]; command.ExecuteNonQuery(); } //提交事务 tran.Commit(); return true; } catch (Exception ex) { //进行回滚。 command.Transaction.Rollback(); //异常后进行连接的关闭 connection.Close(); throw ex; } } } }

Demo7： 说明：简单扩展

//封装DataReader,返回指定类型的list集合， //主要是想说明DataReader的一些参数和方法 //当数据库一个表对应一个的类,一般用于三层架构情况 public static List<T> SQLDataReaderGetList<T>(string comStr, params SqlParameter[] paramters)where T:class,new() { using (SqlConnection connection = new SqlConnection(SQLHelper.ConStr)) { using (SqlCommand command = connection.CreateCommand()) { try { command.CommandText = comStr; if (paramters != null) { command.Parameters.AddRange(paramters); } //必须先将连接打开 connection.Open(); //CommandBehavior.CloseConnection //在执行该命令时，如果关闭关联的 DataReader 对象，则关联的 Connection 对象也将关闭。 using (SqlDataReader reader = command.ExecuteReader()) { List<T> list = new List<T>(); //判断SqlDataReader是否成功读取了数据 if (reader.HasRows) { //使用反射,获取指定类的属性 PropertyInfo[] propertyCollection=typeof(T).GetProperties(); //当SqlDataReader读取到数据后,SqlDataReader执行返回的数据集(也就是查询结构)的第一行之前 //必须先进行调用Read后，指向第一行，每次调用，指向下一行 while (reader.Read()) { T model = new T(); // reader.FieldCount 字段数 //进行循环遍历对T类型对象的属性赋值 for (int i = 0; i < reader.FieldCount; i++) { //获取指定列的名称 string fieldName = reader.GetName(i); for (int j = 0; j < propertyCollection.Length; j++) { //判断是否相等 if (fieldName == propertyCollection[j].Name) { propertyCollection[j].SetValue(model, reader[i], null); } } } list.Add(model); } } return new List<T>(); } } catch (Exception ex) { //异常后进行连接的关闭 connection.Close(); throw ex; } } } } 以上没有进行详细测试，只是正常生成，自己学习时，请多测试，练习。