以下两段代码的工作方式相同,还是本机mysqli
事务函数做了一些额外的事情?
我对在启动和提交事务/创建和释放保存点时如何处理和报告错误(如果有的话)特别感兴趣。
使用特定的mysqli
函数进行事务处理:
$db = new mysqli('localhost', 'root', 'batman', 'batcave');
if (!$db->begin_transaction()) { throw new Exception($db->error); }
exc_query('INSERT INTO utility_belt SET item="apple"');
exc_query('INSERT INTO utility_belt SET item="banana"');
if (!$db->savepoint('vegetables')) { throw new Exception($db->error); }
exc_query('INSERT INTO utility_belt SET item="potato"');
exc_query('DELETE FROM utility_belt WHERE item="turnip"');
if (!$db->release_savepoint('vegetables')) { throw new Exception($db->error); }
exc_query('INSERT INTO utility_belt SET item="orange"');
if (!$db->commit()) { throw new Exception($db->error); }
使用普通的旧query
函数来做同样的事情:
$db = new mysqli('localhost', 'root', 'batman', 'batcave');
exc_query('START TRANSACTION');
exc_query('INSERT INTO utility_belt SET item="apple"');
exc_query('INSERT INTO utility_belt SET item="banana"');
exc_query('SAVEPOINT vegetables');
exc_query('INSERT INTO utility_belt SET item="potato"');
exc_query('DELETE FROM utility_belt WHERE item="turnip"');
exc_query('RELEASE SAVEPOINT vegetables');
exc_query('INSERT INTO utility_belt SET item="orange"');
exc_query('COMMIT');
上面使用的exc_query
函数的实现:
function exc_query($q) {
global $db;
if (!$db->query($q)) {
throw new Exception($db->error);
}
}
我为什么要问?
我偶尔在尝试执行RELEASE SAVEPOINT <name>
时遇到问题,并看到SAVEPOINT <name> does not exist
,即使我确定我之前已将SAVEPOINT <name>
发送到服务器。
根据我在 MariaDB 文档中读到的内容,如果初始START TRANSACTION
在我的示例中失败,则可能会引发此错误。在这种情况下,事务不会启动,因此SAVEPOINT <name>
将被静默忽略,但RELEASE SAVEPOINT <name>
随后会抛出错误。
让我想知道的是,在这些情况下,以下行没有捕获创建初始事务的任何失败:
if (!$db->query($q)) {
throw new Exception($db->error);
}
。所以我不确定我是否正确。不幸的是,关于这些 mysqli 函数如何工作的官方 PHP 文档并不是很有帮助。
基于 https://github.com/php/php-src/blob/master/ext/mysqli/mysqli_nonapi.c#L1115:
static int mysqli_savepoint_libmysql(MYSQL * conn, const char * const name, zend_bool release)
{
int ret;
char * query;
unsigned int query_len = spprintf(&query, 0, release? "RELEASE SAVEPOINT `%s`":"SAVEPOINT `%s`", name);
ret = mysql_real_query(conn, query, query_len);
efree(query);
return ret;
}
PHP 只是将完全相同的查询发送到数据库,而不是其他任何查询。
至于为什么MySQLi::savepoint()
会与MySQLi::query("SAVEPOINT")
工作有任何不同,我不知道。PHP 源代码中的错误处理似乎是相同的,因此我希望如果出现问题,您的$db->query($q)
结果会false
。