多个连接上的事务，一个事务执行时数据完整性失败

Question

我正在尝试为以下场景中的小型应用程序使用带有 OOPS 代码的基于事务的 PHP-MYSqli：

PHP 5.6.x 用于服务器和 PHP 桌面版本 phpdesktop-chrome-57.0-rc-php-7.1.3，因此应用程序将在 5.6.x 上运行和 7.x 版本的 PHP。

多人可以同时访问同一个php应用程序。这意味着每个用户都将有一个独立的连接可用于访问应用程序，因为我通过文件包含在每个页面的顶部都包含了一个连接。我想要的是，当一个用户按下提交按钮时，特定事务中的所有表都应该被锁定为读写模式，并且同一连接或任何其他连接上的任何用户都不能访问它们。因此，我想要 100% 的数据完整性。

我写了以下两个文件：

p1.php

<?php
ini_set('max_execution_time', 500);
$mysqli = new mysqli("localhost", "root", "", "jag_db");

if ($mysqli->connect_errno) {
    printf("Connect failed: %s\n", $mysqli->connect_error);
    exit();
}
if(isset($_POST['submit']))
{
    $mysqli->autocommit(FALSE);
    //$mysqli->begin_transaction(MYSQLI_TRANS_START_READ_WRITE);
    $i=0;
    $val2="Kurukshetra";
    for($i=100;$i<=50000;$i++)
    {
        $stmt=$mysqli->prepare("INSERT INTO transtest (roll,city) VALUES(?,?)");
        $stmt->bind_param('ss', $i, $val2);
        if(!$stmt->execute())
        {
            $mysqli->rollback();
            exit;
        }
    }
    $sql20=$mysqli->prepare("SELECT * FROM transtest");
    $sql20->execute();
    $result20=$sql20->get_result();
    if($result20->num_rows>0)
    {
        while($rows20=$result20->fetch_object())
        {
            $sno=$rows20->sno;
            $stmt=$mysqli->prepare("UPDATE transtest SET city=? WHERE sno=?");
            if($sno%2==0)
                $city="Ambala";
            else
                $city="Kaithal";
            $stmt->bind_param('ss', $city, $sno);
            if(!$stmt->execute())
            {
                $mysqli->rollback();
                exit;
            }
        }
    }
    else
    {
        $mysqli->rollback();
        exit;
    }
    $stmt->close();
    $mysqli->commit();
    $mysqli->autocommit(TRUE);
}
$mysqli->close();
?>
<form method="post">
    <button type="submit" name="submit"/>GO</button>
</form>

p2.php

<?php
ini_set('max_execution_time', 500);
$mysqli = new mysqli("localhost", "root", "", "jag_db");

if ($mysqli->connect_errno) {
    printf("Connect failed: %s\n", $mysqli->connect_error);
    exit();
}
if(isset($_POST['submit']))
{
    $mysqli->autocommit(FALSE);
    //$mysqli->begin_transaction(MYSQLI_TRANS_START_READ_WRITE);
    $i=5001;
    $j="Chandigarh";
    $stmt=$mysqli->prepare("INSERT INTO transtest (roll,city) VALUES(?,?)");
    $stmt->bind_param('ss', $i, $j);
    if(!$stmt->execute())
    {
        $mysqli->rollback();
        exit;
    }
    $sql20=$mysqli->prepare("SELECT * FROM transtest");
    $sql20->execute();
    $result20=$sql20->get_result();
    if($result20->num_rows>0)
    {
        while($rows20=$result20->fetch_object())
        {
            echo $rows20->sno . "    ----    " . $rows20->roll  . "    ----    " . $rows20->city . "<br>";
        }
    }
    else
    {
        $mysqli->rollback();
        exit;
    }
    $sql20->close();
    $mysqli->commit();
    $mysqli->autocommit(TRUE);
}
$mysqli->close();
?>
<form method="post">
    <button type="submit" name="submit"/>GO</button>
</form>

首先我开始执行 p1.php，然后立即开始单击另一个浏览器选项卡的 p2.php 的 go 按钮。 以下是 p2.php 时的结果：

p1.php 仍在执行中

Image: p1.php is still executing

当 p1.php 执行完毕时

Image: when p1.php has finished executing

很高兴看到最后我得到了准确的结果，但很遗憾看到即使执行了一个事务，另一个用户也得到了错误的输出。当 p1.php 正在执行时，第二个用户应该看不到任何东西。

注意：$mysqli->begin_transaction(MYSQLI_TRANS_START_READ_WRITE); 在我当前版本的 php 中不起作用。它说警告： mysqli::begin_transaction(): 这个服务器版本不支持'READ 写”和“只读”。最低要求 5.6.5

如何解决这个问题？

Answer 1

对于Mysql，当你写在代码中的任何操作被执行时，都会对表应用自动锁，所以你是安全的。