as2252258/kiri-databases
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

eee

Browse Source
This commit is contained in:
whwyy
2023-12-12 17:40:51 +08:00
parent 2eb63c6bd4
commit fd71d23802
1 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Connection.php
+3 -6
View File
@@ -193,11 +193,8 @@ class Connection extends Component
*/ */
public function beginTransaction(): static public function beginTransaction(): static
{ {
if ($this->storey == 0) { if ($this->storey < 0 ) {
$pdo = $this->getTransactionClient(); $this->storey = 0;
if (!$pdo->inTransaction()) {
$pdo->beginTransaction();
}
} }
$this->storey++; $this->storey++;
return $this; return $this;
@@ -214,10 +211,10 @@ class Connection extends Component
if ($pdo === null) { if ($pdo === null) {
/** @var PDO $pdo */ /** @var PDO $pdo */
$pdo = Context::set($this->cds, $this->getNormalClientHealth()); $pdo = Context::set($this->cds, $this->getNormalClientHealth());
}
if ($this->storey > 0 && !$pdo->inTransaction()) { if ($this->storey > 0 && !$pdo->inTransaction()) {
$pdo->beginTransaction(); $pdo->beginTransaction();
} }
}
return $pdo; return $pdo;
} }