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-05 20:27:00 +08:00
parent 9bb8582aee
commit ffc8cd7a33
1 changed files with 4 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Command.php
+4 -12
View File
@@ -72,9 +72,7 @@ class Command extends Component
if ($prepare === false || $prepare->execute($this->params) === false) { if ($prepare === false || $prepare->execute($this->params) === false) {
throw new Exception(($prepare ?? $pdo)->errorInfo()[1]); throw new Exception(($prepare ?? $pdo)->errorInfo()[1]);
} }
$count = $prepare->fetchAll(PDO::FETCH_ASSOC); return $prepare->fetchAll(PDO::FETCH_ASSOC);
$prepare->closeCursor();
return $count;
} 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')) {
return $this->all(); return $this->all();
@@ -97,9 +95,7 @@ class Command extends Component
if ($prepare === false || $prepare->execute($this->params) === false) { if ($prepare === false || $prepare->execute($this->params) === false) {
throw new Exception(($prepare ?? $pdo)->errorInfo()[1]); throw new Exception(($prepare ?? $pdo)->errorInfo()[1]);
} }
$count = $prepare->fetch(PDO::FETCH_ASSOC); return $prepare->fetch(PDO::FETCH_ASSOC);
$prepare->closeCursor();
return $count;
} 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')) {
return $this->one(); return $this->one();
@@ -122,9 +118,7 @@ class Command extends Component
if ($prepare === false || $prepare->execute($this->params) === false) { if ($prepare === false || $prepare->execute($this->params) === false) {
throw new Exception(($prepare ?? $pdo)->errorInfo()[1]); throw new Exception(($prepare ?? $pdo)->errorInfo()[1]);
} }
$count = $prepare->fetchColumn(PDO::FETCH_ASSOC); return $prepare->fetchColumn(PDO::FETCH_ASSOC);
$prepare->closeCursor();
return $count;
} 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')) {
return $this->fetchColumn(); return $this->fetchColumn();
@@ -147,9 +141,7 @@ class Command extends Component
if ($prepare === false || $prepare->execute($this->params) === false) { if ($prepare === false || $prepare->execute($this->params) === false) {
throw new Exception(($prepare ?? $pdo)->errorInfo()[1]); throw new Exception(($prepare ?? $pdo)->errorInfo()[1]);
} }
$count = $prepare->rowCount(); return $prepare->rowCount();
$prepare->closeCursor();
return $count;
} 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')) {
return $this->rowCount(); return $this->rowCount();