WCF開發(fā)工具為我們帶來了非常大的好處。它的強大的功能優(yōu)勢令其在開發(fā)領域中占據(jù)著非常重要的地位。在這里我們將會為大家詳細介紹一下有關WCF程序事務的相關定義與實現(xiàn)方法，希望能對大家有所幫助。

WCF程序事務定義如下:

[ServiceContract(SessionModeSessionMode = SessionMode.Required)]  
public interface IComplexService  
{  
[OperationContract]  
[TransactionFlow(TransactionFlowOption.Mandatory)]  
void ExecuteNoneQuery1(string sql);  
[OperationContract]  
[TransactionFlow(TransactionFlowOption.Mandatory)]  
void ExecuteNoneQuery2(string sql);  
[OperationContract]  
[TransactionFlow(TransactionFlowOption.Mandatory)]  
void ExecuteNoneQuery3(string sql);  
} 

WCF程序事務實現(xiàn)如下:

[ServiceBehavior(TransactionTimeout = "00:00:45",
TransactionIsolationLevel = System.Transactions.IsolationLevel.
Serializable)]  
public class ComplexServiceImplement : IComplexService  
{  
private static void ExecuteNoneQuery(string sql)  
{  
string sqlConnectionString = "Password=sa;User 
ID=sa;Initial Catalog=ipedf;Data Source=.";  
string oraConnectionString = "User ID=sample;
Password=sample;Data Source=insapp";  
using (OracleConnection oraConnection = new OracleConnection
(oraConnectionString))  
{  
try  
{  
oraConnection.Open();  
OracleCommand cmd = oraConnection.CreateCommand();  
cmd.CommandText = sql;  
cmd.CommandType = CommandType.Text;  
cmd.ExecuteNonQuery();  
}  
catch (Exception e)  
{  
string Debug = e.Message;  
}  
finally  
{  
oraConnection.Close();  
}  
}  
using (SqlConnection sqlConnection = 
new SqlConnection(sqlConnectionString))  
{  
try  
{  
sqlConnection.Open();  
SqlCommand cmd = sqlConnection.CreateCommand();  
cmd.CommandText = sql;  
cmd.CommandType = CommandType.Text;  
cmd.ExecuteNonQuery();  
}  
catch (Exception e)  
{  
string Debug = e.Message;  
}  
finally  
{  
sqlConnection.Close();  
}  
}  
}  
[OperationBehavior(  
TransactionScopeRequired = true, TransactionAutoComplete = true)]  
public void ExecuteNoneQuery1(string sql)  
{  
ExecuteNoneQuery(sql);  
//OperationContext.Current.SetTransactionComplete();  
}  
[OperationBehavior(  
TransactionScopeRequired = true, TransactionAutoComplete = true)]  
public void ExecuteNoneQuery2(string sql)  
{  
ExecuteNoneQuery(sql);  
//OperationContext.Current.SetTransactionComplete();  
}  
[OperationBehavior(  
TransactionScopeRequired = true, TransactionAutoComplete = true)]  
public void ExecuteNoneQuery3(string sql)  
{  
ExecuteNoneQuery(sql);  
//OperationContext.Current.SetTransactionComplete();  
} 

服務端配置如下:

< system.serviceModel> 
< !--提供的服務--> 
< services> 
< service name="Wf.Complex.Service.ComplexServiceImplement" 
behaviorConfiguration="myServiceBehavior"> 
< endpoint address="" binding="wsHttpBinding" bindingConfiguration=
"transactionalWsatHttpBinding" contract=
"Wf.Complex.Service.IComplexService"/> 
< endpoint address="mex" binding="mexHttpBinding" 
contract="IMetadataExchange"/> 
< /service> 
< /services> 
< behaviors> 
< serviceBehaviors> 
< behavior name="myServiceBehavior"> 
< serviceMetadata httpGetEnabled="True"/> 
< serviceDebug includeExceptionDetailInFaults="False"/> 
< /behavior> 
< /serviceBehaviors> 
< /behaviors> 
< bindings> 
< wsHttpBinding> 
< binding name="transactionalWsatHttpBinding" transactionFlow="true"/> 
< /wsHttpBinding> 
< /bindings> 
< /system.serviceModel> 

客戶端代碼如下:

IComplexService complex = new ComplexServiceClient();  
try  
{  
using (TransactionScope scope = new TransactionScope
(TransactionScopeOption.Required))  
{  
string sql = "delete from student";  
complex.ExecuteNoneQuery1(sql);  
sql = "insert into student(id,name) values(1,'yeyang_1')";  
complex.ExecuteNoneQuery2(sql);  
sql = "insert into student(id,name) values(2,'yeyang_2')";  
complex.ExecuteNoneQuery3(sql);  
scope.Complete();  
}  
Console.WriteLine("succeed");  
}  
catch (Exception expt)  
{  
Console.WriteLine(expt.Message);  
}  
finally  
{  
(complex as ComplexServiceClient).Close();  
} 

運行結果:#t#

服務端的ExecuteNoneQuery方法中using (OracleConnection oraConnection = new OracleConnection(oraConnectionString))代碼塊發(fā)生異常,異常內容如下:

"無法加載 DLL“oramts.dll”: 找不到指定的模塊。 (異常來自 HRESULT:0x8007007E)。"

結論:

對于數(shù)據(jù)庫事務,可以通過WCF程序事務變形的方式來實現(xiàn),但必須獲取對應數(shù)據(jù)庫產(chǎn)品的支持,sqlserver產(chǎn)品默認支持,oracle數(shù)據(jù)庫產(chǎn)品需要考慮本風險,及時規(guī)避.