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

变更

Browse Source
This commit is contained in:
向林
2023-04-02 01:26:10 +08:00
parent 69648e3373
commit 685a0d72b2
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Command.php
+5 -4
View File
@@ -67,6 +67,7 @@ class Command extends Component
{ {
[$pdo, $statement] = $this->search(); [$pdo, $statement] = $this->search();
$statement->execute($this->params);
$data = $statement->fetchAll(PDO::FETCH_ASSOC); $data = $statement->fetchAll(PDO::FETCH_ASSOC);
$this->db->release($pdo); $this->db->release($pdo);
@@ -82,6 +83,7 @@ class Command extends Component
{ {
[$pdo, $statement] = $this->search(); [$pdo, $statement] = $this->search();
$statement->execute($this->params);
$data = $statement->fetch(PDO::FETCH_ASSOC); $data = $statement->fetch(PDO::FETCH_ASSOC);
$this->db->release($pdo); $this->db->release($pdo);
@@ -97,6 +99,7 @@ class Command extends Component
{ {
[$pdo, $statement] = $this->search(); [$pdo, $statement] = $this->search();
$statement->execute($this->params);
$data = $statement->fetchColumn(PDO::FETCH_ASSOC); $data = $statement->fetchColumn(PDO::FETCH_ASSOC);
$this->db->release($pdo); $this->db->release($pdo);
@@ -112,6 +115,7 @@ class Command extends Component
{ {
[$pdo, $statement] = $this->search(); [$pdo, $statement] = $this->search();
$statement->execute($this->params);
$data = $statement->rowCount(); $data = $statement->rowCount();
$this->db->release($pdo); $this->db->release($pdo);
@@ -170,12 +174,9 @@ class Command extends Component
{ {
$pdo = $this->db->getSlaveClient(); $pdo = $this->db->getSlaveClient();
try { try {
if (($statement = $pdo->query($this->sql)) === false) { if (($statement = $pdo->prepare($this->sql)) === false) {
throw new Exception($pdo->errorInfo()[1]); throw new Exception($pdo->errorInfo()[1]);
} }
foreach ($this->params as $key => $param) {
$statement->bindValue($key, $param);
}
return [$pdo, $statement]; return [$pdo, $statement];
} catch (\Throwable $throwable) { } catch (\Throwable $throwable) {
if (str_contains($throwable->getMessage(), 'MySQL server has gone away')) { if (str_contains($throwable->getMessage(), 'MySQL server has gone away')) {