具有多个 mysqli 对象的 PHP 事务处理

Question

假设我们有两个独立的类，每个类都有一个 mysqli 对象用于数据库操作。

class A{
  protected $mysqliObject;
  public function __constructor(){
    $this->mysqliObject=new mysqli(...)
  }
  public function doSomething(){
    $this->mysqliObject->query(...);
  }
}
class B{
  protected $mysqliObject;
  public function __constructor(){
    $this->mysqliObject=new mysqli(...)
  }
  public function doSomething(){
    $this->mysqliObject->query(...);
  }
}

doSomething() 方法使用$mysqliObject 进行数据库查询（SELECT、UPDATE、DELETE 等...）。我想在外面做以下事情：

// Start point
$aObject=new A();
$bObject=new B();
$aObject->doSomething();
$bObject->doSomething();
// End point

...但是如果其中任何一个查询失败，我想回滚这两个查询。我该怎么做？

• 能否在“起点”创建一个全新的mysqli 对象，并使用它在“终点”提交或回滚class A 和class B 的数据库查询？
• 我是否必须在外部创建，并将相同的$mysqliObject 传递给class A 和class B 的__constructor()，并使用它来回滚或提交（外部）。

希望看到更多与赞成者有关的技术。

Answer 1

您拥有的每个数据库连接对象都代表与数据库的不同连接，即使该连接是与同一数据库服务器的连接。每个连接彼此完全独立，因此在一个连接中启动的事务对另一个连接是不可见的。

如果您的所有数据库访问都针对同一台服务器，那么只需创建一个连接并将其传递给需要访问该连接的任何对象。然后事务将是应用程序范围的。

class ClassThatNeedsDbAccess
{
    protected $connection = NULL;

    protected function doQuery ($query)
    {
        return ($this -> connection -> execute ($query));
    }

    public function __construct (PDO $connection)
    {
        $this -> connection = $connection;
    }
}

class OtherClassThatNeedsDbAccess extends ClassThatNeedsDbAccess
{
}

$myDb = new PDO ('dsn_goes_here');

$obj1 = new ClassThatNeedsDbAccess ($myDb);
$obj2 = new OtherClassThatNeedsDbAccess ($myDb);

如果您正在与不同的数据库服务器通信，那么您可能应该将所有连接包装在一个可以协调数据库活动的对象中。该对象负责跟踪哪个数据库连接有一个正在运行的事务。

Answer 2

使用一个 MySQL 对象 - 连接所有业务逻辑...看看单例模式。您可以将其传递给构造函数，也可以使用静态类方法获取 mysql 对象。

那么你的问题是你从哪里开始结束事务，连接必须相同。最好将其抽象为一些通用的数据库访问层。