mysql - 将 AutoCommit 设置为 0 的 DBI 数据库句柄未通过 SELECT 返回正确的数据？

Question

这是一个很难解释的问题(而且非常奇怪)，所以请耐心等待。我将解释问题及其解决方法，但我想看看是否有人可以解释为什么它会以这种方式工作:)

我有一个使用 mod_perl 的网络应用程序。它使用 MySQL 数据库，我定期将数据写入数据库。它是模块化的，所以它也有自己的“数据库”类型的模块，我在其中处理连接、更新等。database::db_connect() 子例程用于连接到数据库，AutoCommit设置为 0。

我制作了另一个 Perl 应用程序(独立守护程序)，它定期从数据库中获取数据，并根据返回的数据执行各种任务。我在其中包含了 database.pm 模块，因此我不必重写/复制所有内容。

我遇到的问题是:

应用程序在启动时连接到数据库，然后永远循环，每 X 秒从数据库中获取数据。但是，如果数据库中的数据已更新，我的应用程序仍会返回“旧”数据，这是我在与数据库的初始连接/查询时获得的。

例如 - 我有 3 行，“名称”列的每条记录的值为“a”、“b”和“c”。如果我更新其中一行(例如，从命令行使用 mysql 客户端)并将名称从“c”更改为“x”，我的独立守护程序将不会获取该数据 - 它仍然会从返回的 a/b/c MySQL。我用 tcpdump 捕获了数据库流量，我可以肯定地看到 MySQL 确实在返回该数据。我也尝试过将 SQL_NO_CACHE 与 SELECT 一起使用(因为我不确定发生了什么)，但这也没有帮助。

然后，我修改了独立守护程序中的数据库连接字符串，并将 AutoCommit 设置为 1。突然，应用程序开始获取正确的数据。

我很纳闷，因为我以为AutoCommit只影响INSERT/UPDATE类型的语句，对SELECT语句没有影响。但它似乎确实如此，我不明白为什么。

有谁知道当 AutoCommit 设置为 0 时，为什么 SELECT 语句不会从数据库返回“更新的”行，而当 AutoCommit 设置为 0 时，为什么它会返回更新的行设置为 1？

这是我在独立守护程序中使用的简化(删除了错误检查等)代码，它不返回更新的行。

#!/usr/bin/perl

use strict;
use warnings;
use DBI;
use Data::Dumper;
$|=1;

my $dsn = "dbi:mysql:database=mp;mysql_read_default_file=/etc/mysql/database.cnf";
my $dbh = DBI->connect($dsn, undef, undef, {RaiseError => 0, AutoCommit => 0});
$dbh->{mysql_enable_utf8} = 1;

while(1)
{
    my $sql = "SELECT * FROM queue";
    my $stb = $dbh->prepare($sql);
    my $ret_hashref = $dbh->selectall_hashref($sql, "ID");
    print Dumper($ret_hashref);
    sleep(30);
}

exit;

将 AutoCommit 更改为 1 可以修复此问题。为什么？

谢谢:)

P.S:不确定是否有人关心，但 DBI 版本是 1.613，DBD::mysql 是 4.017，perl 是 5.10.1(在 Ubuntu 10.04 上)。

Answer 1

我想您使用的是 InnoDB 表而不是 MyISAM 表。如 InnoDB transaction model 中所述，所有您的查询(包括 SELECT)都发生在一个事务中。

当 AutoCommit 打开时，为每个查询启动一个事务，如果成功，则隐式提交(如果失败，行为可能会有所不同，但保证事务结束) .你可以在 MySQL 的 binlog 中看到隐式提交。通过将 AutoCommit 设置为 false，您需要自己管理事务。

默认的事务隔离级别是REPEATABLE READ ，这意味着所有 SELECT 查询都将读取相同的快照(事务开始时建立的快照)。

除了另一个答案中给出的解决方案(ROLLBACK before starting read)这里还有几个解决方案:

您可以选择其他事务隔离级别，例如 READ COMMITTED ，这使得您的 SELECT 查询每次都读取一个新的快照。

您还可以将 AutoCommit 保留为 true(默认设置)并通过发出 BEGIN WORK 开始您自己的事务。这将暂时禁用 AutoCommit 行为，直到您发出 COMMIT 或 ROLLBACK 语句，之后每个查询再次获得自己的事务(或者您启动另一个使用 BEGIN WORK)。

我个人会选择后一种方法，因为它看起来更优雅。