Devart Connectory使用事務範圍的正確方法Mysql

Question

我們一直使用C＃和mysql與.net連接器，但個別提交有時無法提交所有內容。所以我們現在轉向支持分佈式事務的這個工具http://www.devart.com/dotconnect/mysql/。所有的工作都很好，只是我們不太清楚如何放置多重連接。方法1是將每個連接嵌套到另一箇中。方法2是分開的。我們應該關閉連接或由transScope.Complete（）處理;和transScope.Dispose（）;

方法1.

using (TransactionScope transScope = new TransactionScope()) 
{ 
    string myConnStringLocal = "User Id=***;Password=****;Host=" + globalSettings.settingLocalIP + ";Database=" + globalSettings.settingLocalDB; 
    using (MySqlConnection connectionLocal = new MySqlConnection(myConnStringLocal)) 
    { 
     connectionLocal.open() 

     string myConnStringCentral = "User Id=***;Password=*****;Host=" + globalSettings.settingCentralIP + ";Database=" + globalSettings.settingCentralDB; 
     using (MySqlConnection connectionCentral = new MySqlConnection(myConnStringCentral)) 
     { 
      connectionCentral.Open(); 
       string myConnStringCentralCopy = "User Id=*****;Password=*****;Host=" + globalSettings.settingCentralCopyIP + ";Database=" + globalSettings.settingCentralCopyDB; 
       using (MySqlConnection connectionCentralCopy = new MySqlConnection(myConnStringCentralCopy)) 
      { 
       connectionCentralCopy.Open(); 
      } 
     } 
    } 

    if (rollbackBoolean == 0) 
     transScope.Complete(); 
    else 
     transScope.Dispose(); 
} 

方法2

using (TransactionScope transScope = new TransactionScope()) 
{ 
    string myConnStringLocal = "User Id=***;Password=****;Host=" + globalSettings.settingLocalIP + ";Database=" + globalSettings.settingLocalDB; 
    using (MySqlConnection connectionLocal = new MySqlConnection(myConnStringLocal)) 
    { 
     connectionLocal.open() 
    } 

    string myConnStringCentral = "User Id=***;Password=*****;Host=" + globalSettings.settingCentralIP + ";Database=" + globalSettings.settingCentralDB; 
    using (MySqlConnection connectionCentral = new MySqlConnection(myConnStringCentral)) 
    { 
     connectionCentral.Open(); 
    } 

    string myConnStringCentralCopy = "User Id=*****;Password=*****;Host=" + globalSettings.settingCentralCopyIP + ";Database=" + globalSettings.settingCentralCopyDB; 
    using (MySqlConnection connectionCentralCopy = new MySqlConnection(myConnStringCentralCopy)) 
    { 
     connectionCentralCopy.Open(); 
    } 

    if (rollbackBoolean == 0) 
     transScope.Complete(); 
    else 
     transScope.Dispose(); 
} 

Answer 1

這兩種方法都是正確的。在這兩種情況下，TransactionScope將與dotConnect for MySQL一起使用。不需要以下代碼：

else 
transScope.Dispose(); 

因爲離開using (TransactionScope transScope = new TransactionScope())塊時Dispose方法被自動調用。

...我通過它去在我的情況意味着TransactionScope的將關閉它，當我稱之爲完整的儀式...

沒有，transScope.Complete（）不關閉連接。如果連接在TransactionScope的使用塊內關閉，則連接對象將被關閉，但如果內部連接前面有transScope.Complete（），則調用transScope.Dispose（）時，內部連接將保持打開狀態，以便向數據庫發送更改。呼叫。如果爲連接對象調用Close或Dispose方法，transScope.Dispose（）將關閉內部連接。如果連接對象未關閉，則transScope.Dispose（）對連接不起作用。

...在我的每個連接中的另一件事我跟蹤嘗試和捕獲，如果有任何錯誤我將rollbackBoolean標記爲1，所以它不會完成，整個事務應該回滾是一個正確的機制？ ...

如果發生錯誤，請不要致電完成。如果未調用Complete方法，則在執行Dispose方法時將回滾事務。

這裏是用try/catch塊中的示例和錯誤的情況下回滾事務：

using (TransactionScope transScope = new TransactionScope()) 
{ 
    try 
    { 
     string myConnStringLocal = "User Id=***;Password=****;Host=" + globalSettings.settingLocalIP + ";Database=" + globalSettings.settingLocalDB; 
     using (MySqlConnection connectionLocal = new MySqlConnection(myConnStringLocal)) 
     { 
     connectionLocal.Open(); 
     } 

     string myConnStringCentral = "User Id=***;Password=*****;Host=" + globalSettings.settingCentralIP + ";Database=" + globalSettings.settingCentralDB; 
     using (MySqlConnection connectionCentral = new MySqlConnection(myConnStringCentral)) 
     { 
     connectionCentral.Open(); 
     } 
     string myConnStringCentralCopy = "User Id=*****;Password=*****;Host=" + globalSettings.settingCentralCopyIP + ";Database=" + globalSettings.settingCentralCopyDB; 
     using (MySqlConnection connectionCentralCopy = new MySqlConnection(myConnStringCentralCopy)) 
     { 
     connectionCentralCopy.Open(); 
     } 
     transScope.Complete(); 
     Console.WriteLine("Transaction is completed"); 
    } 
    catch (Exception) 
    { 
     Console.WriteLine("Transaction is rolled back"); 
    } 
}