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:10:44 +08:00
parent ebf6862834
commit 12d3d05001
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Command.php
+4 -4
View File
@@ -97,7 +97,7 @@ class Command extends Component
throw new Exception($client->errorInfo()[1]); throw new Exception($client->errorInfo()[1]);
} }
foreach ($this->params as $key => $param) { foreach ($this->params as $key => $param) {
$prepare->bindParam($key, $param); $prepare->bindParam($key, $param, PDO::PARAM_STR | PDO::PARAM_INT);
} }
return $prepare->fetch(PDO::FETCH_ASSOC); return $prepare->fetch(PDO::FETCH_ASSOC);
} catch (\Throwable $throwable) { } catch (\Throwable $throwable) {
@@ -122,7 +122,7 @@ class Command extends Component
throw new Exception($client->errorInfo()[1]); throw new Exception($client->errorInfo()[1]);
} }
foreach ($this->params as $key => $param) { foreach ($this->params as $key => $param) {
$prepare->bindParam($key, $param); $prepare->bindParam($key, $param, PDO::PARAM_STR | PDO::PARAM_INT);
} }
return $prepare->fetchColumn(PDO::FETCH_ASSOC); return $prepare->fetchColumn(PDO::FETCH_ASSOC);
} catch (\Throwable $throwable) { } catch (\Throwable $throwable) {
@@ -147,7 +147,7 @@ class Command extends Component
throw new Exception($client->errorInfo()[1]); throw new Exception($client->errorInfo()[1]);
} }
foreach ($this->params as $key => $param) { foreach ($this->params as $key => $param) {
$prepare->bindParam($key, $param); $prepare->bindParam($key, $param, PDO::PARAM_STR | PDO::PARAM_INT);
} }
return $prepare->rowCount(); return $prepare->rowCount();
} catch (\Throwable $throwable) { } catch (\Throwable $throwable) {
@@ -207,7 +207,7 @@ class Command extends Component
*/ */
private function error(\Throwable $throwable): bool private function error(\Throwable $throwable): bool
{ {
$message = $this->sql . '(' . json_encode($this->params, JSON_UNESCAPED_UNICODE) . ');'; $message = $this->sql . '.' . json_encode($this->params, JSON_UNESCAPED_UNICODE);
return $this->logger->addError($message . $throwable->getMessage(), 'mysql'); return $this->logger->addError($message . $throwable->getMessage(), 'mysql');
} }