全部回滚方法3,和触发器中事务个故事

全部回滚方法3,则只回滚错误操作语句(就是说这句不执行了,/,事务保证性对业务逻辑会有重要影响,事务处理是数据的重要特性,和触发器中事务个故事,如果你有对触发器和事务的概念,begin tran表示事务开始,sql server 2000上不支持这个语句

图片 19
Use TestDB
SET XACT_ABORT ON -- 打开
Begin TransAction
    Insert Into Person(PersonId,PersonName)
                Values('1','Name1')
    Insert Into Person(PersonId,PersonName)
                Values('1','Name1')
    Insert Into Person(PersonId,PersonName)
                Values('3','Name3')
Commit TransAction
/*
    当 SET XACT_ABORT 为 ON 时,
    如果执行 Transact-SQL 语句产生运行时错误,
    则整个事务将终止并回滚。 
    默认情况下它是OFF状态。
*/

图片 1😉

事务处理是数据的重要特性。尤其是对于一些支付系统,事务保证性对业务逻辑会有重要影响。golang的mysql驱动也封装好了事务相关的操作。我们已经学习了db的Query和Exec方法处理查询和修改数据库。


上面的代码显示了SqlTransaction类的基本使用方法。首先使用SqlConnection建立连接后,sqlConn.BeginTransaction()表示事务的开始,在执行一些基本操作后(代码是执行一个insert和一个update)后,执行sqlTrans.Commit();表示事务提交,这时候,刚才insert和update的数据在数据库才能被使用。如果把throw
new Exception(“test exception.the transaction must
rollback”);这句的注释去掉,我们会发现,程序没有执行提交,而是直接执行了catch中的Rollback(),进行了回滚。那么刚才的insert和update一起被回滚。

最后要注意的是:如果一个事务写了 Begin TransAction 而没写 Commit TransAction 或 Rollback TransAction 则相关操作的数据(也许是表,也许是列,这我还没测试。。。)会被锁住。。。而对于锁住的解决办法就是单独执行一下Commit TransAction 或 Rollback TransAction

USE [TestDB]
GO
/****** 对象:  Table [dbo].[Person]   
脚本日期: 11/23/2008 13:37:48 ******/
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE TABLE [dbo].[Person](
    [PersonId] [nchar](18) NOT NULL,
    [PersonName] [nchar](20) NOT NULL,
 CONSTRAINT [PK_Person] PRIMARY KEY CLUSTERED 
(
    [PersonId] ASC
)WITH (PAD_INDEX  = OFF,
STATISTICS_NORECOMPUTE  = OFF,
IGNORE_DUP_KEY = OFF,
ALLOW_ROW_LOCKS  = ON,
ALLOW_PAGE_LOCKS  = ON)
ON [PRIMARY]
) ON [PRIMARY]

实践

前面对事务解释了一堆,说了那么多,其实还不如share的code。下面就事务的使用做简单的介绍。因为事务是单个连接,因此任何事务处理过程的出现了异常,都需要使用rollback,一方面是为了保证数据完整一致性,另一方面是释放事务绑定的连接。

func doSomething(){ panic("A Panic Running Error")}func clearTransaction(tx *sql.Tx){ err := tx.Rollback() if err != sql.ErrTxDone && err != nil{ log.Fatalln }}func main() { db, err := sql.Open("mysql", "root:@tcp(127.0.0.1:3306)/test?parseTime=true") if err != nil { log.Fatalln } defer db.Close() tx, err := db.Begin() if err != nil { log.Fatalln } defer clearTransaction rs, err := tx.Exec("UPDATE user SET gold=50 WHERE real_name='vanyarpy'") if err != nil { log.Fatalln } rowAffected, err := rs.RowsAffected() if err != nil { log.Fatalln } fmt.Println(rowAffected) rs, err = tx.Exec("UPDATE user SET gold=150 WHERE real_name='noldorpy'") if err != nil { log.Fatalln } rowAffected, err = rs.RowsAffected() if err != nil { log.Fatalln } fmt.Println(rowAffected) doSomething() if err := tx.Commit(); err != nil { // tx.Rollback() 此时处理错误,会忽略doSomthing的异常 log.Fatalln }}

我们定义了一个clearTransaction函数,该函数会执行rollback操作。因为我们事务处理过程中,任何一个错误都会导致main函数退出,因此在main函数退出执行defer的rollback操作,回滚事务和释放连接。

如果不添加defer,只在最后Commit后check错误err后再rollback,那么当doSomething发生异常的时候,函数就退出了,此时还没有执行到tx.Commit。这样就导致事务的连接没有关闭,事务也没有回滚。

     在下面的内容,用到一些SQL Server
触发器和事务的一些术语,如果有些不明白的地方,可以查阅MSDN资料库,或SQL
Server本地帮助文档:

三、TransactionScope用法:TransactionScope继承IDisposable接口,所以一般在using中使用。

全部回滚方法2:使用Try…Catch

 

事务与连接

创建Tx对象的时候,会从连接池中取出连接,然后调用相关的Exec方法的时候,连接仍然会绑定在改事务处理中。在实际的事务处理中,go可能创建不同的连接,但是那些其他连接都不属于该事务。例如上面例子中db创建的连接和tx的连接就不是一回事。

事务的连接生命周期从Beigin函数调用起,直到Commit和Rollback函数的调用结束。事务也提供了prepare语句的使用方式,但是需要使用Tx.Stmt方法创建。prepare设计的初衷是多次执行,对于事务,有可能需要多次执行同一个sql。然而无论是正常的prepare和事务处理,prepare对于连接的管理都有点小复杂。因此私以为尽量避免在事务中使用prepare方式。例如下面例子就容易导致错误:

tx, _ := db.Begin()defer tx.Rollback()stmt, _ tx.Prepare("INSERT ...")defer stmt.Close()tx.Commit()

因为stmt.Close使用defer语句,即函数退出的时候再清理stmt,可是实际执行过程的时候,tx.Commit就已经释放了连接。当函数退出的时候,再执行stmt.Close的时候,连接可能有被使用了。

     首先,
说下我写篇文章的目的,我希望能把我对触发器的理解,分享出来与你一起学习。如果你有对触发器和事务的概念,有些了解,这篇文章,对你来说会是很简单,或能让你更进一步的了解触发器里面的一些故事,和触发器中事务个故事。在这边文章里面,我不会从触发器和事务的概念去讲述,而是从常见的两种触发器类型(DML触发器
& DDL触发器)和After触发器 &  Instead Of
触发器的应用不同,开始说起它们,然后是说与事务有关的故事。如果,你有什么建议和意见,都可以通过文章后面的回复与我沟通,或者通过E-Mail方式,与
我交流;我的Email地址是:glal@163.com

一。sql语句:Sql Server2005/2008提供了begin tran,commit tran和rollback
tran三个语句来显示的使用事务。begin tran表示事务开始,commit
tran表示事务提交,rollback tran表示事务回滚。

全部回滚方法3:自定义错误变量

 

事务并发

对于sql.Tx对象,因为事务过程只有一个连接,事务内的操作都是顺序执行的,在开始下一个数据库交互之前,必须先完成上一个数据库交互。例如下面的例子:

rows, _ := db.Query("SELECT id FROM user") for rows.Next() { var mid, did int rows.Scan db.QueryRow("SELECT id FROM detail_user WHERE master = ?", mid).Scan }

调用了Query方法之后,在Next方法中取结果的时候,rows是维护了一个连接,再次调用QueryRow的时候,db会再从连接池取出一个新的连接。rows和db的连接两者可以并存,并且相互不影响。

可是,这样逻辑在事务处理中将会失效:

rows, _ := tx.Query("SELECT id FROM user")for rows.Next() { var mid, did int rows.Scan tx.QueryRow("SELECT id FROM detail_user WHERE master = ?", mid).Scan}

tx执行了Query方法后,连接转移到rows上,在Next方法中,tx.QueryRow将尝试获取该连接进行数据库操作。因为还没有调用rows.Close,因此底层的连接属于busy状态,tx是无法再进行查询的。上面的例子看起来有点傻,毕竟涉及这样的操作,使用query的join语句就能规避这个问题。例子只是为了说明tx的使用问题。

  • DML触发器(DML Triggers)
  • DDL触发器(DDL Triggers)
  • 事务模式(Transaction modes)
  • 显式事务(Explicit Transactions)
  • 自动提交事务(Autocommit Transactions)
  • 隐式事务(Implicit Transactions)
  • 批范围的事务(Batch-scoped Transactions)

     
执行上面的代码,我们会发现,插入和更新同时都成功了。把RAISERROR的注释去掉后,再执行,我们会发现,插入和更新都回滚了。因为RAISERROR抛出异常后,没有执行到commit
tran,而是直接执行begin catch里面的rollback tran回滚语句了。

USE [TestDB]
GO
/****** 对象:  Table [dbo].[Person]    脚本日期: 11/23/2008 13:37:48 ******/
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE TABLE [dbo].[Person](
    [PersonId] [nchar](18) NOT NULL,
    [PersonName] [nchar](20) NOT NULL,
 CONSTRAINT [PK_Person] PRIMARY KEY CLUSTERED 
(
    [PersonId] ASC
)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON) ON [PRIMARY]
) ON [PRIMARY]

全部回滚方法2:使用Try…Catch

tx对象

一般查询使用的是db对象的方法,事务则是使用另外一个对象。sql.Tx对象。使用db的Begin方法可以创建tx对象。tx对象也有数据库交互的Query,Exec和Prepare方法。用法和db的相关用法类似。查询或修改的操作完毕之后,需要调用tx对象的Commit提交或者Rollback方法回滚。

一旦创建了tx对象,事务处理都依赖与tx对象,这个对象会从连接池中取出一个空闲的连接,接下来的sql执行都基于这个连接,直到commit或者rollback调用之后,才会把连接释放到连接池。

在事务处理的时候,不能使用db的查询方法,虽然后者可以获取数据,可是这不属于同一个事务处理,将不会接受commit和rollback的改变,一个简单的事务例子如下:

tx, err := db.Begin()tx.Exectx.Exectx.commit()

在tx中使用db是错误的:

tx, err := db.Begin()db.Exectx.Exectx.commit()

上述代码在调用db的Eexc方法的时候,tx会绑定连接到事务中,db则是额外的一个连接,两者不是同一个事务。需要注意,Begin和Commit方法,与sql语句中的BEGIN或COMMIT语句没有关系。

After触发器 Vs Instead Of触发器

            After 触发器将在处理触发操作(Insert、Update 或
Delete)、Instead Of 触发器和约束之后激发。Instead
Of是将在处理约束前激发,以替代触发操作。下面两张图描述了After触发器和Instead
Of触发器的执行先后顺序。

    
图片 2      
图片 3 

    
图1                                                                            
图2

    
左边的图1,描述了After触发器执行顺序情况,我在这里通过一个简单的例子来说明After触发器的执行顺序,以便能加深对左图1
After触发器的理解。

先创建表Contact

use tempdb

Go

if object_id('Contact') Is Not null 

    Drop Table Contact

Go

Create Table Contact

(

    ID int Primary Key Identity(1,1),

    Name nvarchar(50),

    Sex nchar(2) Check(Sex In(N'F',N'M')) Default('M')

)

Go

再创建After触发器tr_Contact

use tempdb

Go

If Exists(Select 1 From sys.triggers Where name='tr_Contact')

    Drop  Trigger tr_Contact 

Go

Create Trigger     tr_Contact On Contact After Insert

As

Select Name,Sex From Inserted /*显示Inserted表的内容,用来判断触发器执行的先后顺序*/

Go

然后Insert数据,判断After触发器的执行顺序

use tempdb

Go

Insert Into Contact (Name,Sex) Values ('Bill','U')

Go

这里,在没有运行Insert语句之前,我们可以判断,执行Insert过程会触发Check错误,因为字段Sex的值必须是”F”
Or “M”,而这里将要插入的是”U”.好了,再来看运行Insert语句后的情况。

图片 4

本例子,只看到引发Check约束冲突的错误,而无法看到Inserted表的数据,说明一点就是,引起Check约束之前,不会引发After触发器tr_Contact的操作。这就验证了图1的After触发器执行顺序情况。

     好了,接下来,我们再测试Instead Of触发器
图2的情况;我使用上边建好的测试表Contact来举例。

先修改触发器tr_Contact内容,

use tempdb

Go

If Exists(Select 1 From sys.triggers Where name='tr_Contact')

    Drop  Trigger tr_Contact 

Go

Create Trigger     tr_Contact On Contact Instead Of Insert

As

print '触发器作代替执行操作'

Insert Into Contact (Name,Sex) Select Name,Sex From Inserted /*代替触发器外面的Insert行为*/

Go

再Insert数据,观察SQL Server执行后的提示信息,

use tempdb

Go

Insert Into Contact (Name,Sex) Values ('Bill','U')

Go

图片 5  

这里,看到,先是触发器操作,再是Check约束处理。本例中,在触发器里面使用一条Insert的语句来描述触发器的代替执行操作,这SQL语句通过Select表Inserted得到触发器外面Insert内容。当SQL
Server执行到触发器里面的Insert语句,才会引起Check约束处理.倘若,在触发器tr_Contact没有Insert的代替行为,那么就不会出现Check约束处理错误的信息(注:没有Check错误信息,并不表示没有作Check处理)。修改上边的触发器tr_Contact内容,做个简易的验证.

use tempdb

Go

If Exists(Select 1 From sys.triggers Where name='tr_Contact')

    Drop  Trigger tr_Contact 

Go

Create Trigger     tr_Contact On Contact Instead Of Insert

As

print '触发器作代替执行操作'

Go

use tempdb

Go

Insert Into Contact (Name,Sex) Values ('Bill','U')

Go

Select * From Contact

图片 6图片 7

可以看到,Instead Of
触发器tr_Contact内容没有Insert的SQL语句,不会引发Check处理错误,而且检查Insert动作后的结果,发现表Contact也没有之前我们Insert的数据。这些足够验证了Instead
Of触发器的执行先后顺序和代替执行操作。

 

 

 

DML 触发器 Vs DDL 触发器


      DML 触发器在 Insert、Update 和 Delete 语句上操作,可以作为After
触发器 和 Instead Of 触发器。

     DDL 触发器对 Create、Alter、Drop 和其他 DDL 语句以及执行 DDL
式操作的存储过程执行操作,只可作为After触发器,不能Instead Of触发器。

     前面的内容,有描述DML触发器中的After & Instead
Of触发器内容,下面直接来看DDL的操作顺序:

    
图片 8

     图3.

     从图3.可以知道,在DDL触发器中,是没有创建Inserted &
Deleted过程的,我们通过简单的例子去测试下。

     创建一个服务器范围内的DDL触发器,检查有没有Inserted 表,

use master

Go

If Exists(Select 1 From sys.server_triggers Where name='tr_createDataBase')

    Drop Trigger  tr_createDataBase On All Server

Go

Create Trigger tr_createDataBase On All Server After Create_DataBase

As 

Select * From inserted

Go

执行创建数据库SQL语句,

use master

Go

Create Database myDataBase On Primary

(Name='MyDataBase_Data',Filename='E:\DATA\SQL2008DE01\MyDataBase_Data.mdf') Log On 

(Name='MyDataBase_Log',Filename='E:\DATA\SQL2008DE01\MyDataBase_Log.ldf')

Go

返回错误信息,

图片 9

使用上边相同的方法,我们验证DDL触发器中,不会创建Deleted表;是否创建Deleted
&
Inserted,也可以认为是DDL触发器与DML触发器不同之处。在DLL触发器与DML触发器不同的一个重要特征是作用域,DML触发器只能应用在数据库层(Database
Level)的表和视图上,而DDL触发器应用于数据库层(Database
Level)和服务器层(Server
Level);DDL触发器的作用域取决于事件。下面简单描述下事件组的内容。

 

数据库层事件主要包含:

  1. DDL Table events: Create table, Alter table, Drop table
  2. DDL view events : Create view, Alter view, Drop view
  3. DDL trigger events :Create trigger, Drop trigger, Alter trigger
  4. DDL synonym events: Create synonym, drop synonym
  5. DDL Index events: Create index, Alter index, Drop Index
  6. DDL Database level security events:
    • Create User, Drop user, Alter user
    • Create role, Drop role, Alter role
    • Create application role, Drop application role, Alter
      Application role
    • Create Schema, Drop Schema, Alter Schema
    • Grant database access, Revoke database access, Deny Database
      access
  7. DDL Service broker events:
    • Create Message type, Alter Message type, Drop Message type
    • Create contract, Drop contract, Alter contract
    • Create Service, Alter service, Drop Service
    • Create route, Drop route, Alter route

服务器层事件主要包含:

  1. Create Database, Drop Database
  2. Create Login, Drop Login, Alter Login

 

 

触发器和事务的故事


      在前面的几个例子中,如DML触发器例子,Insert
语句执行后,因为触发器操作 或
Check处理错误,没有把数据真正的插入到表Contact中。其实,当执行触发器时,触发器的操作好像有一个未完成的事务在起作用。
通过几个例子来讲解触发器和事务的故事。

创建一个表ContactHIST,用于对表Contact作Update Or
Delete操作时,把操作前的数据Insert到表ContactHIST中。

use tempdb

Go

if object_id('ContactHIST') Is Not null 

    Drop Table ContactHIST

Go

Create Table ContactHIST

(

    ID int Primary Key Identity(1,1),

    ContactID int,

    Name nvarchar(50),

    Sex nchar(2),

    ActionType nvarchar(10) Check(ActionType In('Update','Delete')),

    LastUpdateDate datetime Default(getdate())

)

Go

修改触发器tr_Contact内容,

use tempdb

Go

If Exists(Select 1 From sys.triggers Where name='tr_Contact')

    Drop  Trigger tr_Contact 

Go

Create Trigger     tr_Contact On Contact After Update,Delete

As

Insert Into ContactHIST(ContactID,Name,Sex)

    Select ID,Name,Sex From deleted 

 

Rollback Tran 

 

Begin Tran

Go

测试数据,

use tempdb

Go

Insert Into Contact (Name,Sex) Values ('Bill','F')

Go

--Update

Update Contact 

    Set Sex='M'

    Where Name='Bill'

Go

Select * From Contact

Select * From ContactHIST

Go

测试结果:

图片 10图片 11

从上边的测试情况,看出,Update
Contact触发tr_Contact触发器操作,触发器里面的Rollback Tran
动作导致了触发器外面的Update语句执行回滚,而Rollback Tran
语句后面的Begin
Tran语句,主要是应用于保持整个事务的完整性。为了更能理解这一过程,我模拟了一个触发器中的事务开始结束过程。

图片 12

图4.

在SQL Server 2005 和 SQL Server
2008上面,可以看到如图4.的效果。在低版本的SQL
Server上,可能会出现错误提示情况,不管如何,在触发器外面,SQL
Server都会Rollback Tran。下面我做个错误提示的例子。

修改触发器tr_Contact内容

use tempdb

Go

If Exists(Select 1 From sys.triggers Where name='tr_Contact')

    Drop  Trigger tr_Contact 

Go

Create Trigger     tr_Contact On Contact After Update,Delete

As

Insert Into ContactHIST(ContactID,Name,Sex)

    Select ID,Name,Sex From deleted 

 

Rollback Tran 

 

--Begin Tran 

Go

重新执行Update操作,

use tempdb

Go

Update Contact 

    Set Sex='M'

    Where Name='Bill'

Go    

Select @@TRANCOUNT    

Go

Select * From Contact

Select * From ContactHIST

Go

图片 13图片 14

在触发器里面没有Begin
Tran语句动作,触发器外面也能回滚操作。这里我们可以通过查询表数据和@@Trancount来判断。

         其实,上面的例子,Update语句,是以自动提交事务(Autocommit
Transactions)模式 开始执行的,触发器里Rollback Tran后面,不管有没有Begin
Tran ,最后都会事务都会交回给SQL
Server自动提交事务管理。当然,在DML触发器中,你可以使用显式事务(Explicit
Transactions),或开启隐式事务(Implicit Transactions)
来控制,当然你也可以应用于批范围的事务(Batch-scoped Transactions)
中。这里,我通过开启隐式事务(Implicit Transactions)
的例子来说,触发器与事务的关系。

修改触发器tr_Contact的内容,

use tempdb

Go

If Exists(Select 1 From sys.triggers Where name='tr_Contact')

    Drop  Trigger tr_Contact 

Go

Create Trigger     tr_Contact On Contact After Update,Delete

As

Print N'触发器里Insert 前,@@Trancount='+Rtrim(@@Trancount)

 

Insert Into ContactHIST(ContactID,Name,Sex)

    Select ID,Name,Sex From deleted 

 

Print N'触发器里Insert后,Rollback Tran 前,@@Trancount='+Rtrim(@@Trancount)

 

Rollback Tran 

 

Print N'触发器里Rollback Tran 后,@@Trancount='+Rtrim(@@Trancount)

 

Begin Tran 

Go

开启隐式事务(Implicit Transactions) 来测试,

use tempdb

Go

Set Implicit_transactions On /**/

Go

Print N'Update Contact前,@@Trancount='+Rtrim(@@Trancount)

 

Update Contact 

    Set Sex='M'

    Where Name='Bill'



Print N'Update Contact后,@@Trancount='+Rtrim(@@Trancount)

 

Rollback Tran

 

Print N'触发器外面Rollback Tran 后,@@Trancount='+Rtrim(@@Trancount)



Go    

Set Implicit_transactions Off /**/

Go

 

Go

Select * From Contact

Select * From ContactHIST

Go

 

图片 15

 

这里,你是否发现一个很有意思的问题,在触发器理,执行Insert
ContactHIST之前,@@Trancount=1,执行Insert后,@@Trancount还是为1,触发器外面Update
Contact后,@@Trancount就变成了2,。这里可以理解成,你在触发器里面,发出一个Begin
Tran,那么SQL Server 就会创建一个嵌套事务。当你在触发器里面,在Rollback
Tran后面屏蔽掉Begin Tran,就会出现错误3609,如,

use tempdb

Go

If Exists(Select 1 From sys.triggers Where name='tr_Contact')

    Drop  Trigger tr_Contact 

Go

Create Trigger     tr_Contact On Contact After Update,Delete

As

Print N'触发器里Insert 前,@@Trancount='+Rtrim(@@Trancount)

 

Insert Into ContactHIST(ContactID,Name,Sex)

    Select ID,Name,Sex From deleted 

 

Print N'触发器里Insert后,Rollback Tran 前,@@Trancount='+Rtrim(@@Trancount)

 

Rollback Tran 

 

Print N'触发器里Rollback Tran 后,@@Trancount='+Rtrim(@@Trancount)

 

Go

 

图片 16

这里,可以看到事务在触发器中Rollback,又没有开启新的事务,导致整个批处理就中止,不会继续执行触发器外面的Rollback
Tran操作。倘若,你在触发器中使用Begin Tran …… Commit
Tran格式,那么触发器Commit
Tran不会影响到外面的事务;下面描述三种常见触发器中事务的情况:

图片 17图片 18图片 19

图5.                                                                            
图6.                                                                          
图7.

图5.描述在触发器中含有Begin Tran …… Commit Tran的情况,

图6.描述在触发器中含有Save Tran savepoint_name …… Rollback Tran
savepoint_name 的情况,触发器中的Rollback Tran
只会回滚指定的保存点,不会影响到触发器外面的Commit Tran Or Rollback
Tran操作。

图7.描述在触发器中含有Rollback Tran的情况,不管触发器里面有没有Begin
Tran,都会出现错误3609,中止批处理。

   
注:DDL触发器操作可以触发器中回滚操作,可以使用命令如Rollback,但严重错误可能会导致整个事务自动回滚。不能回滚发生在
DDL 触发器正文内的 Alter Database事件。在触发器中使用Rollback … Begin
Tran
可能会导致意想不到的结果,在没有确认和测试情况下,请不要随便在触发器中直接使用Rollback
…Begin Tran处理方式.特别是Create Database事件,在SQL Server 2008和SQL
Server 2005环境下,产生的结果不同。

Rollback …Begin Tran情况:

Create Trigger ….

As

……

Rollback

Begin Tran

End

小结


 

     回顾前文至后文,从After触发器VsInstead Of 触发器,说到DML触发器 Vs
DDL触发器,再到触发器中事务的故事。也许有些地方描述的有些模糊,有些地方只有一笔带过;你在测试代码过程中,可能发现有些地方与这里测试的情况不同,那可能是因为SQL
Server版本的不同,导致一些测试结果不同。无论如何,只要你感觉对你了解触发器,有些帮助,就OK了。

     

begin try
    begin tran
        insert into dbo.TransTestTable values (1,'1');
        update dbo.TransTestTable set [Name] = '22' where [Id] = 1;
        --RAISERROR ('Error raised in TRY block.',16,1);
    commit tran
end try
begin catch
    rollback tran
end catch
Use TestDB

Begin TransAction
    Insert Into Person(PersonId,PersonName)
                Values('1','Name1')
    Insert Into Person(PersonId,PersonName)
                Values('1','Name1')
    Insert Into Person(PersonId,PersonName)
                Values('3','Name3')
Commit TransAction
/*
    Select 一下 有'1','Name1'和'3','Name3',
    说明只有第二句的错误被取消了
*/

全部回滚方法3:自定义错误变量

总结

database/sql提供了事务处理的功能。通过Tx对象实现。db.Begin会创建tx对象,后者的Exec和Query执行事务的数据库操作,最后在tx的Commit和Rollback中完成数据库事务的提交和回滚,同时释放连接。

tx事务环境中,只有一个数据库连接,事务内的Eexc都是依次执行的,事务中也可以使用db进行查询,但是db查询的过程会新建连接,这个连接的操作不属于该事务。

关于database/sql和mysql的驱动,我们已经分三部分内容介绍了。下一节,将会对之前的内容进行梳理总结,包括错误处理和注意事项的补充。

引述

 代码中的begin try和begin catch是捕获异常时使用的,只在sql
server2005/2008中支持,sql server 2000上不支持这个语句。在begin try 和
end try之间的代码运行时如果发生异常,则程序会跳转到begin catch和end
catch中执行相关的rollback tran回滚操作。在begin tran和commit
tran之间就是一个事务,insert和update必须同时成功,否则就同时失败。RAISERROR
语句的意思是抛出一个异常,只在sql server2005/2008中支持,sql server
2000上不支持这个语句。