joby/destructr
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Better transaction handling

Browse source
This commit is contained in:
Joby 2022-06-08 10:28:45 -06:00 committed by GitHub
parent 11e6e43072
commit 4018095088
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 21 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
src/Drivers/AbstractSQLDriver.php
View file

@ -12,6 +12,9 @@ abstract class AbstractSQLDriver extends AbstractDriver
public $lastPreparationErrorOn;
public $pdo;
protected $schemas = [];
protected $transactions = 0;
const NESTED_TRANSACTION_SUPPORT = false;
abstract protected function sql_ddl(array $args = []): string;
abstract protected function expandPath(string $path): string;
@ -68,17 +71,32 @@ abstract class AbstractSQLDriver extends AbstractDriver
public function beginTransaction(): bool
{
return $this->pdo->beginTransaction();
$this->transactions++;
if (static::NESTED_TRANSACTION_SUPPORT || !$this->pdo->inTransaction()) {
return $this->pdo->beginTransaction();
} else {
return true;
}
}
public function commit(): bool
{
return $this->pdo->commit();
$this->transactions--;
if (static::NESTED_TRANSACTION_SUPPORT || ($this->transactions == 0 && $this->pdo->inTransaction())) {
return $this->pdo->commit();
} else {
return true;
}
}
public function rollBack(): bool
{
return $this->pdo->rollBack();
$this->transactions--;
if (static::NESTED_TRANSACTION_SUPPORT || ($this->transactions == 0 && $this->pdo->inTransaction())) {
return $this->pdo->rollBack();
} else {
return true;
}
}
protected function expandPaths($value)