eee

xxx

Signed-off-by: 向林 <as2252258@163.com>

.phpstorm.meta.php

@@ -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('@'));
-
-}

ActiveQuery.php

@@ -23,14 +23,15 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 
 
 	public bool     $asArray = FALSE;
-    protected mixed $_mock   = null;
+	protected mixed $_mock   = NULL;
 
 
 	/**
 	 * @param bool $asArray
+	 *
 	 * @return static
 	 */
-    public function asArray(bool $asArray = true): static
+	public function asArray(bool $asArray = TRUE): static
 	{
 		$this->asArray = $asArray;
 		return $this;
@@ -38,6 +39,7 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 
 	/**
 	 * @param array $methods
+	 *
 	 * @return $this
 	 */
 	public function with(array $methods): static
@@ -57,7 +59,7 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 		if (is_array($data)) {
 			return $this->populate($data);
 		}
-        return null;
+		return NULL;
 	}
 
 	/**
@@ -69,7 +71,53 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 		if (is_array($data)) {
 			return new Collection($this, $this->modelClass, $data);
 		}
-        return false;
+		return FALSE;
+	}
+
+
+	/**
+	 * @param string    $column
+	 * @param int|float $amount
+	 *
+	 * @return bool
+	 */
+	public function increment(string $column, int|float $amount = 1): bool
+	{
+		return (bool)$this->buildCommand($this->builder->mathematics([$column => $amount]))->exec();
+	}
+
+
+	/**
+	 * @param array $attributes
+	 *
+	 * @return bool
+	 */
+	public function increments(array $attributes): bool
+	{
+		return (bool)$this->buildCommand($this->builder->mathematics($attributes))->exec();
+	}
+
+
+	/**
+	 * @param string    $column
+	 * @param int|float $amount
+	 *
+	 * @return bool
+	 */
+	public function decrement(string $column, int|float $amount = 1): bool
+	{
+		return (bool)$this->buildCommand($this->builder->mathematics([$column => $amount], '-'))->exec();
+	}
+
+
+	/**
+	 * @param array $attributes
+	 *
+	 * @return bool
+	 */
+	public function decrements(array $attributes): bool
+	{
+		return (bool)$this->buildCommand($this->builder->mathematics($attributes, '-'))->exec();
 	}
 
 
@@ -85,10 +133,12 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 	/**
 	 * @param int     $size
 	 * @param Closure $closure
+	 *
 	 * @return void
 	 */
 	public function chunk(int $size, Closure $closure): void
 	{
+		if ($this->offset === -1) $this->offset = 0;
 		$data = $this->offset($this->offset)->limit($size)->get();
 		if (!$data || $data->isEmpty()) {
 			return;
@@ -108,7 +158,7 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 	 *
 	 * @return array|null
 	 */
-    public function column(string $field, ?string $setKey = null): ?array
+	public function column(string $field, ?string $setKey = NULL): ?array
 	{
 		return $this->get()->column($field, $setKey);
 	}
@@ -116,6 +166,7 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 
 	/**
 	 * @param mixed $value
+	 *
 	 * @return $this
 	 */
 	public function withMock(mixed $value): static
@@ -136,6 +187,7 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 
 	/**
 	 * @param array $data
+	 *
 	 * @return ModelInterface|array
 	 * @throws
 	 */
@@ -147,6 +199,15 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 	}
 
 
+	/**
+	 * @return string
+	 */
+	public function toSql(): string
+	{
+		return $this->builder->get();
+	}
+
+
 	/**
 	 * @return int
 	 * @throws
@@ -159,13 +220,14 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 
 	/**
 	 * @param array $data
+	 *
 	 * @return bool
 	 * @throws
 	 */
 	public function update(array $data): bool
 	{
 		if (count($data) < 1) {
-            return true;
+			return TRUE;
 		}
 		$generate = $this->builder->update($data);
 		if (!is_bool($generate)) {
@@ -177,6 +239,7 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 
 	/**
 	 * @param array $data
+	 *
 	 * @return bool
 	 */
 	public function insert(array $data): bool
@@ -186,6 +249,7 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 		return (bool)$this->buildCommand($sql)->exec();
 	}
 
+
 	/**
 	 * @param string $filed
 	 *
@@ -203,13 +267,14 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 	 */
 	public function exists(): bool
 	{
-        return $this->buildCommand($this->builder->one())->rowCount() > 0;
+		return $this->buildCommand($this->limit(1)->builder->exists())->exists();
 	}
 
 
 	/**
 	 * @param string $sql
 	 * @param array  $params
+	 *
 	 * @return int|bool
 	 */
 	public function execute(string $sql, array $params = []): int|bool
@@ -223,6 +288,6 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 	 */
 	public function delete(): bool
 	{
-        return $this->buildCommand($this->builder->delete())->delete();
+		return (bool)$this->buildCommand($this->builder->delete())->exec();
 	}
 }

BackupCommand.php

@@ -31,7 +31,7 @@ class BackupCommand extends Command
     /**
      *
      */
-    protected function configure()
+    protected function configure(): void
     {
         $this->setName('db:backup')
              ->addOption('data', 'd', InputArgument::OPTIONAL)

Base/ActiveQueryInterface.php

@@ -221,10 +221,11 @@ interface ActiveQueryInterface
     public function whereNotBetween(string $column, int|float $start, int|float $end): QueryTrait;
 
     /**
-     * @param array $column
+     * @param array|string $column
+     * @param mixed|null $value
      * @return QueryTrait
      */
-    public function where(array $column): QueryTrait;
+    public function where(array|string $column, mixed $value = null): QueryTrait;
 
 
     /**
@@ -249,7 +250,7 @@ interface ActiveQueryInterface
      *
      * @return QueryTrait
      */
-    public function groupBy(string $name, string $having = NULL): QueryTrait;
+    public function groupBy(string $name, ?string $having = NULL): QueryTrait;
 
     /**
      * @param int $limit

Base/Model.php

@@ -1,4 +1,5 @@
-<?php /** @noinspection ALL */
+<?php
+/** @noinspection ALL */
 /**
  * Created by PhpStorm.
  * User: whwyy
@@ -22,12 +23,21 @@ use Database\ModelInterface;
 use Database\Relation;
 use Database\SqlBuilder;
 use Exception;
+use Kiri\Di\Context;
 use Kiri;
 use Kiri\Abstracts\Component;
 use ReturnTypeWillChange;
 use ReflectionException;
 use validator\Validator;
 
+
+enum Driver
+{
+	case Mysql;
+	case Pgsql;
+}
+
+
 /**
  * Class BOrm
  *
@@ -61,7 +71,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	/**
 	 * @var bool
 	 */
-    protected bool $skipValidate = false;
+	protected bool $skipValidate = FALSE;
 
 
 	/**
@@ -104,6 +114,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param array $data
+	 *
 	 * @return Model
 	 */
 	public function setWith(array $data): static
@@ -162,6 +173,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param bool $bool
+	 *
 	 * @return $this
 	 */
 	public function setIsNowExample(bool $bool = FALSE): static
@@ -210,9 +222,9 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	public function hasPrimaryValue(): bool
 	{
 		if ($this->hasPrimary()) {
-            return $this->getPrimaryValue() === null;
+			return $this->getPrimaryValue() === NULL;
 		}
-        return false;
+		return FALSE;
 	}
 
 
@@ -222,40 +234,44 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	 */
 	public function getPrimaryValue(): ?int
 	{
-        if ($this->hasPrimary()) {
+		if ($this->hasPrimary() && isset($this->_oldAttributes[$this->getPrimary()])) {
-            return (int)$this->_oldAttributes[$this->getPrimary()] ?? null;
+			return (int)$this->_oldAttributes[$this->getPrimary()];
 		} else {
-            return null;
+			return NULL;
 		}
 	}
 
 	/**
 	 * @param int|string|array $param
+	 *
 	 * @return Model|null
 	 * @throws
 	 */
-    public static function findOne(int|string|array $param): ?static
+	public static function findOne(int|string|array|null $param): ?static
 	{
-        $model = static::instance();
+		if (empty($param)) {
-        $query = new ActiveQuery($model);
+			return NULL;
+		}
+		$query = new ActiveQuery($model = static::instance());
 		$query->from($model->getTable())->alias('t1');
 		if (is_numeric($param)) {
-            $query->where([$model->getPrimary() => $param]);
+			$query->where([$model->getPrimary() => +$param]);
 		} else if (is_array($param)) {
 			$query->where($param);
 		} else {
 			$query->whereRaw($param);
 		}
-        $data = $query->first();
+		if (($data = $query->first()) === FALSE) {
-        if ($data === false) {
 			throw new Exception($model->getLastError());
-        }
+		} else {
 			return $data;
 		}
+	}
 
 
 	/**
 	 * @param int $param
+	 *
 	 * @return Model|null
 	 * @throws
 	 */
@@ -283,12 +299,13 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	 */
 	protected static function instance(): static
 	{
-        return new static();
+		return new static;
 	}
 
 
 	/**
 	 * @param int|string|array $condition
+	 *
 	 * @return static|null
 	 * @throws
 	 */
@@ -300,6 +317,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param string|array $condition
+	 *
 	 * @return Collection
 	 * @throws
 	 */
@@ -323,7 +341,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	public static function query(): ActiveQuery
 	{
 		$model = new ActiveQuery(static::instance());
-        $model->from($model->getTable())->alias('t1');
+		$model->select()->from($model->getTable())->alias('t1');
 		return $model;
 	}
 
@@ -377,6 +395,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	/**
 	 * @param string $name
 	 * @param mixed  $value
+	 *
 	 * @return mixed
 	 */
 	public function setAttribute(string $name, mixed $value): mixed
@@ -391,6 +410,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	/**
 	 * @param string $name
 	 * @param mixed  $value
+	 *
 	 * @return mixed
 	 */
 	public function setOldAttribute(string $name, mixed $value): mixed
@@ -404,6 +424,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param array $param
+	 *
 	 * @return $this
 	 * @throws
 	 */
@@ -418,6 +439,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param array $param
+	 *
 	 * @return $this
 	 */
 	public function setOldAttributes(array $param): static
@@ -436,14 +458,17 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	private function insert(): bool|static
 	{
 		$sql    = SqlBuilder::builder($query = static::query())->insert($this->_attributes);
-        $lastId = $this->getConnection()->createCommand($sql, $query->params)->save();
+		$lastId = $this->getConnection()->createCommand($sql, $query->params)->exec();
-        if ($lastId === false) {
+		if ($lastId === FALSE) {
-            return false;
+			return FALSE;
 		}
-        if ($this->hasPrimary()) {
+		if (!$this->hasPrimary()) {
+			return $this->refresh()->afterSave($this->_attributes, []);
+		}
+
 		$this->_attributes[$this->getPrimary()] = $lastId;
-        }
+
-        return $this;
+		return $this->refresh()->afterSave($this->_attributes, [$this->getPrimary() => $lastId]);
 	}
 
 
@@ -451,6 +476,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	 * @param array $old
 	 * @param array $condition
 	 * @param array $change
+	 *
 	 * @return $this|bool
 	 * @throws
 	 */
@@ -458,13 +484,14 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	{
 		$query = static::query()->where($condition);
 		if (count($change) < 1) {
-            return true;
+			return TRUE;
 		}
 		$generate = SqlBuilder::builder($query)->update($change);
-        if ($generate === false) {
+		var_dump($generate, $query->params);
-            return false;
+		if ($generate === FALSE) {
+			return FALSE;
 		}
-        if (!$this->getConnection()->createCommand($generate, $query->params)->save()) {
+		if (!$this->getConnection()->createCommand($generate, $query->params)->exec()) {
 			return FALSE;
 		}
 		return $this->refresh()->afterSave($old, $change);
@@ -476,7 +503,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	 */
 	public function save(): static|bool
 	{
-        if (!$this->validator($this->rules()) || !$this->beforeSave($this)) {
+		if (!$this->validator($this->rules(), $this->_attributes) || !$this->beforeSave($this)) {
 			return FALSE;
 		}
 		if (!$this->isNewExample) {
@@ -503,6 +530,9 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 				$oldPrams[$key] = $this->_oldAttributes[$key];
 			}
 		}
+		if ($this->hasPrimary()) {
+			$condition = [$this->getPrimary() => $this->getPrimaryValue()];
+		}
 		return [$oldPrams, $condition, $params];
 	}
 
@@ -521,6 +551,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param array $value
+	 *
 	 * @return $this
 	 */
 	public function populates(array $value): static
@@ -534,17 +565,18 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param array $rule
+	 *
 	 * @return bool
 	 * @throws
 	 */
-    public function validator(array $rule): bool
+	public function validator(array $rule, array $params): bool
 	{
 		if (count($rule) < 1 || $this->skipValidate) {
 			return TRUE;
 		}
 		$validate = $this->resolve($rule);
-        if (!$validate->validation($this)) {
+		if (!$validate->validation($params)) {
-            return \Kiri::getLogger()->failure($validate->getError() . PHP_EOL, 'mysql');
+			return \Kiri::getLogger()->logCategory($validate->getError() . PHP_EOL, 'mysql');
 		} else {
 			return TRUE;
 		}
@@ -553,12 +585,13 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param array $rule
+	 *
 	 * @return Validator
 	 * @throws
 	 */
 	private function resolve(array $rule): Validator
 	{
-        $validate = new Validator();
+		$validate = new Validator;
 		foreach ($rule as $val) {
 			$field = array_shift($val);
 			if (is_string($field)) {
@@ -573,6 +606,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param string $name
+	 *
 	 * @return null
 	 * @throws
 	 */
@@ -588,18 +622,19 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	 */
 	public function getRelation(): ?Relation
 	{
-        return Kiri::getDi()->get(Relation::class);
+		return di(Relation::class);
 	}
 
 
 	/**
 	 * @param string $attribute
+	 *
 	 * @return bool
 	 * @throws
 	 */
 	public function has(string $attribute): bool
 	{
-        return true;
+		return TRUE;
 	}
 
 
@@ -618,6 +653,13 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 		if (!empty($tablePrefix) && !str_starts_with($table, $tablePrefix)) {
 			$table = $tablePrefix . $table;
 		}
+
+		$driver = strtolower($connection->driver ?? 'mysql');
+		if (in_array($driver, ['pgsql', 'postgresql'])) {
+			// PostgreSQL 使用双引号，并且 schema.table 格式
+			return '"' . $connection->database . '"."' . $table . '"';
+		}
+		// MySQL 使用反引号
 		return '`' . $connection->database . '`.' . $table;
 	}
 
@@ -625,6 +667,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	/**
 	 * @param array $oldAttributes
 	 * @param array $changeAttributes
+	 *
 	 * @return bool
 	 */
 	public function afterSave(array $oldAttributes, array $changeAttributes): bool
@@ -635,6 +678,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param self $model
+	 *
 	 * @return bool
 	 * @throws
 	 */
@@ -650,6 +694,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	public function refresh(): static
 	{
 		$this->_oldAttributes = $this->_attributes;
+		$this->isNewExample   = FALSE;
 		return $this;
 	}
 
@@ -657,17 +702,21 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	/**
 	 * @param string $name
 	 * @param mixed  $value
+	 *
 	 * @return void
 	 */
 	public function __set(string $name, mixed $value): void
 	{
-        if ($this->hasRelateMethod($name, 'set')) {
+		$prefix = 'set' . ucfirst($name);
-            $this->{'set' . ucfirst($name)}($value);
+		if (method_exists($this, $prefix)) {
-        } else {
+			$this->{$prefix}($value);
-            $method = 'set' . ucfirst($name) . 'Attribute';
+			return;
-            if (method_exists($this, $method)) {
-                $value = $this->{$method} ($value);
 		}
+
+		$method = $prefix . 'Attribute';
+		if (method_exists($this, $method)) {
+			$this->_attributes[$name] = $this->{$method}($value);
+		} else {
 			$this->_attributes[$name] = $value;
 		}
 	}
@@ -675,25 +724,35 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param string $name
+	 *
 	 * @return mixed
 	 */
 	public function __get(string $name): mixed
 	{
-        $value = $this->_attributes[$name] ?? null;
+		if (isset($this->_attributes[$name])) {
-        if (!$this->hasRelateMethod($name)) {
+			return $this->withPropertyOverride($name, $this->_attributes[$name]);
-            return $this->withPropertyOverride($name, $value);
-        } else {
-            return $this->withRelate($name);
 		}
+
+		if (isset($this->_oldAttributes[$name])) {
+			return $this->withPropertyOverride($name, $this->_oldAttributes[$name]);
+		}
+
+
+		if (!method_exists($this, 'get' . ucfirst($name))) {
+			return NULL;
+		}
+
+		return $this->{'get' . ucfirst($name)}();
 	}
 
 
 	/**
 	 * @param string     $name
 	 * @param mixed|null $value
+	 *
 	 * @return mixed
 	 */
-    protected function withPropertyOverride(string $name, mixed $value = null): mixed
+	protected function withPropertyOverride(string $name, mixed $value = NULL): mixed
 	{
 		$method = 'get' . ucfirst($name) . 'Attribute';
 		if (method_exists($this, $method)) {
@@ -707,16 +766,26 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	/**
 	 * @param string $name
 	 * @param string $prefix
+	 *
 	 * @return bool
 	 */
-    protected function hasRelateMethod(string $name, string $prefix = 'get'): bool
+	protected function hasRelateMethod(string $name): bool
 	{
-        return method_exists($this, $prefix . ucfirst($name));
+		$reflection = $this->container->get(static::class);
+		if (!$reflection->hasMethod($name)) {
+			return FALSE;
+		}
+		if ($reflection->getMethod($name)->isStatic() || !$reflection->getMethod($name)->isPublic()) {
+			return FALSE;
+		} else {
+			return TRUE;
+		}
 	}
 
 
 	/**
 	 * @param string $name
+	 *
 	 * @return mixed
 	 */
 	protected function withRelate(string $name): mixed
@@ -731,6 +800,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param $name
+	 *
 	 * @return bool
 	 */
 	public function __isset(string $name): bool
@@ -741,6 +811,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param mixed $offset
+	 *
 	 * @return bool
 	 * @throws
 	 */
@@ -751,6 +822,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param mixed $offset
+	 *
 	 * @return mixed
 	 * @throws
 	 */
@@ -762,18 +834,22 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	/**
 	 * @param mixed $offset
 	 * @param mixed $value
+	 *
 	 * @throws
 	 */
-    #[ReturnTypeWillChange] public function offsetSet(mixed $offset, mixed $value): void
+	#[ReturnTypeWillChange]
+	public function offsetSet(mixed $offset, mixed $value): void
 	{
 		$this->__set($offset, $value);
 	}
 
 	/**
 	 * @param mixed $offset
+	 *
 	 * @throws
 	 */
-    #[ReturnTypeWillChange] public function offsetUnset(mixed $offset): void
+	#[ReturnTypeWillChange]
+	public function offsetUnset(mixed $offset): void
 	{
 		if (!isset($this->_attributes[$offset]) && !isset($this->_oldAttributes[$offset])) {
 			return;
@@ -784,6 +860,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param string ...$params
+	 *
 	 * @return array
 	 */
 	public function unset(string ...$params): array
@@ -794,12 +871,13 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
 	/**
 	 * @param array $data
+	 *
 	 * @return static
 	 * @throws
 	 */
 	public static function populate(array $data): static
 	{
-        $model                 = new static();
+		$model                 = new static;
 		$model->_attributes    = $data;
 		$model->_oldAttributes = $data;
 		$model->setIsNowExample();
@@ -810,21 +888,23 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 	/**
 	 * @param string $name
 	 * @param array  $arguments
+	 *
 	 * @return mixed
 	 */
 	public static function __callStatic(string $name, array $arguments)
 	{
-        return (new static())->{$name}(...$arguments);
+		return (new static)->{$name}(...$arguments);
 	}
 
 
 	/**
 	 * @param string $field
+	 *
 	 * @return array
 	 */
 	public function getOldAttribute(string $field): mixed
 	{
-        return $this->_oldAttributes[$field] ?? null;
+		return $this->_oldAttributes[$field] ?? NULL;
 	}
 
 }

Base/PDO.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace Database\Base;
+
+class PDO extends \PDO
+{
+
+    readonly public string $driver;
+
+    /**
+     * @param string $database
+     * @param string $host
+     * @param string $username
+     * @param string $password
+     * @param array $options
+     * @param string $driver
+     */
+    public function __construct(
+        readonly public string $database,
+        readonly public string $host,
+        readonly public string $username,
+        readonly public string $password,
+        readonly public array  $options,
+        string $driver = 'mysql',
+    )
+    {
+        $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,
+        };
+    }
+
+}

Collection.php

@@ -41,7 +41,7 @@ class Collection extends AbstractCollection
     public function update(array $attributes): bool
     {
         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);
     }
@@ -150,7 +150,7 @@ class Collection extends AbstractCollection
     {
         $model = $this->getModel();
         if ($this->isEmpty()) {
-            return $this->getLogger()->failure('No data by delete', 'mysql');
+            return $this->getLogger()->logCategory('No data by delete', 'mysql');
         }
         if (!$model->hasPrimary()) {
             throw new Exception('Must set primary key. if you want to delete data');

Command.php

@@ -23,6 +23,9 @@ use Throwable;
 class Command extends Component
 {
 
+	/** @var int 数据库操作最大重试次数 */
+	private const MAX_RETRIES = 2;
+
 	public Connection $connection;
 	public ?string    $sql    = '';
 	public array      $params = [];
@@ -47,15 +50,6 @@ class Command extends Component
 		return (bool)$this->_prepare();
 	}
 
-    /**
-     * @return bool
-     * @throws
-     */
-    public function save(): bool
-    {
-        return (bool)$this->_prepare();
-    }
-
 
 	/**
 	 * @return bool|array
@@ -75,6 +69,19 @@ class Command extends Component
 		return $this->search('fetch');
 	}
 
+	/**
+	 * @return bool
+	 * @throws Exception
+	 */
+	public function exists(): bool
+	{
+		$data = $this->search('fetch');
+		if (!$data) {
+			return false;
+		}
+		return true;
+	}
+
 	/**
 	 * @return mixed
 	 * @throws
@@ -90,33 +97,27 @@ class Command extends Component
 	 */
 	public function rowCount(): int
 	{
-        return $this->search('rowCount');
+		$data = $this->search('fetch');
+
+		return !$data ? 0 : +current($data);
 	}
 
 
 	/**
-     * @return bool
+	 * 执行查询类 SQL 操作，内置断连重试机制
-     * @throws Exception
+	 * 当数据库连接断开时自动重试，断开的连接不再归还池中防止污染连接池
-     */
+	 * @param string $method PDO 结果获取方法名
-    public function exists(): bool
-    {
-        $total = $this->search('rowCount');
-        if ($total === false) {
-            throw new Exception('Query data is has error.');
-        }
-        return $total > 0;
-    }
-
-
-    /**
-     * @param string $method
 	 * @return mixed
 	 * @throws
 	 */
 	protected function search(string $method): mixed
 	{
+		$retryCount = 0;
+
+		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] . ')' . $client->errorInfo()[2]);
 				}
@@ -126,18 +127,30 @@ class Command extends Component
 				$result = $method == 'rowCount' ? $prepare->rowCount() : $prepare->{$method}(PDO::FETCH_ASSOC);
 				$prepare->closeCursor();
 
+				$this->connection->println($startTime, microtime(true), $this->sql, $this->params);
+
+				$this->connection->release($client);
 				return $result;
 			} catch (Throwable $throwable) {
-            if ($this->isRefresh($throwable)) return $this->search($method);
+				$this->getLogger()->json_log($throwable);
+
+				if ($this->isRefresh($throwable) && $retryCount < self::MAX_RETRIES) {
+					$retryCount++;
+					$this->connection->connections->abandon($this->connection->getName());
+					continue;
+				}
+
+				$this->connection->release($client);
 
 				$errorMsg = $throwable->getMessage() . PHP_EOL . '                 Sql: ' . $this->sql . '.' . json_encode($this->params);
 
-            return $this->getLogger()->failure($errorMsg . PHP_EOL, 'mysql');
+				return $this->getLogger()->logCategory($errorMsg . PHP_EOL, 'mysql');
-        } finally {
-            $this->connection->release($client);
 			}
 		}
 
+		return $this->getLogger()->logCategory('Max retry exceeded for SQL: ' . $this->sql, 'mysql');
+	}
+
 
 	/**
 	 * @return bool
@@ -150,33 +163,58 @@ class Command extends Component
 
 
 	/**
+	 * 执行写入类 SQL 操作，内置断连重试机制
+	 * 当数据库连接断开时自动重试，断开的连接不再归还池中防止污染连接池
 	 * @return int|bool
 	 * @throws
 	 */
 	private function _prepare(): int|bool
 	{
+		$retryCount = 0;
+
+		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]);
 				}
+
+
 				if ($prepare->execute($this->params) === false) {
 					throw new Exception('(' . $prepare->errorInfo()[0] . ')' . $prepare->errorInfo()[2]);
 				}
+
 				$prepare->closeCursor();
 
 				$result = $client->lastInsertId();
 
+				$this->connection->println($startTime, microtime(true), $this->sql, $this->params);
+				if (str_starts_with($this->sql, 'DELETE')) {
+					$this->connection->release($client);
+					return $prepare->rowCount();
+				}
+
+				$this->connection->release($client);
 				return $result == 0 ? $prepare->rowCount() : (int)$result;
 			} catch (Throwable $throwable) {
-            if ($this->isRefresh($throwable)) return $this->_prepare();
+				$this->getLogger()->json_log($throwable);
 
-            $errorMsg = $throwable->getMessage() . PHP_EOL . '                 Sql: ' . $this->sql . '.' . json_encode($this->params);
+				if ($this->isRefresh($throwable) && $retryCount < self::MAX_RETRIES) {
-
+					$retryCount++;
-            return $this->getLogger()->failure($errorMsg . PHP_EOL, 'mysql');
+					$this->connection->connections->abandon($this->connection->getName());
-        } finally {
+					continue;
-            $this->connection->release($client);
 				}
+
+				$this->connection->release($client);
+
+				$errorMsg = $throwable->getMessage() . PHP_EOL . '                 Sql: ' . $this->sql . '.' . json_encode($this->params, JSON_UNESCAPED_UNICODE);
+
+				return $this->getLogger()->logCategory($errorMsg . PHP_EOL, 'mysql');
+			}
+		}
+
+		return $this->getLogger()->logCategory('Max retry exceeded for SQL: ' . $this->sql, 'mysql');
 	}
 
 
@@ -186,15 +224,33 @@ class Command extends Component
 	 */
 	protected function isRefresh(Throwable $throwable): bool
 	{
-        if (str_contains($throwable->getMessage(), 'MySQL server has gone away')) {
+		$message = $throwable->getMessage();
+
+		// MySQL 错误处理
+		if (str_contains($message, 'MySQL server has gone away')) {
 			return true;
 		}
-        if (str_contains($throwable->getMessage(), 'Send of 14 bytes failed with errno=32 Broken pipe')) {
+		if (str_contains($message, 'Send of 14 bytes failed with errno=32 Broken pipe')) {
 			return true;
 		}
-        if (str_contains($throwable->getMessage(), 'Lost connection to MySQL server during query')) {
+		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;
 	}
 
@@ -205,7 +261,7 @@ class Command extends Component
 	 */
 	public function delete(): bool
 	{
-        return (bool)$this->_prepare();
+		return $this->_prepare();
 	}
 
 

Condition/Condition.php

@@ -43,10 +43,9 @@ abstract class Condition extends Component
     public function setValue($params): void
     {
         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;
         } else {
             $this->value = $this->checkIsSqlString($params);

Condition/NotInCondition.php

@@ -17,7 +17,7 @@ class NotInCondition extends Condition
      * @return string|null
      * @throws
      */
-    #[Pure] public function builder(): ?string
+    public function builder(): ?string
     {
         if (!is_array($this->value)) {
             throw new \Exception('Builder data by a empty string. need array');

Connection.php

@@ -14,22 +14,24 @@ namespace Database;
 use Database\Affair\BeginTransaction;
 use Database\Affair\Commit;
 use Database\Affair\Rollback;
+use Database\Base\Driver;
+use Database\Base\PDO;
 use Exception;
-use Kiri;
-use Kiri\Server\Events\OnWorkerExit;
 use Kiri\Abstracts\Component;
 use Kiri\Di\Context;
-use Kiri\Pool\Pool;
-use Kiri\Events\EventProvider;
-use PDO;
-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\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 PDO;
+
 /**
  * Class Connection
  * @package Database
@@ -44,9 +46,10 @@ class Connection extends Component
     public string       $charset     = 'utf-8';
     public string       $tablePrefix = '';
     public string       $database    = '';
+    public string       $driver      = 'mysql';
     public int          $timeout     = 30;
     public int          $waite_time  = 3;
-    public int      $tick_time   = 60;
+    public int          $tick_time   = 60000;
     public int          $idle_count  = 3;
     public int          $idle_time   = 60;
     public array        $pool        = ['max' => 10, 'min' => 1];
@@ -55,6 +58,8 @@ class Connection extends Component
     public bool         $enableCache = false;
     public string       $cacheDriver = 'redis';
     public array        $attributes  = [];
+    public array        $slave       = [];
+    protected ?\Closure $_println    = null;
 
 
     /**
@@ -63,12 +68,37 @@ class Connection extends Component
     #[Container(LoggerInterface::class)]
     public StdoutLogger $logger;
 
+
+    /**
+     * @var EventProvider
+     */
+    #[Container(EventProvider::class)]
+    public EventProvider $eventProvider;
+
+
     /**
      * @param Pool $connections
      */
     public function __construct(public Pool $connections)
     {
         parent::__construct();
+
+        $this->_println = \config('databases.logger', null);
+    }
+
+
+    /**
+     * @param float $startTime
+     * @param float $endTime
+     * @param string $sql
+     * @param array $params
+     * @return void
+     */
+    public function println(float $startTime, float $endTime, string $sql, array $params = []): void
+    {
+        if (is_callable($this->_println)) {
+            call_user_func($this->_println, $startTime, $endTime, $sql, $params);
+        }
     }
 
 
@@ -78,14 +108,13 @@ class Connection extends Component
      */
     public function init(): void
     {
-        $eventProvider = Kiri::getDi()->get(EventProvider::class);
+        $this->eventProvider->on(BeginTransaction::class, [$this, 'beginTransaction'], 0);
-        $eventProvider->on(BeginTransaction::class, [$this, 'beginTransaction'], 0);
+        $this->eventProvider->on(Rollback::class, [$this, 'rollback'], 0);
-        $eventProvider->on(Rollback::class, [$this, 'rollback'], 0);
+        $this->eventProvider->on(Commit::class, [$this, 'commit'], 0);
-        $eventProvider->on(Commit::class, [$this, 'commit'], 0);
+        $this->eventProvider->on(OnAfterRequest::class, [$this, 'clear']);
-        $eventProvider->on(OnAfterRequest::class, [$this, 'clear']);
+        $this->eventProvider->on(OnWorkerExit::class, [$this, 'disconnect']);
-        $eventProvider->on(OnWorkerExit::class, [$this, 'disconnect']);
+        $this->eventProvider->on(OnWorkerStart::class, [$this, 'tick']);
-        $eventProvider->on(OnWorkerStart::class, [$this, 'tick']);
+        $this->eventProvider->on(OnTaskerStart::class, [$this, 'tick']);
-        $eventProvider->on(OnTaskerStart::class, [$this, 'tick']);
     }
 
 
@@ -105,20 +134,29 @@ class Connection extends Component
      */
     protected function checkClientHealth(Pool $pool): void
     {
-        $pool->flush($this->cds, $this->pool['min'] ?? 1);
+        $pool->flush($this->getName(), $this->pool['min'] ?? 1);
-        $length = $pool->size($this->cds);
+//        $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->cds, $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]);
-                }
+//                }
-            }
+//            }
+//        }
     }
+
+
+    /**
+     * @return string
+     */
+    public function getName(): string
+    {
+        return strtolower($this->driver) . '.' . $this->cds;
     }
 
 
@@ -130,7 +168,7 @@ class Connection extends Component
     protected function validator(Pool $pool): PDO|bool
     {
         /** @var $client PDO */
-        if (($client = $pool->get($this->cds)) === false) {
+        if (($client = $pool->get($this->getName())) === false) {
             return false;
         }
         if ($client->query('select 1') === false) {
@@ -160,7 +198,7 @@ class Connection extends Component
      */
     protected function getNormalClientHealth(): PDO
     {
-        $data = $this->pool()->get($this->cds, $this->waite_time);
+        $data = $this->pool()->get($this->getName(), $this->waite_time);
         if ($data === false) {
             throw new Exception('Client Waite timeout.');
         }
@@ -226,6 +264,7 @@ class Connection extends Component
                 $pdo->rollback();
             }
             $this->release($pdo);
+            Context::remove($this->cds);
         }
     }
 
@@ -245,6 +284,7 @@ class Connection extends Component
                 $pdo->commit();
             }
             $this->release($pdo);
+            Context::remove($this->cds);
         }
     }
 
@@ -264,6 +304,8 @@ class Connection extends Component
             $pdo->rollback();
         }
         $this->release($pdo);
+        Context::remove($this->cds);
+        $this->storey = 0;
     }
 
 
@@ -275,7 +317,7 @@ class Connection extends Component
      */
     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);
     }
 
 
@@ -286,7 +328,7 @@ class Connection extends Component
     public function release(PDO $pdo): void
     {
         if (!$this->inTransaction()) {
-            $this->pool()->push($this->cds, $pdo);
+            $this->pool()->push($this->getName(), $pdo);
         }
     }
 
@@ -298,7 +340,7 @@ class Connection extends Component
      */
     public function clear_connection(): void
     {
-        $this->pool()->flush($this->cds, 0);
+        $this->pool()->flush($this->getName(), 0);
     }
 
 
@@ -310,24 +352,31 @@ class Connection extends Component
         if ($this->timerId > -1) {
             Timer::clear($this->timerId);
         }
-        $this->pool()->close($this->cds);
+        $this->pool()->close($this->getName());
     }
 
 
     /**
      * @return PDO
      */
-    public function newConnect(): PDO
+    public function newConnect(): \PDO
     {
-        $pdo = new PDO('mysql:dbname=' . $this->database . ';host=' . $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) {
             $pdo->setAttribute($key, $attribute);
         }
@@ -340,8 +389,8 @@ class Connection extends Component
      */
     protected function pool(): Pool
     {
-        if (!$this->connections->hasChannel($this->cds)) {
+        if (!$this->connections->hasChannel($this->getName())) {
-            $this->connections->created($this->cds, $this->pool['max'] ?? 1, [$this, 'newConnect']);
+            $this->connections->created($this->getName(), $this->pool['max'] ?? 1, [$this, 'newConnect']);
         }
         return $this->connections;
     }

DatabasesProviders.php

@@ -35,7 +35,7 @@ class DatabasesProviders extends Providers
             return;
         }
         foreach ($databases as $key => $database) {
-            $this->set($key, $this->_settings($database));
+            $this->set($key, $this->_settings($key, $database));
         }
     }
 
@@ -64,22 +64,24 @@ class DatabasesProviders extends Providers
 
 
 	/**
+	 * @param string $key
 	 * @param array  $database
 	 * @return array
 	 */
-    private function _settings(array $database): array
+    private function _settings(string $key, array $database): array
     {
         $clientPool = $database['pool'] ?? ['min' => 1, 'max' => 5, 'tick' => 60];
         return [
-            'id'          => $database['id'],
+            'id'          => $key,
             'cds'         => $database['cds'],
             'class'       => Connection::class,
             'username'    => $database['username'],
             'password'    => $database['password'],
             'tablePrefix' => $database['tablePrefix'],
             'database'    => $database['database'],
+            'driver'      => $database['driver'] ?? 'mysql',
             'timeout'     => $database['timeout'] ?? 10,
-            'tick_time'   => $database['tick_time'] ?? 60,
+            'tick_time'   => $database['tick_time'] ?? 60000,
             'waite_time'  => $database['waite_time'] ?? 3,
             'pool'        => $clientPool,
             'attributes'  => $database['attributes'] ?? [],

Db.php

@@ -115,10 +115,11 @@ class Db extends QueryTrait implements ISqlBuilder
 
     /**
      * @return bool
+     * @throws Exception
      */
     public function exists(): bool
     {
-        return $this->connection->createCommand(SqlBuilder::builder($this)->one())->rowCount() > 0;
+        return $this->connection->createCommand(SqlBuilder::builder($this->limit(1))->exists())->exists();
     }
 
     /**
@@ -151,6 +152,55 @@ class Db extends QueryTrait implements ISqlBuilder
         return $this->connection->createCommand(SqlBuilder::builder($this)->delete())->delete();
     }
 
+
+    /**
+     * @return bool|array|null
+     */
+    public function first(): bool|array|null
+    {
+        return $this->connection->createCommand(SqlBuilder::builder($this)->one())->one();
+    }
+
+
+    /**
+     * @return bool|array
+     */
+    public function get(): bool|array
+    {
+        return $this->connection->createCommand(SqlBuilder::builder($this)->all())->all();
+    }
+
+
+    /**
+     * @param string $sql
+     * @return mixed
+     */
+    public function exec(string $sql): mixed
+    {
+        return $this->connection->createCommand($sql)->exec();
+    }
+
+
+    /**
+     * @param string $sql
+     * @return array|bool|null
+     */
+    public function query(string $sql): array|bool|null
+    {
+        return $this->connection->createCommand($sql)->one();
+    }
+
+
+    /**
+     * @param string $sql
+     * @return array|bool
+     */
+    public function queryAll(string $sql): array|bool
+    {
+        return $this->connection->createCommand($sql)->all();
+    }
+
+
     /**
      * @param string $table
      * @return array|bool|null

HasCount.php

@@ -4,8 +4,8 @@ declare(strict_types=1);
 namespace Database;
 
 use Database\Traits\HasBase;
-use Exception;
 use Kiri;
+use Kiri\Di\Context;
 
 /**
  * Class HasCount
@@ -20,8 +20,7 @@ class HasCount extends HasBase
      */
     public function get(): array|ModelInterface|null
     {
-        $relation = Kiri::getDi()->get(Relation::class);
+        return di(Relation::class)->get($this->name);
-        return $relation->get($this->name);
     }
 
 }

HasMany.php

@@ -12,6 +12,7 @@ namespace Database;
 use Database\Traits\HasBase;
 use Exception;
 use Kiri;
+use Kiri\Di\Context;
 
 /**
  * Class HasMany
@@ -28,7 +29,6 @@ class HasMany extends HasBase
      */
     public function get(): array|Collection|null
     {
-        $relation = Kiri::getDi()->get(Relation::class);
+        return di(Relation::class)->get($this->name);
-        return $relation->get($this->name);
     }
 }

HasOne.php

@@ -12,6 +12,7 @@ namespace Database;
 use Database\Traits\HasBase;
 use Exception;
 use Kiri;
+use Kiri\Di\Context;
 
 /**
  * Class HasOne
@@ -27,7 +28,6 @@ class HasOne extends HasBase
      */
     public function get(): array|ModelInterface|null
     {
-        $relation = Kiri::getDi()->get(Relation::class);
+        return di(Relation::class)->first($this->name);
-        return $relation->first($this->name);
     }
 }

Model.php

@@ -116,8 +116,9 @@ class Model extends Base\Model
             $connection->commit();
             return $select;
         } catch (\Throwable $throwable) {
+			$model->getLogger()->json_log($throwable);
 			$connection->rollback();
-            return \Kiri::getLogger()->failure($throwable);
+            return false;
         }
     }
 
@@ -145,8 +146,9 @@ class Model extends Base\Model
             $connection->commit();
             return $select;
         } catch (\Throwable $throwable) {
+			$model->getLogger()->json_log($throwable);
 			$connection->rollback();
-            return \Kiri::getLogger()->failure($throwable);
+			return false;
         }
     }
 
@@ -191,7 +193,7 @@ class Model extends Base\Model
      */
     public function update(array $params): static|bool
     {
-        if (!$this->validator($this->rules()) || !$this->beforeSave($this)) {
+        if (!$this->validator($this->rules(), $params) || !$this->beforeSave($this)) {
             return FALSE;
         }
         return $this->updateInternal(...$this->arrayIntersect($params));
@@ -206,10 +208,11 @@ class Model extends Base\Model
     public static function inserts(array $data): bool
     {
         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 bool
@@ -266,22 +269,23 @@ class Model extends Base\Model
 
 
     /**
-     * @param ModelInterface|string $modelName
+     * @param string $modelName
      * @param string $foreignKey
      * @param string $localKey
      * @return string
      * @throws Exception
      */
-    private function _hasBase(ModelInterface|string $modelName, string $foreignKey, string $localKey): string
+    private function _hasBase(string $modelName, string $foreignKey, string $localKey): string
     {
         if (($value = $this->{$localKey}) === null) {
             throw new Exception("Need join table primary key.");
         }
 
-        $relation = $this->getRelation();
+        $relation = di(Relation::class);
 
-        $primaryKey = $modelName . $foreignKey . $value;
+        $primaryKey = str_replace('\\', '_', $modelName) . '_' . $foreignKey . '_' . $value;
         if (!$relation->hasIdentification($primaryKey)) {
+	        /** @var $modelName ModelInterface */
             $relation->bindIdentification($primaryKey, $modelName::query()->where([$foreignKey => $value]));
         }
         return $primaryKey;
@@ -289,60 +293,61 @@ class Model extends Base\Model
 
 
     /**
-     * @param ModelInterface|string $modelName
+     * @param string $modelName
      * @param string $foreignKey
      * @param string $localKey
      * @return HasOne|ActiveQuery
      * @throws Exception
      */
-    public function hasOne(ModelInterface|string $modelName, string $foreignKey, string $localKey): HasOne|ActiveQuery
+    public function hasOne(string $modelName, string $foreignKey, string $localKey): HasOne|ActiveQuery
     {
         return new HasOne($this->_hasBase($modelName, $foreignKey, $localKey));
     }
 
 
     /**
-     * @param ModelInterface|string $modelName
+     * @param string $modelName
      * @param string $foreignKey
      * @param string $localKey
      * @return ActiveQuery|HasCount
      * @throws Exception
      */
-    public function hasCount(ModelInterface|string $modelName, string $foreignKey, string $localKey): ActiveQuery|HasCount
+    public function hasCount(string $modelName, string $foreignKey, string $localKey): ActiveQuery|HasCount
     {
         return new HasCount($this->_hasBase($modelName, $foreignKey, $localKey));
     }
 
 
     /**
-     * @param ModelInterface|string $modelName
+     * @param string $modelName
      * @param string $foreignKey
      * @param string $localKey
      * @return ActiveQuery|HasMany
      * @throws Exception
      */
-    public function hasMany(ModelInterface|string $modelName, string $foreignKey, string $localKey): ActiveQuery|HasMany
+    public function hasMany(string $modelName, string $foreignKey, string $localKey): ActiveQuery|HasMany
     {
         return new HasMany($this->_hasBase($modelName, $foreignKey, $localKey));
     }
 
     /**
-     * @param ModelInterface|string $modelName
+     * @param string $modelName
      * @param string $foreignKey
      * @param string $localKey
      * @return ActiveQuery|HasMany
      * @throws Exception
      */
-    public function hasIn(ModelInterface|string $modelName, string $foreignKey, string $localKey): ActiveQuery|HasMany
+    public function hasIn(string $modelName, string $foreignKey, string $localKey): ActiveQuery|HasMany
     {
         if (($value = $this->{$localKey}) === null) {
             throw new Exception("Need join table primary key.");
         }
 
-        $relation = $this->getRelation();
+        $relation = di(Relation::class);
 
-        $primaryKey = $modelName . $foreignKey . json_encode($value, JSON_UNESCAPED_UNICODE);
+        $primaryKey = str_replace('\\', '_', $modelName) . '_' . $foreignKey . '_' . implode('_', $value);
         if (!$relation->hasIdentification($primaryKey)) {
+			/** @var $modelName ModelInterface */
             $relation->bindIdentification($primaryKey, $modelName::query()->whereIn($foreignKey, $value));
         }
 

ModelInterface.php

@@ -18,10 +18,10 @@ interface ModelInterface
 {
 
     /**
-     * @param array|string|int $param
+     * @param array|string|int|null $param
      * @return ModelInterface|null
      */
-    public static function findOne(array|string|int $param): ?static;
+    public static function findOne(array|string|int|null $param): ?static;
 
 
     /**

Relation.php

@@ -4,8 +4,10 @@ declare(strict_types=1);
 namespace Database;
 
 
+use Database\Base\ActiveQueryInterface;
 use Kiri\Abstracts\Component;
 use Kiri\Di\Context;
+use Swoole\Coroutine;
 
 /**
  * Class Relation
@@ -34,7 +36,7 @@ class Relation extends Component
      */
     public function hasIdentification(string $identification): bool
     {
-        return isset($this->_query[$identification]) && $this->_query[$identification] instanceof ActiveQuery;
+        return isset($this->_query[$identification]);
     }
 
     /**
@@ -54,12 +56,10 @@ class Relation extends Component
      */
     public function first(string $_identification): mixed
     {
-        if (Context::exists($_identification)) {
+        if (!Context::exists($_identification)) {
-            return Context::get($_identification);
+            Context::set($_identification, $this->_query[$_identification]->first());
         }
-        $activeModel = $this->_query[$_identification]->first();
+        return Context::get($_identification);
-        unset($this->_query[$_identification]);
-        return Context::set($_identification, $activeModel);
     }
 
 
@@ -69,12 +69,10 @@ class Relation extends Component
      */
     public function count(string $_identification): mixed
     {
-        if (Context::exists($_identification)) {
+        if (!Context::exists($_identification)) {
-            return Context::get($_identification);
+            Context::set($_identification, $this->_query[$_identification]->count());
         }
-        $activeModel = $this->_query[$_identification]->count();
+        return Context::get($_identification);
-        unset($this->_query[$_identification]);
-        return Context::set($_identification, $activeModel);
     }
 
 
@@ -86,11 +84,9 @@ class Relation extends Component
     public function get(string $_identification): mixed
     {
         if (Context::exists($_identification)) {
-            return Context::get($_identification);
+            Context::set($_identification, $this->_query[$_identification]->get());
         }
-        $activeModel = $this->_query[$_identification]->get();
+        return Context::get($_identification);
-        unset($this->_query[$_identification]);
-        return Context::set($_identification, $activeModel);
     }
 
 }

SqlBuilder.php

@@ -1,4 +1,5 @@
-<?php /** @noinspection ALL */
+<?php
+/** @noinspection ALL */
 
 declare(strict_types=1);
 
@@ -8,6 +9,7 @@ namespace Database;
 use JetBrains\PhpStorm\Pure;
 use Kiri;
 use Kiri\Abstracts\Component;
+use Database\Traits\QueryTrait;
 
 
 /**
@@ -73,13 +75,13 @@ class SqlBuilder extends Component
 	 */
 	public function update(array $attributes): bool|string
 	{
-        $conditions          = $this->query->params;
+		$params              = $this->query->params;
 		$this->query->params = [];
-        $data                = $this->__updateBuilder($this->makeParams($attributes));
+		$array               = $this->makeParams($attributes);
-        foreach ($conditions as $condition) {
+		foreach ($params as $name => $value) {
-            $this->query->pushParam($condition);
+			$this->query->pushParam($value);
 		}
-        return $data;
+		return $this->__updateBuilder($array);
 	}
 
 
@@ -107,9 +109,10 @@ class SqlBuilder extends Component
 	private function __updateBuilder(array $string): string|bool
 	{
 		if (empty($string)) {
-            return Kiri::getLogger()->failure('None data update.');
+			return Kiri::getLogger()->logCategory('None data update.');
 		}
-        return 'UPDATE ' . $this->query->from . ' SET ' . implode(',', $string) . $this->make();
+
+		return 'UPDATE ' . $this->getFromAlias() . ' ' . 'SET' . ' ' . implode(', ', $string) . ' ' . $this->make();
 	}
 
 
@@ -121,7 +124,7 @@ class SqlBuilder extends Component
 	 */
 	public function insert(array $attributes, bool $isBatch = false): string
 	{
-        $update = 'INSERT INTO ' . $this->query->from;
+		$update = 'INSERT INTO ' . $this->getFromAlias(true);
 		if ($isBatch === false) {
 			$attributes = [$attributes];
 		}
@@ -143,7 +146,7 @@ class SqlBuilder extends Component
 	 */
 	public function delete(): string
 	{
-        return 'DELETE FROM ' . $this->query->from . $this->make();
+		return 'DELETE FROM ' . $this->getFromAlias() . ' ' . $this->make();
 	}
 
 
@@ -151,7 +154,8 @@ class SqlBuilder extends Component
 	 * @param $attributes
 	 * @return array
 	 */
-    #[Pure] private function getFields(array $attributes): array
+	#[Pure]
+	private function getFields(array $attributes): array
 	{
 		return array_keys(current($attributes));
 	}
@@ -189,7 +193,7 @@ class SqlBuilder extends Component
 		if (is_null($value)) {
 			return $keys;
 		}
-        if (is_string($value) && $this->isMath($value)) {
+		if (preg_match('/^[+|-]\s\d+$/', (string)$value)) {
 			$keys[] = $key . '=' . $key . ' ' . $value;
 		} else {
 			$this->query->pushParam($value);
@@ -199,23 +203,14 @@ class SqlBuilder extends Component
 	}
 
 
-    /**
-     * @param string $value
-     * @return bool
-     */
-    private function isMath(string $value): bool
-    {
-        return str_starts_with($value, '+ ') || str_starts_with($value, '- ');
-    }
-
-
 	/**
 	 * @return string
 	 * @throws
 	 */
 	public function one(): string
 	{
-        return $this->makeSelect($this->query->select) . $this->make() . $this->makeLimit($this->query->limit(1));
+		$this->query->offset(0)->limit(1);
+		return $this->all();
 	}
 
 
@@ -225,7 +220,7 @@ class SqlBuilder extends Component
 	 */
 	public function all(): string
 	{
-        return $this->makeSelect($this->query->select) . $this->make() . $this->makeLimit($this->query);
+		return $this->makeSelect($this->query->select) . ' ' . $this->make() . ' ' . $this->makeLimit();
 	}
 
 
@@ -235,16 +230,41 @@ class SqlBuilder extends Component
 	 */
 	public function count(): string
 	{
-        return $this->makeSelect() . $this->make();
+		return $this->makeSelect(['COUNT(*)']) . ' ' . $this->make();
+	}
+
+
+	/**
+	 * @return string
+	 * @throws
+	 */
+	public function exists(): string
+	{
+		return $this->makeSelect(['0']) . ' ' . $this->make();
 	}
 
 
 	/**
 	 * @param string $table
 	 * @return string
+	 * @throws
 	 */
 	public function columns(string $table): string
 	{
+		$driver = $this->getDriver();
+		if (in_array($driver, ['pgsql', 'postgresql'])) {
+			$tableName = trim($table, '"`');
+			return "SELECT 
+                column_name as Field,
+                data_type as Type,
+                is_nullable as Null,
+                column_default as Default,
+                '' as Extra,
+                '' as Key
+            FROM information_schema.columns 
+            WHERE table_name = '$tableName' 
+            ORDER BY ordinal_position";
+		}
 		return 'SHOW FULL FIELDS FROM ' . $table;
 	}
 
@@ -255,26 +275,23 @@ class SqlBuilder extends Component
 	 */
 	private function make(): string
 	{
-        $select = $this->makeCondition();
+		return $this->makeCondition() . ' ' . $this->makeGroup() . ' ' . $this->makeOrder();
-        $select .= $this->makeGroup();
-        $select .= $this->makeOrder();
-        return $select;
 	}
 
 	/**
-     * @param array $select
+	 * @param mixed $select 列名数组或 QueryTrait 对象
 	 * @return string
 	 */
-    private function makeSelect(array $select = ['*']): string
+	private function makeSelect(mixed $select = ['*']): string
 	{
-        $select = "SELECT " . implode(',', $select) . " FROM " . $this->query->from;
+		if (!is_array($select)) {
-        if ($this->query->alias != "") {
+			$select = ['*'];
-            $select .= " AS " . $this->query->alias;
 		}
-        if (count($this->query->join) > 0) {
+		$sql = 'SELECT ' . implode(',', $select) . ' FROM ' . $this->getFromAlias();
-            $select .= ' ' . implode(' ', $this->query->join);
+		if ($this->query->join !== []) {
+			$sql .= ' ' . implode(' ', $this->query->join);
 		}
-        return $select;
+		return $sql;
 	}
 
 
@@ -283,7 +300,7 @@ class SqlBuilder extends Component
 	 */
 	private function makeGroup(): string
 	{
-        if ($this->query->group != "") {
+		if ($this->query->group !== '' && $this->query->group !== '0') {
 			return 'GROUP BY ' . $this->query->group;
 		}
 		return '';
@@ -315,9 +332,17 @@ class SqlBuilder extends Component
 	}
 
 
+	/**
+	 * @return string
+	 * @throws
+	 */
 	private function makeLimit(): string
 	{
 		if ($this->query->offset >= 0 && $this->query->limit >= 1) {
+			$driver = $this->getDriver();
+			if (in_array($driver, ['pgsql', 'postgresql'])) {
+				return 'LIMIT ' . $this->query->limit . ' OFFSET ' . $this->query->offset;
+			}
 			return 'LIMIT ' . $this->query->offset . ',' . $this->query->limit;
 		}
 		return '';
@@ -344,7 +369,7 @@ class SqlBuilder extends Component
 	 */
 	public function truncate(): string
 	{
-        return sprintf('TRUNCATE %s', $this->query->from);
+		return sprintf('TRUNCATE %s', $this->getFromAlias());
 	}
 
 
@@ -397,5 +422,52 @@ class SqlBuilder extends Component
 		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(bool $insert = false): string
+	{
+		$from = $this->query->from;
+		if ($insert) {
+			return $from;
+		}
+
+		if ($this->query->alias !== '' && $this->query->alias !== '0') {
+			$from .= ' AS ' . $this->query->alias;
+		}
+		return $from;
+	}
+
 
 }

Traits/HasBase.php

@@ -12,7 +12,6 @@ namespace Database\Traits;
 use Database\ModelInterface;
 use Database\Collection;
 use Database\Relation;
-use Kiri;
 
 /**
  * Class HasBase
@@ -52,12 +51,16 @@ abstract class HasBase implements \Database\Traits\Relation
      * @param string $name
      * @param array $arguments
      * @return $this|mixed
+     * @throws \Exception
      */
     public function __call(string $name, array $arguments)
     {
         if ($name !== 'get') {
-            $relation = Kiri::getDi()->get(Relation::class);
+            $query    = di(Relation::class)->getQuery($this->name);
-            $relation->getQuery($this->name)->$name(...$arguments);
+            if (is_null($query)) {
+                throw new \Exception('Unknown relation key: ' . $this->name);
+            }
+            $query->$name(...$arguments);
             return $this;
         } else {
             return $this->get();

Traits/QueryTrait.php

@@ -27,33 +27,112 @@ use Kiri\Abstracts\Component;
  */
 abstract class QueryTrait extends Component implements ActiveQueryInterface, ISqlBuilder
 {
-    public array         $where  = [];
+	public array         $where  = [] {
-    public array         $select = ['*'];
+		&get {
-    public array         $join   = [];
+			return $this->where;
-    public array         $order  = [];
+		}
-    public int           $offset = -1;
+	}
-    public int           $limit  = -1;
+	public array         $select = ['t1.*'] {
-    public string        $group  = '';
+		&get {
-    public string        $from   = '';
+			return $this->select;
-    public string        $alias  = 't1';
+		}
-    protected array      $filter = [];
+	}
-    protected bool       $lock   = false;
+	public array         $join   = [] {
+		&get {
+			return $this->join;
+		}
+	}
+	public array         $order  = [] {
+		&get {
+			return $this->order;
+		}
+	}
+	public int           $offset = -1 {
+		get {
+			return $this->offset;
+		}
+		set {
+			$this->offset = $value;
+		}
+	}
+	public int           $limit  = -1 {
+		get {
+			return $this->limit;
+		}
+		set {
+			$this->limit = $value;
+		}
+	}
+	public string        $group  = '' {
+		get {
+			return $this->group;
+		}
+		set {
+			$this->group = $value;
+		}
+	}
+	public string        $from   = '' {
+		get {
+			return $this->from;
+		}
+		set {
+			$this->from = $value;
+		}
+	}
+	public string        $alias  = '' {
+		get {
+			return $this->alias;
+		}
+		set {
+			$this->alias = $value;
+		}
+	}
+	protected array      $filter = [] {
+		&get {
+			return $this->filter;
+		}
+	}
+	protected bool       $lock   = FALSE;
 	protected SqlBuilder $builder;
-    public array         $params = [];
+	public array         $params = [] {
-    private array        $_alias = ['t1'];
+		&get {
+			return $this->params;
+		}
+	}
+	protected array      $_alias = [] {
+		&get {
+			return $this->_alias;
+		}
+	}
 
 
 	/**
 	 * @var ModelInterface|string|null
 	 */
-    protected ModelInterface|string|null $modelClass;
+	protected ModelInterface|string|null $modelClass {
+		get {
+			return $this->modelClass;
+		}
+	}
+
+
+	public function __get(string $name)
+	{
+		if (property_exists($this, $name)) {
+			return $this->$name;
+		}
+		if (method_exists($this, $name)) {
+			return $this->$name();
+		}
+		return parent::__get($name); // TODO: Change the autogenerated stub
+	}
 
 
 	/**
 	 * Comply constructor.
 	 * @throws
 	 */
-    public function __construct($model = null)
+	public function __construct($model = NULL)
 	{
 		if (!is_null($model)) {
 			$this->modelClass = $model;
@@ -63,9 +142,64 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	}
 
 
+	/**
+	 * @param Closure|Query $callback
+	 * @param array         $attributes
+	 *
+	 * @return $this
+	 */
+	public function whereNotExists(Closure|Query $callback, array $attributes = []): static
+	{
+		if ($callback instanceof Query) {
+			$this->where[] = 'NOT EXISTS(' . $callback->build() . ')';
+			$this->mergeParams($callback->params);
+		} else {
+			$this->where[] = 'NOT EXISTS(' . $this->makeClosureFunction($callback) . ')';
+		}
+		if (count($attributes) > 0) {
+			$this->bindParams($attributes);
+		}
+		return $this;
+	}
+
+
+	/**
+	 * @param Closure|Query $callback
+	 * @param array         $attributes
+	 *
+	 * @return $this
+	 */
+	public function whereExists(Closure|Query $callback, array $attributes = []): static
+	{
+		if ($callback instanceof Query) {
+			$this->where[] = 'EXISTS(' . $callback->build() . ')';
+			$this->mergeParams($callback->params);
+		} else {
+			$this->where[] = 'EXISTS(' . $this->makeClosureFunction($callback) . ')';
+		}
+		if (count($attributes) > 0) {
+			$this->bindParams($attributes);
+		}
+		return $this;
+	}
+
+
+	/**
+	 * @param array $params
+	 * @return void
+	 */
+	public function mergeParams(array $params): void
+	{
+		foreach ($params as $key => $value) {
+			$this->pushParam($value);
+		}
+	}
+
+
 	/**
 	 * @param string   $column
 	 * @param callable $callable
+	 *
 	 * @return $this
 	 */
 	public function when(string $column, callable $callable): static
@@ -82,6 +216,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param bool $lock
+	 *
 	 * @return $this
 	 */
 	public function lock(bool $lock): static
@@ -93,6 +228,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param string $whereRaw
+	 *
 	 * @return QueryTrait
 	 */
 	public function whereRaw(string $whereRaw): static
@@ -118,6 +254,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	/**
 	 * @param string $column
 	 * @param string $value
+	 *
 	 * @return $this
 	 */
 	public function whereLocate(string $column, string $value): static
@@ -129,6 +266,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param string $column
+	 *
 	 * @return $this
 	 */
 	public function whereNull(string $column): static
@@ -140,6 +278,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param string $column
+	 *
 	 * @return $this
 	 */
 	public function whereEmpty(string $column): static
@@ -151,6 +290,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param string $column
+	 *
 	 * @return $this
 	 */
 	public function whereNotEmpty(string $column): static
@@ -162,6 +302,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param string $column
+	 *
 	 * @return $this
 	 */
 	public function whereNotNull(string $column): static
@@ -187,16 +328,22 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 
 	/**
-     * @param string|Closure $tableName
+	 * @param string|Closure|Query $tableName
 	 *
 	 * @return $this
 	 */
-    public function from(string|Closure $tableName): static
+	public function from(string|Closure|Query $tableName): static
 	{
-        if ($tableName instanceof Closure) {
+		if ($tableName instanceof Query) {
-            $tableName = call_user_func($tableName, $this->queryInstance());
+			$this->from = '(' . $tableName->build() . ')';
-        }
+			$this->mergeParams($tableName->params);
+		} else if ($tableName instanceof Closure) {
+			$this->from = '(' . $this->makeClosureFunction($tableName) . ')';
+		} else if (class_exists($tableName)) {
+			$this->from = (new $tableName)->getTable();
+		} else {
 			$this->from = $tableName;
+		}
 		return $this;
 	}
 
@@ -206,6 +353,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	 * @param string $alias
 	 * @param array  $on
 	 * @param array  $param
+	 *
 	 * @return $this
 	 * $query->join([$tableName, ['userId'=>'uuvOd']], $param)
 	 * $query->join([$tableName, ['userId'=>'uuvOd'], $param])
@@ -236,6 +384,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param array $params
+	 *
 	 * @return void
 	 */
 	public function bindParams(array $params): void
@@ -248,6 +397,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param array $condition
+	 *
 	 * @return string
 	 */
 	private function onCondition(array $condition): string
@@ -267,16 +417,17 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param string $value
+	 *
 	 * @return bool
 	 */
 	private function isAliasField(string $value): bool
 	{
 		foreach ($this->_alias as $alias) {
 			if (str_starts_with($value, $alias . '.')) {
-                return true;
+				return TRUE;
 			}
 		}
-        return false;
+		return FALSE;
 	}
 
 
@@ -285,6 +436,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	 * @param string $alias
 	 * @param array  $onCondition
 	 * @param array  $param
+	 *
 	 * @return $this
 	 * @throws Exception
 	 */
@@ -306,6 +458,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	 * @param string $alias
 	 * @param array  $onCondition
 	 * @param array  $param
+	 *
 	 * @return $this
 	 * @throws Exception
 	 */
@@ -327,6 +480,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	 * @param string $alias
 	 * @param array  $onCondition
 	 * @param array  $param
+	 *
 	 * @return $this
 	 * @throws Exception
 	 */
@@ -357,6 +511,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param string $field
+	 *
 	 * @return $this
 	 */
 	public function max(string $field): static
@@ -454,10 +609,11 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	 * @param array|Closure|string $conditionArray
 	 * @param string               $opera
 	 * @param null                 $value
+	 *
 	 * @return QueryTrait
 	 * @throws
 	 */
-    public function whereOr(array|Closure|string $conditionArray = [], string $opera = '=', $value = null): static
+	public function whereOr(array|Closure|string $conditionArray = [], string $opera = '=', $value = NULL): static
 	{
 		if ($conditionArray instanceof Closure) {
 			$conditionArray = $this->makeClosureFunction($conditionArray);
@@ -477,6 +633,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	/**
 	 * @param string $column
 	 * @param string $value
+	 *
 	 * @return $this
 	 */
 	public function whereLike(string $column, string $value): static
@@ -490,6 +647,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	/**
 	 * @param string $column
 	 * @param string $value
+	 *
 	 * @return $this
 	 */
 	public function whereLeftLike(string $column, string $value): static
@@ -503,6 +661,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	/**
 	 * @param string $column
 	 * @param string $value
+	 *
 	 * @return $this
 	 */
 	public function whereRightLike(string $column, string $value): static
@@ -516,6 +675,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	/**
 	 * @param string $column
 	 * @param string $value
+	 *
 	 * @return $this
 	 */
 	public function whereNotLike(string $column, string $value): static
@@ -528,19 +688,24 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param string              $columns
-     * @param array|Closure $value
+	 * @param array|Closure|Query $value
+	 *
 	 * @return $this
-     * @throws
+	 * @throws Exception
 	 */
-    public function whereIn(string $columns, array|Closure $value): static
+	public function whereIn(string $columns, array|Closure|Query $value): static
 	{
-        if ($value instanceof Closure) {
+		if (is_array($value)) {
-            $value = $this->makeClosureFunction($value);
+			if (count($value) < 1)
-        }
+				throw new Exception('Value must be an not empty array');
-        if (count($value) < 1) {
+
-            $value = [-1];
-        }
 			$this->where[] = $columns . ' IN (' . implode(',', $value) . ')';
+		} else if ($value instanceof Query) {
+			$this->where[] = $columns . ' IN (' . $value->build() . ')';
+			$this->mergeParams($value->params);
+		} else {
+			$this->where[] = $columns . ' IN (' . $this->makeClosureFunction($value) . ')';
+		}
 		return $this;
 	}
 
@@ -551,13 +716,14 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	 */
 	public function queryInstance(): Query
 	{
-        return new Query();
+		return new Query;
 	}
 
 
 	/**
 	 * @param string $columns
 	 * @param array  $value
+	 *
 	 * @return $this
 	 */
 	public function whereNotIn(string $columns, array $value): static
@@ -574,6 +740,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	 * @param string    $column
 	 * @param int|float $start
 	 * @param int|float $end
+	 *
 	 * @return $this
 	 */
 	public function whereBetween(string $column, int|float $start, int|float $end): static
@@ -594,6 +761,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	 * @param string    $column
 	 * @param int|float $start
 	 * @param int|float $end
+	 *
 	 * @return $this
 	 */
 	public function whereNotBetween(string $column, int|float $start, int|float $end): static
@@ -612,6 +780,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param mixed $value
+	 *
 	 * @return $this
 	 */
 	public function pushParam(mixed $value): static
@@ -623,10 +792,15 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param array|string $column
+	 * @param mixed        $value
+	 *
 	 * @return $this
 	 */
-    public function where(array|string $column): static
+	public function where(array|string $column, mixed $value = NULL): static
 	{
+		if (func_num_args() === 2) {
+			return $this->addArray([$column => $value]);
+		}
 		if (is_string($column)) {
 			return $this->whereRaw($column);
 		} else {
@@ -639,6 +813,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	 * @param string $column
 	 * @param string $opera
 	 * @param mixed  $value
+	 *
 	 * @return $this
 	 */
 	public function whereMath(string $column, string $opera, mixed $value): static
@@ -651,6 +826,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param Closure $closure
+	 *
 	 * @return $this
 	 */
 	public function whereClosure(Closure $closure): static
@@ -662,6 +838,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param Closure|array $closure
+	 *
 	 * @return string
 	 * @throws
 	 */
@@ -673,6 +850,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 		} else {
 			$generate->addArray($closure);
 		}
+		$this->mergeParams($generate->params);
 		return $generate->build();
 	}
 
@@ -683,7 +861,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	 *
 	 * @return $this
 	 */
-    public function groupBy(string $name, string $having = NULL): static
+	public function groupBy(string $name, ?string $having = NULL): static
 	{
 		$this->group = $name;
 		if (empty($having)) {
@@ -708,6 +886,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param int $offset
+	 *
 	 * @return $this
 	 */
 	public function offset(int $offset): static
@@ -736,12 +915,13 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 
 	/**
 	 * @param array $array
+	 *
 	 * @return $this
 	 */
 	private function addArray(array $array): static
 	{
 		foreach ($array as $key => $value) {
-            if ($value === null) {
+			if ($value === NULL) {
 				continue;
 			}
 			$this->where[] = is_numeric($key) ? $value : $this->sprintf($key, $value);
@@ -754,10 +934,21 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	 * @param string $column
 	 * @param mixed  $value
 	 * @param string $opera
+	 *
 	 * @return string
 	 */
 	private function sprintf(string $column, mixed $value, string $opera = '='): string
 	{
+		if (!is_numeric($value)) {
+			if (str_contains($column, '.')) {
+				[$alias, $field] = explode('.', $value);
+			} else {
+				$alias = '';
+			}
+			if (in_array($alias, $this->_alias)) {
+				return $column . ' ' . $opera . ' ' . $value;
+			}
+		}
 		$this->pushParam($value);
 		return $column . ' ' . $opera . ' ?';
 	}
@@ -766,6 +957,7 @@ abstract class QueryTrait extends Component implements ActiveQueryInterface, ISq
 	/**
 	 * @param string $querySql
 	 * @param array  $params
+	 *
 	 * @return Command
 	 */
 	public function buildCommand(string $querySql, array $params = []): Command

Traits/When.php

@@ -21,9 +21,27 @@ class When
 	public ActiveQuery|ISqlBuilder $query;
 
 
-    private array $_condition = [];
+	/**
+	 * @var array
+	 */
+	private array $_condition = [] {
+		&get {
+			return $this->_condition;
+		}
+	}
 
-    private string $else = '';
+
+	/**
+	 * @var string
+	 */
+	private string $else = '' {
+		get {
+			return $this->else;
+		}
+		set(string $value) {
+			$this->else = $value;
+		}
+	}
 
 
 	/**
@@ -63,7 +81,8 @@ class When
 	/**
 	 * @return string
 	 */
-    #[Pure] public function end(): string
+	#[Pure]
+	public function end(): string
 	{
 		if (empty($this->_condition)) {
 			return '';

composer.json

@@ -9,10 +9,10 @@
   ],
   "license": "MIT",
   "require": {
-    "php": ">=8.3",
+    "php": ">=8.5",
     "ext-json": "*",
     "ext-pdo": "*",
-    "game-worker/kiri-pool": "~v1.0"
+    "game-worker/kiri-pool": "^v1.0"
   },
   "autoload": {
     "psr-4": {

test.php

@@ -0,0 +1,23 @@
+<?php
+
+
+use Database\Query;
+
+class Users extends \Database\Model
+{
+
+
+	public function hasD()
+	{
+		return $this->hasOne(static::class, 'id', 'id')->with([]);
+	}
+}
+
+Users::query()
+	->select(['*', (new Query(Users::class))
+		->where(['id' => 2])])
+	->from(function (Query $query) {
+		$query->from(Users::class)
+			->where(['id' => 1])
+			->groupBy('name DESC');
+	})->toSql();