.NET开发中的事务处理大比拼

本文转载:http://www.cnblogs.com/jhxk/articles/2696307.html

http://liubaolongg.blog.163.com/blog/static/21386802201222631355218/

.NET事务

  • ADO.NET事务
using (SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings["MySqlServer"].ConnectionString))
{
    conn.Open();
    using (SqlTransaction tran = conn.BeginTransaction())
    {
        using (SqlCommand cmd = new SqlCommand())
        {
            cmd.Connection = conn;
            cmd.CommandType = CommandType.Text;
            cmd.Transaction = tran;
            try
            {
                cmd.CommandText = sql1;
                cmd.ExecuteNonQuery();
                cmd.CommandText = sql2;
                cmd.ExecuteNonQuery();
                tran.Commit();
                Response.Write("Ok");
            }
            catch (SqlException ex)
            {
                tran.Rollback();
                Response.Write("Error:" + ex.Message);
            }
        }
    }
    conn.Close();
} 

    ADO.NET 显式事务占用资源少、速度快,但功能简单,只能管理单一对象和单一持久资源间的事务,比如想在数据库 B 插入失败,则回滚对数据库 A 的操作,就无法用这种 ADO.NET 显式事务来实现。 
  • 隐式事务(TransactionScope)
隐式事务不具有Commit、Roolback方法。

using (SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings["MySqlServer"].ConnectionString))
{
    using (TransactionScope ts = new TransactionScope())
    {
        conn.Open();
        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();
                ts.Complete();
                Response.Write("Ok");
            }
            catch (SqlException ex)
            {
                Response.Write("Error:" + ex.Message);
            }
        }
    }
    conn.Close();
} 

    TransactionScope没有和数据库直接关联,那是怎么实现用事务的方式执行语句的呢?

    如果我们在连接字符串里面加上Enlist=false;,再执行上面的代码,发现插入了一条1的记录,说明并不是以事务方式执行的。Enlist默认为true,SqlClient会自动检测是否存在事务,如果有事务,则自动登记到事务中。
  • 显示事务(CommittableTransaction)
using (SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings["MySqlServer"].ConnectionString))
{
    using (CommittableTransaction ct = new CommittableTransaction())
    {
        conn.Open();
        conn.EnlistTransaction(ct);//将连接登记到事务
        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();
                ct.Commit();
                Response.Write("Ok");
            }
            catch (SqlException ex)
            {
                ct.Rollback();
                Response.Write("Error:" + ex.Message);
            }
        }
    }
    conn.Close();
}
  • WebService(TransactionOption)
首先引用using System.EnterpriseServices;,然后设置属性TransactionOption = TransactionOption.Required。

设置TransactionOption.Disabled、TransactionOption.NotSupported、TransactionOption.Supported表示不参与事务。

设置TransactionOption.Required、TransactionOption.RequiresNew表示创建一个新的事务。意思是说当TransactionOption的属性为Required或 RequiresNew的WEB服务方法调用另一个TransactionOption的属性为Required或RequiresNew的WEB服务方法时,每个WEB服务方法将参与他们自己的事务,因为Web Service方法只能用作事务中的根对象。


PS:WEB服务方法的TransactionOption默认属性为Disabled

提交事务ContextUtil.SetComplete();

回滚事务ContextUtil.SetAbort();

 

[WebMethod(TransactionOption = TransactionOption.Required)]
public string HelloWorld()
{
    try
    {
        ContextUtil.EnableCommit();//开启事务
        SqlConnection con = new SqlConnection("server=.;uid=sa;pwd=sa;database=db.mdf;");
        SqlCommand cmd = new SqlCommand("update users set name = 'yangxing' where id = 5", con);
        con.Open();
        cmd.ExecuteNonQuery();
        cmd.CommandText = "update users1 set name = 'yangxing1' where id = 6";//users1表不存在,执行该语句报错
        cmd.ExecuteNonQuery();//抛出异常
        ContextUtil.SetComplete();//提交事务
        return "true";
    }
    catch
    {
        ContextUtil.SetAbort();//回滚事务
        return "false";
    }
} 
  • 自动事务处理
在方法之前增加属性[AutoComplete(true)],这样如果方法执行时没有异常就默认提交,如果有异常则这个方法就会回滚。
                                    
using System;
using System.Data.SqlClient;
using System.EnterpriseServices;//企业级服务COM+事务
namespace ClassTran
{
    [Transaction(TransactionOption.Required)]
    public class OrderData2 : ServicedComponent
    {
        //自动事务
        [AutoComplete(true)]
        public string WorkTran()
        {
            string msg = "";
            string conString = "data source=127.0.0.1;database=codematic;
               user id=sa;password=";
            SqlConnection myConnection = new SqlConnection(conString);
            myConnection.Open();                                   
            SqlCommand myCommand = new SqlCommand();
            myCommand.Connection = myConnection;           
            try
            {
                myCommand.CommandText = "update P_Product set Name='电脑2'
                     where Id=52";
                myCommand.ExecuteNonQuery();
                myCommand.CommandText = "update P_Product set Name='电脑3'
                where Id=53";
                myCommand.ExecuteNonQuery();
                msg ="成功!";
            }
            catch (Exception ex)
            {
                msg = "失败:"+ex.Message;              
            }
            finally
            {
                myConnection.Close();
            }
            return msg;
        }
    }
}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏NetCore

[原创]Fluent NHibernate之旅(四)-- 关系(上)

经过了前面三篇的介绍,相信大家对Fluent NHibernate已经有一定的了解了,在我们学习中,Fluent 也已经进入了RTM版本。这次的版本发布离RC版...

2166
来自专栏小樱的经验随笔

自己手动复现一个熊猫烧香病毒

最近逛了一下 bilibili ,偶然的一次机会,我在 bilibili 上看到了某个 up 主分享了一个他自己仿照熊猫病毒的原型制作的一个病毒的演示视频,虽然...

6482
来自专栏各种机器学习基础算法

laravel5.4上传EXCEL并解析

首先,通过composer引入Laravel Excel v2.1库 composer require maatwebsite/excel ~2.1.0 将Se...

35312
来自专栏编程软文

1小时轻松上手springmvc,视频网站后台开发

2003
来自专栏我杨某人的青春满是悔恨

Kingfisher源码阅读(二)

上次说到了downloadAndCacheImageWithURL这个方法,看名字就知道既要下载图片又要缓存图片,它的方法体是这样的:

1665
来自专栏马洪彪

Java生成条码二维码

一、概述 可用barcode4j或zxing等第三方库,推荐zxing。 barcode4j资料链接:http://barcode4j.sourceforge....

4898
来自专栏小尘哥的专栏

小程序(3):授权登录

判断是否授权,如果没有,则显示授权按钮。注意上面的open-type="getUserInfo",这个会自动调起授权框。看一下js

2504
来自专栏Hadoop实操

如何使用HBase存储图片

5312
来自专栏后端技术探索

使用Swoole异步发送邮件

最近做公司的一个管理系统,需要把每天的统计信息发送到领导的邮箱。由于使用SMTP协议发送邮件的速度太慢,所以只能异步发送。刚开始实现了一个基于php-reque...

1921
来自专栏运维

安装rhel6系统分区指导

系统分区指导 1,Unless you have a reason for doing otherwise, we recommend that you cr...

1543

扫码关注云+社区

领取腾讯云代金券