e800

专题： 雷曼破产谷歌Chrome 山寨机企业SOA 测试产业反盗版战争程序员移动嵌入串串烧

更多精彩专题

开发者

首页新闻动态 java开发 .net开发 Web开发开发管理移动/嵌入开发数据结构&算法分析开源关注数据库开发 C/C++开发

甩掉DTC，实现客户端控制事务-WCF的状态

2008-04-23 11:51:10.0 推荐:0 收藏:0 评论:0 来源:e800.com.cn

把事务放到客户端控制，实际上控制还是在服务器端的，只不过操作权给了客户端而已。思路和WebService实现是一样的，即用WCF的状态化记住控制事务所需的对象，然后给客户端提供接口来操作这些对象。

闲话少说，代码如下：

服务器端代码：

[ServiceContract(SessionMode=SessionMode.Required)]
public interface IMyService
{
[OperationContract(IsTerminating=true)]
void ReleaseSession();
[OperationContract]
void BeginTransaction();
[OperationContract]
void CommitTransaction();
[OperationContract]
void RollbackTransaction();
[OperationContract]
int ExecuteNonQuery(string strCmdText);
}
[ServiceBehavior(InstanceContextMode=InstanceContextMode.PerSession)]
public class MyService : IMyService
{
private string strConnString = "server=namihei2\\KHOS;database=AEGIS_TEST;uid=sa;pwd=
Password01
!";
private SqlConnection mySqlConnection;
private SqlTransaction mySqlTransaction;

public void ReleaseSession()
{
if (mySqlConnection.State == ConnectionState.Open)
{
mySqlConnection.Close();
}
}
public void BeginTransaction()
{
mySqlConnection = new SqlConnection(strConnString);
mySqlConnection.Open();
mySqlTransaction = mySqlConnection.BeginTransaction();
}
public void CommitTransaction()
{
mySqlTransaction.Commit();
}
public void RollbackTransaction()
{
mySqlTransaction.Rollback();
}
public int ExecuteNonQuery(string strCmdText)
{
try
{
SqlCommand objSqlCommand = new SqlCommand(strCmdText);
objSqlCommand.Connection = mySqlConnection;
objSqlCommand.Transaction = mySqlTransaction;
return objSqlCommand.ExecuteNonQuery();
}
catch (Exception ex)
{
throw new FaultException(ex.Message);
}
}
}

客户端代码：

static void Main(string[] args)
{
Console.WriteLine("Session Transaction Begin");
SessionTrans.MyServiceClient serviceProxy = new ConsoleTest.SessionTrans.
MyServiceClient();
try
{
serviceProxy.BeginTransaction();
serviceProxy.ExecuteNonQuery("update ATMAccount set Amount = 1000");
serviceProxy.ExecuteNonQuery("insert into ATMLog(AccountNumber,OperationType) 
values ('888', 'good')");
//serviceProxy.ExecuteNonQuery("insert into ATMLog(AccountNumber,OperationType) 
values ('888', 'goodgoodgoodgoodgoodgoodgoodgoodgoodgoodgoodgoodgoodgoodgoodgoodgood')");
serviceProxy.CommitTransaction();
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
serviceProxy.RollbackTransaction();
}
finally
{
serviceProxy.ReleaseSession();
serviceProxy.Close();
}
Console.WriteLine("Session Transaction End");
Console.Read();