This commit is contained in:
2021-04-28 10:55:09 +08:00
parent ef9a1a397e
commit 491ec4cf4e
+4 -5
View File
@@ -11,11 +11,9 @@ namespace Database;
use Exception; use Exception;
use JetBrains\PhpStorm\Pure;
use PDO; use PDO;
use PDOStatement; use PDOStatement;
use Snowflake\Abstracts\Component; use Snowflake\Abstracts\Component;
use Snowflake\Core\Json;
use Swoole\Coroutine; use Swoole\Coroutine;
/** /**
@@ -123,8 +121,8 @@ class Command extends Component
private function execute($type, $isInsert = null, $hasAutoIncrement = null): int|bool|array|string|null private function execute($type, $isInsert = null, $hasAutoIncrement = null): int|bool|array|string|null
{ {
try { try {
$time = microtime(true); $time = microtime(true);
if ($type === static::EXECUTE) { if ($type === static::EXECUTE) {
$result = $this->insert_or_change($isInsert, $hasAutoIncrement); $result = $this->insert_or_change($isInsert, $hasAutoIncrement);
} else { } else {
$result = $this->search($type); $result = $this->search($type);
@@ -209,7 +207,8 @@ class Command extends Component
return $this->addError($this->sql . ':' . $error, 'mysql'); return $this->addError($this->sql . ':' . $error, 'mysql');
} }
$result = $prepare->execute($this->params); $result = $prepare->execute($this->params);
$prepare->closeCursor(); var_dump($result, $connect->errorInfo());
defer(fn() => $prepare->closeCursor());
if ($result === false) { if ($result === false) {
return $this->addError($connect->errorInfo()[2], 'mysql'); return $this->addError($connect->errorInfo()[2], 'mysql');
} }