1 public class TransactionInformation
 2 {
 3       //返回分布式事務(wù)標識符
 4       public Guid DistributedIdentifier 
 5       {get;}
 6 
 7       //返回本地事務(wù)標識符
 8       public string LocalIdentifier
 9       {get;}
10 }

 1     class Program
 2     {
 3         static void Main(string[] args)
 4         {
 5             using (TransactionScope scope = new TransactionScope())
 6             {
 7                 TransactionManager.DistributedTransactionStarted += OnDistributedTransactionStarted;
 8                 ............
 9                 scope.Complete();
10             }
11             Console.ReadKey();
12         }
13 
14         //當執(zhí)行分布式事務(wù)是就會啟動此方法顯示事務(wù)信息
15         static void OnDistributedTransactionStarted(object sender, TransactionEventArgs args)
16         {
17             Transaction transaction = args.Transaction;
18             Console.WriteLine("Distributed Transaction Started!\n  DistributedIndentifier:"
19                  +transaction.TransactionInformation.DistributedIdentifier);
20         }
21     }

1 public interface IDbTransaction：IDisposable
2 {
3       IDbConnection Connection {get;}     //返回Connection對象
4       IsolationLevel IsolationLevel{get;}   
5       void Commit();      //數(shù)據(jù)提交，把所有改變數(shù)據(jù)保存到持久化數(shù)據(jù)庫
6       void Rollback();     //數(shù)據(jù)回滾，把所有數(shù)據(jù)恢復原值
7 }

 1 private static void Execute(string connectionString)
 2 {
 3     using (SqlConnection connection = new SqlConnection(connectionString))
 4     {
 5         connection.Open();
 6 
 7         SqlCommand command = connection.CreateCommand();
 8         SqlTransaction transaction;
 9 
10         //啟動事務(wù)
11         transaction = connection.BeginTransaction("SampleTransaction");
12 
13         //設(shè)定SqlCommand的事務(wù)和連接對象
14         command.Connection = connection;
15         command.Transaction = transaction;
16 
17         try
18         {
19             command.CommandText ="Insert into ......";
20             command.ExecuteNonQuery();
21         
22             // 完成提交
23             transaction.Commit();
24             ......
25         }
26         catch (Exception ex)
27         {
28             //數(shù)據(jù)回滾
29             transaction.Rollback();
30             .....
31         }
32     }
33 }

 1  using(MyDataContext context=new MyDataContext())
 2  {
 3       try
 4       {
 5           context.Connection.Open();
 6           context.Transaction=context.Connection.BeginTransaction();
 7           //更新數(shù)據(jù)
 8           .........
 9           context.SubmitChanges();
10           //事務(wù)提交
11           context.Transaction.Commit();
12       }
13       catch(Excetion ex)
14       {
15          //數(shù)據(jù)回滾
16          context.Transaction.Rollback();
17          //錯誤處理
18          .........
19       }
20 }

 1 public class TransactionScope:IDisposable
 2 {
 3     //多個構(gòu)造函數(shù)
 4     public TransactionScope();
 5     public TransactionScope(Transaction)
 6     public TransactionScope(TransactionScopeOption)
 7     ......
 8     public void Complete();   //提交事務(wù)
 9     public void Dispose();     //釋放事務(wù)對象
10 }
11 
12 //調(diào)用方式
13 using(TransactionScope scope=new TransactionScope())
14 {
15      //執(zhí)行事務(wù)型工作
16      ............
17      scope.Complete();
18 }

 1 void DoWork()
 2  {
 3      using(TransactionScope scope=new TransactionScope())
 4      {
 5           //在事務(wù)環(huán)境中執(zhí)行操作
 6           ......  
 7           NoTransaction();
 8           scope.Complete();
 9      }
10  }
11  
12  void NoTransaction()
13  {
14      //在無事務(wù)環(huán)境中執(zhí)行操作
15      using(TransactionScope scope=new TransactionScope(TransactionScopeOption.Suppress)）
16      {
17          ......
18      }
19  }

 1         public int UpdateOrder(Order order)
 2         {
 3             using (BusinessEntities context = new BusinessEntities())
 4             {
 5                 EntityKey entityKey = new
 6                     EntityKey("BasicArchitectureEntities.Order", "Id", order.Id);
 7                 var objResult = context.GetObjectByKey(entityKey);
 8 
 9                 using (TransactionScope scope = new TransactionScope())
10                 {
11                     if (objResult != null)
12                         context.ApplyCurrentValues<Order>("Order", order);
13                     foreach (OrderItem item in order.OrderItem)
14                         UpdateOrderItem(item);
15                     return context.SaveChanges();
16                 }
17             }
18         }
19 
20         public int UpdateOrderItem(OrderItem item)
21         {
22             using (BusinessEntities context = new BusinessEntities())
23             {
24                 EntityKey entityKey = new
25                     EntityKey("BasicArchitectureEntities.OrderItem", "Id", item.Id);
26                 var objResult = context.GetObjectByKey(entityKey);
27 
28                 //更新實體屬性
29                 if (objResult != null)
30                     context.ApplyCurrentValues<OrderItem>("OrderItem", item);
31                 return context.SaveChanges();
32             }
33         }

 1 [ServiceContract(SessionMode=SessionMode.Required)]
 2  public interface IService
 3  {
 4      [OperationContract]
 5      void Method1();
 6  
 7      [OperationContract]
 8      void Method2();
 9  }
10  
11  public class Service : IService
12  {
13     //隱式事務(wù)
14     [OperationBehavior(TransactionScopeRequired=true,TransactionAutoComplete=true)]
15      public void Method1()
16      {
17         ...........
18      }
19  
20      //顯式事務(wù)
21      [OperationBehavior(TransactionScopeRequired=true,TransactionAutoComplete=false)]
22      public void Method2()
23      {
24         ...........
25         OperationContext.Current.SetTransactionComplete();
26      }
27  }

 1 namespace Example
 2  {
 3      [ServiceContract]
 4      public interface IExampleService
 5      {
 6          [OperationContract]
 7          void Method1();
 8      }
 9  
10      public class ExampleService : IExampleService
11      {
12         //使用隱式事務(wù)，并把TransactionFlowOption設(shè)置為Allowed打開事務(wù)流
13          [OperationBehavior(TransactionAutoComplete=true,TransactionScopeRequired=true)]
14          [TransactionFlow(TransactionFlowOption.Allowed)]
15          public void Method1()
16          {
17              //通過TransactionInformation檢測事務(wù)狀態(tài)
18              Transaction transaction = Transaction.Current;
19              string info=string.Format("  DistributedIndentifier:{0} \n  LocalIndentifier:{1}",
20                  transaction.TransactionInformation.DistributedIdentifier,
21                  transaction.TransactionInformation.LocalIdentifier);
22              Console.WriteLine("Method1: \n"+info);
23          }
24  
25          static void Main(string[] args)
26          {
27               //啟動服務(wù)
28              ServiceHost exampleHost = new ServiceHost(typeof(Example.ExampleService));
29  
30              exampleHost.Open();
31  
32              Console.WriteLine("service start");
33              Console.ReadKey();
34              Console.WriteLine("service end");
35  
36              exampleHost.Close();
37          }
38      }
39  }
40  
41  <configuration>
42      <system.serviceModel>
43        <bindings>
44          <wsHttpBinding>
45             <!--啟動事務(wù)流-->
46            <binding name="defaultWSHttpBinding" transactionFlow="true" />
47          </wsHttpBinding>
48        </bindings>
49          <behaviors>
50              <serviceBehaviors>
51                  <behavior name="">
52                      <serviceMetadata httpGetEnabled="true" />
53                      <serviceDebug includeExceptionDetailInFaults="false" />
54                  </behavior>
55              </serviceBehaviors>
56          </behaviors>
57          <services>
58              <service name="Example.ExampleService">
59                  <!--使用支持事務(wù)流的wsHttpBinding綁定-->
60                  <endpoint address="" binding="wsHttpBinding" bindingConfiguration="defaultWSHttpBinding"
61                                       contract="Example.IExampleService">
62                      <identity>
63                          <dns value="localhost" />
64                      </identity>
65                  </endpoint>
66                  <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" />
67                  <host>
68                      <baseAddresses>
69                          <add baseAddress="http://localhost:7200/Example/ExampleService/" />
70                      </baseAddresses>
71                  </host>
72              </service>
73          </services>
74      </system.serviceModel>
75  </configuration>

 1  class Program
 2  {
 3         static void Main(string[] args)
 4         {
 5             using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required))
 6             {
 7                 ShowTransactionMessage("start");
 8 
 9                 ExampleServiceReference.ExampleServiceClient exampleService1 = new 
10                                         ExampleServiceReference.ExampleServiceClient();
11                 exampleService1.Method1();
12                 ShowTransactionMessage("exampleService started");
13                 exampleService1.Close(); 
14                 //事務(wù)提交
15                 scope.Complete();  
16             }   
17             Console.ReadKey();
18         }
19 
20         //檢查事務(wù)的狀態(tài)
21         static void ShowTransactionMessage(string data)
22         {
23             if (Transaction.Current != null)
24             {
25                 Transaction transaction = Transaction.Current;
26                 string info = string.Format("  DistributedIndentifier:{0} \n  LocalIndentifier:{1}",
27                transaction.TransactionInformation.DistributedIdentifier,
28                transaction.TransactionInformation.LocalIdentifier);
29                 Console.WriteLine(data+" \n" + info);
30             }
31         }
32 }

  1 //*******************************ExampleService*************************************************************************//
  2 namespace Example
  3 {
  4       [ServiceContract]
  5       public interface IExampleService
  6       {
  7           [OperationContract]
  8           void Method1();
  9       }
 10   
 11       public class ExampleService : IExampleService
 12       {
 13            //使用隱式事務(wù)，并把TransactionFlowOption設(shè)置為Allowed 
 14           [OperationBehavior(TransactionAutoComplete=true,TransactionScopeRequired=true)]
 15           [TransactionFlow(TransactionFlowOption.Allowed)]
 16           public void Method1()
 17           {
 18               //通過TransactionInformation檢測事務(wù)狀態(tài)
 19               Transaction transaction = Transaction.Current;
 20               string info=string.Format("  DistributedIndentifier:{0} \n  LocalIndentifier:{1}",
 21                   transaction.TransactionInformation.DistributedIdentifier,
 22                   transaction.TransactionInformation.LocalIdentifier);
 23               Console.WriteLine("Method1: \n"+info);
 24           }
 25   
 26           static void Main(string[] args)
 27           {
 28                //啟動服務(wù)
 29               ServiceHost exampleHost = new ServiceHost(typeof(Example.ExampleService));
 30   
 31               exampleHost.Open();
 32   
 33               Console.WriteLine("service start");
 34               Console.ReadKey();
 35               Console.WriteLine("service end");
 36   
 37               exampleHost.Close();
 38           }
 39       }
 40   }
 41   
 42   <configuration>
 43       <system.serviceModel>
 44         <bindings>
 45           <wsHttpBinding>
 46              <!--啟動事務(wù)流-->
 47             <binding name="defaultWSHttpBinding" transactionFlow="true" />
 48           </wsHttpBinding>
 49         </bindings>
 50           <behaviors>
 51               <serviceBehaviors>
 52                   <behavior name="">
 53                       <serviceMetadata httpGetEnabled="true" />
 54                       <serviceDebug includeExceptionDetailInFaults="false" />
 55                   </behavior>
 56               </serviceBehaviors>
 57           </behaviors>
 58           <services>
 59               <service name="Example.ExampleService">
 60                   <!--使用支持事務(wù)流的wsHttpBinding綁定-->
 61                   <endpoint address="" binding="wsHttpBinding"   contract="Example.IExampleService"
 62                                 bindingConfiguration="defaultWSHttpBinding"  >
 63                       <identity>
 64                           <dns value="localhost" />
 65                       </identity>
 66                   </endpoint>
 67                   <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" />
 68                   <host>
 69                       <baseAddresses>
 70                           <add baseAddress="http://localhost:7200/Example/ExampleService/" />
 71                       </baseAddresses>
 72                   </host>
 73               </service>
 74           </services>
 75       </system.serviceModel>
 76   </configuration>
 77 
 78 //*************************************Extension**************************************************************//
 79 namespace Extension
 80 {
 81     [ServiceContract]
 82     public interface IExtensionService
 83     {
 84         [OperationContract]
 85         void DoWork();
 86     }
 87 
 88     public class ExtensionService : IExtensionService
 89     {
 90         [OperationBehavior(TransactionAutoComplete=true,TransactionScopeRequired=true)]
 91         [TransactionFlow(TransactionFlowOption.Allowed)]
 92         public void DoWork()
 93         {
 94             Transaction transaction = Transaction.Current;
 95             string info = string.Format("  DistributedIndentifier:{0} \n  LocalIndentifier:{1}",
 96                 transaction.TransactionInformation.DistributedIdentifier,
 97                 transaction.TransactionInformation.LocalIdentifier);
 98             Console.WriteLine("DoWork: \n" + info);
 99         }
100 
101         static void Main(string[] args)
102         {
103             Console.WriteLine("extension service start");
104             ServiceHost host = new ServiceHost(typeof(ExtensionService));
105             host.Open();
106             Console.ReadKey();
107             host.Close();
108         }
109     }
110 }
111 <configuration>
112      <!--略-->
113      ...................  
114 </configuration>

 1 namespace Test
 2 {
 3     class Program
 4     {
 5         static void Main(string[] args)
 6         {
 7             using (TransactionScope scope = new TransactionScope(TransactionScopeOption.RequiresNew))
 8             {
 9                 ShowTransactionMessage("start");
10 
11                 ExampleServiceReference.ExampleServiceClient exampleService1 = new 
12                                         ExampleServiceReference.ExampleServiceClient();
13                 exampleService1.Method1();
14                 ShowTransactionMessage("exampleService started");
15                 ExtensionServiceReference.ExtensionServiceClient extensionService = new 
16                                         ExtensionServiceReference.ExtensionServiceClient();
17                 extensionService.DoWork();
18                 ShowTransactionMessage("extensionService started");
19         
20                 exampleService1.Close();
21                 extensionService.Close();
22                 
23                 scope.Complete();
24              }
25                 
26              Console.ReadKey();
27         }
28 
29         //檢查事務(wù)的狀態(tài)
30         static void ShowTransactionMessage(string data)
31         {
32             if (Transaction.Current != null)
33             {
34                 Transaction transaction = Transaction.Current;
35                 string info = string.Format("  DistributedIndentifier:{0} \n  LocalIndentifier:{1}",
36                      transaction.TransactionInformation.DistributedIdentifier,
37                      transaction.TransactionInformation.LocalIdentifier);
38                 Console.WriteLine(data+" \n" + info);
39             }
40 
41         }
42     }
43 }

 1    public interface IService
 2    {
 3        [OperationContract]
 4        void Method();
 5    }
 6    
 7    [ServiceBehavior(TransasctionIsolationLevel=IsolationLevel.ReadCommitted)]
 8    public class Service : IService
 9    {
10       //隱式事務(wù)
11        [OperationBehavior(TransactionScopeRequired=true,TransactionAutoComplete=true)]
12        public void Method()
13        {..........}
14    }

 1 [ServiceBehavior(TransactionTimeout="00:00:10")]
 2 public class Service:IService
 3 {......}
 4 
 5  <configuration>
 6        ........
 7       <system.serviceModel>
 8            ........
 9            <services>
10                 <service name="MyService" behaviorConfiguration="myBehavior">
11                        ......
12                 </service>
13            </services>
14            <behaviors>
15                 <serviceBehaviors>
16                     <behavior name="myBehavior" transactionTimeout="00:00:10"/>
17                </serviceBehaviors>
18            </behaviors>
19       </system.serviceModel>
20 </configuration>

 1 using (TransactionScope scope1 = new TransactionScope())            
 2 {
 3        ..............               
 4        using (TransactionScope scope2=new TransactionScope(TransactionScopeOption.RequiresNew))
 5        {
 6               ..............
 7               scope2.Complete();   //只完成嵌套式的內(nèi)部事務(wù)，但事務(wù)并未正式提交
 8        }
 9        scope1.Complete();  //代表完成所有事務(wù)，事務(wù)正式提交
10 }

 1 namespace DAL
 2 {     
 3      public class OrderDAL
 4      {
 5          public void UpdateOrder(Order order)
 6          {
 7              using (TransactionScope scope = new TransactionScope())
 8              {
 9                   ......         
10                   scope.Complete();
11              }
12          }
13      }
14  
15      public class OrderItemDAL
16      {
17          public void AddOrderItem(OrderItem orderItem)
18          {
19              using (TransactionScope scope = new TransactionScope())
20              {
21                  ......
22                  scope.Complete();
23              }
24          }
25      }
26  }
27 
28 namespace BLL
29 {
30      public class OrderManager
31      {
32          public void AddOrderItem(OrderItem item)
33          {
34              using (TransactionScope scope = new TransactionScope())
35              {
36                  OrderItemDAL orderItemDAL=new OrderItemDAL();
37                  orderItemDAL.AddOrderItem(item);
38                  OrderDAL orderDAL=new OrderDAL();
39                  ........
40                  orderDAL.UpdateOrder(order);
41                  scope.Complete();
42              }
43          }
44      }
45 }

 1      class Program
 2      {
 3          static void Main(string[] args)
 4          {
 5              Method();
 6              Console.ReadKey();
 7          }
 8  
 9          static void Method()
10          {
11              using (TransactionScope scope = new TransactionScope())
12              {
13                  ShowMessage("Main Thread");
14  
15                  //獲取一個依賴事務(wù)，把依賴事務(wù)作為回調(diào)參數(shù)傳到回調(diào)函數(shù)中
16                  DependentTransaction dependentTransaction=
17                     Transaction.Current.DependentClone(DependentCloneOption.BlockCommitUntilComplete);
18                  ThreadPool.QueueUserWorkItem(new WaitCallback(AsyncThread), dependentTransaction);
19                  ........
20                  scope.Complete(); //完成主線程事務(wù)，在依賴事務(wù)完成前，事務(wù)提交將處于阻塞狀態(tài)
21              }
22          }
23  
24          static void AsyncThread(object transaction)
25          {
26              //獲取依賴事務(wù)，利用TransactionScope（Transaction）構(gòu)造函數(shù)生成隱式事務(wù)
27              DependentTransaction dependentTransaction = (DependentTransaction)transaction;
28              using (TransactionScope scope = new TransactionScope(dependentTransaction))
29              {
30                  ShowMessage("AsyncThread");
31                  ..........
32                  scope.Complete();  //完成異步事務(wù)
33              }
34              //完成依賴事務(wù)
35              dependentTransaction.Complete();
36          }
37  
38          static void ShowMessage(string data)
39          {
40              if (Transaction.Current != null)
41              {
42                  Transaction transaction = Transaction.Current;
43                  string info = string.Format("{0}:{1}\nTransaction:\n  DistributedIndentifier:{2} \n  LocalIndentifier:{3}\n",
44                      data,Thread.CurrentThread.ManagedThreadId.ToString(),
45                      transaction.TransactionInformation.DistributedIdentifier,
46                      transaction.TransactionInformation.LocalIdentifier);
47                  Console.WriteLine(info);
48              }
49          }
50      }