上篇博客，實例介紹了一個事務執行多條SQL語句函數（int ExecuteSqlTran(List<String> SQLStringList)）點擊打開鏈接，方便之余又發現了它的缺陷——不能傳入Sql語句的參數，只能靠拼接字符串完成Sql語句，很是麻煩哈！人類是‘貪婪’滴(*^__^*) 嘻嘻……，同時也是勇于探索滴，有不可傳參的，那我想 必定就有可傳參的，這篇博客就分享一下——執行多條SQL語句，實現數據庫事務函數（可傳Sql參數）

（注：本篇博客涉及到哈希表的些許知識，就不做介紹了，用一次也就大概了解了。哪天姐姐高興，再來對哈希表來個分析? O(∩_∩)O哈哈~）

D層SqlTaskAssignInfo類：

[csharp]?view plaincopy

?///?<summary>??

?///?組長分配任務（更新任務信息表T_TaskInfo和任務分配表T_TaskAssignInfo）??

??///?</summary>??

///?<param?name="modelTaskAssignInfo">任務分配信息實體類（任務ID、小組ID、成員ID、成員姓名、組長分配日期、組長分配時間）</param>??

///?<returns>bool（true：分配成功；false：分配失敗）</returns>??

?public?bool?AssignTask2(Entity.TaskAssignInfoEntity?enTaskAssignInfo)??

?{??

?????//1,sql1語句：根據任務ID和分配等級，更新任務分配信息表T_TaskAssignInfo中任務分配狀態字段taskDistributeState的值為‘已分配’??

?????string?sql1?=?"update?T_TaskAssignInfo?set?taskDistributeState='已分配'?where?taskID=@taskID?and?distributeLevel='1'";??

?????

?????//2，sql2語句：向任務分配信息表中插入一條組長分配的任務信息，包括（任務ID，小組ID，成員ID，成員姓名、分配日期、分配時間、分配等級、提交狀態）??

?????string?sql2?=?"insert?into?T_TaskAssignInfo(taskID,groupID,memberID,memberName,distributeDate,distributeTime,distributeLevel,submitState)???

[csharp]?view plaincopy

values?(@taskID,@groupID,@memberID,@memberName,@distributeDate,@distributeTime,?'2','未提交')";??

???????????

????????????

????????????//3，設置參數（任務ID、小組ID、成員ID、成員姓名、分配日期、分配時間）??

????????????SqlParameter[]?parameters?={new?SqlParameter?("@taskID",enTaskAssignInfo.taskID?),??

???????????????????????????????????????new?SqlParameter("@groupID",enTaskAssignInfo.groupID),??

???????????????????????????????????????new?SqlParameter("@memberID",enTaskAssignInfo.memberID),??

???????????????????????????????????????new?SqlParameter("@memberName",enTaskAssignInfo.memberName?),??

???????????????????????????????????????new?SqlParameter("@distributeDate",enTaskAssignInfo.distributeDate),??

???????????????????????????????????????new?SqlParameter("@distributeTime",enTaskAssignInfo.distributeTime)};??

?????????????

????????????//4，創建哈希表????????????????????????

????????????Hashtable?SQLStringList=new?Hashtable?();??

????????????SQLStringList.Add(sql1,parameters);//4.1將sql1語句，和參數添加到哈希表??

????????????SQLStringList.Add(sql2,parameters);//4.2將sql2語句和參數添加到哈希表??

?????????????

????????????try???

????????????{//5，調用DbHelperSQL類的事務函數（執行多條sql語句，完成數據庫事務）??

????????????????DbHelperSQL.ExecuteSqlTran(SQLStringList);???

????????????????return?true;??

????????????}??

??

???????????catch(SystemException)??

????????????{??

???????????????return?false;??

???????????}??

????????}??

（注：DbHelperSQL類代碼中的ConnectionString是寫在配置文件里的數據庫連接字符串）

DbHelperSQL類：

[csharp]?view plaincopy

using?System.Configuration?'這里添加后，還必須在管理器中添加引用??

??

public?static?string?connectionString?=?ConfigurationManager.AppSettings["ConnectionString"];??

??

?????????????????///?<summary>??

????????///?執行多條SQL語句，實現數據庫事務。??

????????///?</summary>??

????????///?<param?name="SQLStringList">SQL語句的哈希表（key為sql語句，value是該語句的SqlParameter[]）</param>??

????????public?static?void?ExecuteSqlTran(Hashtable?SQLStringList)??

????????{??

????????????using?(SqlConnection?conn?=?new?SqlConnection(connectionString))??

????????????{??

????????????????conn.Open();//打開數據庫連接??

????????????????using?(SqlTransaction?trans?=?conn.BeginTransaction())//開始數據庫事務??

????????????????{??

????????????????????SqlCommand?cmd?=?new?SqlCommand();//創建SqlCommand命令??

????????????????????try??

????????????????????{??

????????????????????????//循環??

????????????????????????foreach?(DictionaryEntry?myDE?in?SQLStringList)//循環哈希表（本例中?即，循環執行添加在哈希表中的sql語句??

????????????????????????{??

????????????????????????????string?cmdText?=?myDE.Key.ToString();//獲取鍵值（本例中?即，sql語句）??

????????????????????????????SqlParameter[]?cmdParms?=?(SqlParameter[])myDE.Value;//獲取鍵值（本例中?即，sql語句對應的參數）??

????????????????????????????PrepareCommand(cmd,?conn,?trans,?cmdText,?cmdParms);?//調用PrepareCommand()函數，添加參數??

????????????????????????????int?val?=?cmd.ExecuteNonQuery();//調用增刪改函數ExcuteNoQuery()，執行哈希表中添加的sql語句??

????????????????????????????cmd.Parameters.Clear();?//清除參數??

????????????????????????}??

????????????????????????trans.Commit();//提交事務??

????????????????????}??

????????????????????catch?//捕獲異常??

????????????????????{??

????????????????????????trans.Rollback();?//事務回滾??

????????????????????????throw;?//拋出異常??

????????????????????}??

????????????????}??

????????????}??

????????}??

?

[csharp]?view plaincopy

//添加參數??

?private?static?void?PrepareCommand(SqlCommand?cmd,?SqlConnection?conn,?SqlTransaction?trans,?string?cmdText,?SqlParameter[]?cmdParms)??

????????{??

????????????if?(conn.State?!=?ConnectionState.Open)//如果數據庫連接為關閉狀態??

????????????????conn.Open();//打開數據庫連接??

????????????cmd.Connection?=?conn;//設置命令連接??

????????????cmd.CommandText?=?cmdText;//設置執行命令的sql語句??

????????????if?(trans?!=?null)//如果事務不為空??

????????????????cmd.Transaction?=?trans;//設置執行命令的事務??

????????????cmd.CommandType?=?CommandType.Text;//設置解釋sql語句的類型為“文本”類型（也是就說該函數不適用于存儲過程）??

????????????if?(cmdParms?!=?null)//如果參數數組不為空??

????????????{??

??

??

????????????????foreach?(SqlParameter?parameter?in?cmdParms)?//循環傳入的參數數組??

????????????????{??

????????????????????if?((parameter.Direction?==?ParameterDirection.InputOutput?||?parameter.Direction?==?ParameterDirection.Input)?&&??

????????????????????????(parameter.Value?==?null))??

????????????????????{??

????????????????????????parameter.Value?=?DBNull.Value;?//獲取參數的值??

????????????????????}??

????????????????????cmd.Parameters.Add(parameter);//添加參數??

????????????????}??

????????????}??

????????}??

?

配置文件：

[csharp]?view plaincopy

<appSettings>???<add?key="ConnectionString"?value="server=hanxuemin;database=Library;uid=sa;pwd=123456"/>??

</appSettings>??

?

???對比上篇博客中介紹的“執行多條sql語句，實現數據庫事務（不可傳入sql參數）函數”點擊打開鏈接，體會兩個函數的優缺點，了解兩個函數在D層函數中是如何調用的，學會使用！

總結

以上是生活随笔為你收集整理的执行多条SQL语句，执行数据库事务（可传入Sql参数）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。