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-07 21:41:49 +08:00
parent 44d350cfea
commit 0a6fbed5d0
1 changed files with 9 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Command.php
+9 -15
View File
@@ -67,13 +67,11 @@ class Command extends Component
public function all(): null|bool|array
{
try {
$pdo = $this->connection->getConnection();
if (($prepare = $pdo->query($this->sql)) === false) {
throw new Exception($pdo->errorInfo()[1]);
}
foreach ($this->params as $key => $param) {
$prepare->bindParam($key, $param);
$client = $this->connection->getConnection();
if (($prepare = $client->prepare($this->sql)) === false) {
throw new Exception($client->errorInfo()[1]);
}
$prepare->execute($this->params);
return $prepare->fetchAll(PDO::FETCH_ASSOC);
} catch (\Throwable $throwable) {
if (str_contains($throwable->getMessage(), 'MySQL server has gone away')) {
@@ -81,7 +79,7 @@ class Command extends Component
}
return $this->error($throwable);
} finally {
$this->connection->release($pdo ?? null);
$this->connection->release($client ?? null);
}
}
@@ -116,12 +114,10 @@ class Command extends Component
{
try {
$client = $this->connection->getConnection();
if (($prepare = $client->query($this->sql)) === false) {
if (($prepare = $client->prepare($this->sql)) === false) {
throw new Exception($client->errorInfo()[1]);
}
foreach ($this->params as $key => $param) {
$prepare->bindParam($key, $param, PDO::PARAM_STR | PDO::PARAM_INT);
}
$prepare->execute($this->params);
return $prepare->fetchColumn(PDO::FETCH_ASSOC);
} catch (\Throwable $throwable) {
if (str_contains($throwable->getMessage(), 'MySQL server has gone away')) {
@@ -141,12 +137,10 @@ class Command extends Component
{
try {
$client = $this->connection->getConnection();
if (($prepare = $client->query($this->sql)) === false) {
if (($prepare = $client->prepare($this->sql)) === false) {
throw new Exception($client->errorInfo()[1]);
}
foreach ($this->params as $key => $param) {
$prepare->bindParam($key, $param, PDO::PARAM_STR | PDO::PARAM_INT);
}
$prepare->execute($this->params);
return $prepare->rowCount();
} catch (\Throwable $throwable) {
if (str_contains($throwable->getMessage(), 'MySQL server has gone away')) {