Mysqli transaction/savepoint functions vs. 手动使用 query()


mysqli transaction/savepoint functions vs. manually using query()

以下两段代码的工作方式相同,还是本机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