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

@@ -22,250 +22,272 @@ class ActiveQuery extends QueryTrait implements ISqlBuilder
 {
 
 
-    public bool     $asArray = FALSE;
+	public bool     $asArray = FALSE;
-    protected mixed $_mock   = null;
+	protected mixed $_mock   = NULL;
 
 
-    /**
+	/**
-     * @param bool $asArray
+	 * @param bool $asArray
-     * @return static
+	 *
-     */
+	 * @return static
-    public function asArray(bool $asArray = true): static
+	 */
-    {
+	public function asArray(bool $asArray = TRUE): static
-        $this->asArray = $asArray;
+	{
-        return $this;
+		$this->asArray = $asArray;
-    }
+		return $this;
+	}
 
-    /**
+	/**
-     * @param array $methods
+	 * @param array $methods
-     * @return $this
+	 *
-     */
+	 * @return $this
-    public function with(array $methods): static
+	 */
-    {
+	public function with(array $methods): static
-        $this->modelClass->setWith($methods);
+	{
-        return $this;
+		$this->modelClass->setWith($methods);
-    }
+		return $this;
+	}
 
 
-    /**
+	/**
-     * @return ModelInterface|array|null|bool
+	 * @return ModelInterface|array|null|bool
-     * @throws
+	 * @throws
-     */
+	 */
-    public function first(): ModelInterface|null|array|bool
+	public function first(): ModelInterface|null|array|bool
-    {
+	{
-        $data = $this->buildCommand($this->builder->one())->one();
+		$data = $this->buildCommand($this->builder->one())->one();
-        if (is_array($data)) {
+		if (is_array($data)) {
-            return $this->populate($data);
+			return $this->populate($data);
-        }
+		}
-        return null;
+		return NULL;
-    }
+	}
 
-    /**
+	/**
-     * @return bool|Collection
+	 * @return bool|Collection
-     */
+	 */
-    public function get(): bool|Collection
+	public function get(): bool|Collection
-    {
+	{
-        $data = $this->buildCommand($this->builder->all())->all();
+		$data = $this->buildCommand($this->builder->all())->all();
-        if (is_array($data)) {
+		if (is_array($data)) {
-            return new Collection($this, $this->modelClass, $data);
+			return new Collection($this, $this->modelClass, $data);
-        }
+		}
-        return false;
+		return FALSE;
-    }
+	}
 
 
-    /**
+	/**
-     * @param string $column
+	 * @param string    $column
-     * @param int|float $amount
+	 * @param int|float $amount
-     * @return bool
+	 *
-     */
+	 * @return bool
-    public function increment(string $column, int|float $amount = 1): bool
+	 */
-    {
+	public function increment(string $column, int|float $amount = 1): bool
-        return (bool)$this->buildCommand($this->builder->mathematics([$column => $amount]))->exec();
+	{
-    }
+		return (bool)$this->buildCommand($this->builder->mathematics([$column => $amount]))->exec();
+	}
 
 
-    /**
+	/**
-     * @param array $attributes
+	 * @param array $attributes
-     * @return bool
+	 *
-     */
+	 * @return bool
-    public function increments(array $attributes): bool
+	 */
-    {
+	public function increments(array $attributes): bool
-        return (bool)$this->buildCommand($this->builder->mathematics($attributes))->exec();
+	{
-    }
+		return (bool)$this->buildCommand($this->builder->mathematics($attributes))->exec();
+	}
 
 
-    /**
+	/**
-     * @param string $column
+	 * @param string    $column
-     * @param int|float $amount
+	 * @param int|float $amount
-     * @return bool
+	 *
-     */
+	 * @return bool
-    public function decrement(string $column, int|float $amount = 1): bool
+	 */
-    {
+	public function decrement(string $column, int|float $amount = 1): bool
-        return (bool)$this->buildCommand($this->builder->mathematics([$column => $amount], '-'))->exec();
+	{
-    }
+		return (bool)$this->buildCommand($this->builder->mathematics([$column => $amount], '-'))->exec();
+	}
 
 
-    /**
+	/**
-     * @param array $attributes
+	 * @param array $attributes
-     * @return bool
+	 *
-     */
+	 * @return bool
-    public function decrements(array $attributes): bool
+	 */
-    {
+	public function decrements(array $attributes): bool
-        return (bool)$this->buildCommand($this->builder->mathematics($attributes, '-'))->exec();
+	{
-    }
+		return (bool)$this->buildCommand($this->builder->mathematics($attributes, '-'))->exec();
+	}
 
 
-    /**
+	/**
-     * @throws
+	 * @throws
-     */
+	 */
-    public function flush(): bool
+	public function flush(): bool
-    {
+	{
-        return (bool)$this->buildCommand($this->builder->truncate())->exec();
+		return (bool)$this->buildCommand($this->builder->truncate())->exec();
-    }
+	}
 
 
-    /**
+	/**
-     * @param int $size
+	 * @param int     $size
-     * @param Closure $closure
+	 * @param Closure $closure
-     * @return void
+	 *
-     */
+	 * @return void
-    public function chunk(int $size, Closure $closure): 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 ($this->offset === -1) $this->offset = 0;
-        if (!$data || $data->isEmpty()) {
+		$data = $this->offset($this->offset)->limit($size)->get();
-            return;
+		if (!$data || $data->isEmpty()) {
-        }
+			return;
-        if (Context::inCoroutine()) {
+		}
-            Coroutine::create(fn () => $closure($data));
+		if (Context::inCoroutine()) {
-        } else {
+			Coroutine::create(fn() => $closure($data));
-            call_user_func($closure, $data);
+		} else {
-        }
+			call_user_func($closure, $data);
-        $this->offset += $size;
+		}
-        $this->chunk($size, $closure);
+		$this->offset += $size;
-    }
+		$this->chunk($size, $closure);
+	}
 
-    /**
+	/**
-     * @param string $field
+	 * @param string      $field
-     * @param string|null $setKey
+	 * @param string|null $setKey
-     *
+	 *
-     * @return array|null
+	 * @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);
+		return $this->get()->column($field, $setKey);
-    }
+	}
 
 
-    /**
+	/**
-     * @param mixed $value
+	 * @param mixed $value
-     * @return $this
+	 *
-     */
+	 * @return $this
-    public function withMock(mixed $value): static
+	 */
-    {
+	public function withMock(mixed $value): static
-        $this->_mock = $value;
+	{
-        return $this;
+		$this->_mock = $value;
-    }
+		return $this;
+	}
 
 
-    /**
+	/**
-     * @return mixed
+	 * @return mixed
-     */
+	 */
-    public function mock(): mixed
+	public function mock(): mixed
-    {
+	{
-        return $this->_mock;
+		return $this->_mock;
-    }
+	}
 
 
-    /**
+	/**
-     * @param array $data
+	 * @param array $data
-     * @return ModelInterface|array
+	 *
-     * @throws
+	 * @return ModelInterface|array
-     */
+	 * @throws
-    public function populate(array $data): ModelInterface|array
+	 */
-    {
+	public function populate(array $data): ModelInterface|array
-        $model = $this->modelClass->populates($data);
+	{
+		$model = $this->modelClass->populates($data);
 
-        return $this->asArray ? $model->toArray() : $model;
+		return $this->asArray ? $model->toArray() : $model;
-    }
+	}
 
 
-    /**
+	/**
-     * @return int
+	 * @return string
-     * @throws
+	 */
-     */
+	public function toSql(): string
-    public function count(): int
+	{
-    {
+		return $this->builder->get();
-        return $this->buildCommand($this->builder->count())->rowCount();
+	}
-    }
 
 
-    /**
+	/**
-     * @param array $data
+	 * @return int
-     * @return bool
+	 * @throws
-     * @throws
+	 */
-     */
+	public function count(): int
-    public function update(array $data): bool
+	{
-    {
+		return $this->buildCommand($this->builder->count())->rowCount();
-        if (count($data) < 1) {
+	}
-            return true;
-        }
-        $generate = $this->builder->update($data);
-        if (!is_bool($generate)) {
-            return (bool)$this->buildCommand($generate)->exec();
-        } else {
-            return $generate;
-        }
-    }
-
-    /**
-     * @param array $data
-     * @return bool
-     */
-    public function insert(array $data): bool
-    {
-        $sql = $this->builder->insert($data, isset($data[0]));
-
-        return (bool)$this->buildCommand($sql)->exec();
-    }
-
-    /**
-     * @param string $filed
-     *
-     * @return mixed
-     * @throws
-     */
-    public function value(string $filed): mixed
-    {
-        return $this->first()[$filed] ?? NULL;
-    }
-
-    /**
-     * @return bool
-     * @throws
-     */
-    public function exists(): bool
-    {
-        return $this->buildCommand($this->limit(1)->builder->exists())->exists();
-    }
 
 
-    /**
+	/**
-     * @param string $sql
+	 * @param array $data
-     * @param array $params
+	 *
-     * @return int|bool
+	 * @return bool
-     */
+	 * @throws
-    public function execute(string $sql, array $params = []): int|bool
+	 */
-    {
+	public function update(array $data): bool
-        return $this->buildCommand($sql, $params)->exec();
+	{
-    }
+		if (count($data) < 1) {
+			return TRUE;
+		}
+		$generate = $this->builder->update($data);
+		if (!is_bool($generate)) {
+			return (bool)$this->buildCommand($generate)->exec();
+		} else {
+			return $generate;
+		}
+	}
+
+	/**
+	 * @param array $data
+	 *
+	 * @return bool
+	 */
+	public function insert(array $data): bool
+	{
+		$sql = $this->builder->insert($data, isset($data[0]));
+
+		return (bool)$this->buildCommand($sql)->exec();
+	}
 
 
-    /**
+	/**
-     * @return bool
+	 * @param string $filed
-     */
+	 *
-    public function delete(): bool
+	 * @return mixed
-    {
+	 * @throws
-        return $this->buildCommand($this->builder->delete())->delete();
+	 */
-    }
+	public function value(string $filed): mixed
+	{
+		return $this->first()[$filed] ?? NULL;
+	}
+
+	/**
+	 * @return bool
+	 * @throws
+	 */
+	public function exists(): bool
+	{
+		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
+	{
+		return $this->buildCommand($sql, $params)->exec();
+	}
+
+
+	/**
+	 * @return bool
+	 */
+	public function delete(): bool
+	{
+		return $this->buildCommand($this->builder->delete())->delete();
+	}
 }

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

@@ -250,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
@@ -267,4 +267,4 @@ interface ActiveQueryInterface
     public function offset(int $offset): QueryTrait;
 
 
-}
+}

Base/Model.php

@@ -30,6 +30,14 @@ use ReturnTypeWillChange;
 use ReflectionException;
 use validator\Validator;
 
+
+enum Driver
+{
+    case Mysql;
+    case Pgsql;
+}
+
+
 /**
  * Class BOrm
  *
@@ -63,7 +71,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
     /**
      * @var bool
      */
-    protected bool $skipValidate = false;
+    protected bool $skipValidate = FALSE;
 
 
     /**
@@ -106,6 +114,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param array $data
+     *
      * @return Model
      */
     public function setWith(array $data): static
@@ -138,7 +147,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
      */
     public function clean(): void
     {
-        $this->_attributes    = [];
+        $this->_attributes = [];
         $this->_oldAttributes = [];
     }
 
@@ -164,6 +173,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param bool $bool
+     *
      * @return $this
      */
     public function setIsNowExample(bool $bool = FALSE): static
@@ -212,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;
     }
 
 
@@ -227,19 +237,20 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
         if ($this->hasPrimary() && isset($this->_oldAttributes[$this->getPrimary()])) {
             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|null $param): ?static
     {
         if (empty($param)) {
-            return null;
+            return NULL;
         }
         $query = new ActiveQuery($model = static::instance());
         $query->from($model->getTable())->alias('t1');
@@ -250,7 +261,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
         } else {
             $query->whereRaw($param);
         }
-        if (($data = $query->first()) === false) {
+        if (($data = $query->first()) === FALSE) {
             throw new Exception($model->getLastError());
         } else {
             return $data;
@@ -260,6 +271,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param int $param
+     *
      * @return Model|null
      * @throws
      */
@@ -293,6 +305,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param int|string|array $condition
+     *
      * @return static|null
      * @throws
      */
@@ -304,6 +317,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param string|array $condition
+     *
      * @return Collection
      * @throws
      */
@@ -327,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;
     }
 
@@ -381,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
@@ -395,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
@@ -408,6 +424,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param array $param
+     *
      * @return $this
      * @throws
      */
@@ -422,6 +439,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param array $param
+     *
      * @return $this
      */
     public function setOldAttributes(array $param): static
@@ -439,10 +457,10 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
      */
     private function insert(): bool|static
     {
-        $sql    = SqlBuilder::builder($query = static::query())->insert($this->_attributes);
+        $sql = SqlBuilder::builder($query = static::query())->insert($this->_attributes);
         $lastId = $this->getConnection()->createCommand($sql, $query->params)->exec();
-        if ($lastId === false) {
+        if ($lastId === FALSE) {
-            return false;
+            return FALSE;
         }
         if (!$this->hasPrimary()) {
             return $this->refresh()->afterSave($this->_attributes, []);
@@ -458,6 +476,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
      * @param array $old
      * @param array $condition
      * @param array $change
+     *
      * @return $this|bool
      * @throws
      */
@@ -465,11 +484,11 @@ 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) {
+        if ($generate === FALSE) {
-            return false;
+            return FALSE;
         }
         if (!$this->getConnection()->createCommand($generate, $query->params)->exec()) {
             return FALSE;
@@ -501,7 +520,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
     protected function arrayIntersect(array $params): array
     {
         $condition = [];
-        $oldPrams  = [];
+        $oldPrams = [];
         foreach ($this->_oldAttributes as $key => $attribute) {
             if (!array_key_exists($key, $params) || $params[$key] == $attribute) {
                 $condition[$key] = $attribute;
@@ -531,11 +550,12 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param array $value
+     *
      * @return $this
      */
     public function populates(array $value): static
     {
-        $this->_attributes    = $value;
+        $this->_attributes = $value;
         $this->_oldAttributes = $value;
         $this->setIsNowExample();
         return $this;
@@ -544,6 +564,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param array $rule
+     *
      * @return bool
      * @throws
      */
@@ -554,7 +575,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
         }
         $validate = $this->resolve($rule);
         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;
         }
@@ -563,6 +584,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param array $rule
+     *
      * @return Validator
      * @throws
      */
@@ -583,6 +605,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param string $name
+     *
      * @return null
      * @throws
      */
@@ -604,12 +627,13 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param string $attribute
+     *
      * @return bool
      * @throws
      */
     public function has(string $attribute): bool
     {
-        return true;
+        return TRUE;
     }
 
 
@@ -619,7 +643,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
      */
     public function getTable(): string
     {
-        $connection  = $this->getConnection();
+        $connection = $this->getConnection();
         $tablePrefix = $connection->tablePrefix;
         if (empty($this->table)) {
             throw new Exception('You need add static method `tableName` and return table name.');
@@ -628,6 +652,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;
     }
 
@@ -635,6 +666,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
@@ -645,6 +677,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param self $model
+     *
      * @return bool
      * @throws
      */
@@ -660,7 +693,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
     public function refresh(): static
     {
         $this->_oldAttributes = $this->_attributes;
-        $this->isNewExample   = false;
+        $this->isNewExample = FALSE;
         return $this;
     }
 
@@ -668,17 +701,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)) {
+            $this->{$prefix}($value);
+            return;
+        }
+
+        $method = $prefix . 'Attribute';
+        if (method_exists($this, $method)) {
+            $this->_attributes[$name] = $this->{$method}($value);
         } else {
-            $method = 'set' . ucfirst($name) . 'Attribute';
-            if (method_exists($this, $method)) {
-                $value = $this->{$method} ($value);
-            }
             $this->_attributes[$name] = $value;
         }
     }
@@ -686,12 +723,13 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param string $name
+     *
      * @return mixed
      */
     public function __get(string $name): mixed
     {
-        $value = $this->_attributes[$name] ?? null;
+        $value = $this->_attributes[$name] ?? NULL;
-        if (!$this->hasRelateMethod($name)) {
+        if (!method_exists($this, 'get' . ucfirst($name))) {
             return $this->withPropertyOverride($name, $value);
         } else {
             return $this->withRelate($name);
@@ -702,9 +740,10 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
     /**
      * @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)) {
@@ -718,16 +757,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
@@ -742,6 +791,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param $name
+     *
      * @return bool
      */
     public function __isset(string $name): bool
@@ -752,6 +802,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param mixed $offset
+     *
      * @return bool
      * @throws
      */
@@ -762,6 +813,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param mixed $offset
+     *
      * @return mixed
      * @throws
      */
@@ -773,18 +825,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;
@@ -795,6 +851,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param string ...$params
+     *
      * @return array
      */
     public function unset(string ...$params): array
@@ -805,13 +862,14 @@ 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->_attributes = $data;
         $model->_oldAttributes = $data;
         $model->setIsNowExample();
         return $model;
@@ -821,6 +879,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
     /**
      * @param string $name
      * @param array $arguments
+     *
      * @return mixed
      */
     public static function __callStatic(string $name, array $arguments)
@@ -831,11 +890,12 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, \
 
     /**
      * @param string $field
+     *
      * @return array
      */
     public function getOldAttribute(string $field): mixed
     {
-        return $this->_oldAttributes[$field] ?? null;
+        return $this->_oldAttributes[$field] ?? NULL;
     }
 
 }

Base/PDO.php

@@ -5,6 +5,7 @@ namespace Database\Base;
 class PDO extends \PDO
 {
 
+    readonly public string $driver;
 
     /**
      * @param string $database
@@ -12,6 +13,7 @@ class PDO extends \PDO
      * @param string $username
      * @param string $password
      * @param array $options
+     * @param string $driver
      */
     public function __construct(
         readonly public string $database,
@@ -19,10 +21,23 @@ class PDO extends \PDO
         readonly public string $username,
         readonly public string $password,
         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,
+        };
+    }
 
 }

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

@@ -123,11 +123,15 @@ class Command extends Component
 
             return $result;
         } catch (Throwable $throwable) {
-            if ($this->isRefresh($throwable)) return $this->search($method);
+            $this->getLogger()->json_log($throwable);
+
+            if ($this->isRefresh($throwable)) {
+				return $this->search($method);
+			}
 
             $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);
         }
@@ -167,11 +171,15 @@ class Command extends Component
 
             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)) {
+				return $this->_prepare();
+			}
 
-            return $this->getLogger()->failure($errorMsg . PHP_EOL, 'mysql');
+            $errorMsg = $throwable->getMessage() . PHP_EOL . '                 Sql: ' . $this->sql . '.' . json_encode($this->params, JSON_UNESCAPED_UNICODE);
+
+            return $this->getLogger()->logCategory($errorMsg . PHP_EOL, 'mysql');
         } finally {
             $this->connection->release($client);
         }
@@ -184,15 +192,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;
     }
 

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,21 +14,21 @@ 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 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 Database\Base\PDO;
 
 //use PDO;
 
@@ -46,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];
@@ -134,19 +135,19 @@ class Connection extends Component
     protected function checkClientHealth(Pool $pool): void
     {
         $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
     {
-        return 'mysql.' . $this->cds;
+        return strtolower($this->driver) . '.' . $this->cds;
     }
 
 
@@ -312,7 +313,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);
     }
 
 
@@ -356,15 +357,22 @@ class Connection extends Component
      */
     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) {
             $pdo->setAttribute($key, $attribute);
         }

DatabasesProviders.php

@@ -78,8 +78,9 @@ class DatabasesProviders extends Providers
             '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'] ?? [],

Model.php

@@ -116,8 +116,9 @@ class Model extends Base\Model
             $connection->commit();
             return $select;
         } 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();
             return $select;
         } 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
     {
         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);
+		}
     }
 
     /**

SqlBuilder.php

@@ -1,4 +1,5 @@
-<?php /** @noinspection ALL */
+<?php
+/** @noinspection ALL */
 
 declare(strict_types=1);
 
@@ -107,7 +108,7 @@ 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->getFrom() . ' SET ' . implode(',', $string) . $this->make();
     }
@@ -189,7 +190,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 +200,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->getSelect()) . $this->make() . $this->makeLimit($this->query->limit(1));
+        $this->query->offset(0)->limit(1);
+        return $this->makeSelect($this->query->getSelect()) . $this->make() . $this->makeLimit();
     }
 
 
@@ -225,7 +217,7 @@ class SqlBuilder extends Component
      */
     public function all(): string
     {
-        return $this->makeSelect($this->query->getSelect()) . $this->make() . $this->makeLimit($this->query);
+        return $this->makeSelect($this->query->getSelect()) . $this->make() . $this->makeLimit();
     }
 
 
@@ -252,9 +244,26 @@ class SqlBuilder extends Component
     /**
      * @param string $table
      * @return string
+     * @throws
      */
     public function columns(string $table): string
     {
+        $driver = $this->getDriver();
+        if (in_array($driver, ['pgsql', 'postgresql'])) {
+            // PostgreSQL 使用 information_schema
+            $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";
+        }
+        // MySQL 使用 SHOW FULL FIELDS
         return 'SHOW FULL FIELDS FROM ' . $table;
     }
 
@@ -325,9 +334,19 @@ class SqlBuilder extends Component
     }
 
 
+    /**
+     * @return string
+     * @throws
+     */
     private function makeLimit(): string
     {
         if ($this->query->getOffset() >= 0 && $this->query->getLimit() >= 1) {
+            $driver = $this->getDriver();
+            if (in_array($driver, ['pgsql', 'postgresql'])) {
+                // PostgreSQL 使用 LIMIT ... OFFSET ... 语法
+                return ' LIMIT ' . $this->query->getLimit() . ' OFFSET ' . $this->query->getOffset();
+            }
+            // MySQL 使用 LIMIT offset,limit 语法
             return ' LIMIT ' . $this->query->getOffset() . ',' . $this->query->getLimit();
         }
         return '';
@@ -407,5 +426,37 @@ class SqlBuilder extends Component
         return $_array;
     }
 
+    /**
+     * 获取数据库驱动类型
+     * @return string
+     * @throws
+     */
+    private function getDriver(): string
+    {
+        try {
+            // 尝试从 query 对象获取 connection
+            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');
+                    }
+                }
+            }
+            // 如果是 Db 查询，尝试获取默认 connection
+            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);
+		}
+        // 默认返回 mysql
+        return 'mysql';
+    }
+
 
 }

Traits/HasBase.php

@@ -12,8 +12,6 @@ namespace Database\Traits;
 use Database\ModelInterface;
 use Database\Collection;
 use Database\Relation;
-use Kiri;
-use Kiri\Di\Context;
 
 /**
  * Class HasBase

composer.json

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

test.php

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