• 示例
    • 示例

    示例

    假如你的项目的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();