博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
关于.NET编程中各种事务的实现
阅读量:4984 次
发布时间:2019-06-12

本文共 2672 字,大约阅读时间需要 8 分钟。

从数据库事务开始

在很早的以前,我们要实现一个事务通常是基于SQL的数据库事务,一般的通过SQL查询语言来实现,如下所示,同时更新两本书的价格:

BEGIN TRANSACTION  UPDATE tb_Book SET Price=122 WHERE IDENT_CURRENT=1001UPDATE tb_Book SET Price=88 WHERE IDENT_CURRENT=1002IF @@ERROR <> 0   BEGIN     ROLLBACK TRANSACTION  END ELSE    COMMIT TRANSACTION

ADO.NET事务和分布式事务

随着.NET技术的不断发展,可通过ADO.NET来实现,这样我们可以将事务更好的应用在业务逻辑中,而非数据库存储中,这样能够更好的实现业务和存储分离,使的事务被业务逻辑所控制,数据库专注于数据存储,达到各负其责的作用,在ADO.NET中事务的写法是:

using (DbTransaction transaction = connection.BeginTransaction()){    command.Transaction = transaction;    try    {        command.ExecuteNonQuery();        transaction.Commit();    }    catch (Exception e)    {        transaction.Rollback();        throw;    }}

上面的代码只能基于同一个数据库连接进行,后来为了实现远程多个数据库的事务,提出了分布式事务,夸数据库服务器进行事务关联:

using (TransactionScope transactionScope = new TransactionScope()){    //操作数据库服务器1中的数据库    using (SqlConnection connection = new SqlConnection(connectionString1))    {        SqlCommand command = new SqlCommand(commandText1, connection);        connection.Open();        command.ExecuteNonQuery();        connection.Close();    }    //操作数据库服务器2中的数据库    using (SqlConnection connection = new SqlConnection(connectionString2))    {        SqlCommand command = new SqlCommand(commandText2, connection);        connection.Open();        command.ExecuteNonQuery();        connection.Close();    }    transactionScope.Complete();}

基于文件系统的事务(TXF)

有时候,我们需要将NTFS文件系统的操作进行事务管理,例如:首先将图片保存到硬盘,然后将文件路径存入数据库,这两个步骤是满足事务(ACID)原则的,数据库应该与文件系统保持同步,要么都删除,要么都存在,同生共死。但可惜微软没有在.NET中提供这样的API接口供开发人员使用,零度博主抱着对技术精益求精的态度进行了一番的折腾,终于在国外的一个社区找到了针对操作系统内核(kernel32.dll)封装的KTM事务管理方案,零度博主针对自己的需求进行了改进,本方案的C#.NET调用方式如下:

using (TransactionScope transactionScope = new TransactionScope()){    string commandText = "UPDATE Book SET Price=88.50 WHERE ID=1001";    var fileStream = TransactedFile.Open(@"log.txt", FileMode.OpenOrCreate, FileAccess.Write, FileShare.Write);    StreamWriter streamWrite = new StreamWriter(fileStream);    streamWrite.WriteLine(string.Concat(DateTime.Now, commandText));    streamWrite.Flush();    streamWrite.Close();    SqlConnection connection = new SqlConnection(connectionString);    SqlCommand command = new SqlCommand(commandText, connection);    connection.Open();    command.ExecuteNonQuery();    connection.Close();    transactionScope.Complete();}

以上示例代码首先创建TransactionScope事务环境,将文件操作和数据库操作关联成成同一个事务,TransactedFile正是上文提到的基于KTM的本地事务封装,数据库事务本身支持隐式自动关联,当前者和后者同时被关联到TransactionScope事务上下文环境后,就形成了一个完成的事务。上面的示例首先向磁盘的log.txt中写入当前的时间和要执行的SQL语句,然后通过SQL更新Book价格,如果更新价格失败则回滚写入的日志(自动删除日志)。

总之:事务是一个复杂的系统,主要有KTM、DTC和LTM事务,内部实现及其复杂,本文主要简单说明事务的基本用法,针对原理性的研究请关注零度博客未来的文章,感谢您的阅读,希望对您有所帮助!

转载于:https://www.cnblogs.com/amylis_chen/p/8961614.html

你可能感兴趣的文章
NOIP2011T2 统计单词数
查看>>
每日5min分享-接口测试框架
查看>>
超好用超短的小程序请求封装
查看>>
PHP 解析Url 面向对象
查看>>
nodejs express route 的用法
查看>>
Python多线程
查看>>
java IO整理-File
查看>>
粗谈Springboot框架,众所周知Springboot是有spring推出的微服务框架,什么是微服务框架呢!...
查看>>
家庭记账本六
查看>>
离钱越近,才能赚钱越‘稳’
查看>>
mapping.mapper.xml文件中的标签详解
查看>>
软件工程——理论、方法与实践⑦
查看>>
商品评论
查看>>
【转】Android 组件系列-----Activity保存状态
查看>>
批处理实现多线程执行命令列表文件
查看>>
跟牛牛老师学习python自动化的第六天
查看>>
利用Flume将本地文件数据中收集到HDFS
查看>>
html5的优缺点
查看>>
Vim 加 Gmail 变身 Vmail
查看>>
P1294 高手去散步
查看>>