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-17 10:18:59 +08:00
parent 409f75eff6
commit 8c6f9676b5
1 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Command.php
+10 -7
View File
@@ -15,6 +15,8 @@ use Kiri\Abstracts\Component;
use Kiri\Di\Container; use Kiri\Di\Container;
use Kiri\Exception\ConfigException; use Kiri\Exception\ConfigException;
use PDO; use PDO;
use ReflectionException;
use Throwable;
/** /**
* Class Command * Class Command
@@ -83,7 +85,7 @@ class Command extends Component
} }
$prepare->execute($this->params); $prepare->execute($this->params);
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')) {
return $this->all(); return $this->all();
} }
@@ -106,7 +108,7 @@ class Command extends Component
} }
$prepare->execute($this->params); $prepare->execute($this->params);
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')) {
return $this->one(); return $this->one();
} }
@@ -129,7 +131,7 @@ class Command extends Component
} }
$prepare->execute($this->params); $prepare->execute($this->params);
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')) {
return $this->fetchColumn(); return $this->fetchColumn();
} }
@@ -152,7 +154,7 @@ class Command extends Component
} }
$prepare->execute($this->params); $prepare->execute($this->params);
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')) {
return $this->rowCount(); return $this->rowCount();
} }
@@ -194,7 +196,7 @@ class Command extends Component
$this->connection->release($client); $this->connection->release($client);
} }
return $result == 0 ? true : $result; return $result == 0 ? true : $result;
} 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->_execute(); return $this->_execute();
} }
@@ -204,10 +206,11 @@ class Command extends Component
/** /**
* @param \Throwable $throwable * @param Throwable $throwable
* @return bool * @return bool
* @throws ReflectionException
*/ */
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 \Kiri::getLogger()->addError($message . $throwable->getMessage(), 'mysql'); return \Kiri::getLogger()->addError($message . $throwable->getMessage(), 'mysql');