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 19:00:37 +08:00
parent 2153481f69
commit ebf6862834
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Command.php
+12 -4
View File
@@ -71,7 +71,9 @@ class Command extends Component
if (($prepare = $pdo->query($this->sql)) === false) { if (($prepare = $pdo->query($this->sql)) === false) {
throw new Exception($pdo->errorInfo()[1]); throw new Exception($pdo->errorInfo()[1]);
} }
$prepare->execute($this->params); foreach ($this->params as $key => $param) {
$prepare->bindParam($key, $param);
}
return $prepare->fetchAll(PDO::FETCH_ASSOC); return $prepare->fetchAll(PDO::FETCH_ASSOC);
} 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')) {
@@ -94,7 +96,9 @@ class Command extends Component
if (($prepare = $client->query($this->sql)) === false) { if (($prepare = $client->query($this->sql)) === false) {
throw new Exception($client->errorInfo()[1]); throw new Exception($client->errorInfo()[1]);
} }
$prepare->execute($this->params); foreach ($this->params as $key => $param) {
$prepare->bindParam($key, $param);
}
return $prepare->fetch(PDO::FETCH_ASSOC); return $prepare->fetch(PDO::FETCH_ASSOC);
} 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')) {
@@ -117,7 +121,9 @@ class Command extends Component
if (($prepare = $client->query($this->sql)) === false) { if (($prepare = $client->query($this->sql)) === false) {
throw new Exception($client->errorInfo()[1]); throw new Exception($client->errorInfo()[1]);
} }
$prepare->execute($this->params); foreach ($this->params as $key => $param) {
$prepare->bindParam($key, $param);
}
return $prepare->fetchColumn(PDO::FETCH_ASSOC); return $prepare->fetchColumn(PDO::FETCH_ASSOC);
} 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')) {
@@ -140,7 +146,9 @@ class Command extends Component
if (($prepare = $client->query($this->sql)) === false) { if (($prepare = $client->query($this->sql)) === false) {
throw new Exception($client->errorInfo()[1]); throw new Exception($client->errorInfo()[1]);
} }
$prepare->execute($this->params); foreach ($this->params as $key => $param) {
$prepare->bindParam($key, $param);
}
return $prepare->rowCount(); return $prepare->rowCount();
} 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')) {