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

eee

Browse Source
This commit is contained in:
whwyy
2024-01-10 17:59:05 +08:00
parent a439c616b4
commit d8b2d1ca2c
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Command.php
+4 -1
View File
@@ -117,7 +117,6 @@ class Command extends Component
{ {
$client = $this->connection->getConnection(); $client = $this->connection->getConnection();
try { try {
$this->connection->println($this->sql, $this->params);
if (($prepare = $client->prepare($this->sql)) === false) { if (($prepare = $client->prepare($this->sql)) === false) {
throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $client->errorInfo()[2]); throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $client->errorInfo()[2]);
} }
@@ -127,6 +126,8 @@ class Command extends Component
$result = $method == 'rowCount' ? $prepare->rowCount() : $prepare->{$method}(PDO::FETCH_ASSOC); $result = $method == 'rowCount' ? $prepare->rowCount() : $prepare->{$method}(PDO::FETCH_ASSOC);
$prepare->closeCursor(); $prepare->closeCursor();
$this->connection->println($this->sql, $this->params);
return $result; return $result;
} catch (Throwable $throwable) { } catch (Throwable $throwable) {
if ($this->isRefresh($throwable)) return $this->search($method); if ($this->isRefresh($throwable)) return $this->search($method);
@@ -169,6 +170,8 @@ class Command extends Component
$result = $client->lastInsertId(); $result = $client->lastInsertId();
$this->connection->println($this->sql, $this->params);
return $result == 0 ? $prepare->rowCount() : (int)$result; return $result == 0 ? $prepare->rowCount() : (int)$result;
} catch (Throwable $throwable) { } catch (Throwable $throwable) {
if ($this->isRefresh($throwable)) return $this->_prepare(); if ($this->isRefresh($throwable)) return $this->_prepare();