PHP/MySQL -如何使用MySQL开始/提交与PDO

Question

我想知道如何使用MySQL BEGIN/COMMIT与PDO。我读到过，最好创建一个查询，要么插入所有数据，要么根本不插入，以提供数据库中的"一致性"这是我的代码

$query = $db -> prepare 
                        ("
                        BEGIN;
                        INSERT INTO chat (chat_id,msg,datetime) 
                        VALUES (:cid,:msg,:datetime)
                        INSERT INTO chat_connect (chat_id,sender_id,receiver_id)
                        VALUES (:cid2,:sender_id,:receiver_id);
                        COMMIT;
                        ");
$query -> execute(array(
            "cid" => $cid,
            "msg" => $msg,
            "datetime" => $datetime,
            "sender_id" => $getid,
            "receiver_id" => $frid,
            "cid2" => $cid
            ));

Answer 1

您的代码只有在打开仿真模式时才能工作。

否则，您必须像这样在单独的调用中运行查询。

$db->query("BEGIN");
$stmt = $db->prepare("INSERT INTO chat (chat_id,msg,datetime) VALUES (:cid,:msg,:datetime)");
$stmt->execute(...);
$stmt = $db->prepare("INSERT INTO chat_connect (chat_id,sender_id,receiver_id)
                        VALUES (:cid2,:sender_id,:receiver_id)");
$stmt->execute(...);
$db->query("COMMIT");

这是在PHP中运行多个查询语句的一般规则。

然而，在事务的情况下，您可以使用它们的PDO对应项而不是SQL命令BEGIN和COMMIT。

Answer 2

事务语法:

开始交易[transaction_characteristic [， transaction_characteristic]…]

transaction_characteristic:WITH CONSISTENT SNAPSHOT | READ WRITE | READ ONLY

开始[工作]提交[工作][和[无]链][[无]释放]回滚[WORK] [AND [NO] CHAIN] [[NO] RELEASE] SET autocommit = {0 | 1}

事务的例子:

START TRANSACTION;
SELECT @A:=SUM(salary) FROM table1 WHERE type=1;
UPDATE table2 SET summary=@A WHERE type=1;
COMMIT;

从这里取。

您打算通过PDO创建transaction。这不是真正的问题。您可以通过生成相应的查询文本来实现:

$query = $db -> prepare 
                        ("
                        START TRANSACTION;
                        INSERT INTO chat (chat_id,msg,datetime) 
                        VALUES (:cid,:msg,:datetime)
                        INSERT INTO chat_connect (chat_id,sender_id,receiver_id)
                        VALUES (:cid2,:sender_id,:receiver_id);
                        COMMIT;
                        ");
$query -> execute(array(
            "cid" => $cid,
            "msg" => $msg,
            "datetime" => $datetime,
            "sender_id" => $getid,
            "receiver_id" => $frid,
            "cid2" => $cid
            ));

在这里你可以看到如何编写一个防弹的交易。