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

modify plugin name

Browse Source
This commit is contained in:
向林
2022-06-09 10:05:37 +08:00
parent 9a93687c53
commit d9b9b78128
1 changed files with 4 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Connection.php
+4 -10
View File
@@ -106,7 +106,7 @@ class Connection extends Component
*/ */
public function getConnect($isSearch): PDO public function getConnect($isSearch): PDO
{ {
return !$isSearch ? $this->getMasterClient() : $this->getSlaveClient(); return !$isSearch ? $this->getPdo() : $this->getSlaveClient();
} }
@@ -149,9 +149,6 @@ class Connection extends Component
*/ */
public function getMasterClient(): PDO public function getMasterClient(): PDO
{ {
if ($this->_pdo instanceof PDO) {
return $this->_pdo;
}
return $this->connections()->get([ return $this->connections()->get([
'cds' => $this->cds, 'cds' => $this->cds,
'username' => $this->username, 'username' => $this->username,
@@ -171,7 +168,7 @@ class Connection extends Component
public function getSlaveClient(): PDO public function getSlaveClient(): PDO
{ {
if (empty($this->slaveConfig) || $this->slaveConfig['cds'] == $this->cds) { if (empty($this->slaveConfig) || $this->slaveConfig['cds'] == $this->cds) {
return $this->getMasterClient(); return $this->getPdo();
} }
return $this->connections()->get($this->slaveConfig); return $this->connections()->get($this->slaveConfig);
} }
@@ -193,7 +190,7 @@ class Connection extends Component
*/ */
public function beginTransaction(): static public function beginTransaction(): static
{ {
$pdo = $this->getMasterClient(); $pdo = $this->getPdo();
$pdo->beginTransaction(); $pdo->beginTransaction();
return $this; return $this;
} }
@@ -217,10 +214,7 @@ class Connection extends Component
*/ */
public function inTransaction(): bool|static public function inTransaction(): bool|static
{ {
if (!$this->_pdo) { return $this->getPdo()->inTransaction();
$this->_pdo = $this->getMasterClient();
}
return $this->_pdo->inTransaction();
} }
/** /**