赞
踩
以PDO MySQL为例说明.
http://php.net/manual/zh/pdo.transactions.php
假设只有一个PHP进程,开启了到MySQL的数据库长连接.
该进程处理请求A时,代码没有提交事务,就提前结束了请求,这时PDO会自动回滚该事务.
但要注意:
$db->beginTransaction(); // 重要:这样开启事务,才能确保PDO能自动回滚没有提交的事务$db->query('START TRANSACTION'); // 这样开启事务,PDO无法知晓,因此在必要时不能进行回滚
该进程处理请求B时,会重用这个数据库长连接.
但要注意:
如果上一个请求 $db->query('SET AUTOCOMMIT=0') 关闭了事务自动提交的功能,会影响到整个数据库长连接.
那么同一请求中的下一次调用或者下一次请求,一定要在获取$db时重新打开事务自动提交这个功能.否则所有MySQL写操作(INSERT/UPDATE/DELETE等)将失效,即无法自动提交,需要显式 $db->commit() 提交,因为MySQL InnoDB引擎把所有写操作当做事务来处理.
补充:
PHP文档里说beginTransaction会关闭事务自动提交模式,在commit或rollBack后会返回到自动提交模式.也就是PHP程序里可以不用显式使用SET AUTOCOMMIT开关自动提交,但前提是保证beginTransaction和commit/rollBack配对执行.
function io_db() {
static $db;
if (!$db) {
$db = new PDO($dsn, IO_DB_USERNAME, IO_DB_PASSWORD, array(
PDO::ATTR_PERSISTENT => true, // 数据库长连接PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8'
));
$db->query('SET AUTOCOMMIT=1'); // 重要:确保事务自动提交return $db;
} else {
$db->query('SET AUTOCOMMIT=1'); // 重要:确保事务自动提交return $db;
}
}
function io_transaction() {
$db = io_db();
$table = IO_DB_PREFIX . 'post';
$db->query('SET AUTOCOMMIT=0'); // 使用包含多个SQL操作的事务时,一般需要关闭事务自动提交功能var_export($db->query('SELECT @@autocommit')->fetchAll(PDO::FETCH_ASSOC));
$db->beginTransaction(); // 重要:这样开启事务,才能确保PDO能自动回滚没有提交的事务//~ $db->query('START TRANSACTION'); // 这样开启事务,PDO无法知晓,因此在必要时不能进行回滚
var_export($db->query("SELECT * FROM `{$table}` WHERE `id` = 1 FOR UPDATE")->fetchAll(PDO::FETCH_ASSOC));
sleep(3); // id为1的数据被SELECT FOR UPDATE锁定. 其他客户端写操作如 UPDATE `io_post` SET `date` = 100000000000 WHERE `id` = 1; 将被阻塞.var_export($db->query("UPDATE `{$table}` SET `date` = " . mt_rand(100000000000, 999999999999) . " WHERE `id` = 1")->rowCount());
// 重要:提交还是回滚事务,一定要二选一.依赖PDO自动回滚未提交的事务是下下策.$db->commit(); // 提交事务//~ $db->rollBack(); // 回滚事务
// 重要:事务结束后,正常情况下应该把事务自动提交还原为真.$db->query('SET AUTOCOMMIT=1');
// 注意:该操作隐含COMMIT操作,会导致请求结束时PDO自动回滚操作无效.// 也就是说,你没有执行$db->commit(),在执行$db->query('SET AUTOCOMMIT=1')时MySQL也会把之前的事务提交.}
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。