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

布满荆棘的人生 2022-11-05 03:09 356阅读 0赞

一、事务定义：

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

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

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

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

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

二、显示事务实例：

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();

三、隐式事务实例：

using (MyDataContext datacontext = new MyDataContext())

TransactionOptions option=newTransactionOptions();

option.IsolationLevel =System.Transactions.IsolationLevel.ReadCommitted;//隔离级别

option.Timeout = new TimeSpan(0, 2, 0);//事务超时时间 为2分钟 默认为60秒

using (TransactionScopescope = 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\{//遇到异常自动回滚\}

三、分布式隐式事务实例：

使用分布式事务必须开启服务：Distributed Transaction Coordinator 否则报错  “服务器 'MRWANG' 上的 MSDTC 不可用 ”

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

using (MyDataContext datacontext1 = new MyDataContext())

using (TransactionScopescope1 = 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 (OtherDataContextdatacontext2 = 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\{//遇到异常自动回滚\}

三、分布式显式事务实例：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();

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

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关隐式参数和显式参数

相关 mysql 显式事务隐式事务_显式事务、隐式事务、分布式隐式事务、分布式显式事务定义以及事例...

相关显式intent和隐式intent区别

相关显式Intent与隐式Intent

相关 HTML5 label 显式、隐式联系

相关 HTML5 label 显式、隐式联系

相关隐式转换与显式转换【C#】

相关嵌套事务、隐式事务

相关 Oracle隐式游标和显式游标

相关显式Intent和隐式Intent