一次提交中的 Magento 多个数据库事务

Question

我知道如何在zend框架中做到这一点

$db->beginTransaction();

try {
   $db->query(...);
   $db->query(...);
   $db->query(...);
   .
   . 
   .
   $db->commit();
} catch (Exception $e) {
    $db->rollBack();
}

但我想用 magento 模型来做，比如

$db->beginTransaction();

try {
   $modelOne   = Mage::getModel('modulename/table1');
   $modelTwo   = Mage::getModel('modulename/table2');
   $modelThree = Mage::getModel('modulename/table3');

   $db->query($modelOne);
   $db->query($modelTwo);
   $db->query($modelThree);
   .
   . 
   .
   $db->commit();
} catch (Exception $e) {
    $db->rollBack();
}

如果其中任何一个未能保存，则应全部回滚

谢谢

Answer 1

查看app/code/core/Mage/Core/Model/Resource/Transaction.php

此模型允许在事务中添加另一个模型作为对象。在保存期间，它为每个添加的对象调用$object->save()。如果某事失败，它会调用 $object->getResource()->rollBack() 用于每个对象。您还可以通过addCommitCallback(array($object, 'callbackFunctionName')) 添加提交回调。

如果您需要删除事务，请调用$transaction->delete() 而不是$transaction->save() 在这种情况下，它为每个对象调用$object->delete() 而不是$object->save()。

例子：

try {
    $transaction = Mage::getModel('core/resource_transaction')
                           ->addObject(Mage::getModel('modulename/table1'))
                           ->addObject(Mage::getModel('modulename/table2'))
                           ->addObject(Mage::getModel('modulename/table3'));

    $transaction->save();
} catch (Exception $e) {
    echo $e->getMessage();
}

Answer 2

对于单个事务中的 INSERT 、 DELETE 和 UPDATE （根据您的评论），请尝试以下操作，

<?php

$id1 = 1; //update id
$id2 = 2; //delete id
$data = array('title'=>'New Title','content'=>'Hello, there..!','status'=>1);
$update = array('title'=>'My title', 'content'=>'Hi, there..!', 'status'=>1); 

try {
    $transaction = Mage::getModel('core/resource_transaction')
                           ->addObject(Mage::getModel('modulename/table1')->load($id1)->addData($update));
                           ->addObject(Mage::getModel('modulename/table2')->setId($id2)->delete());
                           ->addObject(Mage::getModel('modulename/table3')->setData($data));

    $transaction->save();
} catch (Exception $e) {
    echo $e->getMessage();
}

我没有测试过这个。请自行承担风险尝试。问题是您无法在此获取所有 db-transaction 的最后一个插入 ID。 delete() 不需要调用 save()。但是 INSERT 和 UPDATE 方法你需要最后调用save()。请更新结果是否有效。