PHP/PDO::commit 在“try”块中不起作用

Question

当我将“PDO::commit()”方法放入“try”块时，它不起作用，即使 SQL 代码正常，我也没有得到“commit”。

$conn->dbh->beginTransaction();

$stmt = $conn->dbh->prepare('some SQL-code');

$stmt->bindValue(...);

try 
{ 
    $stmt->execute();
    $conn->dbh->commit();
} 
catch (Exception $e) 
{
    $dbh->rollBack();
    echo $e->getMessage();
}

但如果我把它放在“catch”块之后，一切正常。

...
try 
{ 
    $stmt->execute();
} 
catch (Exception $e) 
{
    $dbh->rollBack();
    echo $e->getMessage();
}
$conn->dbh->commit();

这是预期的行为吗？为什么 PDO::commit() 在“try”块中不起作用？

只是想为自己澄清一下，因为我已经花了整整两个小时来找到解决这个问题的方法，但我不确定这个解决方案是否正确。

---

代码如下：

Class Connection
{
public $dbh;
private static $instance;

private function __construct()
{
    $config = parse_ini_file('config.ini');
    $dsn = $config['db.dbms'] . ':host=' . $config['db.host'] .
           ';dbname='    . $config['db.dbname'] .
           ';port='      . $config['db.port'] .
           ';connect_timeout=15';
    $this->dbh = new PDO($dsn, $config['db.user'], $config['db.password'], array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"));
    $this->dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
}

public static function getInstance()
{
    if (!isset(self::$instance))
    {
        $object = __CLASS__;
        self::$instance = new $object;
    }
    return self::$instance;
}
}

Class NestedSet
{
public function insertAsLastChildOf ($parentnode)
{
    $fields = '';
    $params = '';

    $conn = Connection::getInstance();

    $conn->dbh->beginTransaction();

    foreach ($this->_modelfields as $field => $type)
    {
        $fields .= '`'.$field.'`, ';
        $params .= ':'.$field.', ';            
    }

    $stmt = $conn->dbh->prepare('UPDATE `' . $this->_tablename . '`
                           SET `rgt` = `rgt` + 2
                           WHERE `rgt` >= :parentnodergt;


                           UPDATE `' . $this->_tablename . '`
                           SET `lft` = `lft` + 2
                           WHERE `lft` > :parentnodergt;


                           INSERT INTO `' . $this->_tablename . '`  
                              (' . $fields . '
                               `lft`,
                               `rgt`,
                               `level`)
                            SELECT  
                                ' . $params . '
                                `rgt` - 2, 
                                `rgt` - 1, 
                                `level` + 1                                    
                            FROM `' . $this->_tablename . '`
                            WHERE `id` = :parentnodeid;');

    foreach ($this->_modelfields as $field => $type)
    {
        $pdoparam = (stripos($type, 'int') === 0) ? PDO::PARAM_INT : PDO::PARAM_STR;
        $stmt->bindValue(':'.$field.'', $this->$field, $pdoparam);
    }

    $stmt->bindValue(':parentnodergt', $parentnode->rgt, PDO::PARAM_INT);
    $stmt->bindValue(':parentnodeid', $parentnode->id, PDO::PARAM_INT);

    try
    {
        $stmt->execute();
        $conn->dbh->commit();
    }
    catch (PDOException $e)
    {
        $conn->dbh->rollBack();
        echo $e->getMessage() . '<br/> file - ' . __FILE__ . '<br/> line - ' . __LINE__ . '<br/>';
    }

    unset($stmt); 
}
}

我尝试重写代码，以便每个准备好的语句都有一个查询。在这种情况下，一切正常 - 如果没有错误，我会执行代码并获得异常，否则会回滚。

这是代码

    $stmt_1 = $conn->dbh->prepare('UPDATE `' . $this->_tablename . '`
                            SET `rgt` = `rgt` + 2
                            WHERE `rgt` >= :parentnodergt;');
    $stmt_1->bindValue(':parentnodergt', $parentnode->rgt, PDO::PARAM_INT);

    $stmt_2 = $conn->dbh->prepare('UPDATE `' . $this->_tablename . '`
                            SET `lft` = `lft` + 2
                            WHERE `lft` > :parentnodergt;');
    $stmt_2->bindValue(':parentnodergt', $parentnode->rgt, PDO::PARAM_INT);

    $stmt_3 = $conn->dbh->prepare('INSERT INTO `' . $this->_tablename . '`  
                              (' . $fields . '
                               `lft`,
                               `rgt`,
                               `level`)
                            SELECT  
                                ' . $params . '
                                `rgt` - 2, 
                                `rgt` - 1, 
                                `level` + 1                                    
                            FROM `' . $this->_tablename . '`
                            WHERE `id` = :parentnodeid;');

    foreach ($this->_modelfields as $field => $type)
    {
        $pdoparam = (stripos($type, 'int') === 0) ? PDO::PARAM_INT : PDO::PARAM_STR;
        $stmt_3->bindValue(':'.$field.'', $this->$field, $pdoparam);
    }

    $stmt_3->bindValue(':parentnodeid', $parentnode->id, PDO::PARAM_INT);

    try
    {
        $stmt_1->execute();
        $stmt_2->execute();
        $stmt_3->execute();
        $conn->dbh->commit();
    }
    catch (PDOException $e)
    {
        $conn->dbh->rollBack();
        echo $e->getMessage() . '<br/> file - ' . __FILE__ . '<br/> line - ' . __LINE__ . '<br/>';
    }
    unset($stmt);

这是否意味着 PDO::prepare() 不应该与多个查询一起使用？

我之所以问，是因为我在 PDO 手册中没有找到任何相关内容。

Answer 1

您的查询有问题。它在 t/c 块中不起作用，因为execute() 导致错误，因此在commit() 调用之前引发了异常。当你在 t/c 块之后移动它时它起作用的唯一原因是因为它是一个程序步骤。尝试跟踪您的错误日志。