Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
 as2252258
|
06074c38c1 | ||
|
as2252258
|
404b511c5f | ||
|
as2252258
|
bf4f8538ed |
+288
-260
@@ -1,260 +1,288 @@
|
|||||||
<?php
|
<?php
|
||||||
/**
|
/**
|
||||||
* Created by PhpStorm.
|
* Created by PhpStorm.
|
||||||
* User: whwyy
|
* User: whwyy
|
||||||
* Date: 2018/3/30 0030
|
* Date: 2018/3/30 0030
|
||||||
* Time: 15:23
|
* Time: 15:23
|
||||||
*/
|
*/
|
||||||
declare(strict_types=1);
|
declare(strict_types=1);
|
||||||
|
|
||||||
namespace Database;
|
namespace Database;
|
||||||
|
|
||||||
|
|
||||||
use Exception;
|
use Exception;
|
||||||
use Kiri\Abstracts\Component;
|
use Kiri\Abstracts\Component;
|
||||||
use Kiri\Di\Container;
|
use Kiri\Di\Container;
|
||||||
use PDO;
|
use PDO;
|
||||||
use Throwable;
|
use Throwable;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Class Command
|
* Class Command
|
||||||
* @package Database
|
* @package Database
|
||||||
*/
|
*/
|
||||||
class Command extends Component
|
class Command extends Component
|
||||||
{
|
{
|
||||||
|
|
||||||
public Connection $connection;
|
/** @var int 数据库操作最大重试次数 */
|
||||||
public ?string $sql = '';
|
private const MAX_RETRIES = 2;
|
||||||
public array $params = [];
|
|
||||||
|
public Connection $connection;
|
||||||
/**
|
public ?string $sql = '';
|
||||||
* @param array $params
|
public array $params = [];
|
||||||
* @throws
|
|
||||||
*/
|
/**
|
||||||
public function __construct(array $params = [])
|
* @param array $params
|
||||||
{
|
* @throws
|
||||||
parent::__construct();
|
*/
|
||||||
Container::configure($this, $params);
|
public function __construct(array $params = [])
|
||||||
}
|
{
|
||||||
|
parent::__construct();
|
||||||
|
Container::configure($this, $params);
|
||||||
/**
|
}
|
||||||
* @return bool
|
|
||||||
* @throws
|
|
||||||
*/
|
/**
|
||||||
public function incrOrDecr(): bool
|
* @return bool
|
||||||
{
|
* @throws
|
||||||
return (bool)$this->_prepare();
|
*/
|
||||||
}
|
public function incrOrDecr(): bool
|
||||||
|
{
|
||||||
|
return (bool)$this->_prepare();
|
||||||
/**
|
}
|
||||||
* @return bool|array
|
|
||||||
* @throws
|
|
||||||
*/
|
/**
|
||||||
public function all(): bool|array
|
* @return bool|array
|
||||||
{
|
* @throws
|
||||||
return $this->search('fetchAll');
|
*/
|
||||||
}
|
public function all(): bool|array
|
||||||
|
{
|
||||||
/**
|
return $this->search('fetchAll');
|
||||||
* @return array|bool|null
|
}
|
||||||
* @throws
|
|
||||||
*/
|
/**
|
||||||
public function one(): array|null|bool
|
* @return array|bool|null
|
||||||
{
|
* @throws
|
||||||
return $this->search('fetch');
|
*/
|
||||||
}
|
public function one(): array|null|bool
|
||||||
|
{
|
||||||
/**
|
return $this->search('fetch');
|
||||||
* @return bool
|
}
|
||||||
* @throws Exception
|
|
||||||
*/
|
/**
|
||||||
public function exists(): bool
|
* @return bool
|
||||||
{
|
* @throws Exception
|
||||||
$data = $this->search('fetch');
|
*/
|
||||||
if (!$data) {
|
public function exists(): bool
|
||||||
return false;
|
{
|
||||||
}
|
$data = $this->search('fetch');
|
||||||
return true;
|
if (!$data) {
|
||||||
}
|
return false;
|
||||||
|
}
|
||||||
/**
|
return true;
|
||||||
* @return mixed
|
}
|
||||||
* @throws
|
|
||||||
*/
|
/**
|
||||||
public function fetchColumn(): mixed
|
* @return mixed
|
||||||
{
|
* @throws
|
||||||
return $this->search('fetchColumn');
|
*/
|
||||||
}
|
public function fetchColumn(): mixed
|
||||||
|
{
|
||||||
/**
|
return $this->search('fetchColumn');
|
||||||
* @return mixed
|
}
|
||||||
* @throws
|
|
||||||
*/
|
/**
|
||||||
public function rowCount(): int
|
* @return mixed
|
||||||
{
|
* @throws
|
||||||
$data = $this->search('fetch');
|
*/
|
||||||
|
public function rowCount(): int
|
||||||
return !$data ? 0 : +current($data);
|
{
|
||||||
}
|
$data = $this->search('fetch');
|
||||||
|
|
||||||
|
return !$data ? 0 : +current($data);
|
||||||
/**
|
}
|
||||||
* @param string $method
|
|
||||||
* @return mixed
|
|
||||||
* @throws
|
/**
|
||||||
*/
|
* 执行查询类 SQL 操作，内置断连重试机制
|
||||||
protected function search(string $method): mixed
|
* 当数据库连接断开时自动重试，断开的连接不再归还池中防止污染连接池
|
||||||
{
|
* @param string $method PDO 结果获取方法名
|
||||||
$client = $this->connection->getConnection();
|
* @return mixed
|
||||||
try {
|
* @throws
|
||||||
$startTime = microtime(true);
|
*/
|
||||||
if (($prepare = $client->prepare($this->sql)) === false) {
|
protected function search(string $method): mixed
|
||||||
throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $client->errorInfo()[2]);
|
{
|
||||||
}
|
$retryCount = 0;
|
||||||
|
|
||||||
$prepare->execute($this->params);
|
while ($retryCount <= self::MAX_RETRIES) {
|
||||||
|
$client = $this->connection->getConnection();
|
||||||
$result = $method == 'rowCount' ? $prepare->rowCount() : $prepare->{$method}(PDO::FETCH_ASSOC);
|
try {
|
||||||
$prepare->closeCursor();
|
$startTime = microtime(true);
|
||||||
|
if (($prepare = $client->prepare($this->sql)) === false) {
|
||||||
$this->connection->println($startTime, microtime(true), $this->sql, $this->params);
|
throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $client->errorInfo()[2]);
|
||||||
|
}
|
||||||
return $result;
|
|
||||||
} catch (Throwable $throwable) {
|
$prepare->execute($this->params);
|
||||||
$this->getLogger()->json_log($throwable);
|
|
||||||
|
$result = $method == 'rowCount' ? $prepare->rowCount() : $prepare->{$method}(PDO::FETCH_ASSOC);
|
||||||
if ($this->isRefresh($throwable)) {
|
$prepare->closeCursor();
|
||||||
return $this->search($method);
|
|
||||||
}
|
$this->connection->println($startTime, microtime(true), $this->sql, $this->params);
|
||||||
|
|
||||||
$errorMsg = $throwable->getMessage() . PHP_EOL . ' Sql: ' . $this->sql . '.' . json_encode($this->params);
|
$this->connection->release($client);
|
||||||
|
return $result;
|
||||||
return $this->getLogger()->logCategory($errorMsg . PHP_EOL, 'mysql');
|
} catch (Throwable $throwable) {
|
||||||
} finally {
|
$this->getLogger()->json_log($throwable);
|
||||||
$this->connection->release($client);
|
|
||||||
}
|
if ($this->isRefresh($throwable) && $retryCount < self::MAX_RETRIES) {
|
||||||
}
|
$retryCount++;
|
||||||
|
$this->connection->connections->abandon($this->connection->getName());
|
||||||
|
continue;
|
||||||
/**
|
}
|
||||||
* @return bool
|
|
||||||
* @throws
|
$this->connection->release($client);
|
||||||
*/
|
|
||||||
public function flush(): bool
|
$errorMsg = $throwable->getMessage() . PHP_EOL . ' Sql: ' . $this->sql . '.' . json_encode($this->params);
|
||||||
{
|
|
||||||
return (bool)$this->_prepare();
|
return $this->getLogger()->logCategory($errorMsg . PHP_EOL, 'mysql');
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
$errorMsg = 'Max retry exceeded for SQL: ' . $this->sql;
|
||||||
* @return int|bool
|
return $this->getLogger()->logCategory($errorMsg, 'mysql');
|
||||||
* @throws
|
}
|
||||||
*/
|
|
||||||
private function _prepare(): int|bool
|
|
||||||
{
|
/**
|
||||||
$client = $this->connection->getConnection();
|
* @return bool
|
||||||
try {
|
* @throws
|
||||||
$startTime = microtime(true);
|
*/
|
||||||
if (($prepare = $client->prepare($this->sql)) === false) {
|
public function flush(): bool
|
||||||
throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $prepare->errorInfo()[2]);
|
{
|
||||||
}
|
return (bool)$this->_prepare();
|
||||||
if ($prepare->execute($this->params) === false) {
|
}
|
||||||
throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $prepare->errorInfo()[2]);
|
|
||||||
}
|
|
||||||
|
/**
|
||||||
$prepare->closeCursor();
|
* 执行写入类 SQL 操作，内置断连重试机制
|
||||||
|
* 当数据库连接断开时自动重试，断开的连接不再归还池中防止污染连接池
|
||||||
$result = $client->lastInsertId();
|
* @return int|bool
|
||||||
|
* @throws
|
||||||
$this->connection->println($startTime, microtime(true), $this->sql, $this->params);
|
*/
|
||||||
if (str_starts_with($this->sql, 'DELETE')) {
|
private function _prepare(): int|bool
|
||||||
return $prepare->rowCount();
|
{
|
||||||
}
|
$retryCount = 0;
|
||||||
|
|
||||||
return $result == 0 ? $prepare->rowCount() : (int)$result;
|
while ($retryCount <= self::MAX_RETRIES) {
|
||||||
} catch (Throwable $throwable) {
|
$client = $this->connection->getConnection();
|
||||||
$this->getLogger()->json_log($throwable);
|
try {
|
||||||
|
$startTime = microtime(true);
|
||||||
if ($this->isRefresh($throwable)) {
|
if (($prepare = $client->prepare($this->sql)) === false) {
|
||||||
return $this->_prepare();
|
throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $prepare->errorInfo()[2]);
|
||||||
}
|
}
|
||||||
|
if ($prepare->execute($this->params) === false) {
|
||||||
$errorMsg = $throwable->getMessage() . PHP_EOL . ' Sql: ' . $this->sql . '.' . json_encode($this->params, JSON_UNESCAPED_UNICODE);
|
throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $prepare->errorInfo()[2]);
|
||||||
|
}
|
||||||
return $this->getLogger()->logCategory($errorMsg . PHP_EOL, 'mysql');
|
|
||||||
} finally {
|
$prepare->closeCursor();
|
||||||
$this->connection->release($client);
|
|
||||||
}
|
$result = $client->lastInsertId();
|
||||||
}
|
|
||||||
|
$this->connection->println($startTime, microtime(true), $this->sql, $this->params);
|
||||||
|
if (str_starts_with($this->sql, 'DELETE')) {
|
||||||
/**
|
$this->connection->release($client);
|
||||||
* @param Throwable $throwable
|
return $prepare->rowCount();
|
||||||
* @return bool
|
}
|
||||||
*/
|
|
||||||
protected function isRefresh(Throwable $throwable): bool
|
$this->connection->release($client);
|
||||||
{
|
return $result == 0 ? $prepare->rowCount() : (int)$result;
|
||||||
$message = $throwable->getMessage();
|
} catch (Throwable $throwable) {
|
||||||
|
$this->getLogger()->json_log($throwable);
|
||||||
// MySQL 错误处理
|
|
||||||
if (str_contains($message, 'MySQL server has gone away')) {
|
if ($this->isRefresh($throwable) && $retryCount < self::MAX_RETRIES) {
|
||||||
return true;
|
$retryCount++;
|
||||||
}
|
$this->connection->connections->abandon($this->connection->getName());
|
||||||
if (str_contains($message, 'Send of 14 bytes failed with errno=32 Broken pipe')) {
|
continue;
|
||||||
return true;
|
}
|
||||||
}
|
|
||||||
if (str_contains($message, 'Lost connection to MySQL server during query')) {
|
$this->connection->release($client);
|
||||||
return true;
|
|
||||||
}
|
$errorMsg = $throwable->getMessage() . PHP_EOL . ' Sql: ' . $this->sql . '.' . json_encode($this->params, JSON_UNESCAPED_UNICODE);
|
||||||
|
|
||||||
// PostgreSQL 错误处理
|
return $this->getLogger()->logCategory($errorMsg . PHP_EOL, 'mysql');
|
||||||
if (str_contains($message, 'server closed the connection unexpectedly')) {
|
}
|
||||||
return true;
|
}
|
||||||
}
|
|
||||||
if (str_contains($message, 'Connection refused')) {
|
$errorMsg = 'Max retry exceeded for SQL: ' . $this->sql;
|
||||||
return true;
|
return $this->getLogger()->logCategory($errorMsg, 'mysql');
|
||||||
}
|
}
|
||||||
if (str_contains($message, 'Broken pipe')) {
|
|
||||||
return true;
|
|
||||||
}
|
/**
|
||||||
if (str_contains($message, 'connection to server was lost')) {
|
* @param Throwable $throwable
|
||||||
return true;
|
* @return bool
|
||||||
}
|
*/
|
||||||
|
protected function isRefresh(Throwable $throwable): bool
|
||||||
return false;
|
{
|
||||||
}
|
$message = $throwable->getMessage();
|
||||||
|
|
||||||
|
// MySQL 错误处理
|
||||||
/**
|
if (str_contains($message, 'MySQL server has gone away')) {
|
||||||
* @return bool
|
return true;
|
||||||
* @throws
|
}
|
||||||
*/
|
if (str_contains($message, 'Send of 14 bytes failed with errno=32 Broken pipe')) {
|
||||||
public function delete(): bool
|
return true;
|
||||||
{
|
}
|
||||||
return $this->_prepare();
|
if (str_contains($message, 'Lost connection to MySQL server during query')) {
|
||||||
}
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
// PostgreSQL 错误处理
|
||||||
* @return int|bool
|
if (str_contains($message, 'server closed the connection unexpectedly')) {
|
||||||
*/
|
return true;
|
||||||
public function exec(): int|bool
|
}
|
||||||
{
|
if (str_contains($message, 'Connection refused')) {
|
||||||
return $this->_prepare();
|
return true;
|
||||||
}
|
}
|
||||||
|
if (str_contains($message, 'Broken pipe')) {
|
||||||
/**
|
return true;
|
||||||
* @param array $data
|
}
|
||||||
* @return $this
|
if (str_contains($message, 'connection to server was lost')) {
|
||||||
*/
|
return true;
|
||||||
public function bindValues(array $data = []): static
|
}
|
||||||
{
|
|
||||||
if (count($data) > 0) {
|
return false;
|
||||||
$this->params = array_merge($this->params, $data);
|
}
|
||||||
}
|
|
||||||
return $this;
|
|
||||||
}
|
/**
|
||||||
|
* @return bool
|
||||||
}
|
* @throws
|
||||||
|
*/
|
||||||
|
public function delete(): bool
|
||||||
|
{
|
||||||
|
return $this->_prepare();
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return int|bool
|
||||||
|
*/
|
||||||
|
public function exec(): int|bool
|
||||||
|
{
|
||||||
|
return $this->_prepare();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param array $data
|
||||||
|
* @return $this
|
||||||
|
*/
|
||||||
|
public function bindValues(array $data = []): static
|
||||||
|
{
|
||||||
|
if (count($data) > 0) {
|
||||||
|
$this->params = array_merge($this->params, $data);
|
||||||
|
}
|
||||||
|
return $this;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|||||||
+59
-55
@@ -248,61 +248,65 @@ class Connection extends Component
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @throws
|
* @throws
|
||||||
* 事务回滚
|
* 事务回滚
|
||||||
*/
|
*/
|
||||||
public function rollback(): void
|
public function rollback(): void
|
||||||
{
|
{
|
||||||
$this->storey--;
|
$this->storey--;
|
||||||
if ($this->storey == 0) {
|
if ($this->storey == 0) {
|
||||||
if (!Context::exists($this->cds)) {
|
if (!Context::exists($this->cds)) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
$pdo = $this->getTransactionClient();
|
$pdo = $this->getTransactionClient();
|
||||||
if ($pdo->inTransaction()) {
|
if ($pdo->inTransaction()) {
|
||||||
$pdo->rollback();
|
$pdo->rollback();
|
||||||
}
|
}
|
||||||
$this->release($pdo);
|
$this->release($pdo);
|
||||||
}
|
Context::remove($this->cds);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
/**
|
|
||||||
* @throws
|
/**
|
||||||
* 事务提交
|
* @throws
|
||||||
*/
|
* 事务提交
|
||||||
public function commit(): void
|
*/
|
||||||
{
|
public function commit(): void
|
||||||
$this->storey--;
|
{
|
||||||
if ($this->storey == 0) {
|
$this->storey--;
|
||||||
if (!Context::exists($this->cds)) {
|
if ($this->storey == 0) {
|
||||||
return;
|
if (!Context::exists($this->cds)) {
|
||||||
}
|
return;
|
||||||
$pdo = $this->getTransactionClient();
|
}
|
||||||
if ($pdo->inTransaction()) {
|
$pdo = $this->getTransactionClient();
|
||||||
$pdo->commit();
|
if ($pdo->inTransaction()) {
|
||||||
}
|
$pdo->commit();
|
||||||
$this->release($pdo);
|
}
|
||||||
}
|
$this->release($pdo);
|
||||||
}
|
Context::remove($this->cds);
|
||||||
|
}
|
||||||
|
}
|
||||||
/**
|
|
||||||
* @return void
|
|
||||||
* @throws
|
/**
|
||||||
*/
|
* @return void
|
||||||
public function clear(): void
|
* @throws
|
||||||
{
|
*/
|
||||||
/** @var PDO $pdo */
|
public function clear(): void
|
||||||
$pdo = Context::get($this->cds);
|
{
|
||||||
if ($pdo === null) {
|
/** @var PDO $pdo */
|
||||||
return;
|
$pdo = Context::get($this->cds);
|
||||||
}
|
if ($pdo === null) {
|
||||||
if ($this->inTransaction()) {
|
return;
|
||||||
$pdo->rollback();
|
}
|
||||||
}
|
if ($this->inTransaction()) {
|
||||||
$this->release($pdo);
|
$pdo->rollback();
|
||||||
}
|
}
|
||||||
|
$this->release($pdo);
|
||||||
|
Context::remove($this->cds);
|
||||||
|
$this->storey = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
+470
-462
@@ -1,462 +1,470 @@
|
|||||||
<?php
|
<?php
|
||||||
/** @noinspection ALL */
|
/** @noinspection ALL */
|
||||||
|
|
||||||
declare(strict_types=1);
|
declare(strict_types=1);
|
||||||
|
|
||||||
namespace Database;
|
namespace Database;
|
||||||
|
|
||||||
|
|
||||||
use JetBrains\PhpStorm\Pure;
|
use JetBrains\PhpStorm\Pure;
|
||||||
use Kiri;
|
use Kiri;
|
||||||
use Kiri\Abstracts\Component;
|
use Kiri\Abstracts\Component;
|
||||||
|
use Database\Traits\QueryTrait;
|
||||||
|
|
||||||
/**
|
|
||||||
* Class SqlBuilder
|
/**
|
||||||
* @package Database
|
* Class SqlBuilder
|
||||||
*/
|
* @package Database
|
||||||
class SqlBuilder extends Component
|
*/
|
||||||
{
|
class SqlBuilder extends Component
|
||||||
|
{
|
||||||
/**
|
|
||||||
* @var ActiveQuery|Query|ISqlBuilder|null
|
/**
|
||||||
*/
|
* @var ActiveQuery|Query|ISqlBuilder|null
|
||||||
public ActiveQuery|Query|ISqlBuilder|null $query;
|
*/
|
||||||
|
public ActiveQuery|Query|ISqlBuilder|null $query;
|
||||||
|
|
||||||
/**
|
|
||||||
* @param ActiveQuery|Query|ISqlBuilder|null $config
|
/**
|
||||||
*/
|
* @param ActiveQuery|Query|ISqlBuilder|null $config
|
||||||
public function __construct(ActiveQuery|Query|null|ISqlBuilder $config)
|
*/
|
||||||
{
|
public function __construct(ActiveQuery|Query|null|ISqlBuilder $config)
|
||||||
parent::__construct();
|
{
|
||||||
|
parent::__construct();
|
||||||
$this->query = $config;
|
|
||||||
}
|
$this->query = $config;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @param ISqlBuilder|null $query
|
/**
|
||||||
* @return $this
|
* @param ISqlBuilder|null $query
|
||||||
* @throws
|
* @return $this
|
||||||
*/
|
* @throws
|
||||||
public static function builder(ISqlBuilder|null $query): static
|
*/
|
||||||
{
|
public static function builder(ISqlBuilder|null $query): static
|
||||||
return new static($query);
|
{
|
||||||
}
|
return new static($query);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @return string
|
/**
|
||||||
* @throws
|
* @return string
|
||||||
*/
|
* @throws
|
||||||
public function getCondition(): string
|
*/
|
||||||
{
|
public function getCondition(): string
|
||||||
return $this->where($this->query);
|
{
|
||||||
}
|
return $this->where($this->query->where);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @param array $compiler
|
/**
|
||||||
* @return string
|
* @param array $compiler
|
||||||
* @throws
|
* @return string
|
||||||
*/
|
* @throws
|
||||||
public function hashCompiler(array $compiler): string
|
*/
|
||||||
{
|
public function hashCompiler(array $compiler): string
|
||||||
return $this->where($compiler);
|
{
|
||||||
}
|
return $this->where($compiler);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @param array $attributes
|
/**
|
||||||
* @return bool|array
|
* @param array $attributes
|
||||||
* @throws
|
* @return bool|array
|
||||||
*/
|
* @throws
|
||||||
public function update(array $attributes): bool|string
|
*/
|
||||||
{
|
public function update(array $attributes): bool|string
|
||||||
$conditions = $this->query;
|
{
|
||||||
$this->query = [];
|
$conditions = $this->query;
|
||||||
$data = $this->__updateBuilder($this->makeParams($attributes));
|
$this->query = [];
|
||||||
foreach ($conditions as $condition) {
|
$data = $this->__updateBuilder($this->makeParams($attributes));
|
||||||
$this->query->pushParam($condition);
|
foreach ($conditions as $condition) {
|
||||||
}
|
$this->query->pushParam($condition);
|
||||||
return $data;
|
}
|
||||||
}
|
return $data;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @param array $attributes
|
/**
|
||||||
* @param string $opera
|
* @param array $attributes
|
||||||
* @return bool|array
|
* @param string $opera
|
||||||
* @throws
|
* @return bool|array
|
||||||
*/
|
* @throws
|
||||||
public function mathematics(array $attributes, string $opera = '+'): bool|string
|
*/
|
||||||
{
|
public function mathematics(array $attributes, string $opera = '+'): bool|string
|
||||||
$string = [];
|
{
|
||||||
foreach ($attributes as $attribute => $value) {
|
$string = [];
|
||||||
$string[] = $attribute . '=' . $attribute . $opera . $value;
|
foreach ($attributes as $attribute => $value) {
|
||||||
}
|
$string[] = $attribute . '=' . $attribute . $opera . $value;
|
||||||
return $this->__updateBuilder($string);
|
}
|
||||||
}
|
return $this->__updateBuilder($string);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @param array $string
|
/**
|
||||||
* @return string|bool
|
* @param array $string
|
||||||
* @throws
|
* @return string|bool
|
||||||
*/
|
* @throws
|
||||||
private function __updateBuilder(array $string): string|bool
|
*/
|
||||||
{
|
private function __updateBuilder(array $string): string|bool
|
||||||
if (empty($string)) {
|
{
|
||||||
return Kiri::getLogger()->logCategory('None data update.');
|
if (empty($string)) {
|
||||||
}
|
return Kiri::getLogger()->logCategory('None data update.');
|
||||||
return 'UPDATE ' . $this->query . ' SET ' . implode(',', $string) . $this->make();
|
}
|
||||||
}
|
return 'UPDATE ' . $this->getFromAlias() . ' SET ' . implode(',', $string) . $this->make();
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @param array $attributes
|
/**
|
||||||
* @param false $isBatch
|
* @param array $attributes
|
||||||
* @return array
|
* @param false $isBatch
|
||||||
* @throws
|
* @return array
|
||||||
*/
|
* @throws
|
||||||
public function insert(array $attributes, bool $isBatch = false): string
|
*/
|
||||||
{
|
public function insert(array $attributes, bool $isBatch = false): string
|
||||||
$update = 'INSERT INTO ' . $this->query;
|
{
|
||||||
if ($isBatch === false) {
|
$update = 'INSERT INTO ' . $this->getFromAlias();
|
||||||
$attributes = [$attributes];
|
if ($isBatch === false) {
|
||||||
}
|
$attributes = [$attributes];
|
||||||
$update .= '(' . implode(',', $this->getFields($attributes)) . ') VALUES ';
|
}
|
||||||
|
$update .= '(' . implode(',', $this->getFields($attributes)) . ') VALUES ';
|
||||||
$keys = [];
|
|
||||||
foreach ($attributes as $attribute) {
|
$keys = [];
|
||||||
$_keys = $this->makeParams($attribute, true);
|
foreach ($attributes as $attribute) {
|
||||||
|
$_keys = $this->makeParams($attribute, true);
|
||||||
$keys[] = implode(',', $_keys);
|
|
||||||
}
|
$keys[] = implode(',', $_keys);
|
||||||
return $update . '(' . implode('),(', $keys) . ')';
|
}
|
||||||
}
|
return $update . '(' . implode('),(', $keys) . ')';
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @return string
|
/**
|
||||||
* @throws
|
* @return string
|
||||||
*/
|
* @throws
|
||||||
public function delete(): string
|
*/
|
||||||
{
|
public function delete(): string
|
||||||
return 'DELETE FROM ' . $this->query . $this->make();
|
{
|
||||||
}
|
return 'DELETE FROM ' . $this->getFromAlias() . $this->make();
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @param $attributes
|
/**
|
||||||
* @return array
|
* @param $attributes
|
||||||
*/
|
* @return array
|
||||||
#[Pure] private function getFields(array $attributes): array
|
*/
|
||||||
{
|
#[Pure] private function getFields(array $attributes): array
|
||||||
return array_keys(current($attributes));
|
{
|
||||||
}
|
return array_keys(current($attributes));
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @param array $attributes
|
/**
|
||||||
* @param bool $isInsert
|
* @param array $attributes
|
||||||
* @return array[]
|
* @param bool $isInsert
|
||||||
* a=:b,
|
* @return array[]
|
||||||
*/
|
* a=:b,
|
||||||
private function makeParams(array $attributes, bool $isInsert = false): array
|
*/
|
||||||
{
|
private function makeParams(array $attributes, bool $isInsert = false): array
|
||||||
$keys = [];
|
{
|
||||||
foreach ($attributes as $key => $value) {
|
$keys = [];
|
||||||
if ($isInsert === true) {
|
foreach ($attributes as $key => $value) {
|
||||||
$keys[] = '?';
|
if ($isInsert === true) {
|
||||||
$this->query->pushParam($value);
|
$keys[] = '?';
|
||||||
} else {
|
$this->query->pushParam($value);
|
||||||
$keys = $this->resolveParams($key, $value, $keys);
|
} else {
|
||||||
}
|
$keys = $this->resolveParams($key, $value, $keys);
|
||||||
}
|
}
|
||||||
return $keys;
|
}
|
||||||
}
|
return $keys;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @param string $key
|
/**
|
||||||
* @param mixed $value
|
* @param string $key
|
||||||
* @param array $keys
|
* @param mixed $value
|
||||||
* @return array
|
* @param array $keys
|
||||||
*/
|
* @return array
|
||||||
private function resolveParams(string $key, mixed $value, array $keys): array
|
*/
|
||||||
{
|
private function resolveParams(string $key, mixed $value, array $keys): array
|
||||||
if (is_null($value)) {
|
{
|
||||||
return $keys;
|
if (is_null($value)) {
|
||||||
}
|
return $keys;
|
||||||
if (preg_match('/^[+|-]\s\d+$/', (string)$value)) {
|
}
|
||||||
$keys[] = $key . '=' . $key . ' ' . $value;
|
if (preg_match('/^[+|-]\s\d+$/', (string)$value)) {
|
||||||
} else {
|
$keys[] = $key . '=' . $key . ' ' . $value;
|
||||||
$this->query->pushParam($value);
|
} else {
|
||||||
$keys[] = $key . '= ?';
|
$this->query->pushParam($value);
|
||||||
}
|
$keys[] = $key . '= ?';
|
||||||
return $keys;
|
}
|
||||||
}
|
return $keys;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @return string
|
/**
|
||||||
* @throws
|
* @return string
|
||||||
*/
|
* @throws
|
||||||
public function one(): string
|
*/
|
||||||
{
|
public function one(): string
|
||||||
$this->query->offset(0)->limit(1);
|
{
|
||||||
return $this->makeSelect($this->query) . $this->make() . $this->makeLimit();
|
$this->query->offset(0)->limit(1);
|
||||||
}
|
return $this->makeSelect($this->query) . $this->make() . $this->makeLimit();
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @return string
|
/**
|
||||||
* @throws
|
* @return string
|
||||||
*/
|
* @throws
|
||||||
public function all(): string
|
*/
|
||||||
{
|
public function all(): string
|
||||||
return $this->makeSelect($this->query) . $this->make() . $this->makeLimit();
|
{
|
||||||
}
|
return $this->makeSelect($this->query) . $this->make() . $this->makeLimit();
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @return string
|
/**
|
||||||
* @throws
|
* @return string
|
||||||
*/
|
* @throws
|
||||||
public function count(): string
|
*/
|
||||||
{
|
public function count(): string
|
||||||
return $this->makeSelect(['COUNT(*)']) . $this->make();
|
{
|
||||||
}
|
return $this->makeSelect(['COUNT(*)']) . $this->make();
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @return string
|
/**
|
||||||
* @throws
|
* @return string
|
||||||
*/
|
* @throws
|
||||||
public function exists(): string
|
*/
|
||||||
{
|
public function exists(): string
|
||||||
return $this->makeSelect(['0']) . $this->make();
|
{
|
||||||
}
|
return $this->makeSelect(['0']) . $this->make();
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @param string $table
|
/**
|
||||||
* @return string
|
* @param string $table
|
||||||
* @throws
|
* @return string
|
||||||
*/
|
* @throws
|
||||||
public function columns(string $table): string
|
*/
|
||||||
{
|
public function columns(string $table): string
|
||||||
$driver = $this->getDriver();
|
{
|
||||||
if (in_array($driver, ['pgsql', 'postgresql'])) {
|
$driver = $this->getDriver();
|
||||||
// PostgreSQL 使用 information_schema
|
if (in_array($driver, ['pgsql', 'postgresql'])) {
|
||||||
$tableName = trim($table, '"`');
|
$tableName = trim($table, '"`');
|
||||||
return "SELECT
|
return "SELECT
|
||||||
column_name as Field,
|
column_name as Field,
|
||||||
data_type as Type,
|
data_type as Type,
|
||||||
is_nullable as Null,
|
is_nullable as Null,
|
||||||
column_default as Default,
|
column_default as Default,
|
||||||
'' as Extra,
|
'' as Extra,
|
||||||
'' as Key
|
'' as Key
|
||||||
FROM information_schema.columns
|
FROM information_schema.columns
|
||||||
WHERE table_name = '$tableName'
|
WHERE table_name = '$tableName'
|
||||||
ORDER BY ordinal_position";
|
ORDER BY ordinal_position";
|
||||||
}
|
}
|
||||||
// MySQL 使用 SHOW FULL FIELDS
|
return 'SHOW FULL FIELDS FROM ' . $table;
|
||||||
return 'SHOW FULL FIELDS FROM ' . $table;
|
}
|
||||||
}
|
|
||||||
|
|
||||||
|
/**
|
||||||
/**
|
* @return string
|
||||||
* @return string
|
* @throws
|
||||||
* @throws
|
*/
|
||||||
*/
|
private function make(): string
|
||||||
private function make(): string
|
{
|
||||||
{
|
$select = $this->makeCondition();
|
||||||
$select = $this->makeCondition();
|
$select .= $this->makeGroup();
|
||||||
$select .= $this->makeGroup();
|
$select .= $this->makeOrder();
|
||||||
$select .= $this->makeOrder();
|
return $select;
|
||||||
return $select;
|
}
|
||||||
}
|
|
||||||
|
/**
|
||||||
/**
|
* @param mixed $select 列名数组或 QueryTrait 对象
|
||||||
* @param array $select
|
* @return string
|
||||||
* @return string
|
*/
|
||||||
*/
|
private function makeSelect(mixed $select = ['*']): string
|
||||||
private function makeSelect(array $select = ['*']): string
|
{
|
||||||
{
|
if (!is_array($select)) {
|
||||||
$select = "SELECT " . implode(',', $select) . " FROM " . $this->query;
|
$select = ['*'];
|
||||||
if ($this->query != "") {
|
}
|
||||||
$select .= " AS " . $this->query;
|
$sql = "SELECT " . implode(',', $select) . " FROM " . $this->getFromAlias();
|
||||||
}
|
if ($this->query->join !== []) {
|
||||||
if (count($this->query) > 0) {
|
$sql .= ' ' . implode(' ', $this->query->join);
|
||||||
$select .= ' ' . implode(' ', $this->query);
|
}
|
||||||
}
|
return $sql;
|
||||||
return $select;
|
}
|
||||||
}
|
|
||||||
|
|
||||||
|
/**
|
||||||
/**
|
* @return string
|
||||||
* @return string
|
*/
|
||||||
*/
|
private function makeGroup(): string
|
||||||
private function makeGroup(): string
|
{
|
||||||
{
|
if ($this->query->group !== '' && $this->query->group !== '0') {
|
||||||
if ($this->query != "") {
|
return ' GROUP BY ' . $this->query->group;
|
||||||
return ' GROUP BY ' . $this->query;
|
}
|
||||||
}
|
return '';
|
||||||
return '';
|
}
|
||||||
}
|
|
||||||
|
|
||||||
|
/**
|
||||||
/**
|
* @return string
|
||||||
* @return string
|
*/
|
||||||
*/
|
private function makeOrder(): string
|
||||||
private function makeOrder(): string
|
{
|
||||||
{
|
if (count($this->query->order) > 0) {
|
||||||
if (count($this->query) > 0) {
|
return ' ORDER BY ' . implode(',', $this->query->order);
|
||||||
return ' ORDER BY ' . implode(',', $this->query);
|
}
|
||||||
}
|
return '';
|
||||||
return '';
|
}
|
||||||
}
|
|
||||||
|
|
||||||
|
/**
|
||||||
/**
|
* @return string
|
||||||
* @return string
|
*/
|
||||||
*/
|
private function makeCondition(): string
|
||||||
private function makeCondition(): string
|
{
|
||||||
{
|
$condition = $this->where($this->query->where);
|
||||||
$condition = $this->where($this->query);
|
if (empty($condition)) {
|
||||||
if (empty($condition)) {
|
return '';
|
||||||
return '';
|
}
|
||||||
}
|
return ' WHERE ' . $condition;
|
||||||
return ' WHERE ' . $condition;
|
}
|
||||||
}
|
|
||||||
|
|
||||||
|
/**
|
||||||
/**
|
* @return string
|
||||||
* @return string
|
* @throws
|
||||||
* @throws
|
*/
|
||||||
*/
|
private function makeLimit(): string
|
||||||
private function makeLimit(): string
|
{
|
||||||
{
|
if ($this->query->offset >= 0 && $this->query->limit >= 1) {
|
||||||
if ($this->query >= 0 && $this->query >= 1) {
|
$driver = $this->getDriver();
|
||||||
$driver = $this->getDriver();
|
if (in_array($driver, ['pgsql', 'postgresql'])) {
|
||||||
if (in_array($driver, ['pgsql', 'postgresql'])) {
|
return ' LIMIT ' . $this->query->limit . ' OFFSET ' . $this->query->offset;
|
||||||
// PostgreSQL 使用 LIMIT ... OFFSET ... 语法
|
}
|
||||||
return ' LIMIT ' . $this->query . ' OFFSET ' . $this->query;
|
return ' LIMIT ' . $this->query->offset . ',' . $this->query->limit;
|
||||||
}
|
}
|
||||||
// MySQL 使用 LIMIT offset,limit 语法
|
return '';
|
||||||
return ' LIMIT ' . $this->query . ',' . $this->query;
|
}
|
||||||
}
|
|
||||||
return '';
|
|
||||||
}
|
/**
|
||||||
|
* @param false $isCount
|
||||||
|
* @return string
|
||||||
/**
|
* @throws
|
||||||
* @param false $isCount
|
*/
|
||||||
* @return string
|
public function get(bool $isCount = false): string
|
||||||
* @throws
|
{
|
||||||
*/
|
if ($isCount === false) {
|
||||||
public function get(bool $isCount = false): string
|
return $this->all();
|
||||||
{
|
}
|
||||||
if ($isCount === false) {
|
return $this->count();
|
||||||
return $this->all();
|
}
|
||||||
}
|
|
||||||
return $this->count();
|
|
||||||
}
|
/**
|
||||||
|
* @return string
|
||||||
|
* @throws
|
||||||
/**
|
*/
|
||||||
* @return string
|
public function truncate(): string
|
||||||
* @throws
|
{
|
||||||
*/
|
return sprintf('TRUNCATE %s', $this->getFromAlias());
|
||||||
public function truncate(): string
|
}
|
||||||
{
|
|
||||||
return sprintf('TRUNCATE %s', $this->query);
|
|
||||||
}
|
/**
|
||||||
|
* @param array $where
|
||||||
|
* @return string
|
||||||
/**
|
*/
|
||||||
* @param array $where
|
private function where(array $where): string
|
||||||
* @return string
|
{
|
||||||
*/
|
if (count($where) < 1) {
|
||||||
private function where(array $where): string
|
return '';
|
||||||
{
|
}
|
||||||
if (count($where) < 1) {
|
$_tmp = [];
|
||||||
return '';
|
foreach ($where as $key => $value) {
|
||||||
}
|
$_tmp[] = $this->resolveCondition($key, $value);
|
||||||
$_tmp = [];
|
}
|
||||||
foreach ($where as $key => $value) {
|
return implode(' AND ', $_tmp);
|
||||||
$_tmp[] = $this->resolveCondition($key, $value);
|
}
|
||||||
}
|
|
||||||
return implode(' AND ', $_tmp);
|
|
||||||
}
|
/**
|
||||||
|
* @param string $field
|
||||||
|
* @param mixed $condition
|
||||||
/**
|
* @return string
|
||||||
* @param string $field
|
*/
|
||||||
* @param mixed $condition
|
private function resolveCondition(string|int $field, mixed $condition): string
|
||||||
* @return string
|
{
|
||||||
*/
|
if (is_string($field)) {
|
||||||
private function resolveCondition(string|int $field, mixed $condition): string
|
$this->query->pushParam($condition);
|
||||||
{
|
return $field . ' = ?';
|
||||||
if (is_string($field)) {
|
} else if (is_string($condition)) {
|
||||||
$this->query->pushParam($condition);
|
return $condition;
|
||||||
return $field . ' = ?';
|
} else {
|
||||||
} else if (is_string($condition)) {
|
return implode(' AND ', $this->_hashMap($condition));
|
||||||
return $condition;
|
}
|
||||||
} else {
|
}
|
||||||
return implode(' AND ', $this->_hashMap($condition));
|
|
||||||
}
|
|
||||||
}
|
/**
|
||||||
|
* @param $condition
|
||||||
|
* @return array
|
||||||
/**
|
*/
|
||||||
* @param $condition
|
private function _hashMap(array $condition): array
|
||||||
* @return array
|
{
|
||||||
*/
|
$_array = [];
|
||||||
private function _hashMap(array $condition): array
|
foreach ($condition as $key => $value) {
|
||||||
{
|
$this->query->pushParam($value);
|
||||||
$_array = [];
|
$_array[] = $key . '= ?';
|
||||||
foreach ($condition as $key => $value) {
|
}
|
||||||
$this->query->pushParam($value);
|
return $_array;
|
||||||
$_array[] = $key . '= ?';
|
}
|
||||||
}
|
|
||||||
return $_array;
|
/**
|
||||||
}
|
* 获取数据库驱动类型
|
||||||
|
* @return string
|
||||||
/**
|
* @throws
|
||||||
* 获取数据库驱动类型
|
*/
|
||||||
* @return string
|
private function getDriver(): string
|
||||||
* @throws
|
{
|
||||||
*/
|
try {
|
||||||
private function getDriver(): string
|
if ($this->query instanceof ActiveQuery && $this->query->modelClass !== null) {
|
||||||
{
|
if ($this->query->modelClass instanceof Model) {
|
||||||
try {
|
$connection = $this->query->modelClass->getConnection();
|
||||||
// 尝试从 query 对象获取 connection
|
if ($connection instanceof Connection) {
|
||||||
if ($this->query instanceof ActiveQuery && $this->query->modelClass !== null) {
|
return strtolower($connection->driver ?? 'mysql');
|
||||||
if ($this->query->modelClass instanceof Model) {
|
}
|
||||||
$connection = $this->query->modelClass->getConnection();
|
}
|
||||||
if ($connection instanceof Connection) {
|
}
|
||||||
return strtolower($connection->driver ?? 'mysql');
|
if (method_exists($this->query, 'getConnection')) {
|
||||||
}
|
$connection = $this->query->getConnection();
|
||||||
}
|
if ($connection instanceof Connection) {
|
||||||
}
|
return strtolower($connection->driver ?? 'mysql');
|
||||||
// 如果是 Db 查询，尝试获取默认 connection
|
}
|
||||||
if (method_exists($this->query, 'getConnection')) {
|
}
|
||||||
$connection = $this->query->getConnection();
|
} catch (\Throwable $e) {
|
||||||
if ($connection instanceof Connection) {
|
$this->getLogger()->json_log($e);
|
||||||
return strtolower($connection->driver ?? 'mysql');
|
}
|
||||||
}
|
return 'mysql';
|
||||||
}
|
}
|
||||||
} catch (\Throwable $e) {
|
|
||||||
// 忽略错误，返回默认值
|
|
||||||
$this->getLogger()->json_log($e);
|
/**
|
||||||
}
|
* 获取 FROM 子句（表名 + 别名）
|
||||||
// 默认返回 mysql
|
* QueryTrait 对象有 $from 和 $alias 属性
|
||||||
return 'mysql';
|
* @return string
|
||||||
}
|
*/
|
||||||
|
private function getFromAlias(): string
|
||||||
|
{
|
||||||
}
|
$from = $this->query->from;
|
||||||
|
if ($this->query->alias !== '' && $this->query->alias !== '0') {
|
||||||
|
$from .= ' AS ' . $this->query->alias;
|
||||||
|
}
|
||||||
|
return $from;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user