Compare commits

...

45 Commits

Author SHA1 Message Date
as2252258 06074c38c1 eee 2026-06-24 22:00:50 +08:00
as2252258 404b511c5f eee 2026-06-24 21:53:42 +08:00
as2252258 bf4f8538ed eee 2026-06-24 20:11:10 +08:00
as2252258 8a985a65df eee 2026-06-12 23:57:19 +08:00
as2252258 c7b980d969 eee 2026-04-23 00:23:32 +08:00
as2252258 fea649413c eee 2026-04-23 00:20:00 +08:00
as2252258 959407a95e eee 2026-04-23 00:19:10 +08:00
as2252258 0abc7c32f7 eee 2026-04-21 14:59:51 +08:00
as2252258 9c6340d0b3 eee 2026-01-11 19:59:20 +08:00
as2252258 0f01416351 eee 2026-01-11 19:57:24 +08:00
as2252258 b1d2c0fb51 eee 2026-01-11 19:56:26 +08:00
as2252258 db18a2d73a eee 2026-01-11 19:55:00 +08:00
as2252258 3cb3dcf384 eee 2026-01-11 19:53:35 +08:00
as2252258 fd8652ccd1 eee 2026-01-11 19:32:32 +08:00
as2252258 279151825a eee 2026-01-11 19:29:35 +08:00
as2252258 3dd2d4abf2 eee 2026-01-06 21:44:27 +08:00
as2252258 8bf5027582 eee 2026-01-03 20:44:19 +08:00
as2252258 0b27a7dc7d eee 2026-01-02 01:08:47 +08:00
as2252258 c016853ff8 ea 2026-01-01 23:01:44 +08:00
as2252258 758c322679 eee 2026-01-01 21:46:00 +08:00
as2252258 cbbc6ea7f1 eee 2025-12-31 00:52:06 +08:00
as2252258 456c7f29b6 eee 2025-12-31 00:49:39 +08:00
as2252258 89d5b604d6 eee 2025-12-31 00:19:29 +08:00
as2252258 c943d6258b eee 2025-12-23 19:03:22 +08:00
as2252258 466cee4ab5 update composer.json.
xxx

Signed-off-by: 向林 <as2252258@163.com>
2025-12-23 02:28:56 +00:00
as2252258 ee1a5a993d eee 2025-12-16 20:20:08 +08:00
as2252258 0dcd548645 eee 2025-12-07 14:01:37 +08:00
as2252258 d796a86ce3 eee 2025-12-07 12:18:24 +08:00
as2252258 ef19079727 ea 2025-11-23 23:11:49 +08:00
as2252258 dcee10b77b eee 2025-07-14 18:34:02 +08:00
as2252258 2bf66fc17f eee 2025-07-14 18:05:40 +08:00
as2252258 61f549362d eee 2025-07-14 18:03:42 +08:00
as2252258 583e2214c3 eee 2025-07-14 15:34:45 +08:00
as2252258 e190c42dd0 eee 2025-07-14 11:04:30 +08:00
as2252258 190c272ea3 eee 2025-07-14 10:59:34 +08:00
as2252258 28c64daae7 eee 2025-07-14 08:57:17 +08:00
as2252258 7c347bc373 eee 2025-07-09 10:34:46 +08:00
as2252258 d5c9b3bc86 eee 2025-07-09 10:28:20 +08:00
as2252258 ef7e85746d eee 2025-05-19 11:20:32 +08:00
as2252258 89f6949556 eee 2025-05-19 11:19:20 +08:00
as2252258 555d160b40 eee 2025-05-19 11:09:33 +08:00
as2252258 45b949747d eee 2025-05-19 11:06:27 +08:00
as2252258 94857ecb46 eee 2025-02-17 16:29:10 +08:00
as2252258 0f0a3349fb eee 2025-02-17 16:26:32 +08:00
as2252258 7fb9c3ea05 eee 2025-01-18 20:28:24 +08:00
18 changed files with 2755 additions and 2678 deletions
-18
View File
@@ -1,18 +0,0 @@
<?php
namespace PHPSTORM_META {
// Reflect
use Kiri\Di\Container;
use Psr\Container\ContainerInterface;
override(ContainerInterface::get(0), map('@'));
override(Container::make(0), map('@'));
override(Container::get(0), map('@'));
override(Container::create(0), map('@'));
// override(\Hyperf\Utils\Context::get(0), map('@'));
// override(\make(0), map('@'));
override(\di(0), map('@'));
override(\duplicate(0), map('@'));
}
+1 -1
View File
@@ -288,6 +288,6 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
*/ */
public function delete(): bool public function delete(): bool
{ {
return $this->buildCommand($this->builder->delete())->delete(); return (bool)$this->buildCommand($this->builder->delete())->exec();
} }
} }
+1 -1
View File
@@ -31,7 +31,7 @@ class BackupCommand extends Command
/** /**
* *
*/ */
protected function configure() protected function configure(): void
{ {
$this->setName('db:backup') $this->setName('db:backup')
->addOption('data', 'd', InputArgument::OPTIONAL) ->addOption('data', 'd', InputArgument::OPTIONAL)
+2 -2
View File
@@ -250,7 +250,7 @@ interface ActiveQueryInterface
* *
* @return QueryTrait * @return QueryTrait
*/ */
public function groupBy(string $name, string $having = NULL): QueryTrait; public function groupBy(string $name, ?string $having = NULL): QueryTrait;
/** /**
* @param int $limit * @param int $limit
@@ -267,4 +267,4 @@ interface ActiveQueryInterface
public function offset(int $offset): QueryTrait; public function offset(int $offset): QueryTrait;
} }
+849 -826
View File
File diff suppressed because it is too large Load Diff
+16 -1
View File
@@ -5,6 +5,7 @@ namespace Database\Base;
class PDO extends \PDO class PDO extends \PDO
{ {
readonly public string $driver;
/** /**
* @param string $database * @param string $database
@@ -12,6 +13,7 @@ class PDO extends \PDO
* @param string $username * @param string $username
* @param string $password * @param string $password
* @param array $options * @param array $options
* @param string $driver
*/ */
public function __construct( public function __construct(
readonly public string $database, readonly public string $database,
@@ -19,10 +21,23 @@ class PDO extends \PDO
readonly public string $username, readonly public string $username,
readonly public string $password, readonly public string $password,
readonly public array $options, readonly public array $options,
string $driver = 'mysql',
) )
{ {
parent::__construct('mysql:dbname=' . $this->database . ';host=' . $this->host, $this->username, $this->password, $this->options); $this->driver = strtolower($driver);
$dsn = $this->buildDsn();
parent::__construct($dsn, $this->username, $this->password, $this->options);
} }
/**
* @return string
*/
private function buildDsn(): string
{
return match ($this->driver) {
'pgsql', 'postgresql' => 'pgsql:host=' . $this->host . ';dbname=' . $this->database,
default => 'mysql:dbname=' . $this->database . ';host=' . $this->host,
};
}
} }
+2 -2
View File
@@ -41,7 +41,7 @@ class Collection extends AbstractCollection
public function update(array $attributes): bool public function update(array $attributes): bool
{ {
if ($this->isEmpty()) { if ($this->isEmpty()) {
return $this->getLogger()->failure('No data by update', 'mysql'); return $this->getLogger()->logCategory('No data by update', 'mysql');
} }
return $this->batch()->update($attributes); return $this->batch()->update($attributes);
} }
@@ -150,7 +150,7 @@ class Collection extends AbstractCollection
{ {
$model = $this->getModel(); $model = $this->getModel();
if ($this->isEmpty()) { if ($this->isEmpty()) {
return $this->getLogger()->failure('No data by delete', 'mysql'); return $this->getLogger()->logCategory('No data by delete', 'mysql');
} }
if (!$model->hasPrimary()) { if (!$model->hasPrimary()) {
throw new Exception('Must set primary key. if you want to delete data'); throw new Exception('Must set primary key. if you want to delete data');
+288 -230
View File
@@ -1,230 +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);
if ($this->isRefresh($throwable)) return $this->search($method);
$result = $method == 'rowCount' ? $prepare->rowCount() : $prepare->{$method}(PDO::FETCH_ASSOC);
$errorMsg = $throwable->getMessage() . PHP_EOL . ' Sql: ' . $this->sql . '.' . json_encode($this->params); $prepare->closeCursor();
return $this->getLogger()->failure($errorMsg . PHP_EOL, 'mysql'); $this->connection->println($startTime, microtime(true), $this->sql, $this->params);
} finally {
$this->connection->release($client); $this->connection->release($client);
} return $result;
} } catch (Throwable $throwable) {
$this->getLogger()->json_log($throwable);
/** if ($this->isRefresh($throwable) && $retryCount < self::MAX_RETRIES) {
* @return bool $retryCount++;
* @throws $this->connection->connections->abandon($this->connection->getName());
*/ continue;
public function flush(): bool }
{
return (bool)$this->_prepare(); $this->connection->release($client);
}
$errorMsg = $throwable->getMessage() . PHP_EOL . ' Sql: ' . $this->sql . '.' . json_encode($this->params);
/** return $this->getLogger()->logCategory($errorMsg . PHP_EOL, 'mysql');
* @return int|bool }
* @throws }
*/
private function _prepare(): int|bool $errorMsg = 'Max retry exceeded for SQL: ' . $this->sql;
{ return $this->getLogger()->logCategory($errorMsg, 'mysql');
$client = $this->connection->getConnection(); }
try {
$startTime = microtime(true);
if (($prepare = $client->prepare($this->sql)) === false) { /**
throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $prepare->errorInfo()[2]); * @return bool
} * @throws
if ($prepare->execute($this->params) === false) { */
throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $prepare->errorInfo()[2]); public function flush(): bool
} {
$prepare->closeCursor(); return (bool)$this->_prepare();
}
$result = $client->lastInsertId();
$this->connection->println($startTime, microtime(true), $this->sql, $this->params); /**
* 执行写入类 SQL 操作,内置断连重试机制
return $result == 0 ? $prepare->rowCount() : (int)$result; * 当数据库连接断开时自动重试,断开的连接不再归还池中防止污染连接池
} catch (Throwable $throwable) { * @return int|bool
if ($this->isRefresh($throwable)) return $this->_prepare(); * @throws
*/
$errorMsg = $throwable->getMessage() . PHP_EOL . ' Sql: ' . $this->sql . '.' . json_encode($this->params); private function _prepare(): int|bool
{
return $this->getLogger()->failure($errorMsg . PHP_EOL, 'mysql'); $retryCount = 0;
} finally {
$this->connection->release($client); while ($retryCount <= self::MAX_RETRIES) {
} $client = $this->connection->getConnection();
} try {
$startTime = microtime(true);
if (($prepare = $client->prepare($this->sql)) === false) {
/** throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $prepare->errorInfo()[2]);
* @param Throwable $throwable }
* @return bool if ($prepare->execute($this->params) === false) {
*/ throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $prepare->errorInfo()[2]);
protected function isRefresh(Throwable $throwable): bool }
{
if (str_contains($throwable->getMessage(), 'MySQL server has gone away')) { $prepare->closeCursor();
return true;
} $result = $client->lastInsertId();
if (str_contains($throwable->getMessage(), 'Send of 14 bytes failed with errno=32 Broken pipe')) {
return true; $this->connection->println($startTime, microtime(true), $this->sql, $this->params);
} if (str_starts_with($this->sql, 'DELETE')) {
if (str_contains($throwable->getMessage(), 'Lost connection to MySQL server during query')) { $this->connection->release($client);
return true; return $prepare->rowCount();
} }
return false;
} $this->connection->release($client);
return $result == 0 ? $prepare->rowCount() : (int)$result;
} catch (Throwable $throwable) {
/** $this->getLogger()->json_log($throwable);
* @return bool
* @throws if ($this->isRefresh($throwable) && $retryCount < self::MAX_RETRIES) {
*/ $retryCount++;
public function delete(): bool $this->connection->connections->abandon($this->connection->getName());
{ continue;
return (bool)$this->_prepare(); }
}
$this->connection->release($client);
/** $errorMsg = $throwable->getMessage() . PHP_EOL . ' Sql: ' . $this->sql . '.' . json_encode($this->params, JSON_UNESCAPED_UNICODE);
* @return int|bool
*/ return $this->getLogger()->logCategory($errorMsg . PHP_EOL, 'mysql');
public function exec(): int|bool }
{ }
return $this->_prepare();
} $errorMsg = 'Max retry exceeded for SQL: ' . $this->sql;
return $this->getLogger()->logCategory($errorMsg, 'mysql');
/** }
* @param array $data
* @return $this
*/ /**
public function bindValues(array $data = []): static * @param Throwable $throwable
{ * @return bool
if (count($data) > 0) { */
$this->params = array_merge($this->params, $data); protected function isRefresh(Throwable $throwable): bool
} {
return $this; $message = $throwable->getMessage();
}
// MySQL 错误处理
} if (str_contains($message, 'MySQL server has gone away')) {
return true;
}
if (str_contains($message, 'Send of 14 bytes failed with errno=32 Broken pipe')) {
return true;
}
if (str_contains($message, 'Lost connection to MySQL server during query')) {
return true;
}
// PostgreSQL 错误处理
if (str_contains($message, 'server closed the connection unexpectedly')) {
return true;
}
if (str_contains($message, 'Connection refused')) {
return true;
}
if (str_contains($message, 'Broken pipe')) {
return true;
}
if (str_contains($message, 'connection to server was lost')) {
return true;
}
return false;
}
/**
* @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;
}
}
+3 -4
View File
@@ -43,10 +43,9 @@ abstract class Condition extends Component
public function setValue($params): void public function setValue($params): void
{ {
if (is_array($params)) { if (is_array($params)) {
$values = []; $values = array_map(function ($value) {
foreach ($params as $item => $value) { return is_numeric($value) ? $value : '\'' . $value . '\'';
$values[$item] = is_numeric($value) ? $value : '\'' . $value . '\''; }, $params);
}
$this->value = $values; $this->value = $values;
} else { } else {
$this->value = $this->checkIsSqlString($params); $this->value = $this->checkIsSqlString($params);
+1 -1
View File
@@ -17,7 +17,7 @@ class NotInCondition extends Condition
* @return string|null * @return string|null
* @throws * @throws
*/ */
#[Pure] public function builder(): ?string public function builder(): ?string
{ {
if (!is_array($this->value)) { if (!is_array($this->value)) {
throw new \Exception('Builder data by a empty string. need array'); throw new \Exception('Builder data by a empty string. need array');
+102 -90
View File
@@ -14,21 +14,21 @@ namespace Database;
use Database\Affair\BeginTransaction; use Database\Affair\BeginTransaction;
use Database\Affair\Commit; use Database\Affair\Commit;
use Database\Affair\Rollback; use Database\Affair\Rollback;
use Database\Base\Driver;
use Database\Base\PDO;
use Exception; use Exception;
use Kiri;
use Kiri\Server\Events\OnWorkerExit;
use Kiri\Abstracts\Component; use Kiri\Abstracts\Component;
use Kiri\Di\Context; use Kiri\Di\Context;
use Kiri\Pool\Pool;
use Kiri\Events\EventProvider;
use Kiri\Error\StdoutLogger;
use Psr\Log\LoggerInterface;
use Kiri\Server\Events\OnWorkerStart;
use Kiri\Server\Events\OnTaskerStart;
use Kiri\Server\Events\OnAfterRequest;
use Kiri\Di\Inject\Container; use Kiri\Di\Inject\Container;
use Kiri\Error\StdoutLogger;
use Kiri\Events\EventProvider;
use Kiri\Pool\Pool;
use Kiri\Server\Events\OnAfterRequest;
use Kiri\Server\Events\OnTaskerStart;
use Kiri\Server\Events\OnWorkerExit;
use Kiri\Server\Events\OnWorkerStart;
use Psr\Log\LoggerInterface;
use Swoole\Timer; use Swoole\Timer;
use Database\Base\PDO;
//use PDO; //use PDO;
@@ -46,9 +46,10 @@ class Connection extends Component
public string $charset = 'utf-8'; public string $charset = 'utf-8';
public string $tablePrefix = ''; public string $tablePrefix = '';
public string $database = ''; public string $database = '';
public string $driver = 'mysql';
public int $timeout = 30; public int $timeout = 30;
public int $waite_time = 3; public int $waite_time = 3;
public int $tick_time = 60; public int $tick_time = 60000;
public int $idle_count = 3; public int $idle_count = 3;
public int $idle_time = 60; public int $idle_time = 60;
public array $pool = ['max' => 10, 'min' => 1]; public array $pool = ['max' => 10, 'min' => 1];
@@ -134,19 +135,19 @@ class Connection extends Component
protected function checkClientHealth(Pool $pool): void protected function checkClientHealth(Pool $pool): void
{ {
$pool->flush($this->getName(), $this->pool['min'] ?? 1); $pool->flush($this->getName(), $this->pool['min'] ?? 1);
$length = $pool->size($this->getName()); // $length = $pool->size($this->getName());
for ($i = 0; $i < $length; $i++) { // for ($i = 0; $i < $length; $i++) {
try { // try {
if (($client = $this->validator($pool)) === false) { // if (($client = $this->validator($pool)) === false) {
break; // break;
} // }
$pool->push($this->getName(), $client); // $pool->push($this->getName(), $client);
} catch (\Throwable $exception) { // } catch (\Throwable $exception) {
if (!str_contains($exception->getMessage(), 'Client timeout.')) { // if (!str_contains($exception->getMessage(), 'Client timeout.')) {
$this->logger->error(throwable($exception), [$this->cds]); // $this->logger->error(throwable($exception), [$this->cds]);
} // }
} // }
} // }
} }
@@ -155,7 +156,7 @@ class Connection extends Component
*/ */
private function getName(): string private function getName(): string
{ {
return 'mysql.' . $this->cds; return strtolower($this->driver) . '.' . $this->cds;
} }
@@ -247,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;
}
/** /**
@@ -312,7 +317,7 @@ class Connection extends Component
*/ */
public function createCommand(string $sql, array $attributes = []): Command public function createCommand(string $sql, array $attributes = []): Command
{ {
return (new Command(['connection' => $this, 'sql' => $sql]))->bindValues($attributes); return new Command(['connection' => $this, 'sql' => $sql])->bindValues($attributes);
} }
@@ -356,15 +361,22 @@ class Connection extends Component
*/ */
public function newConnect(): \PDO public function newConnect(): \PDO
{ {
$pdo = new PDO($this->database, $this->cds, $this->username, $this->password, [ $driver = strtolower($this->driver);
\PDO::ATTR_CASE => \PDO::CASE_NATURAL, $options = [
\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION, \PDO::ATTR_CASE => \PDO::CASE_NATURAL,
\PDO::ATTR_ORACLE_NULLS => \PDO::NULL_NATURAL, \PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION,
\PDO::ATTR_STRINGIFY_FETCHES => false, \PDO::ATTR_ORACLE_NULLS => \PDO::NULL_NATURAL,
\PDO::ATTR_EMULATE_PREPARES => true, \PDO::ATTR_STRINGIFY_FETCHES => false,
\PDO::ATTR_TIMEOUT => $this->timeout, \PDO::ATTR_EMULATE_PREPARES => true,
\PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES ' . $this->charset \PDO::ATTR_TIMEOUT => $this->timeout,
]); ];
// MySQL 特定的选项
if ($driver === 'mysql') {
$options[\PDO::MYSQL_ATTR_INIT_COMMAND] = 'SET NAMES ' . $this->charset;
}
$pdo = new PDO($this->database, $this->cds, $this->username, $this->password, $options, $driver);
foreach ($this->attributes as $key => $attribute) { foreach ($this->attributes as $key => $attribute) {
$pdo->setAttribute($key, $attribute); $pdo->setAttribute($key, $attribute);
} }
+2 -1
View File
@@ -78,8 +78,9 @@ class DatabasesProviders extends Providers
'password' => $database['password'], 'password' => $database['password'],
'tablePrefix' => $database['tablePrefix'], 'tablePrefix' => $database['tablePrefix'],
'database' => $database['database'], 'database' => $database['database'],
'driver' => $database['driver'] ?? 'mysql',
'timeout' => $database['timeout'] ?? 10, 'timeout' => $database['timeout'] ?? 10,
'tick_time' => $database['tick_time'] ?? 60, 'tick_time' => $database['tick_time'] ?? 60000,
'waite_time' => $database['waite_time'] ?? 3, 'waite_time' => $database['waite_time'] ?? 3,
'pool' => $clientPool, 'pool' => $clientPool,
'attributes' => $database['attributes'] ?? [], 'attributes' => $database['attributes'] ?? [],
+12 -7
View File
@@ -116,8 +116,9 @@ class Model extends Base\Model
$connection->commit(); $connection->commit();
return $select; return $select;
} catch (\Throwable $throwable) { } catch (\Throwable $throwable) {
$connection->rollback(); $model->getLogger()->json_log($throwable);
return \Kiri::getLogger()->failure($throwable); $connection->rollback();
return false;
} }
} }
@@ -145,8 +146,9 @@ class Model extends Base\Model
$connection->commit(); $connection->commit();
return $select; return $select;
} catch (\Throwable $throwable) { } catch (\Throwable $throwable) {
$connection->rollback(); $model->getLogger()->json_log($throwable);
return \Kiri::getLogger()->failure($throwable); $connection->rollback();
return false;
} }
} }
@@ -206,9 +208,10 @@ class Model extends Base\Model
public static function inserts(array $data): bool public static function inserts(array $data): bool
{ {
if (empty($data)) { if (empty($data)) {
return trigger_print_error('Insert data empty.', 'mysql'); return \Kiri::getLogger()->logCategory('Insert data empty.', 'mysql');
} } else {
return static::query()->insert($data); return static::query()->insert($data);
}
} }
/** /**
@@ -282,6 +285,7 @@ class Model extends Base\Model
$primaryKey = str_replace('\\', '_', $modelName) . '_' . $foreignKey . '_' . $value; $primaryKey = str_replace('\\', '_', $modelName) . '_' . $foreignKey . '_' . $value;
if (!$relation->hasIdentification($primaryKey)) { if (!$relation->hasIdentification($primaryKey)) {
/** @var $modelName ModelInterface */
$relation->bindIdentification($primaryKey, $modelName::query()->where([$foreignKey => $value])); $relation->bindIdentification($primaryKey, $modelName::query()->where([$foreignKey => $value]));
} }
return $primaryKey; return $primaryKey;
@@ -343,6 +347,7 @@ class Model extends Base\Model
$primaryKey = str_replace('\\', '_', $modelName) . '_' . $foreignKey . '_' . implode('_', $value); $primaryKey = str_replace('\\', '_', $modelName) . '_' . $foreignKey . '_' . implode('_', $value);
if (!$relation->hasIdentification($primaryKey)) { if (!$relation->hasIdentification($primaryKey)) {
/** @var $modelName ModelInterface */
$relation->bindIdentification($primaryKey, $modelName::query()->whereIn($foreignKey, $value)); $relation->bindIdentification($primaryKey, $modelName::query()->whereIn($foreignKey, $value));
} }
+470 -401
View File
@@ -1,401 +1,470 @@
<?php /** @noinspection ALL */ <?php
/** @noinspection ALL */
declare(strict_types=1);
declare(strict_types=1);
namespace Database;
namespace Database;
use JetBrains\PhpStorm\Pure;
use Kiri; use JetBrains\PhpStorm\Pure;
use Kiri\Abstracts\Component; use Kiri;
use Kiri\Abstracts\Component;
use Database\Traits\QueryTrait;
/**
* Class SqlBuilder
* @package Database /**
*/ * Class SqlBuilder
class SqlBuilder extends Component * @package Database
{ */
class SqlBuilder extends Component
/** {
* @var ActiveQuery|Query|ISqlBuilder|null
*/ /**
public ActiveQuery|Query|ISqlBuilder|null $query; * @var ActiveQuery|Query|ISqlBuilder|null
*/
public ActiveQuery|Query|ISqlBuilder|null $query;
/**
* @param ActiveQuery|Query|ISqlBuilder|null $config
*/ /**
public function __construct(ActiveQuery|Query|null|ISqlBuilder $config) * @param ActiveQuery|Query|ISqlBuilder|null $config
{ */
parent::__construct(); public function __construct(ActiveQuery|Query|null|ISqlBuilder $config)
{
$this->query = $config; parent::__construct();
}
$this->query = $config;
}
/**
* @param ISqlBuilder|null $query
* @return $this /**
* @throws * @param ISqlBuilder|null $query
*/ * @return $this
public static function builder(ISqlBuilder|null $query): static * @throws
{ */
return new static($query); public static function builder(ISqlBuilder|null $query): static
} {
return new static($query);
}
/**
* @return string
* @throws /**
*/ * @return string
public function getCondition(): string * @throws
{ */
return $this->where($this->query->getWhere()); public function getCondition(): string
} {
return $this->where($this->query->where);
}
/**
* @param array $compiler
* @return string /**
* @throws * @param array $compiler
*/ * @return string
public function hashCompiler(array $compiler): string * @throws
{ */
return $this->where($compiler); public function hashCompiler(array $compiler): string
} {
return $this->where($compiler);
}
/**
* @param array $attributes
* @return bool|array /**
* @throws * @param array $attributes
*/ * @return bool|array
public function update(array $attributes): bool|string * @throws
{ */
$conditions = $this->query->getParams(); public function update(array $attributes): bool|string
$this->query->setParams([]); {
$data = $this->__updateBuilder($this->makeParams($attributes)); $conditions = $this->query;
foreach ($conditions as $condition) { $this->query = [];
$this->query->pushParam($condition); $data = $this->__updateBuilder($this->makeParams($attributes));
} foreach ($conditions as $condition) {
return $data; $this->query->pushParam($condition);
} }
return $data;
}
/**
* @param array $attributes
* @param string $opera /**
* @return bool|array * @param array $attributes
* @throws * @param string $opera
*/ * @return bool|array
public function mathematics(array $attributes, string $opera = '+'): bool|string * @throws
{ */
$string = []; public function mathematics(array $attributes, string $opera = '+'): bool|string
foreach ($attributes as $attribute => $value) { {
$string[] = $attribute . '=' . $attribute . $opera . $value; $string = [];
} foreach ($attributes as $attribute => $value) {
return $this->__updateBuilder($string); $string[] = $attribute . '=' . $attribute . $opera . $value;
} }
return $this->__updateBuilder($string);
}
/**
* @param array $string
* @return string|bool /**
* @throws * @param array $string
*/ * @return string|bool
private function __updateBuilder(array $string): string|bool * @throws
{ */
if (empty($string)) { private function __updateBuilder(array $string): string|bool
return Kiri::getLogger()->failure('None data update.'); {
} if (empty($string)) {
return 'UPDATE ' . $this->query->getFrom() . ' SET ' . implode(',', $string) . $this->make(); return Kiri::getLogger()->logCategory('None data update.');
} }
return 'UPDATE ' . $this->getFromAlias() . ' SET ' . implode(',', $string) . $this->make();
}
/**
* @param array $attributes
* @param false $isBatch /**
* @return array * @param array $attributes
* @throws * @param false $isBatch
*/ * @return array
public function insert(array $attributes, bool $isBatch = false): string * @throws
{ */
$update = 'INSERT INTO ' . $this->query->getFrom(); public function insert(array $attributes, bool $isBatch = false): string
if ($isBatch === false) { {
$attributes = [$attributes]; $update = 'INSERT INTO ' . $this->getFromAlias();
} if ($isBatch === false) {
$update .= '(' . implode(',', $this->getFields($attributes)) . ') VALUES '; $attributes = [$attributes];
}
$keys = []; $update .= '(' . implode(',', $this->getFields($attributes)) . ') VALUES ';
foreach ($attributes as $attribute) {
$_keys = $this->makeParams($attribute, true); $keys = [];
foreach ($attributes as $attribute) {
$keys[] = implode(',', $_keys); $_keys = $this->makeParams($attribute, true);
}
return $update . '(' . implode('),(', $keys) . ')'; $keys[] = implode(',', $_keys);
} }
return $update . '(' . implode('),(', $keys) . ')';
}
/**
* @return string
* @throws /**
*/ * @return string
public function delete(): string * @throws
{ */
return 'DELETE FROM ' . $this->query->getFrom() . $this->make(); public function delete(): string
} {
return 'DELETE FROM ' . $this->getFromAlias() . $this->make();
}
/**
* @param $attributes
* @return array /**
*/ * @param $attributes
#[Pure] private function getFields(array $attributes): array * @return array
{ */
return array_keys(current($attributes)); #[Pure] private function getFields(array $attributes): array
} {
return array_keys(current($attributes));
}
/**
* @param array $attributes
* @param bool $isInsert /**
* @return array[] * @param array $attributes
* a=:b, * @param bool $isInsert
*/ * @return array[]
private function makeParams(array $attributes, bool $isInsert = false): array * a=:b,
{ */
$keys = []; private function makeParams(array $attributes, bool $isInsert = false): array
foreach ($attributes as $key => $value) { {
if ($isInsert === true) { $keys = [];
$keys[] = '?'; foreach ($attributes as $key => $value) {
$this->query->pushParam($value); if ($isInsert === true) {
} else { $keys[] = '?';
$keys = $this->resolveParams($key, $value, $keys); $this->query->pushParam($value);
} } else {
} $keys = $this->resolveParams($key, $value, $keys);
return $keys; }
} }
return $keys;
}
/**
* @param string $key
* @param mixed $value /**
* @param array $keys * @param string $key
* @return array * @param mixed $value
*/ * @param array $keys
private function resolveParams(string $key, mixed $value, array $keys): array * @return array
{ */
if (is_null($value)) { private function resolveParams(string $key, mixed $value, array $keys): array
return $keys; {
} if (is_null($value)) {
if (preg_match('/^[+|-]\s\d+$/', $value)) { return $keys;
$keys[] = $key . '=' . $key . ' ' . $value; }
} else { if (preg_match('/^[+|-]\s\d+$/', (string)$value)) {
$this->query->pushParam($value); $keys[] = $key . '=' . $key . ' ' . $value;
$keys[] = $key . '= ?'; } else {
} $this->query->pushParam($value);
return $keys; $keys[] = $key . '= ?';
} }
return $keys;
}
/**
* @return string
* @throws /**
*/ * @return string
public function one(): string * @throws
{ */
return $this->makeSelect($this->query->getSelect()) . $this->make() . $this->makeLimit($this->query->limit(1)); public function one(): string
} {
$this->query->offset(0)->limit(1);
return $this->makeSelect($this->query) . $this->make() . $this->makeLimit();
/** }
* @return string
* @throws
*/ /**
public function all(): string * @return string
{ * @throws
return $this->makeSelect($this->query->getSelect()) . $this->make() . $this->makeLimit($this->query); */
} public function all(): string
{
return $this->makeSelect($this->query) . $this->make() . $this->makeLimit();
/** }
* @return string
* @throws
*/ /**
public function count(): string * @return string
{ * @throws
return $this->makeSelect(['COUNT(*)']) . $this->make(); */
} public function count(): string
{
return $this->makeSelect(['COUNT(*)']) . $this->make();
/** }
* @return string
* @throws
*/ /**
public function exists(): string * @return string
{ * @throws
return $this->makeSelect(['0']) . $this->make(); */
} public function exists(): string
{
return $this->makeSelect(['0']) . $this->make();
/** }
* @param string $table
* @return string
*/ /**
public function columns(string $table): string * @param string $table
{ * @return string
return 'SHOW FULL FIELDS FROM ' . $table; * @throws
} */
public function columns(string $table): string
{
/** $driver = $this->getDriver();
* @return string if (in_array($driver, ['pgsql', 'postgresql'])) {
* @throws $tableName = trim($table, '"`');
*/ return "SELECT
private function make(): string column_name as Field,
{ data_type as Type,
$select = $this->makeCondition(); is_nullable as Null,
$select .= $this->makeGroup(); column_default as Default,
$select .= $this->makeOrder(); '' as Extra,
return $select; '' as Key
} FROM information_schema.columns
WHERE table_name = '$tableName'
/** ORDER BY ordinal_position";
* @param array $select }
* @return string return 'SHOW FULL FIELDS FROM ' . $table;
*/ }
private function makeSelect(array $select = ['*']): string
{
$select = "SELECT " . implode(',', $select) . " FROM " . $this->query->getFrom(); /**
if ($this->query->getAlias() != "") { * @return string
$select .= " AS " . $this->query->getAlias(); * @throws
} */
if (count($this->query->getJoin()) > 0) { private function make(): string
$select .= ' ' . implode(' ', $this->query->getJoin()); {
} $select = $this->makeCondition();
return $select; $select .= $this->makeGroup();
} $select .= $this->makeOrder();
return $select;
}
/**
* @return string /**
*/ * @param mixed $select 列名数组或 QueryTrait 对象
private function makeGroup(): string * @return string
{ */
if ($this->query->getGroup() != "") { private function makeSelect(mixed $select = ['*']): string
return ' GROUP BY ' . $this->query->getGroup(); {
} if (!is_array($select)) {
return ''; $select = ['*'];
} }
$sql = "SELECT " . implode(',', $select) . " FROM " . $this->getFromAlias();
if ($this->query->join !== []) {
/** $sql .= ' ' . implode(' ', $this->query->join);
* @return string }
*/ return $sql;
private function makeOrder(): string }
{
if (count($this->query->getOrder()) > 0) {
return ' ORDER BY ' . implode(',', $this->query->getOrder()); /**
} * @return string
return ''; */
} private function makeGroup(): string
{
if ($this->query->group !== '' && $this->query->group !== '0') {
/** return ' GROUP BY ' . $this->query->group;
* @return string }
*/ return '';
private function makeCondition(): string }
{
$condition = $this->where($this->query->getWhere());
if (empty($condition)) { /**
return ''; * @return string
} */
return ' WHERE ' . $condition; private function makeOrder(): string
} {
if (count($this->query->order) > 0) {
return ' ORDER BY ' . implode(',', $this->query->order);
private function makeLimit(): string }
{ return '';
if ($this->query->getOffset() >= 0 && $this->query->getLimit() >= 1) { }
return ' LIMIT ' . $this->query->getOffset() . ',' . $this->query->getLimit();
}
return ''; /**
} * @return string
*/
private function makeCondition(): string
/** {
* @param false $isCount $condition = $this->where($this->query->where);
* @return string if (empty($condition)) {
* @throws return '';
*/ }
public function get(bool $isCount = false): string return ' WHERE ' . $condition;
{ }
if ($isCount === false) {
return $this->all();
} /**
return $this->count(); * @return string
} * @throws
*/
private function makeLimit(): string
/** {
* @return string if ($this->query->offset >= 0 && $this->query->limit >= 1) {
* @throws $driver = $this->getDriver();
*/ if (in_array($driver, ['pgsql', 'postgresql'])) {
public function truncate(): string return ' LIMIT ' . $this->query->limit . ' OFFSET ' . $this->query->offset;
{ }
return sprintf('TRUNCATE %s', $this->query->getFrom()); return ' LIMIT ' . $this->query->offset . ',' . $this->query->limit;
} }
return '';
}
/**
* @param array $where
* @return string /**
*/ * @param false $isCount
private function where(array $where): string * @return string
{ * @throws
if (count($where) < 1) { */
return ''; public function get(bool $isCount = false): string
} {
$_tmp = []; if ($isCount === false) {
foreach ($where as $key => $value) { return $this->all();
$_tmp[] = $this->resolveCondition($key, $value); }
} return $this->count();
return implode(' AND ', $_tmp); }
}
/**
/** * @return string
* @param string $field * @throws
* @param mixed $condition */
* @return string public function truncate(): string
*/ {
private function resolveCondition(string|int $field, mixed $condition): string return sprintf('TRUNCATE %s', $this->getFromAlias());
{ }
if (is_string($field)) {
$this->query->pushParam($condition);
return $field . ' = ?'; /**
} else if (is_string($condition)) { * @param array $where
return $condition; * @return string
} else { */
return implode(' AND ', $this->_hashMap($condition)); private function where(array $where): string
} {
} if (count($where) < 1) {
return '';
}
/** $_tmp = [];
* @param $condition foreach ($where as $key => $value) {
* @return array $_tmp[] = $this->resolveCondition($key, $value);
*/ }
private function _hashMap(array $condition): array return implode(' AND ', $_tmp);
{ }
$_array = [];
foreach ($condition as $key => $value) {
$this->query->pushParam($value); /**
$_array[] = $key . '= ?'; * @param string $field
} * @param mixed $condition
return $_array; * @return string
} */
private function resolveCondition(string|int $field, mixed $condition): string
{
} if (is_string($field)) {
$this->query->pushParam($condition);
return $field . ' = ?';
} else if (is_string($condition)) {
return $condition;
} else {
return implode(' AND ', $this->_hashMap($condition));
}
}
/**
* @param $condition
* @return array
*/
private function _hashMap(array $condition): array
{
$_array = [];
foreach ($condition as $key => $value) {
$this->query->pushParam($value);
$_array[] = $key . '= ?';
}
return $_array;
}
/**
* 获取数据库驱动类型
* @return string
* @throws
*/
private function getDriver(): string
{
try {
if ($this->query instanceof ActiveQuery && $this->query->modelClass !== null) {
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');
}
}
} catch (\Throwable $e) {
$this->getLogger()->json_log($e);
}
return 'mysql';
}
/**
* 获取 FROM 子句(表名 + 别名)
* QueryTrait 对象有 $from 和 $alias 属性
* @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;
}
}
-2
View File
@@ -12,8 +12,6 @@ namespace Database\Traits;
use Database\ModelInterface; use Database\ModelInterface;
use Database\Collection; use Database\Collection;
use Database\Relation; use Database\Relation;
use Kiri;
use Kiri\Di\Context;
/** /**
* Class HasBase * Class HasBase
+939 -1043
View File
File diff suppressed because it is too large Load Diff
+65 -46
View File
@@ -18,61 +18,80 @@ use JetBrains\PhpStorm\Pure;
class When class When
{ {
public ActiveQuery|ISqlBuilder $query; public ActiveQuery|ISqlBuilder $query;
private array $_condition = []; /**
* @var array
private string $else = ''; */
private array $_condition = [] {
&get {
return $this->_condition;
}
}
/** /**
* CaseWhen constructor. * @var string
* @param string $column */
* @param ActiveQuery|ISqlBuilder $activeQuery private string $else = '' {
*/ get {
public function __construct(public string $column, public ActiveQuery|ISqlBuilder $activeQuery) return $this->else;
{ }
$this->_condition[] = 'CASE ' . $column; set(string $value) {
} $this->else = $value;
}
}
/** /**
* @param string|int $condition * CaseWhen constructor.
* @param string $then * @param string $column
* @return $this * @param ActiveQuery|ISqlBuilder $activeQuery
* @throws */
*/ public function __construct(public string $column, public ActiveQuery|ISqlBuilder $activeQuery)
public function when(string|int $condition, string $then): static {
{ $this->_condition[] = 'CASE ' . $column;
$this->_condition[] = sprintf('WHEN %s THEN %s', $condition, $then); }
return $this;
}
/** /**
* @param string $alias * @param string|int $condition
*/ * @param string $then
public function else(string $alias): void * @return $this
{ * @throws
$this->else = $alias; */
} public function when(string|int $condition, string $then): static
{
$this->_condition[] = sprintf('WHEN %s THEN %s', $condition, $then);
return $this;
}
/** /**
* @return string * @param string $alias
*/ */
#[Pure] public function end(): string public function else(string $alias): void
{ {
if (empty($this->_condition)) { $this->else = $alias;
return ''; }
}
$prefix = implode(' ', $this->_condition);
if (!empty($this->else)) { /**
$prefix .= ' ELSE ' . $this->else; * @return string
} */
return '(' . $prefix . ' END)'; #[Pure]
} public function end(): string
{
if (empty($this->_condition)) {
return '';
}
$prefix = implode(' ', $this->_condition);
if (!empty($this->else)) {
$prefix .= ' ELSE ' . $this->else;
}
return '(' . $prefix . ' END)';
}
} }
+2 -2
View File
@@ -9,10 +9,10 @@
], ],
"license": "MIT", "license": "MIT",
"require": { "require": {
"php": ">=8.3", "php": ">=8.5",
"ext-json": "*", "ext-json": "*",
"ext-pdo": "*", "ext-pdo": "*",
"game-worker/kiri-pool": "~v1.0" "game-worker/kiri-pool": "^v1.0"
}, },
"autoload": { "autoload": {
"psr-4": { "psr-4": {