.NET数据库编程求索之路--4.使用ADO.NET实现（三层架构篇-使用Table传递数据）（1）

  1  using System;
  2  using System.Collections.Generic;
  3  using System.Linq;
  4  using System.Text;
  5  using System.Data; // 新添命名空间
  6  using System.Configuration; // 新添命名空间
  7  using System.Data.SqlClient; // 新添命名空间
  8 
  9  namespace HomeShop.DbUtility
 10 {
 11      // 功能：SQL Server数据访问基础类；
 12       // 作者：夏春涛；
 13       // 日期：2011-11-30；
 14       public  class SqlDbHelper
 15     {
 16          // 数据库连接字符串
 17           private  string connectionString =  "";
 18          public  string ConnectionString
 19         {
 20              get { return connectionString; }
 21         }
 22 
 23          // 数据库连接对象
 24           private SqlConnection connection;
 25         
 26          // 默认构造函数，从应用程序配置文件中读取第1个数据库连接字符串
 27           public SqlDbHelper()
 28         {
 29              this.connectionString = ConfigurationManager.ConnectionStrings[ 1].ConnectionString;
 30              this.connection =  new SqlConnection( this.connectionString);            
 31         }
 32 
 33          // 重载构造函数，根据入参初始化数据库连接字符串
 34           public SqlDbHelper( string connectionString)
 35         {
 36              this.connectionString = connectionString;
 37              this.connection =  new SqlConnection( this.connectionString);
 38         }
 39 
 40          // 执行SQL命令（Select），获取返回数据-重载函数
 41           public DataTable ExecuteQuery( string selectCommandText)
 42         {
 43              return ExecuteQuery(selectCommandText,  null);
 44         }
 45 
 46          // 执行SQL命令（Select），获取返回数据
 47           public DataTable ExecuteQuery( string selectCommandText,  params SqlParameter[] cmdParameters)
 48         {            
 49             connection.Open();
 50             SqlCommand command =  new SqlCommand(selectCommandText, connection);
 51              if ( null != cmdParameters)
 52             {
 53                  for ( int i =  0; i < cmdParameters.Length; i++)
 54                 {
 55                     command.Parameters.Add(cmdParameters[i]);
 56                 }
 57             }
 58             SqlDataAdapter adapter =  new SqlDataAdapter(command);
 59             DataTable dataTable =  new DataTable();
 60             adapter.Fill(dataTable);
 61             connection.Close();
 62 
 63              return dataTable;
 64         }
 65 
 66          // 执行SQL命令（Insert/Delete/Update），以数据库事务方式
 67           public  int ExecuteNonQueryTrans( string cmdText,  params SqlParameter[] cmdParameters)
 68         {
 69              int rowsCountAffected =  0;            
 70             connection.Open();
 71             SqlCommand command =  new SqlCommand(cmdText, connection);
 72              if ( null != cmdParameters)
 73             {
 74                  for ( int i =  0; i < cmdParameters.Length; i++)
 75                 {
 76                     command.Parameters.Add(cmdParameters[i]);
 77                 }
 78             }
 79              // 开始数据库事务
 80              SqlTransaction trans = connection.BeginTransaction();
 81             command.Transaction = trans;
 82              try
 83             {
 84                 rowsCountAffected += command.ExecuteNonQuery();
 85                 trans.Commit(); // 提交数据库事务
 86              }
 87              catch
 88             {
 89                 trans.Rollback(); // 回滚数据库事务
 90                   throw;
 91             }
 92             connection.Close();
 93 
 94              return rowsCountAffected;
 95         }
 96 
 97          // 执行多条SQL（Insert/Delete/Update），以数据库事务方式-重载函数
 98           public  int ExecuteNonQueryTrans( params SqlCmdTextAndParams[] cmdTextAndParams)
 99         {
100             List<SqlCmdTextAndParams> list =  new List<SqlCmdTextAndParams>();
101              for( int i= 0;i<cmdTextAndParams.Length;i++)
102             {
103                 list.Add(cmdTextAndParams[i]);
104             }
105 
106              return ExecuteNonQueryTrans(list);
107         }
108 
109          // 执行多条SQL（Insert/Delete/Update），以数据库事务方式
110           public  int ExecuteNonQueryTrans(List<SqlCmdTextAndParams> listCmdTextAndParams)
111         {
112              int rowsCountAffected =  0;            
113             connection.Open();
114              // 开始数据库事务
115              SqlTransaction trans = connection.BeginTransaction();
116             SqlCommand command =  new SqlCommand();
117             command.Connection = connection;
118             command.Transaction = trans;
119              try
120             {
121                  // 循环执行每一个CommandTextAndParameters对象
122                   foreach (SqlCmdTextAndParams cmdTextAndParams  in listCmdTextAndParams)
123                 {
124                     command.CommandText = cmdTextAndParams.CommandText;
125                      foreach (SqlParameter param  in cmdTextAndParams.CommandParameters)
126                     {
127                         command.Parameters.Add(param);
128                     }
129                     rowsCountAffected += command.ExecuteNonQuery();
130                      // 清空参数列表，避免参数重名问题
131                      command.Parameters.Clear();
132                 }
133                 trans.Commit(); // 提交数据库事务
134              }
135              catch
136             {
137                 trans.Rollback(); // 回滚数据库事务
138                   throw;
139             }
140             connection.Close();
141 
142              return rowsCountAffected;
143         }
144 
145          // 开始（生成）一个数据库事务
146           public SqlTransaction BeginTransaction()
147         { 
148             connection.Open();
149             SqlTransaction trans = connection.BeginTransaction();
150 
151              return trans;
152         }
153 
154          // 在指定的数据库事务中执行SQL命令，最后要手工提交事务
155           public  int ExecuteNonQueryTrans(SqlTransaction inTransaction,  string cmdText,  params SqlParameter[] cmdParameters)
156         {
157              int rowsCountAffected =  0;            
158             SqlCommand command =  new SqlCommand(cmdText, inTransaction.Connection);
159              if ( null != cmdParameters)
160             {
161                  for ( int i =  0; i < cmdParameters.Length; i++)
162                 {
163                     command.Parameters.Add(cmdParameters[i]);
164                 }
165             }
166             command.Transaction = inTransaction;
167             rowsCountAffected += command.ExecuteNonQuery();
168             command.Parameters.Clear(); // 清空参数列表，避免参数重名问题
169 
170              return rowsCountAffected;
171         }
172 
173          // 关闭数据库连接
174           public  void Close()
175         {
176              if (ConnectionState.Open ==  this.connection.State )
177                  this.connection.Close();
178         }
179 
180          /* ************************************************************************************** */
181     }
182 }

 1  using System;
 2  using System.Collections.Generic;
 3  using System.Linq;
 4  using System.Text;
 5  using System.Data.SqlClient; // 新添命名空间
 6 
 7  namespace HomeShop.DbUtility
 8 {
 9      // 用于保存一条SQL命令及对应参数的类
10       public  class SqlCmdTextAndParams
11     {
12          public SqlCmdTextAndParams( string commandText,  params SqlParameter[] commandParamters)
13         {
14              this.CommandText = commandText;
15              this.CommandParameters = commandParamters;
16         }
17 
18          public  string CommandText {  set;  get; }
19 
20          public SqlParameter[] CommandParameters {  set;  get; }
21     }
22 }