1

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->db = NULL;
-		$this->useCache = false;
+        $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
@@ -266,7 +297,7 @@ 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();
@@ -280,7 +311,7 @@ class ActiveQuery extends Component implements ISqlBuilder
      */
     public function value($filed)
     {
-		return $this->first()[$filed] ?? null;
+        return $this->first()[$filed] ?? NULL;
     }
 
     /**
@@ -298,10 +329,10 @@ class ActiveQuery extends Component implements ISqlBuilder
      * @return int|bool|string|null
      * @throws Exception
      */
-	public function delete(bool $getSql = false): int|bool|string|null
+    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/Model.php

@@ -40,7 +40,7 @@ use validator\Validator;
  *
  * @package Kiri\Abstracts
  *
- * @property bool $isCreate
+ * @property bool $isNowExample
  * @property Application $container
  * @property EventDispatch $eventDispatch
  * @property array $attributes
@@ -229,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;
     }
@@ -239,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;
@@ -263,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;
     }
 
 
@@ -278,7 +278,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      */
     public function isAutoIncrement(): bool
     {
-		return $this->getAutoIncrement() !== null;
+        return $this->getAutoIncrement() !== NULL;
     }
 
     /**
@@ -296,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;
     }
@@ -308,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);
     }
@@ -324,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);
@@ -357,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)) {
@@ -365,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];
     }
@@ -441,11 +441,11 @@ 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 (bool)static::query()->delete();
         }
@@ -539,7 +539,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
         [$sql, $param] = SqlBuilder::builder(static::query())->insert($param);
         $dbConnection = $this->getConnection()->createCommand($sql, $param);
 
-		$lastId = $dbConnection->save(true);
+        $lastId = $dbConnection->save(TRUE);
 
         $lastId = $this->setPrimary((int)$lastId, $param);
 
@@ -584,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()];
@@ -594,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,14 +611,15 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
             $this->_attributes = merge($this->_attributes, $data);
         }
         if (!$this->validator($this->rules()) || !$this->beforeSave($this)) {
-			return false;
+            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);
         }
+    }
 
 
     /**
@@ -629,7 +630,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
     {
         $this->_attributes = $value;
         $this->_oldAttributes = $value;
-        $this->setIsCreate(FALSE);
+        $this->setIsNowExample(FALSE);
         return $this;
     }
 
@@ -641,10 +642,10 @@ 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');
+            return $this->addError($validate->getError(), 'mysql');
         } else {
             return TRUE;
         }
@@ -680,7 +681,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
         if ($this->hasNote($name)) {
             return $this->runNote($name, $this->_attributes[$name]);
         }
-		return $this->_attributes[$name] ?? null;
+        return $this->_attributes[$name] ?? NULL;
     }
 
 
@@ -705,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 {
@@ -833,7 +834,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      */
     public function afterSave($attributes, $changeAttributes): bool
     {
-		return true;
+        return TRUE;
     }
 
 
@@ -843,7 +844,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
      */
     public function beforeSave($model): bool
     {
-		return true;
+        return TRUE;
     }
 
 
@@ -882,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);
     }
@@ -932,7 +933,7 @@ abstract class Model extends Component implements ModelInterface, ArrayAccess, T
     protected function hasNote($name, string $type = self::GET): bool
     {
         if (!isset($this->_annotations[$type])) {
-			return false;
+            return FALSE;
         }
         return isset($this->_annotations[$type][$name]);
     }
@@ -1058,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/Connection.php

@@ -75,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);
+		$eventProvider = Kiri::getDi()->get(EventProvider::class);
-		$this->eventProvider->on(OnWorkerExit::class, [$this, 'clear_connection'], 0);
+		$eventProvider->on(OnWorkerStop::class, [$this, 'clear_connection'], 0);
-		$this->eventProvider->on(BeginTransaction::class, [$this, 'beginTransaction'], 0);
+		$eventProvider->on(OnWorkerExit::class, [$this, 'clear_connection'], 0);
-		$this->eventProvider->on(Rollback::class, [$this, 'rollback'], 0);
+		$eventProvider->on(BeginTransaction::class, [$this, 'beginTransaction'], 0);
-		$this->eventProvider->on(Commit::class, [$this, 'commit'], 0);
+		$eventProvider->on(Rollback::class, [$this, 'rollback'], 0);
+		$eventProvider->on(Commit::class, [$this, 'commit'], 0);
 
 		if (Db::transactionsActive()) {
 			$this->beginTransaction();

src/DatabasesProviders.php

@@ -11,7 +11,6 @@ use Kiri\Application;
 use Kiri\Events\EventProvider;
 use Kiri\Exception\ConfigException;
 use Kiri\Kiri;
-use Note\Inject;
 use Server\Events\OnWorkerStart;
 
 /**
@@ -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

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');