1. using System;
   
2. using System.Data.SqlClient;
   
3. namespace ExecuteSqlTran
   
4. {
   
5.     class Program
   
6.     {
   
7.         class Result<T>
   
8.         {
   
9.             public T data;
   
10.             public string Message;
    
11.             public bool Success;
    
12.             public string StackTrace;
    
13.         }
    
14. 
    
15.         struct ExecuteableUnit
    
16.         {
    
17.             public string SQL;
    
18.             public SqlParameter[] param;
    
19.         }
    
20. 
    
21.         /// <summary>
    
22.         /// 执行多条SQL语句，实现数据库事务。
    
23.         /// </summary>
    
24.         /// <param name="SQLStringList">SQL语句的哈希表（key为sql语句，value是该语句的SqlParameter[]）</param>
    
25.         private static Result<int> ExecuteSqlTransaction(params ExecuteableUnit[] executeableUnits)
    
26.         {
    
27.             using (SqlConnection connection = new SqlConnection(""))
    
28.             {
    
29.                 connection.Open();
    
30.                 SqlCommand command = connection.CreateCommand();
    
31.                 SqlTransaction transaction = connection.BeginTransaction();
    
32.                 command.Connection = connection;
    
33.                 command.Transaction = transaction;
    
34.                 int result = 0;
    
35.                 try
    
36.                 {
    
37.                     foreach(ExecuteableUnit exeUnit in executeableUnits)
    
38.                     {
    
39.                         command.CommandText = exeUnit.SQL;
    
40.                         if(exeUnit.param.GetLength(1) > 0)
    
41.                         {
    
42.                             foreach(SqlParameter p in exeUnit.param)
    
43.                                 command.Parameters.Add(p);
    
44.                         }
    
45.                         result += command.ExecuteNonQuery();
    
46.                     }
    
47.                     transaction.Commit();
    
48.                 }
    
49.                 catch (Exception ex)
    
50.                 {
    
51.                     // Attempt to roll back the transaction.
    
52.                     try
    
53.                     {
    
54.                         transaction.Rollback();
    
55.                     }
    
56.                     catch (Exception ex2)
    
57.                     {
    
58.                         return new Result<int>()
    
59.                         {
    
60.                             Success = false, Message = ex2.Message, StackTrace = ex2.StackTrace
    
61.                         };
    
62.                     }
    
63.                     return new Result<int>()
    
64.                     {
    
65.                         Success = false, Message = ex.Message, StackTrace = ex.StackTrace
    
66.                     };
    
67.                 }
    
68.                 finally
    
69.                 {
    
70.                     // Attempt to roll back the transaction.
    
71.                     try
    
72.                     {
    
73.                         connection.Close();
    
74.                     }
    
75.                     catch (Exception ex)
    
76.                     {
    
77.                     }
    
78.                 }
    
79.                 return new Result<int>()
    
80.                 {
    
81.                     Success = true, data = result
    
82.                 };
    
83.             }
    
84.         }
    
85. 
    
86.         public static void Main(string[] args)
    
87.         {
    
88.         }
    
89.     }
    
90. }

复制代码

值得学习ing!