2

我真的很喜欢Yii 的NestedPDO解决方案，但我需要一些不同的事务处理。

只有当所有嵌套事务都可以提交并且一个事务执行回滚时，我才想提交我的嵌套事务，所有事务都应该回滚。

我怎样才能做到这一点？

我尝试更改不起作用的回滚功能：

public function rollBack() {
    $this->transLevel--;

    if($this->transLevel == 0 || !$this->nestable()) {
        parent::rollBack();
    } else {

        $level = $this->transLevel;
        for($level; $level>1; $level--){
            $this->exec("ROLLBACK TO SAVEPOINT LEVEL{$this->constantlevel}");
        }
        //parent::rollBack();
    }
}

我正在考虑调整 NestedPDO：在函数 commit() 中仅在最外层事务上执行提交，在函数 rollBack() 中回滚到最外层事务，无论哪个子事务导致回滚。但我无法完成它......

我正在使用 MySQL 和 InnoDB 表，我不确定自动提交，但是当在事务中回显自动提交的值时，我总是得到值 1，这应该意味着自动提交已打开，但在事务中自动提交应该设置为 0。我'不确定这是否是整个回滚对我不起作用的原因？

4

3 回答 3

0

如果您希望在发生错误后立即自动回滚整个事务，则可以B在从某些特定位置（例如 from A()）调用时从 的异常处理程序中重新抛出异常：

function A(){
   ...
   $this->B(true);
   ...
}

/*
* @param B boolean Throw an exception if the transaction is rolled back
*/
function B($rethrow) {
    $transaction=Yii::app()->db->beginTransaction();
    try {
        //do something
        $transaction->commit();
    } catch(Exception $e) {
        $transaction->rollBack();
        if ($rethrow) throw $e;
    }
}

现在我知道您实际上只是希望您的包装器检测事务是否已经在进行中，并且在这种情况下不启动事务。

因此，您实际上并不需要该NestedPDO课程。你可以创建一个这样的类：

class SingleTransactionManager extends PDO {
    private $nestingDepth = 0;

    public function beginTransaction() {
        if(!$this->nestingDepth++ == 0) {
            parent::beginTransaction();
        } // else do nothing
    }
    public function commit() {
        $this->nestingDepth--;
        if (--$this->nestingDepth == 0) {
            parent::commit();
        } // else do nothing
    }

    public function rollback() {
        parent::rollback();
        if (--$this->nestingDepth > 0) {
            $this->nestingDepth = 0;
            throw new Exception(); // so as to interrupt outer the transaction ASAP, which has become pointless
        }

    }
}
于 2013-06-12T11:44:57.123 回答
0

根据@RandomSeed 的回答，我为默认的 Yii 事务处理创建了一个“插入”：

$connection = Yii::app()->db;
$transaction=$connection->beginTransaction();
try
{
   $connection->createCommand($sql1)->execute();
   $connection->createCommand($sql2)->execute();
   //.... other SQL executions
   $transaction->commit();
}
catch(Exception $e)
{
   $transaction->rollback();
}

这是我的 SingleTransactionManager 类：

class SingleTransactionManager extends CComponent 
{
    // The current transaction level.
    private $transLevel = 0;

    // The CDbConnection object that should be wrapped
    public $dbConnection;

    public function init()
    {
        if($this->dbConnection===null)
            throw new Exception('Property `dbConnection` must be set.');

        $this->dbConnection=$this->evaluateExpression($this->dbConnection);
    }
    // We only start a transaction if we're the first doing so
    public function beginTransaction() {
        if($this->transLevel == 0) {
            $transaction = parent::beginTransaction();
        } else {
            $transaction = new SingleTransactionManager_Transaction($this->dbConnection, false);
        }
        // always increase transaction level:
        $this->transLevel++;

        return $transaction;
    }

    public function __call($name, $parameters)
    {
        return call_user_func_array(array($this->dbConnection, $name), $parameters);
    }
}

class SingleTransactionManager_Transaction extends CDbTransaction
{
    // boolean, whether this instance 'really' started the transaction
    private $_startedTransaction;

    public function __construct(CDbConnection $connection, $startedTransaction = false)
    {
        $this->_startedTransaction = $startedTransaction;
        parent::__construct($connection);
        $this->setActive($startedTransaction);
    }

    // We only commit a transaction if we've started the transaction
    public function commit() {
        if($this->_startedTransaction)
            parent::commit();
    }

    // We only rollback a transaction if we've started the transaction
    // else throw an Exception to revert parent transactions/take adquate action
    public function rollback() {
        if($this->_startedTransaction)
            parent::rollback();
        else
            throw new Exception('Child transaction rolled back!');
    }
}

此类“包装”主数据库连接，您应该在配置中将其声明为这样的组件：

'components'=>array(

    // database
    'db'=>array(
        'class' => 'CDbConnection',
        // using mysql
        'connectionString'=>'....',
        'username'=>'...',
        'password'=>'....',
    ),

    // database
    'singleTransaction'=>array(
        'class' => 'pathToComponents.db.SingleTransactionManager',
        'dbConnection' => 'Yii::app()->db'
    )

请注意，该dbConnection属性应该是主数据库连接的表达式。现在，当在嵌套的 try catch 块中嵌套事务时，您可以在嵌套事务 3 中创建错误，并且 1 和 2 上的错误也会回滚。

测试代码：

$connection = Yii::app()->singleTransaction;

$connection->createCommand('CREATE TABLE IF NOT EXISTS `test_transactions` (
  `number` int(10) NOT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;')->execute();

$connection->createCommand('TRUNCATE TABLE `test_transactions`;')->execute();

testNesting(4, 3, 1);

echo '<br>';
echo 'Rows:';
echo '<br>';
$rows = $connection->createCommand('SELECT * FROM `test_transactions`')->queryAll();
if($rows)
{
    foreach($rows as $row)
    {
        print_r($row);
    }
}
else
    echo 'Table is empty!';

function testNesting(int $total, int $createErrorIn = null, int $current = 1)
{
    if($current>=$total)
        return;

    $connection = Yii::app()->singleTransaction;
    $indent = str_repeat('&nbsp;', ($current*4));

    echo $indent.'Transaction '.$current;
    echo '<br>';
    $transaction=$connection->beginTransaction();
    try
    {
        // create nonexisting columnname when we need to create an error in this nested transaction
        $columnname = 'number'.($createErrorIn===$current ? 'rr' : '');
        $connection->createCommand('INSERT INTO `test_transactions` (`'.$columnname.'`) VALUES ('.$current.')')->execute();

        testNesting($total, $createErrorIn, ($current+1));

        $transaction->commit();
    }
    catch(Exception $e)
    {
        echo $indent.'Exception';
        echo '<br>';
        echo $indent.$e->getMessage();
        echo '<br>';
        $transaction->rollback();
    }
}

结果如下：

    Transaction 1
        Transaction 2
            Transaction 3
            Exception
            CDbCommand failed to execute the SQL statement: SQLSTATE[42S22]: Column not found: 1054 Unknown column 'numberrr' in 'field list'. The SQL statement executed was: INSERT INTO `test_transactions` (`numberrr`) VALUES (3)
        Exception
        Child transaction rolled back!
    Exception
    Child transaction rolled back!

Rows:
Table is empty!
于 2019-01-09T15:12:34.237 回答
0

恕我直言，在应用程序代码中模拟“嵌套事务”的想法是一种反模式。应用程序中有许多无法解决的异常情况（请参阅我对https://stackoverflow.com/a/319939/20860的回答）。

在 PHP 中，最好保持简单。工作自然地组织成请求，所以使用请求作为事务范围。

  • 在调用任何模型类之前，在控制器级别启动事务。
  • 如果出现任何问题，让模型抛出异常。
  • 在控制器级别捕获异常，并在必要时回滚。
  • 如果没有捕获到异常，则提交。

忘记所有关于交易级别的废话。模型不应启动、提交或回滚任何事务。

于 2019-01-09T15:22:07.183 回答