显式事务、隐式事务、分布式隐式事务、分布式显式事务 定义以及事例

一、事务定义：

　　显[b][b]式[/b]事务：明确指定事务的开始，connection需要打开方可使用，默认为closed，即：显示调用con.BeginTransaction()[/b]

　　隐式事务：无法[b]明确指定事务的开始，默认connection已被打开为open [/b]

[b]　　分布式隐式事务：使用TransactionScope类 , 【[b]跨库且使用同一个事务提交】[/b][/b]

[b]　　分布式显式事务：使用[b]CommittableTransaction类，con.EnlistTransaction([b][b]Transaction对象[/b])//将连接登记到事务 [b]【跨库且使用同一个事务提交】[/b][/b][/b][/b]

//以下事例采用Linq to SQL 数据源

[b][b]二、[/b]显示事务[/b]实例：

　　

using (DataClasses1DataContext datacontext = new DataClasses1DataContext())

{
try
{
//必须打开连接，用于事务的创建
if (datacontext.Connection.State == ConnectionState.Closed) datacontext.Connection.Open();
//创建事务以及将创建的事务分配给该DataContext的Transaction
datacontext.Transaction = datacontext.Connection.BeginTransaction();
var test_tran = datacontext.Products.Where(a => a.ProductID < 5).OrderBy(a => a.ProductID).Select(a => a);
foreach (var test in test_tran)
{
test.ProductName = test.ProductName + "A";
}
//datacontext.SubmitChanges();
//提交事务
//datacontext.Transaction.Commit();
}
catch
{
//回滚事务
datacontext.Transaction.Rollback();
}
}

　　[b][b]三、[/b]隐式事务[/b]实例：　　

using (MyDataContext datacontext = new MyDataContext())

　　TransactionOptions option=new TransactionOptions();

　option.IsolationLevel =System.Transactions.IsolationLevel.ReadCommitted;//隔离级别
option.Timeout = new TimeSpan(0, 2, 0);//事务超时时间  为2分钟 默认为60秒

using (TransactionScope scope = new TransactionScope())
{

　　　try
{

　　　　　　　//在无事务环境中执行操作，即：取消环境事务(TransactionScopeOption.Suppress)

//每次进入创建新的事务环境(TransactionScopeOption.RequiresNew)    　　　　　　

　　　　　　　　//每次进入将检测是否存在事务环境，若存在则使用，不存在则重新创建(TransactionScopeOption.Required)

　　　　　　　　var test_tran = datacontext.Products.Where(a => a.ProductID < 5).OrderBy(a => a.ProductID).Select(a => a);
foreach (var test in test_tran)
{
test.ProductName = test.ProductName + "A";
}
　　　　 datacontext.SubmitChanges();

scope.Complete();  //代表完成事务，事务提交
｝catch{//遇到异常自动回滚}

[b][b][b]三、分布式[/b]隐式事务[/b]实例：
使用分布式事务必须开启[b]服务：Distributed Transaction Coordinator[/b] 否则报错  “服务器 'MRWANG' 上的 MSDTC 不可用 ”
[/b]

  //分布在不同数据库之间的事务操作,如下事例：MyDataContext 和 OtherDataContext 两个不同数据库 即：分布式

using (MyDataContext datacontext1 = new MyDataContext())

using (TransactionScope scope1 = new TransactionScope())
{
　try{　　　　　

　　  var test = datacontext1.TestTable.Where(a => a.ID == 1);
foreach (var test in test)
{
test.Name = test.Name + "B";
}
datacontext1.SubmitChanges();
注：

　　　　　　///////////--如下设置以后，嵌套事务(scope2)提交将和外层(scope1)TransactionScope无关--////////////

　　　　　　      　//1.在无事务环境中执行操作，取消环境事务(TransactionScopeOption.Suppress)

//2.每次进入创建新的事务环境(TransactionScopeOption.RequiresNew)    　　　　　　

　　　　　　　///////////////--scope2提交将和外层(scope1)TransactionScope有密切关联，scope2提交成功，外层遇到异常，则全部回滚，因为属于同一个事务环境--//////////////
　　　　　　　 　//1.每次进入将检测是否存在事务环境，若存在则使用，不存在则重新创建(TransactionScopeOption.Required)　　　

　　　　　　using (OtherDataContext datacontext2 = new OtherDataContext())

using (TransactionScope scope2=new TransactionScope(TransactionScopeOption.Required))
{　　　　　　　

　　　　　　　　var test_tran = datacontext2.Products.Where(a => a.ProductID < 5).OrderBy(a => a.ProductID).Select(a => a);
foreach (var test in test_tran)
{
test.ProductName = test.ProductName + "A";
}
　　　　    　　　　　　 datacontext2.SubmitChanges();

　　　　　　　　　　　　scope2.Complete(); //只完成嵌套式的内部事务，但事务并未正式提交
}
scope1.Complete();  //代表完成所有事务，事务正式提交

    ｝catch{//遇到异常自动回滚}

[b][b][b]三、分布式显式[/b]事务[/b]实例：
[/b]using (SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings["MySqlServer"].ConnectionString))
{
using (CommittableTransaction tran= new CommittableTransaction())
{
conn.Open();
conn.EnlistTransaction(tran);//将连接登记到事务
using (SqlCommand cmd = new SqlCommand())
{
cmd.Connection = conn;
cmd.CommandType = CommandType.Text;
try
{
cmd.CommandText = "insert into TranTable(Priority) values(1)";
cmd.ExecuteNonQuery();
cmd.CommandText = "insert into TranTable(Priority) values(256)";
cmd.ExecuteNonQuery();
tran.Commit();//提交事务
}
catch (SqlException ex)
{
　　　　　　　　//回滚
tran.Rollback();
}
}
}
conn.Close();
}