WCF TransactionScope不回滾

Question

我已經使用此GUID：http://www.c-sharpcorner.com/uploadfile/shivprasadk/wcf-faq-part-5-transactions/ 爲什麼不回滾？我不明白！

我有一個服務和客戶端應用程序，我沒有線索這個代碼有什麼問題。 完美地做這行，並將其保存在我的數據庫後，

proxy.AddEmployee("Stav", "20"); 

下一行拋出異常becouse我沒有發送一個數字時代的參數，但成交犯規回滾的第一行這樣的信息：STAV， 20我的數據庫仍然存在！

proxy.AddEmployee("Stav123", "Not a Number(-->will do Exception)") 

編輯1： 我添加AddEmployee實現。

客戶端：

static void Main(string[] args) 
     { 
      ServiceReference1.IJob proxy = new ServiceReference1.JobClient(); 
      using (TransactionScope ts = new TransactionScope(TransactionScopeOption.Required)) 
      { 
       try 
       { 
        proxy.AddEmployee("Stav", "20"); 
        proxy.AddEmployee("Stav123", "Not a Number(-->will do Exception) ");//stop the running and show the Exception but keep the stav,20 in DB 
        ts.Complete(); 
       } 
       catch 
       { 
        ts.Dispose(); 
       } 
      } 
     } 

服務：

[ServiceContract] 
    public interface IJob 
    { 
     [OperationContract] 
     [TransactionFlow(TransactionFlowOption.Allowed)] 
     void AddEmployee(string Name, string Age); 
    } 
public class JobImplement:IJob 
    { 
     [OperationBehavior(TransactionScopeRequired = true)] 
     public void AddEmployee(string Name, string Age) 
     { 
string strConnection = @"Data Source=.\SQLEXPRESS;AttachDbFilename=C:\Users\stavalfi\Desktop\WCF2\ConsoleApplication4\WCF_DB.mdf;Integrated Security=True;Connect Timeout=30;User Instance=True"; 
     SqlConnection objConnection = new SqlConnection(strConnection); 
     objConnection.Open(); 
     SqlCommand objCommand = new SqlCommand("INSERT INTO Employee (Name,Age) " + "VALUES ('" + Name + "' ,'" + Age + "')", objConnection); 
     objCommand.ExecuteNonQuery(); 
     objConnection.Close(); 
     } 
    } 
static void Main(string[] args) 
     { 
      WSHttpBinding Basic = new WSHttpBinding(); 
      Basic.TransactionFlow = true; 
      ServiceHost host = new ServiceHost(typeof(JobImplement), new Uri("http://localhost:8080")); 
      // 
      ServiceMetadataBehavior behavior = new ServiceMetadataBehavior(); 
      behavior.HttpGetEnabled = true; 
      host.Description.Behaviors.Add(behavior); 
      // 
      host.AddServiceEndpoint(typeof(IJob), new BasicHttpBinding(), "Request123"); 
      host.Open(); 
      // 
      Console.WriteLine("opened"); 
      Console.ReadLine(); 
      // 
      host.Close(); 
     } 

Answer 1

看起來你在你的代碼在這裏有一個可能的拼寫錯誤：

static void Main(string[] args)   
{    
    ... 
    host.AddServiceEndpoint(typeof(IJob), new BasicHttpBinding(), "Request123"); 
    ... 
} 

您要添加類型的basicHttpBinding的端點 - 不支持事務具有約束力的協議。

我在想，你其實是要做到這一點：

static void Main(string[] args)   
{    
    WSHttpBinding Basic = new WSHttpBinding(); 
    Basic.TransactionFlow = true; 
    ... 
    host.AddServiceEndpoint(typeof(IJob), Basic, "Request123"); 
    ... 
} 

這會給你一個WsHttpBinding的終點 - 有約束力的協議，不支持事務。

Answer 2

你應該實現自己的回滾功能。這是做這件事的基本方法。在您的服務類接口添加[ServiceBehavior(InstanceContextMode = InstanceContextMode.PerSession, ConcurrencyMode = ConcurrencyMode.Single)]屬性。然後將這些代碼：

private SqlCommand Command { get; set; } 

[OperationContract] 
public void BeginTransaction() 
{ 
    this.Command = new SqlCommand(); 
    string strConnection = @"Data Source=.\SQLEXPRESS;AttachDbFilename=C:\Users\stavalfi\Desktop\WCF2\ConsoleApplication4\WCF_DB.mdf;Integrated Security=True;Connect Timeout=30;User Instance=True"; 
    SqlConnection objConnection = new SqlConnection(strConnection); 
    objConnection.Open(); 
    this.Command.Connection = objConnection; 
} 

[OperationContract] 
public void RollBackTransaction() 
{ 
    this.Command.Transaction.Rollback(); 
} 

[OperationContract] 
public void CommitTransaction() 
{ 
    this.Command.Transaction.Commit(); 
} 

[OperationContract] 
public void CloseConnection() 
{ 
    this.Command.Connection.Close(); 
    this.Command = null; 
} 

[OperationBehavior(TransactionScopeRequired = true)] 
public void AddEmployee(string Name, string Age) 
{ 
    this.Command.CommandText = "INSERT INTO Employee (Name,Age) " + "VALUES ('" + Name + "' ,'" + Age + "')"; 
    this.Command.ExecuteNonQuery(); 
} 

然後你就可以在客戶端代碼這樣的訪問：

try 
{ 
    proxy.BeginTransaction(); 
    proxy.AddEmployee("Stav", "20"); 
    proxy.AddEmployee("Stav123", "Not a Number(-->will do Exception)"); 
    proxy.CommitTransaction(); 
} 
catch 
{ 
    proxy.RollBackTransaction(); 
} 
finally 
{ 
    proxy.CloseConnection(); 
} 

希望這有助於。