示例

假如你的项目的tp的风格，可以继承EasySwoole\Mysqli\TpORM来自定义

  1. <?php
  3. namespace App;
  5. use EasySwoole\Mysqli\DbObject;
  6. use App\Pool\MysqlPool;
  7. use App\Pool\MysqlObject;
  8. use EasySwoole\Mysqli\TpORM;
  9. use EasySwoole\Component\Pool\PoolManager;
  10. use EasySwoole\EasySwoole\Config;
  12. /**
  13.  * Class Model
  14.  * @package ezswoole
  15.  * @method mixed|static where($whereProps, $whereValue = 'DBNULL', $operator = '=', $cond = 'AND')
  16.  * @method mixed|static field($field)
  17.  *
  18.  */
  19. class Model extends TpORM
  20. {
  21.     protected $prefix;
  22.     protected $modelPath = '\\App\\Model';
  23.     protected $fields = [];
  24.     protected $limit;
  25.     protected $throwable;
  26.     protected $createTime = false;
  27.     protected $createTimeName = 'create_time';
  29.     /**
  30.      * Model constructor.
  31.      * @param null $data
  32.      */
  33.     public function __construct( $data = null )
  34.     {
  35.         $this->prefix = Config::getInstance()->getConf( 'MYSQL.prefix' );
  36.         $db           = PoolManager::getInstance()->getPool( MysqlPool::class )->getObj( Config::getInstance()->getConf( 'MYSQL.POOL_TIME_OUT' ) );
  37.         if( $db instanceof MysqlObject ){
  38.             parent::__construct( $data );
  39.             $this->setDb( $db );
  40.         } else{
  41.             // todo log
  42.             return null;
  43.         }
  44.     }
  46.     public function __destruct()
  47.     {
  48.         $db = $this->getDb();
  49.         if( $db instanceof MysqlObject ){
  50.             $db->gc();
  51.             PoolManager::getInstance()->getPool( MysqlPool::class )->recycleObj( $db );
  52.             $this->setDb( null );
  53.         }
  54.     }
  56.     /**
  57.      * @param null $data
  58.      * @return bool|int
  59.      */
  60.     protected function add( $data = null )
  61.     {
  62.         try{
  63.             if( $this->createTime === true ){
  64.                 $data[$this->createTimeName] = time();
  65.             }
  66.             return parent::insert( $data );
  67.         } catch( \EasySwoole\Mysqli\Exceptions\ConnectFail $e ){
  68.             $this->throwable = $e;
  69.             return false;
  70.         } catch( \EasySwoole\Mysqli\Exceptions\PrepareQueryFail $e ){
  71.             $this->throwable = $e;
  72.             return false;
  73.         } catch( \Throwable $t ){
  74.             $this->throwable = $t;
  75.             return false;
  76.         }
  77.     }
  79.     /**
  80.      * @param null $data
  81.      * @return bool|mixed
  82.      */
  83.     protected function edit( $data = null )
  84.     {
  85.         try{
  86.             return $this->update( $data );
  87.         } catch( \EasySwoole\Mysqli\Exceptions\ConnectFail $e ){
  88.             $this->throwable = $e;
  89.             return false;
  90.         } catch( \EasySwoole\Mysqli\Exceptions\PrepareQueryFail $e ){
  91.             $this->throwable = $e;
  92.             return false;
  93.         } catch( \Throwable $t ){
  94.             $this->throwable = $t;
  95.             return false;
  96.         }
  97.     }
  99.     /**
  100.      * @return bool|null
  101.      */
  102.     public function del()
  103.     {
  104.         try{
  105.             if( $this->softDelete === true ){
  106.                 $data[$this->softDeleteTimeName] = time();
  107.                 return $this->update( $data );
  108.             } else{
  109.                 return parent::delete();
  110.             }
  111.         } catch( \EasySwoole\Mysqli\Exceptions\ConnectFail $e ){
  112.             $this->throwable = $e;
  113.             return false;
  114.         } catch( \EasySwoole\Mysqli\Exceptions\PrepareQueryFail $e ){
  115.             $this->throwable = $e;
  116.             return false;
  117.         } catch( \Throwable $t ){
  118.             $this->throwable = $t;
  119.             return false;
  120.         }
  121.     }
  123.     /**
  124.      * @return array|bool|false|null
  125.      */
  126.     public function select()
  127.     {
  128.         try{
  129.             return parent::select();
  130.         } catch( \EasySwoole\Mysqli\Exceptions\ConnectFail $e ){
  131.             $this->throwable = $e;
  132.             return false;
  133.         } catch( \EasySwoole\Mysqli\Exceptions\PrepareQueryFail $e ){
  134.             $this->throwable = $e;
  135.             return false;
  136.         } catch( \Throwable $t ){
  137.             $this->throwable = $t;
  138.             return false;
  139.         }
  140.     }
  142.     /**
  143.      * @param string $name
  144.      * @return array|bool
  145.      */
  146.     public function column( string $name )
  147.     {
  148.         try{
  149.             return parent::column();
  150.         } catch( \EasySwoole\Mysqli\Exceptions\ConnectFail $e ){
  151.             $this->throwable = $e;
  152.             return false;
  153.         } catch( \EasySwoole\Mysqli\Exceptions\PrepareQueryFail $e ){
  154.             $this->throwable = $e;
  155.             return false;
  156.         } catch( \Throwable $t ){
  157.             $this->throwable = $t;
  158.             return false;
  159.         }
  160.     }
  162.     /**
  163.      * @param string $name
  164.      * @return array|bool|null
  165.      */
  166.     public function value( string $name )
  167.     {
  168.         try{
  169.             return parent::value();
  170.         } catch( \EasySwoole\Mysqli\Exceptions\ConnectFail $e ){
  171.             $this->throwable = $e;
  172.             return false;
  173.         } catch( \EasySwoole\Mysqli\Exceptions\PrepareQueryFail $e ){
  174.             $this->throwable = $e;
  175.             return false;
  176.         } catch( \Throwable $t ){
  177.             $this->throwable = $t;
  178.             return false;
  179.         }
  180.     }
  182.     /**
  183.      * @return array|bool
  184.      */
  185.     protected function find( $id = null )
  186.     {
  187.         try{
  188.             if( $id ){
  189.                 return $this->byId( $id );
  190.             } else{
  191.                 return parent::find();
  192.             }
  193.         } catch( \EasySwoole\Mysqli\Exceptions\ConnectFail $e ){
  194.             $this->throwable = $e;
  195.             return false;
  196.         } catch( \EasySwoole\Mysqli\Exceptions\PrepareQueryFail $e ){
  197.             $this->throwable = $e;
  198.             return false;
  199.         } catch( \Throwable $t ){
  200.             $this->throwable = $t;
  201.             return false;
  202.         }
  203.     }
  204. }

示例

WikiModel.php

  1. <?php
  3. namespace App\Model;
  5. use yourPath\Model;
  8. class Wiki extends Model
  9. {
  10.     protected $softDelete = true;
  11.     protected $softDeleteTimeName = 'delete_time';
  12.     protected $createTime = true;
  13.     protected $createTimeName = 'create_time';
  14.     protected $dbFields
  15.         = [
  16.             'content'     => ['text', 'required'],
  17.             'id'          => ['int'],
  18.             'name'        => ['text'],
  19.             'create_time' => ['int'],
  20.             'delete_time' => ['int'],
  21.         ];
  22. }
  24. ?>

查询多条

  1. WikiModel::where( ['id' => ['>', 5]] )->field( ['id'] )->select();
  2. WikiModel::where( ['id' => ['>', 5]] )->column( 'id' );
  3. WikiModel::where( ['id' => ['>', 5]] )->value( 'id' );
  4. WikiModel::where( ['id' => ['>', 5]] )->field( ['id'] )->select();

单条

  1. WikiModel::where( ['id' => ['>', 5]] )->find();

添加

  1. WikiModel::add( ['content' => "1111"] );

修改

注意：对象的主键。’id’是默认值。protected $primaryKey = ‘id’;

如果想改为其他，请继承并替换

  1. // 方式1，逻辑是先查询有没有，如果有就实例化出来一个对象，然后调用edit方法
  2. $wiki   = WikiModel::byId( 4 );
  3. $wiki->edit( ['content' => 'xxxxxxxxxxx'] );
  4. // 方式2，不管有没有直接就修改
  5. $wiki->edit( ['id'=>'4','content' => 'xxxxxxxxxxx'] );
  6. // 还可以这么写
  7. WikiModel::where( ['id' => ['>' => 64]] )->edit( ['content' => '我是64'] );

删除

  1. // 方式1
  2. WikiModel::byId( 64 )->del();
  3. // 方式2
  4. WikiModel::where( ['id' => ['>=' => 63]] )->del();