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

e

Browse Source
This commit is contained in:
Mr·x
2021-08-16 18:14:22 +08:00
parent 2e1297f8af
commit 37a43ef66e
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Mysql/PDO.php
+9 -9
View File
@@ -58,7 +58,7 @@ class PDO
if (time() - $this->_last > 10 * 60) { if (time() - $this->_last > 10 * 60) {
$this->stopHeartbeatCheck(); $this->stopHeartbeatCheck();
} }
if (!$this->pdo->getAttribute(\PDO::ATTR_SERVER_INFO)) { if (!$this->_pdo()->getAttribute(\PDO::ATTR_SERVER_INFO)) {
$this->stopHeartbeatCheck(); $this->stopHeartbeatCheck();
} }
} catch (\Throwable $throwable) { } catch (\Throwable $throwable) {
@@ -88,7 +88,7 @@ class PDO
public function beginTransaction() public function beginTransaction()
{ {
if ($this->_transaction == 0) { if ($this->_transaction == 0) {
$this->pdo->beginTransaction(); $this->_pdo()->beginTransaction();
} }
$this->_transaction++; $this->_transaction++;
} }
@@ -100,7 +100,7 @@ class PDO
public function commit() public function commit()
{ {
if ($this->_transaction == 0) { if ($this->_transaction == 0) {
$this->pdo->commit(); $this->_pdo()->commit();
} }
$this->_transaction--; $this->_transaction--;
} }
@@ -112,7 +112,7 @@ class PDO
public function rollback() public function rollback()
{ {
if ($this->_transaction == 0) { if ($this->_transaction == 0) {
$this->pdo->rollBack(); $this->_pdo()->rollBack();
} }
$this->_transaction--; $this->_transaction--;
} }
@@ -175,8 +175,8 @@ class PDO
private function queryPrev(string $sql, array $params = []): PDOStatement private function queryPrev(string $sql, array $params = []): PDOStatement
{ {
$this->_last = time(); $this->_last = time();
if (($statement = $this->pdo->query($sql)) === false) { if (($statement = $this->_pdo()->query($sql)) === false) {
throw new Exception($this->pdo->errorInfo()[1]); throw new Exception($this->_pdo()->errorInfo()[1]);
} }
return $this->bindValue($statement, $params); return $this->bindValue($statement, $params);
} }
@@ -206,21 +206,21 @@ class PDO
public function execute(string $sql, array $params = []): int public function execute(string $sql, array $params = []): int
{ {
$this->_last = time(); $this->_last = time();
if (!(($prepare = $this->pdo->prepare($sql)) instanceof PDOStatement)) { if (!(($prepare = $this->_pdo()->prepare($sql)) instanceof PDOStatement)) {
throw new Exception($prepare->errorInfo()[2] ?? static::DB_ERROR_MESSAGE); throw new Exception($prepare->errorInfo()[2] ?? static::DB_ERROR_MESSAGE);
} }
defer(fn() => $prepare->closeCursor()); defer(fn() => $prepare->closeCursor());
if ($prepare->execute($params) === false) { if ($prepare->execute($params) === false) {
throw new Exception($prepare->errorInfo()[2] ?? static::DB_ERROR_MESSAGE); throw new Exception($prepare->errorInfo()[2] ?? static::DB_ERROR_MESSAGE);
} }
return (int)$this->pdo->lastInsertId(); return (int)$this->_pdo()->lastInsertId();
} }
/** /**
* @return \PDO * @return \PDO
*/ */
public function getPdo(): \PDO public function _pdo(): \PDO
{ {
if (!($this->pdo instanceof \PDO)) { if (!($this->pdo instanceof \PDO)) {
$this->pdo = $this->newClient(); $this->pdo = $this->newClient();