由于项目设计里面,牵扯到了金钱的转移,于是就要用到MYSQL的事务处理,来保证一组处理结果的正确性,用了事务,就不可避免的要牺牲一部分速度,来保证数据的正确性.

只有InnoDB支持事务

事务 ACID Atomicity（原子性）、Consistency（稳定性）、Isolation（隔离性）、Durability（可靠性）

1、事务的原子性

一组事务,要么成功；要么撤回。

2、稳定性

有非法数据（外键约束之类），事务撤回。

3、隔离性

事务独立运行,一个事务处理后的结果,影响了其他事务,那么其他事务会撤回,事务的100%隔离,需要牺牲速度.

4、可靠性

软、硬件崩溃后,InnoDB数据表驱动会利用日志文件重构修改,可靠性和高速度不可兼得,innodb_flush_log_at_trx_commit选项决定什么时候吧事务保存到日志里.

开启事务:START TRANSACTION 或 BEGIN

提交事务（关闭事务）:COMMIT

放弃事务（关闭事务）:ROLLBACK

折返点

SAVEPOINT adqoo_1

ROLLBACK TO SAVEPOINT adqoo_1

发生在折返点 adqoo_1 之前的事务被提交,之后的被忽略.

事务的终止

设置“自动提交”模式:SET AUTOCOMMIT = 0,每条SQL都是同一个事务的不同命令,之间由 COMMIT 或 ROLLBACK隔开,掉线后,没有 COMMIT 的事务都被放弃.

事务锁定模式

系统默认:不需要等待某事务结束,可直接查询到结果,但不能再进行修改、删除.

缺点:查询到的结果,可能是已经过期的.

优点:不需要等待某事务结束,可直接查询到结果.

需要用以下模式来设定锁定模式

1、SELECT …… LOCK IN SHARE MODE（共享锁）

查询到的数据，就是数据库在这一时刻的数据（其他已commit事务的结果，已经反应到这里了）

SELECT 必须等待，某个事务结束后才能执行

2、SELECT …… FOR UPDATE（排它锁）

例如 SELECT * FROM tablename WHERE id<200,那么id<200的数据，被查询到的数据，都将不能再进行修改、删除、SELECT …… LOCK IN SHARE MODE操作一直到此事务结束,共享锁 和 排它锁 的区别：在于是否阻断其他客户发出的 SELECT …… LOCK IN SHARE MODE命令

3、INSERT / UPDATE / DELETE

所有关联数据都会被锁定，加上排它锁

4、防插入锁

例如 SELECT * FROM tablename WHERE id>200,那么id>200的记录无法被插入.

5、死锁

自动识别死锁,先进来的进程被执行,后来的进程收到出错消息,并按ROLLBACK方式回滚innodb_lock_wait_timeout = n 来设置最长等待时间,默认是50秒.

事务隔离模式

SET [SESSION|GLOBAL] TRANSACTION ISOLATION LEVEL 

READ UNCOMMITTED | READ COMMITTED | REPEATABLE READ | SERIALIZABLE

1、不带SESSION、GLOBAL的SET命令:只对下一个事务有效

2、SET SESSION:为当前会话设置隔离模式

3、SET GLOBAL:为以后新建的所有MYSQL连接设置隔离模式（当前连接不包括在内）

隔离模式:READ UNCOMMITTED

不隔离SELECT,其他事务未完成的修改（未COMMIT）,其结果也考虑在内,READ COMMITTED,把其他事务的 COMMIT 修改考虑在内,同一个事务中，同一 SELECT 可能返回不同结果

REPEATABLE READ(默认),不把其他事务的修改考虑在内,无论其他事务是否用COMMIT命令提交过,同一个事务中,同一 SELECT 返回同一结果(前提是本事务,不修改).

SERIALIZABLE,和REPEATABLE READ类似,给所有的SELECT都加上了共享锁.

出错处理,根据出错信息,执行相应的处理,最后看看PHP + MySQL事务操作的代码演示,实际LAMP应用中,一般PHP使用AdoDB操作MySQL,下面给出AdoDB相应的代码方便大家查阅,代码如下:

1. <?php  
2. // ... 
3.  
4. $adodb->startTrans(); 
5.  
6. //实际，getOne所调用的查询也可以直接放到rowLock来进行，这里只是为了演示效果能更明显些。 
7.  
8. $adodb->rowLock('book', 'book_id = 123'); 
9.  
10. $bookNumber = $adodb->getOne("SELECT book_number FROM book WHERE  book_id = 123"); 
11.  
12. $adodb->execute("UPDATE book SET book_number = book_number - 1 WHERE  book_id = 123"); 
13. //phpfensi.com 
14. $adodb->completeTrans(); 
15.  
16. // ...  
17. ?> 

其中,rowLock的方法就是调用的FOR UPDATE来实现的行锁,你可能会想把“FOR UPDATE”直接写到$adodb->getOne()调用的那条SQL语句里面去实现行锁的功能,不错，那样确实可以，但是并不是所有的数据库都使用“FOR UPDATE”语法来实现行锁功能，比如Sybase使用“HOLDLOCK”的语法来实现行锁功能,所以为了你的数据库抽象层保持可移植性,我还是劝你用rowLock来实现行锁功能.

Tags: MYSQL事务 MYSQL事务处理

分享到：