Обработка транзакций PHP с несколькими объектами mysqli

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 в __constructor() из class A и class B и использовать их для откат или фиксации (снаружи).

Хотелось бы увидеть больше приемов с проконсонами.

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.

Тогда это вопрос вас, когда вы начинаете конечную транзакцию, соединение должно быть одинаковым. Лучше всего было бы абстрагировать его на некоторый общий уровень доступа к базе данных.