1

.phpstorm.meta.php

@@ -4,7 +4,10 @@ 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('@'));

src/ActiveQuery.php

@@ -11,6 +11,7 @@ namespace Database;
 
 use Database\Traits\QueryTrait;
 use Exception;
+use JetBrains\PhpStorm\ArrayShape;
 use Kiri\Abstracts\Component;
 
 /**
@@ -63,8 +64,8 @@ class ActiveQuery extends Component implements ISqlBuilder
      */
     public function clear()
     {
-		$this->db = null;
-		$this->useCache = false;
+        $this->db = NULL;
+        $this->useCache = FALSE;
         $this->with = [];
     }
 
@@ -79,6 +80,36 @@ class ActiveQuery extends Component implements ISqlBuilder
         return $this;
     }
 
+
+    /**
+     * @param int $size
+     * @param int $page
+     * @return array
+     * @throws Exception
+     */
+    #[ArrayShape(['code' => "int", 'message' => "string", 'size' => "mixed", 'page' => "mixed", 'count' => "int", 'next' => "mixed", 'prev' => "mixed", 'param' => "array"])]
+    public function pagination(int $size = 20, int $page = 1): array
+    {
+        $page = max(1, $page);
+        $size = max(1, $size);
+
+        $offset = ($page - 1) * $size;
+
+        $count = $this->count();
+        $lists = $this->limit($offset, $size)->get()->toArray();
+        return [
+            'code'   => 0,
+            'message'   => 'ok',
+            'size'   => $size,
+            'page'   => $page,
+            'count'  => $count,
+            'next'   => max($page + 1, 1),
+            'prev'   => max($page - 1, 1),
+            'param' => $lists,
+        ];
+    }
+
+
     /**
      * @param array $values
      * @return $this
@@ -198,7 +229,7 @@ class ActiveQuery extends Component implements ISqlBuilder
     public function all(): Collection|array
     {
         $data = $this->execute($this->builder->all())->all();
-		if (!empty($this->with)){
+        if (!empty($this->with)) {
             $this->getWith($this->modelClass);
         }
         $collect = new Collection($this, $data, $this->modelClass);
@@ -237,7 +268,6 @@ class ActiveQuery extends Component implements ISqlBuilder
      */
     public function count(): int
     {
-		$this->select = ['COUNT(*)'];
         $data = $this->execute($this->builder->count())->one();
         if ($data && is_array($data)) {
             return (int)array_shift($data);
@@ -267,10 +297,10 @@ class ActiveQuery extends Component implements ISqlBuilder
      */
     public function batchInsert(array $data): bool
     {
-		[$sql, $params] = $this->builder->insert($data, true);
+        [$sql, $params] = $this->builder->insert($data, TRUE);
 
 
-		return $this->execute($sql, $params)->exec(null, true);
+        return $this->execute($sql, $params)->exec();
     }
 
     /**
@@ -281,7 +311,7 @@ class ActiveQuery extends Component implements ISqlBuilder
      */
     public function value($filed)
     {
-		return $this->first()[$filed] ?? null;
+        return $this->first()[$filed] ?? NULL;
     }
 
     /**
@@ -296,13 +326,13 @@ class ActiveQuery extends Component implements ISqlBuilder
 
     /**
      * @param bool $getSql
-	 * @return string|bool
+     * @return int|bool|string|null
      * @throws Exception
      */
-	public function delete(bool $getSql = false): string|bool
+    public function delete(bool $getSql = FALSE): int|bool|string|null
     {
         $sql = $this->builder->delete();
-		if ($getSql === false) {
+        if ($getSql === FALSE) {
             return $this->execute($sql)->delete();
         }
         return $sql;

src/Base/AbstractCollection.php

@@ -134,7 +134,7 @@ abstract class AbstractCollection extends Component implements \IteratorAggregat
             return NULL;
         }
         if (!($this->_item[$offset] instanceof ModelInterface)) {
-            return $this->model->setAttributes($this->_item[$offset]);
+            return $this->model->populates($this->_item[$offset]);
         }
         return $this->_item[$offset];
     }

src/Base/CollectionIterator.php

@@ -56,7 +56,7 @@ class CollectionIterator extends \ArrayIterator
 	 */
 	protected function newModel($current): ModelInterface
 	{
-		return $this->model->setAttributes($current);
+		return $this->model->populates($current);
 	}
 
 

src/Base/Model.php

@@ -13,12 +13,10 @@ defined('SAVE_FAIL') or define('SAVE_FAIL', 3227);
 defined('FIND_OR_CREATE_MESSAGE') or define('FIND_OR_CREATE_MESSAGE', 'Create a new model, but the data cannot be empty.');
 
 
-use Annotation\Inject;
 use ArrayAccess;
 use Closure;
 use Database\ActiveQuery;
 use Database\Connection;
-use Database\HasCount;
 use Database\HasMany;
 use Database\HasOne;
 use Database\ModelInterface;
@@ -42,7 +40,7 @@ use validator\Validator;
  *
  * @package Kiri\Abstracts
  *
- * @property bool $isCreate
+ * @property bool $isNowExample
  * @property Application $container
  * @property EventDispatch $eventDispatch
  * @property array $attributes
@@ -98,12 +96,6 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
     protected string $connection = 'db';
 
 
-	/**
-	 * @var array
-	 */
-	protected array $rules = [];
-
-
     /**
      * @var array
      */
@@ -111,25 +103,27 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
 
 
     /**
-	 * @return Application
+     * @return array
      */
-	#[Pure] protected function getContainer(): Application
+    public function rules(): array
     {
-		return Kiri::app();
+        return [];
     }
 
 
     /**
      * @param string $name
      * @param mixed $value
+     * @return mixed
+     * @throws ReflectionException
      */
-	private function _setter(string $name, mixed $value): void
+    private function _setter(string $name, mixed $value): mixed
     {
         $method = di(Setter::class)->getSetter(static::class, $name);
         if (!empty($method)) {
             $value = $this->{$method}($value);
         }
-		$this->_attributes[$name] = $value;
+        return $value;
     }
 
 
@@ -137,7 +131,6 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      * @param string $name
      * @param $value
      * @return mixed
-	 * @throws NotFindClassException
      * @throws ReflectionException
      */
     private function _getter(string $name, $value): mixed
@@ -154,7 +147,6 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      * @param string $name
      * @param $value
      * @return mixed
-	 * @throws NotFindClassException
      * @throws ReflectionException
      * @throws Exception
      */
@@ -174,6 +166,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
 
     /**
      * @return EventDispatch
+     * @throws ReflectionException
      */
     protected function getEventDispatch(): EventDispatch
     {
@@ -219,7 +212,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      */
     public function init()
     {
-		$an = Kiri::app()->getAnnotation();
+        $an = Kiri::app()->getNote();
         $an->injectProperty($this);
     }
 
@@ -236,7 +229,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
     /**
      * @return bool
      */
-	public function getIsCreate(): bool
+    public function getIsNowExample(): bool
     {
         return $this->isNewExample === TRUE;
     }
@@ -246,7 +239,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      * @param bool $bool
      * @return $this
      */
-	public function setIsCreate(bool $bool = FALSE): static
+    public function setIsNowExample(bool $bool = FALSE): static
     {
         $this->isNewExample = $bool;
         return $this;
@@ -270,13 +263,13 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
     public function hasPrimary(): bool
     {
         if ($this->primary !== NULL) {
-			return true;
+            return TRUE;
         }
         $primary = $this->getColumns()->getPrimaryKeys();
         if (!empty($primary)) {
             return $this->primary = is_array($primary) ? current($primary) : $primary;
         }
-		return false;
+        return FALSE;
     }
 
 
@@ -285,7 +278,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      */
     public function isAutoIncrement(): bool
     {
-		return $this->getAutoIncrement() !== null;
+        return $this->getAutoIncrement() !== NULL;
     }
 
     /**
@@ -303,7 +296,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
     public function getPrimary(): ?string
     {
         if (!$this->hasPrimary()) {
-			return null;
+            return NULL;
         }
         return $this->primary;
     }
@@ -315,7 +308,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
     public function getPrimaryValue(): ?int
     {
         if (!$this->hasPrimary()) {
-			return null;
+            return NULL;
         }
         return $this->getAttribute($this->primary);
     }
@@ -331,7 +324,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
     public static function findOne($param, $db = NULL): static|null
     {
         if (is_bool($param)) {
-			return null;
+            return NULL;
         }
         if (is_numeric($param)) {
             $param = static::getPrimaryCondition($param);
@@ -364,7 +357,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      * @throws Exception
      * @throws Exception
      */
-	public static function max($field = null): ?ModelInterface
+    public static function max($field = NULL): ?ModelInterface
     {
         $columns = static::makeNewInstance()->getColumns();
         if (empty($field)) {
@@ -372,11 +365,11 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
         }
         $columns = $columns->get_fields();
         if (!isset($columns[$field])) {
-			return null;
+            return NULL;
         }
         $first = static::query()->max($field)->first();
         if (empty($first)) {
-			return null;
+            return NULL;
         }
         return $first[$field];
     }
@@ -401,6 +394,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
 
     /**
      * @return static
+     * @throws ReflectionException
      */
     private static function makeNewInstance(): static
     {
@@ -447,19 +441,19 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      * @return bool
      * @throws Exception
      */
-	protected static function deleteByCondition($condition = NULL, array $attributes = [], bool $if_condition_is_null = false): bool
+    protected static function deleteByCondition($condition = NULL, array $attributes = [], bool $if_condition_is_null = FALSE): bool
     {
         if (empty($condition)) {
             if (!$if_condition_is_null) {
-				return false;
+                return FALSE;
             }
-			return static::query()->delete();
+            return (bool)static::query()->delete();
         }
         $model = static::query()->ifNotWhere($if_condition_is_null)->where($condition);
         if (!empty($attributes)) {
             $model->bindParams($attributes);
         }
-		return $model->delete();
+        return (bool)$model->delete();
     }
 
 
@@ -484,20 +478,22 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      * @param $name
      * @param $value
      * @return mixed
+     * @throws ReflectionException
      */
     public function setAttribute($name, $value): mixed
     {
-		return $this->_attributes[$name] = $value;
+        return $this->_attributes[$name] = $this->_setter($name, $value);
     }
 
     /**
      * @param $name
      * @param $value
      * @return mixed
+     * @throws ReflectionException
      */
     public function setOldAttribute($name, $value): mixed
     {
-		return $this->_oldAttributes[$name] = $value;
+        return $this->_oldAttributes[$name] = $this->_setter($name, $value);
     }
 
     /**
@@ -510,21 +506,24 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
         if (empty($param)) {
             return $this;
         }
-		$this->_attributes = array_merge($this->_attributes, $param);
+        foreach ($param as $key => $attribute) {
+            $this->setAttribute($key, $attribute);
+        }
         return $this;
     }
 
     /**
      * @param $param
      * @return $this
+     * @throws ReflectionException
      */
     public function setOldAttributes($param): static
     {
         if (empty($param) || !is_array($param)) {
             return $this;
         }
-		foreach ($param as $key => $val) {
-			$this->setOldAttribute($key, $val);
+        foreach ($param as $key => $attribute) {
+            $this->setOldAttribute($key, $attribute);
         }
         return $this;
     }
@@ -539,10 +538,10 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
     {
         [$sql, $param] = SqlBuilder::builder(static::query())->insert($param);
         $dbConnection = $this->getConnection()->createCommand($sql, $param);
-		if (!($lastId = (int)$dbConnection->save(true, $this))) {
-			throw new Exception('保存失败.');
-		}
-		$lastId = $this->setPrimary($lastId, $param);
+
+        $lastId = $dbConnection->save(TRUE);
+
+        $lastId = $this->setPrimary((int)$lastId, $param);
 
         $this->refresh()->afterSave($attributes, $param);
 
@@ -571,7 +570,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
         if (!isset($param[$primary]) || empty($param[$primary])) {
             $this->setAttribute($primary, (int)$lastId);
         }
-		return $this->setAttributes($param);
+        return $this;
     }
 
 
@@ -585,7 +584,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
     private function updateInternal($fields, $condition, $param): bool|static
     {
         if (empty($param)) {
-			return true;
+            return TRUE;
         }
         if ($this->hasPrimary()) {
             $condition = [$this->getPrimary() => $this->getPrimaryValue()];
@@ -595,10 +594,10 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
             return $generate;
         }
         $command = $this->getConnection()->createCommand($generate[0], $generate[1]);
-		if ($command->save(false, $this)) {
+        if ($command->save(FALSE, $this)) {
             return $this->refresh()->afterSave($fields, $param);
         }
-		return false;
+        return FALSE;
     }
 
     /**
@@ -611,15 +610,29 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
         if (!is_null($data)) {
             $this->_attributes = merge($this->_attributes, $data);
         }
-		if (!$this->validator($this->rules) || !$this->beforeSave($this)) {
-			return false;
+        if (!$this->validator($this->rules()) || !$this->beforeSave($this)) {
+            return FALSE;
         }
         [$change, $condition, $fields] = $this->separation();
-		if (!$this->isNewExample) {
+        if (!empty($this->_oldAttributes)) {
             return $this->updateInternal($fields, $condition, $change);
-		}
+        } else {
             return $this->insert($change, $fields);
         }
+    }
+
+
+    /**
+     * @param $value
+     * @return $this
+     */
+    public function populates($value): static
+    {
+        $this->_attributes = $value;
+        $this->_oldAttributes = $value;
+        $this->setIsNowExample(FALSE);
+        return $this;
+    }
 
 
     /**
@@ -629,7 +642,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      */
     public function validator(?array $rule): bool
     {
-		if (empty($rule)) return true;
+        if (empty($rule)) return TRUE;
         $validate = $this->resolve($rule);
         if (!$validate->validation()) {
             return $this->addError($validate->getError(), 'mysql');
@@ -665,10 +678,10 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      */
     public function getAttribute(string $name)
     {
-		if ($this->hasAnnotation($name)) {
-			return $this->runAnnotation($name, $this->_attributes[$name]);
+        if ($this->hasNote($name)) {
+            return $this->runNote($name, $this->_attributes[$name]);
         }
-		return $this->_attributes[$name] ?? null;
+        return $this->_attributes[$name] ?? NULL;
     }
 
 
@@ -678,7 +691,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      * @param string $type
      * @return mixed
      */
-	protected function runAnnotation(string $name, mixed $value, string $type = self::GET): mixed
+    protected function runNote(string $name, mixed $value, string $type = self::GET): mixed
     {
         return call_user_func($this->_annotations[$type][$name], $value);
     }
@@ -693,7 +706,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
         $_tmp = [];
         $condition = [];
         foreach ($this->_attributes as $key => $val) {
-			$oldValue = $this->_oldAttributes[$key] ?? null;
+            $oldValue = $this->_oldAttributes[$key] ?? NULL;
             if ($val === $oldValue) {
                 $condition[$key] = $val;
             } else {
@@ -764,6 +777,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
 
     /**
      * @return Relation|null
+     * @throws ReflectionException
      */
     public function getRelation(): ?Relation
     {
@@ -805,8 +819,8 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
             throw new Exception('You need add static method `tableName` and return table name.');
         }
         $table = trim($this->table, '{{%}}');
-		if (!empty($tablePrefix) && !str_starts_with($this->table, $tablePrefix)) {
-			$table = $tablePrefix . $this->table;
+        if (!empty($tablePrefix) && !str_starts_with($table, $tablePrefix)) {
+            $table = $tablePrefix . $table;
         }
         return '`' . $connection->database . '`.' . $table;
     }
@@ -820,7 +834,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      */
     public function afterSave($attributes, $changeAttributes): bool
     {
-		return true;
+        return TRUE;
     }
 
 
@@ -830,7 +844,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      */
     public function beforeSave($model): bool
     {
-		return true;
+        return TRUE;
     }
 
 
@@ -853,7 +867,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
         if (method_exists($this, 'set' . ucfirst($name))) {
             $this->{'set' . ucfirst($name)}($value);
         } else {
-			$this->_setter($name, $value);
+            $this->_attributes[$name] = $this->_setter($name, $value);
         }
     }
 
@@ -869,7 +883,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
         if (method_exists($this, $method)) {
             return $this->{$method}();
         }
-		$value = $this->_attributes[$name] ?? null;
+        $value = $this->_attributes[$name] ?? NULL;
 
         return $this->_getter($name, $value);
     }
@@ -905,7 +919,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      * @param string $type
      * @return array
      */
-	protected function getAnnotation(string $type = self::GET): array
+    protected function getNote(string $type = self::GET): array
     {
         return $this->_annotations[$type] ?? [];
     }
@@ -916,10 +930,10 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      * @param string $type
      * @return bool
      */
-	protected function hasAnnotation($name, string $type = self::GET): bool
+    protected function hasNote($name, string $type = self::GET): bool
     {
         if (!isset($this->_annotations[$type])) {
-			return false;
+            return FALSE;
         }
         return isset($this->_annotations[$type][$name]);
     }
@@ -1045,7 +1059,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
         $model = duplicate(static::class);
         $model->_attributes = $data;
         $model->_oldAttributes = $data;
-		$model->setIsCreate(false);
+        $model->setIsNowExample(FALSE);
         return $model;
     }
 

src/Command.php

@@ -60,7 +60,7 @@ class Command extends Component
 	 */
 	public function save(bool $isInsert = TRUE, mixed $hasAutoIncrement = null): int|bool|array|string|null
 	{
-		return $this->execute(static::EXECUTE, $isInsert, $hasAutoIncrement);
+		return $this->execute(static::EXECUTE);
 	}
 
 
@@ -111,17 +111,15 @@ class Command extends Component
 
 	/**
 	 * @param $type
-	 * @param null $isInsert
-	 * @param bool|null $hasAutoIncrement
 	 * @return int|bool|array|string|null
 	 * @throws Exception
 	 */
-	private function execute($type, $isInsert = null, mixed $hasAutoIncrement = null): int|bool|array|string|null
+	private function execute($type): int|bool|array|string|null
 	{
 		try {
 			$time = microtime(true);
 			if ($type === static::EXECUTE) {
-				$result = $this->insert_or_change($isInsert, $hasAutoIncrement);
+				$result = $this->db->getConnect($this->sql)->execute($this->sql,$this->params);
 			} else {
 				$result = $this->search($type);
 			}
@@ -158,22 +156,6 @@ class Command extends Component
 	}
 
 
-	/**
-	 * @param $isInsert
-	 * @param $hasAutoIncrement
-	 * @return bool|int
-	 * @throws Exception
-	 */
-	private function insert_or_change($isInsert, $hasAutoIncrement): bool|int
-	{
-		$pdo = $this->db->getConnect($this->sql);
-		$result = $pdo->execute($this->sql, $isInsert, $this->params);
-		if ($hasAutoIncrement && $result == 0) {
-			return false;
-		}
-		return $result;
-	}
-
 	/**
 	 * @return int|bool|array|string|null
 	 * @throws Exception
@@ -184,14 +166,12 @@ class Command extends Component
 	}
 
 	/**
-	 * @param null $scope
-	 * @param bool $insert
 	 * @return int|bool|array|string|null
 	 * @throws Exception
 	 */
-	public function exec($scope = null, bool $insert = false): int|bool|array|string|null
+	public function exec(): int|bool|array|string|null
 	{
-		return $this->execute(static::EXECUTE, $insert, $scope);
+		return $this->execute(static::EXECUTE);
 	}
 
 	/**

src/Condition/Condition.php

@@ -5,14 +5,13 @@ namespace Database\Condition;
 
 
 use JetBrains\PhpStorm\Pure;
-use Kiri\Abstracts\BaseObject;
-use Kiri\Core\Str;
+use Kiri\Abstracts\Component;
 
 /**
  * Class Condition
  * @package Database\Condition
  */
-abstract class Condition extends BaseObject
+abstract class Condition extends Component
 {
 
 	protected string $column = '';

src/Condition/HashCondition.php

@@ -20,9 +20,8 @@ class HashCondition extends Condition
 			return '';
 		}
 		foreach ($this->value as $key => $value) {
-			if ($value === null) {
-				continue;
-			}
+			if (is_null($value)) continue;
+
 			$array[] = sprintf("%s = '%s'", $key, addslashes($value));
 		}
 		return implode(' AND ', $array);

src/Connection.php

@@ -11,7 +11,6 @@ declare(strict_types=1);
 namespace Database;
 
 
-use Annotation\Inject;
 use Database\Affair\BeginTransaction;
 use Database\Affair\Commit;
 use Database\Affair\Rollback;
@@ -23,6 +22,7 @@ use Kiri\Abstracts\Config;
 use Kiri\Events\EventProvider;
 use Kiri\Exception\NotFindClassException;
 use Kiri\Kiri;
+use Note\Inject;
 use ReflectionException;
 use Server\Events\OnWorkerExit;
 use Server\Events\OnWorkerStop;
@@ -43,7 +43,11 @@ class Connection extends Component
 
 	public string $database = '';
 
-	public int $timeout = 1900;
+	public int $connect_timeout = 30;
+
+	public int $read_timeout = 10;
+
+	public array $pool;
 
 	/**
 	 * @var bool
@@ -61,6 +65,7 @@ class Connection extends Component
 	 * @var array
 	 */
 	public array $slaveConfig = [];
+	public array $attributes = [];
 
 
 	/**
@@ -70,24 +75,18 @@ class Connection extends Component
 	public Schema $_schema;
 
 
-	/**
-	 * @var EventProvider
-	 */
-	#[Inject(EventProvider::class)]
-	public EventProvider $eventProvider;
-
-
 	/**
 	 * execute by __construct
 	 * @throws Exception
 	 */
 	public function init()
 	{
-		$this->eventProvider->on(OnWorkerStop::class, [$this, 'clear_connection'], 0);
-		$this->eventProvider->on(OnWorkerExit::class, [$this, 'clear_connection'], 0);
-		$this->eventProvider->on(BeginTransaction::class, [$this, 'beginTransaction'], 0);
-		$this->eventProvider->on(Rollback::class, [$this, 'rollback'], 0);
-		$this->eventProvider->on(Commit::class, [$this, 'commit'], 0);
+		$eventProvider = Kiri::getDi()->get(EventProvider::class);
+		$eventProvider->on(OnWorkerStop::class, [$this, 'clear_connection'], 0);
+		$eventProvider->on(OnWorkerExit::class, [$this, 'clear_connection'], 0);
+		$eventProvider->on(BeginTransaction::class, [$this, 'beginTransaction'], 0);
+		$eventProvider->on(Rollback::class, [$this, 'rollback'], 0);
+		$eventProvider->on(Commit::class, [$this, 'commit'], 0);
 
 		if (Db::transactionsActive()) {
 			$this->beginTransaction();
@@ -108,6 +107,17 @@ class Connection extends Component
 	}
 
 
+	/**
+	 * @param $config
+	 * @return $this
+	 */
+	public function configure($config): static
+	{
+		Kiri::configure($this, $config);
+		return $this;
+	}
+
+
 	/**
 	 * @throws Exception
 	 */
@@ -141,7 +151,7 @@ class Connection extends Component
 	 * @return mixed
 	 * @throws ReflectionException
 	 * @throws NotFindClassException
-	 * @throws \Exception
+	 * @throws Exception
 	 */
 	public function getSchema(): Schema
 	{
@@ -189,7 +199,11 @@ class Connection extends Component
 			'cds'             => $this->cds,
 			'username'        => $this->username,
 			'password'        => $this->password,
-			'database' => $this->database
+			'attributes'      => $this->attributes,
+			'connect_timeout' => $this->connect_timeout,
+			'read_timeout'    => $this->read_timeout,
+			'dbname'          => $this->database,
+			'pool'            => $this->pool
 		], true);
 	}
 

src/DatabasesProviders.php

@@ -4,15 +4,14 @@ declare(strict_types=1);
 namespace Database;
 
 
-use Annotation\Inject;
 use Exception;
-use Server\Events\OnWorkerStart;
 use Kiri\Abstracts\Config;
 use Kiri\Abstracts\Providers;
 use Kiri\Application;
 use Kiri\Events\EventProvider;
 use Kiri\Exception\ConfigException;
 use Kiri\Kiri;
+use Server\Events\OnWorkerStart;
 
 /**
  * Class DatabasesProviders
@@ -24,13 +23,6 @@ class DatabasesProviders extends Providers
 	private array $_pooLength = ['min' => 0, 'max' => 1];
 
 
-	/**
-	 * @var EventProvider
-	 */
-	#[Inject(EventProvider::class)]
-	public EventProvider $eventProvider;
-
-
 	/**
 	 * @param Application $application
 	 * @throws Exception
@@ -53,11 +45,9 @@ class DatabasesProviders extends Providers
 	 */
 	public function get($name): Connection
 	{
-		$application = Kiri::app();
-		if (!$application->has('databases.' . $name)) {
-			$application->set('databases.' . $name, $this->_settings($this->getConfig($name)));
-		}
-		return $application->get('databases.' . $name);
+		$config = $this->_settings($this->getConfig($name));
+
+		return Kiri::getDi()->get(Connection::class)->configure($config);
 	}
 
 
@@ -71,11 +61,10 @@ class DatabasesProviders extends Providers
 		if (empty($databases)) {
 			return;
 		}
-		$application = Kiri::app();
-		foreach ($databases as $name => $database) {
+		$connection = Kiri::getDi()->get(Connection::class);
+		foreach ($databases as $database) {
 			/** @var Connection $connection */
-			$application->set('databases.' . $name, $this->_settings($database));
-			$application->get('databases.' . $name)->fill();
+			$connection->configure($database)->fill();
 		}
 	}
 
@@ -86,16 +75,18 @@ class DatabasesProviders extends Providers
 	 */
 	private function _settings($database): array
 	{
+		$clientPool = $database['pool'] ?? ['min' => 1, 'max' => 5, 'tick' => 60];
 		return [
-			'class'       => Connection::class,
 			'id'              => $database['id'],
 			'cds'             => $database['cds'],
 			'username'        => $database['username'],
 			'password'        => $database['password'],
 			'tablePrefix'     => $database['tablePrefix'],
 			'database'        => $database['database'],
-			'maxNumber'   => $this->_pooLength['max'],
-			'minNumber'   => $this->_pooLength['min'],
+			'connect_timeout' => $database['connect_timeout'] ?? 30,
+			'read_timeout'    => $database['read_timeout'] ?? 10,
+			'pool'            => $clientPool,
+			'attributes'      => $database['attributes'] ?? [],
 			'charset'         => $database['charset'] ?? 'utf8mb4',
 			'slaveConfig'     => $database['slaveConfig']
 		];

src/Model.php

@@ -117,6 +117,7 @@ class Model extends Base\Model
 		if (empty($select)) {
 			$select = duplicate(static::class);
 			$select->attributes = $attributes;
+			$select->setIsNowExample(true);
 			if (!$select->save()) {
 				Db::rollback();
 				return $logger->addError($select->getLastError(), 'mysql');
@@ -334,7 +335,7 @@ class Model extends Base\Model
 	 */
 	public function hasOne(string $modelName, $foreignKey, $localKey): HasOne|ActiveQuery
 	{
-		if (($value = $this->getAttribute($localKey)) === null) {
+		if (($value = $this->{$localKey}) === null) {
 			throw new Exception("Need join table primary key.");
 		}
 
@@ -353,7 +354,7 @@ class Model extends Base\Model
 	 */
 	public function hasCount($modelName, $foreignKey, $localKey): ActiveQuery|HasCount
 	{
-		if (($value = $this->getAttribute($localKey)) === null) {
+		if (($value = $this->{$localKey}) === null) {
 			throw new Exception("Need join table primary key.");
 		}
 
@@ -372,7 +373,7 @@ class Model extends Base\Model
 	 */
 	public function hasMany($modelName, $foreignKey, $localKey): ActiveQuery|HasMany
 	{
-		if (($value = $this->getAttribute($localKey)) === null) {
+		if (($value = $this->{$localKey}) === null) {
 			throw new Exception("Need join table primary key.");
 		}
 
@@ -390,7 +391,7 @@ class Model extends Base\Model
 	 */
 	public function hasIn($modelName, $foreignKey, $localKey): ActiveQuery|HasMany
 	{
-		if (($value = $this->getAttribute($localKey)) === null) {
+		if (($value = $this->{$localKey}) === null) {
 			throw new Exception("Need join table primary key.");
 		}
 

src/ModelInterface.php

@@ -33,9 +33,10 @@ interface ModelInterface
 
 
     /**
-	 * @return string
+     * @param array $data
+     * @return static
      */
-	public static function className(): string;
+    public static function populate(array $data): static;
 
 
 	/**

src/Mysql/Columns.php

@@ -316,7 +316,7 @@ class Columns extends Component
 
 
 	/**
-	 * @param $column
+	 * @param array $column
 	 * @param $table
 	 * @return array
 	 */

src/Mysql/PDO.php

@@ -3,7 +3,7 @@
 namespace Database\Mysql;
 
 use Exception;
-use Kiri\Context;
+use Kiri\Abstracts\Config;
 use Kiri\Abstracts\Logger;
 use Kiri\Kiri;
 use Kiri\Pool\StopHeartbeatCheck;
@@ -29,18 +29,31 @@ class PDO implements StopHeartbeatCheck
 
 	private int $_last = 0;
 
+	public string $dbname;
+	public string $cds;
+	public string $username;
+	public string $password;
+	public string $charset;
+	public int $connect_timeout;
+	public int $read_timeout;
+
+
+	public array $attributes = [];
+
 
 	/**
-     * @param string $dbname
-     * @param string $cds
-     * @param string $username
-     * @param string $password
-     * @param string $chatset
-     * @throws
+	 * @param array $config
 	 */
-    public function __construct(public string $dbname, public string $cds,
-                                public string $username, public string $password, public string $chatset = 'utf8mb4')
+	public function __construct(array $config)
 	{
+		$this->dbname = $config['dbname'];
+		$this->cds = $config['cds'];
+		$this->username = $config['username'];
+		$this->password = $config['password'];
+		$this->connect_timeout = $config['connect_timeout'] ?? 30;
+		$this->read_timeout = $config['read_timeout'] ?? 10;
+		$this->charset = $config['charset'] ?? 'utf8mb4';
+		$this->attributes = $config['attributes'] ?? [];
 	}
 
 
@@ -67,22 +80,29 @@ class PDO implements StopHeartbeatCheck
 		if (env('state', 'start') == 'exit') {
 			return;
 		}
-        if ($this->_timer === -1 && Context::inCoroutine()) {
-            $this->_timer = Timer::tick(1000, function () {
+		if ($this->_timer === -1) {
+			$this->_timer = Timer::tick(1000, fn() => $this->waite());
+		}
+	}
+
+
+	/**
+	 * @throws Exception
+	 */
+	private function waite(): void
+	{
 		try {
 			if (env('state', 'start') == 'exit') {
 				Kiri::getDi()->get(Logger::class)->critical('timer end');
 				$this->stopHeartbeatCheck();
 			}
-                    if (time() - $this->_last > 10 * 60) {
+			if (time() - $this->_last > (int)Config::get('databases.pool.tick', 60)) {
 				$this->stopHeartbeatCheck();
 				$this->pdo = null;
 			}
 		} catch (\Throwable $throwable) {
 			error($throwable);
 		}
-            });
-        }
 	}
 
 
@@ -212,14 +232,12 @@ class PDO implements StopHeartbeatCheck
 				throw new Exception($this->_pdo()->errorInfo()[1]);
 			}
 			return $this->bindValue($statement, $params);
-        } catch (\Throwable $throwable) {
-
+		} catch (\PDOException | \Throwable $throwable) {
 			if (str_contains($throwable->getMessage(), 'MySQL server has gone away')) {
 				$this->pdo = null;
 
 				return $this->queryPrev($sql, $params);
 			}
-
 			throw new Exception($throwable->getMessage());
 		}
 	}
@@ -242,25 +260,25 @@ class PDO implements StopHeartbeatCheck
 
 	/**
 	 * @param string $sql
-     * @param $isInsert
 	 * @param array $params
 	 * @return int
 	 * @throws Exception
 	 */
-    public function execute(string $sql, $isInsert, array $params = []): int
+	public function execute(string $sql, array $params = []): int
 	{
 		$this->_last = time();
-        if (!(($prepare = $this->_pdo()->prepare($sql)) instanceof PDOStatement)) {
+		$pdo = $this->_pdo();
+		if (!(($prepare = $pdo->prepare($sql)) instanceof PDOStatement)) {
 			throw new Exception($prepare->errorInfo()[2] ?? static::DB_ERROR_MESSAGE);
 		}
 		if ($prepare->execute($params) === false) {
 			throw new Exception($prepare->errorInfo()[2] ?? static::DB_ERROR_MESSAGE);
 		}
-        $result = 1;
-        if ($isInsert) {
-            $result = (int)$this->_pdo()->lastInsertId();
-        }
+		$result = (int)$pdo->lastInsertId();
 		$prepare->closeCursor();
+		if ($result == 0) {
+			return true;
+		}
 		return $result;
 	}
 
@@ -288,13 +306,18 @@ class PDO implements StopHeartbeatCheck
 		$link = new \PDO('mysql:dbname=' . $this->dbname . ';host=' . $this->cds, $this->username, $this->password, [
 			\PDO::ATTR_EMULATE_PREPARES         => false,
 			\PDO::ATTR_CASE                     => \PDO::CASE_NATURAL,
-            \PDO::ATTR_TIMEOUT                  => 60,
+			\PDO::ATTR_TIMEOUT                  => $this->connect_timeout,
 			\PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => true,
-            \PDO::MYSQL_ATTR_INIT_COMMAND       => 'SET NAMES ' . $this->chatset
+			\PDO::MYSQL_ATTR_INIT_COMMAND       => 'SET NAMES ' . $this->charset
 		]);
 		$link->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
 		$link->setAttribute(\PDO::ATTR_STRINGIFY_FETCHES, false);
 		$link->setAttribute(\PDO::ATTR_ORACLE_NULLS, \PDO::NULL_EMPTY_STRING);
+		if (!empty($this->attributes) && is_array($this->attributes)) {
+			foreach ($this->attributes as $key => $attribute) {
+				$link->setAttribute($key, $attribute);
+			}
+		}
 		return $link;
 	}
 

src/Note/Get.php

@@ -1,7 +1,7 @@
 <?php
 
 
-namespace Database\Annotation;
+namespace Database\Note;
 
 
 use Attribute;
@@ -11,9 +11,9 @@ use Exception;
 
 /**
  * Class Get
- * @package Annotation\Model
+ * @package Note\Model
  */
-#[Attribute(Attribute::TARGET_METHOD)] class Get extends \Annotation\Attribute
+#[Attribute(Attribute::TARGET_METHOD)] class Get extends \Note\Attribute
 {
 
 

src/Note/Relation.php

@@ -1,17 +1,17 @@
 <?php
 
 
-namespace Database\Annotation;
+namespace Database\Note;
 
 
-use Annotation\Attribute;
+use Note\Attribute;
 use Database\Base\Relate;
 use Exception;
 
 
 /**
  * Class Relation
- * @package Annotation\Model
+ * @package Note\Model
  */
 #[\Attribute(\Attribute::TARGET_METHOD)] class Relation extends Attribute
 {

src/Note/Set.php

@@ -1,10 +1,10 @@
 <?php
 
 
-namespace Database\Annotation;
+namespace Database\Note;
 
 
-use Annotation\Attribute;
+use Note\Attribute;
 use Database\Base\Setter;
 use Exception;
 

src/SqlBuilder.php

@@ -240,7 +240,7 @@ class SqlBuilder extends Component
 		if (empty($this->query->from) && !empty($this->query->modelClass)) {
 			$this->query->from($this->query->getTable());
 		}
-		return $this->_prefix();
+		return $this->_prefix(false, true);
 	}
 
 
@@ -256,14 +256,15 @@ class SqlBuilder extends Component
 
 	/**
 	 * @param bool $hasOrder
+	 * @param bool $isCount
 	 * @return string
 	 * @throws Exception
 	 */
-	private function _prefix(bool $hasOrder = false): string
+	private function _prefix(bool $hasOrder = false, bool $isCount = false): string
 	{
 		$select = '';
 		if (!empty($this->query->from)) {
-			$select = $this->_selectPrefix();
+			$select = $this->_selectPrefix($isCount);
 		}
 		$select = $this->_wherePrefix($select);
 		if (!empty($this->query->attributes) && is_array($this->query->attributes)) {
@@ -302,12 +303,13 @@ class SqlBuilder extends Component
 
 
 	/**
+	 * @param bool $isCount
 	 * @return string
 	 * @throws Exception
 	 */
-	private function _selectPrefix(): string
+	private function _selectPrefix(bool $isCount): string
 	{
-		$select = $this->builderSelect($this->query->select) . ' FROM ' . $this->tableName();
+		$select = $this->builderSelect($this->query->select, $isCount) . ' FROM ' . $this->tableName();
 		if (!empty($this->query->alias)) {
 			$select .= $this->builderAlias($this->query->alias);
 		}

src/Traits/Builder.php

@@ -61,10 +61,14 @@ trait Builder
 
 	/**
 	 * @param null $select
+	 * @param bool $isCount
 	 * @return string
 	 */
-	#[Pure] private function builderSelect($select = NULL): string
+	#[Pure] private function builderSelect($select = NULL, bool $isCount = false): string
 	{
+		if ($isCount) {
+			return "SELECT COUNT(*)";
+		}
 		if (empty($select)) {
 			return "SELECT *";
 		}
@@ -129,6 +133,8 @@ trait Builder
 		if (empty($where)) return '';
 		if (is_string($where)) return $where;
 		foreach ($where as $key => $value) {
+			if (is_null($value)) continue;
+
 			$_value = $this->resolveCondition($key, $value, $_tmp);
 
 			if (empty($_value)) continue;
@@ -188,7 +194,7 @@ trait Builder
 			$class = $defaultConfig['class'];
 			unset($defaultConfig['class']);
 
-			$builder = Kiri::getDi()->get($class, [], $defaultConfig);
+			$builder = Kiri::getDi()->make($class, [], $defaultConfig);
 			$builder->setValue($condition[2]);
 			$builder->setColumn($condition[1]);
 		} else {
@@ -210,6 +216,8 @@ trait Builder
 	{
 		$_array = [];
 		foreach ($condition as $key => $value) {
+			if (is_null($value)) continue;
+
 			$value = is_numeric($value) ? $value : '\'' . $value . '\'';
 			if (!is_numeric($key)) {
 				$_array[] = sprintf('%s = %s', $key, $value);

src/Traits/QueryTrait.php

@@ -522,7 +522,7 @@ trait QueryTrait
 			$conditionArray = $this->sprintf($conditionArray, $value, $opera);
 		}
 
-		$this->where = ['(' . implode(' AND ', $this->where) . ') OR (' . $conditionArray . ')'];
+		$this->where = ['((' . implode(' AND ', $this->where) . ') OR (' . $conditionArray . '))'];
 		return $this;
 	}
 
@@ -923,6 +923,7 @@ trait QueryTrait
 	private function addArray(array $array): static
 	{
 		foreach ($array as $key => $value) {
+			if (is_null($value)) continue;
 			if (is_numeric($key)) {
 				[$column, $opera, $value] = $this->opera(...$value);