php mysql事务详解
在说php mysql事务之前,可以先了解下 php mysql与mysqli 区别
首先, mysqli 连接是永久连接,而mysql是非永久连接。什么意思呢? mysql连接每当第二次使用的时候,都会重新打开一个新的进程,而mysqli则只使用同一个进程,这样可以很大程度的减轻服务器端压力。
<?php$lnk = mysql_connect("localhost", "root", "");mysql_select_db("test");mysql_query("BEGIN");try {mysql_query("INSERT INTO test VALUES(1, 'yangjun')");mysql_query("INSERT INTO test VALUES(1, 'yangjun')");mysql_query("INSERT INTO test VALUES(2, '杨俊')");mysql_query("COMMIT"); //全部成功,提交执行结果}catch (Exception $e){//$e->getMessage();mysql_query("ROLLBACK"); //有任何错误发生,回滚并取消执行结果}在PHP中,mysqli 已经很好的封装了mysql事务的相关操作。如下示例:
$sql1 = "update User set ScoreCount = ScoreCount +10 where ID= '123456'";$sql2 = "update ScoreDetail set FScore = 300 where ID= '123456'";$sql3 = "insert into (ScoreDetail ID,Score) values ('123456',60)";$mysqli = new mysqli('localhost','root','','DB_Lib2Test');$mysqli->autocommit(false);//开始事物$mysqli->query($sql1);$mysqli->query($sql2);if(!$mysqli->errno){ $mysqli->commit(); echo 'ok';}else{ echo 'err'; $mysqli->rollback();}在这里,我们再使用 php mysql 系列函数执行事务。
$sql1 = "update User set ScoreCount = ScoreCount +10 where ID= '123456'";$sql2 = "update ScoreDetail set FScore = 300 where ID= '123456'";$sql3 = "insert into (ScoreDetail ID,Score) values ('123456',60)";$conn = mysql_connect('localhost','root','');mysql_select_db('DB_Lib2Test');mysql_query('start transaction');//mysql_query('SET autocommit=0');mysql_query($sql1);mysql_query($sql2);if(mysql_errno ()){ mysql_query('rollback'); echo 'err';}else{ mysql_query('commit'); echo 'ok';}// mysql_query('SET autocommit=1');// mysql_query($sql3); 在这里要注意,
MyISAM:不支持事务,用于只读程序提高性能
InnoDB:支持ACID事务、行级锁、并发
Berkeley?DB:支持事务
还有一点要注意:MySQL默认的行为是在每条SQL语句执行后执行一个COMMIT语句,从而有效的将每条语句独立为一个事务。
但往往,我们需要在使用事务的时候,是需要执行多条sql语句的。这就需要我们手动设置MySQL的autocommit属性为0,默认为1。
同时,使用START TRANSACTION语句显式的打开一个事务 。如上面的示例。
如果不这样做,会有什么结果呢?
我们将上面第二段代码中 //mysql_query(‘SET autocommit=0′); 和 // mysql_query($sql3); 注释去掉,然后执行。
此时,mysql_query($sql3) 执行就不会insert到数据库中。
如果我们将 // mysql_query(‘SET autocommit=1′); 本句注释去掉,那么mysql_query($sql3); 就会执行成功。
通常COMMIT或ROLLBACK语句执行时才完成一个事务,但是有些DDL语句等会隐式触发COMMIT。
比如下列语句
ALTER FUNCTIONALTER PROCEDUREALTER TABLEBEGINCREATE DATABASECREATE FUNCTIONCREATE INDEXCREATE PROCEDURECREATE TABLEDROP DATABASEDROP FUNCTIONDROP INDEXDROP PROCEDUREDROP TABLEUNLOCK TABLESLOAD MASTER DATALOCK TABLESRENAME TABLETRUNCATE TABLESET AUTOCOMMIT=1START TRANSACTION
?我们再来举个例子看下。
$sql1 = 'create table ScoreDetail_new(id int)';$sql2 = 'rename table ScoreDetail to ScoreDetail_bak';$sql3 = 'rename table ScoreDetail_new to ScoreDetail';$mysqli = new mysqli('localhost','root','','DB_Lib2Test');$mysqli->autocommit(false);//开始事物$mysqli->query($sql1);$mysqli->query($sql2);$mysqli->query($sql3);if(!$mysqli->errno){ $mysqli->commit(); echo 'ok';}else{ echo 'err'; $mysqli->rollback();}在上面的示例中,假如$sql2执行出错了,$sql1照样会执行的。为什么呢?
因为rename在执行的时候,mysql默认会先执行commit,再执行rename。
事物一般和异常处理结合
try { $error = 'Always throw this error'; throw new Exception($error); // Code following an exception is not executed. echo 'commit';} catch (Exception $e) { echo 'roll back', $e->getMessage(), "\n";}创建可抛出一个异常的函数
<?php //创建可抛出一个异常的函数function checkNum($number){if($number>1){throw new Exception("Value must be 1 or below");}return true;}//在 "try" 代码块中触发异常try{checkNum(2);//如果异常被抛出,那么下面一行代码将不会被输出echo 'If you see this, the number is 1 or below';}catch(Exception $e){//捕获异常echo 'Message: ' .$e->getMessage();}?> ?