PHPackages                             mokuyu/mokuyu - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Database & ORM](/categories/database)
4. /
5. mokuyu/mokuyu

ActiveLibrary[Database & ORM](/categories/database)

mokuyu/mokuyu
=============

mysql sqlite pdo

2.0.23(5y ago)1128MITPHPPHP >=7.4CI failing

Since Jan 10Pushed 5y ago1 watchersCompare

[ Source](https://github.com/zhaokeli/mokuyu-mokuyu)[ Packagist](https://packagist.org/packages/mokuyu/mokuyu)[ RSS](/packages/mokuyu-mokuyu/feed)WikiDiscussions master Synced today

READMEChangelogDependencies (3)Versions (44)Used By (0)

Mokuyu数据库操作
===========

[](#mokuyu数据库操作)

- [Mokuyu数据库操作](#mokuyu%E6%95%B0%E6%8D%AE%E5%BA%93%E6%93%8D%E4%BD%9C)
    - [安装方法](#%E5%AE%89%E8%A3%85%E6%96%B9%E6%B3%95)
        - [composer](#composer)
        - [手动安装](#%E6%89%8B%E5%8A%A8%E5%AE%89%E8%A3%85)
    - [使用规则说明](#%E4%BD%BF%E7%94%A8%E8%A7%84%E5%88%99%E8%AF%B4%E6%98%8E)
        - [数据库表/字段](#%E6%95%B0%E6%8D%AE%E5%BA%93%E8%A1%A8%E5%AD%97%E6%AE%B5)
        - [特别注意/解析规则](#%E7%89%B9%E5%88%AB%E6%B3%A8%E6%84%8F%E8%A7%A3%E6%9E%90%E8%A7%84%E5%88%99)
        - [功能亮点和要求](#%E5%8A%9F%E8%83%BD%E4%BA%AE%E7%82%B9%E5%92%8C%E8%A6%81%E6%B1%82)
    - [连接数据库](#%E8%BF%9E%E6%8E%A5%E6%95%B0%E6%8D%AE%E5%BA%93)
        - [连接mysql](#%E8%BF%9E%E6%8E%A5mysql)
        - [连接pgsql](#%E8%BF%9E%E6%8E%A5pgsql)
        - [连接sqlite](#%E8%BF%9E%E6%8E%A5sqlite)
    - [查询条件连贯操作](#%E6%9F%A5%E8%AF%A2%E6%9D%A1%E4%BB%B6%E8%BF%9E%E8%B4%AF%E6%93%8D%E4%BD%9C)
        - [fieldMap(array map)](#fieldmaparray-map)
        - [fieldMode(int type=0)](#fieldmodeint-type0)
        - [tableMode(int type=0)](#tablemodeint-type0)
        - [forceIndex(string field)](#forceindexstring-field)
        - [useWriteConn()](#usewriteconn)
        - [field(string/array fields)](#fieldstringarray-fields)
        - [where(string/array)](#wherestringarray)
        - [whereOr(string/array)](#whereorstringarray)
        - [limit(start,end=null)](#limitstartendnull)
        - [order(string/array)](#orderstringarray)
        - [rand()](#rand)
        - [group(string data)](#groupstring-data)
        - [page(int page=1,int pageSize=15)](#pageint-page1int-pagesize15)
        - [debug(bool $debug=false)](#debugbool-debugfalse)
        - [join(array data)](#joinarray-data)
    - [执行查询并返回结果](#%E6%89%A7%E8%A1%8C%E6%9F%A5%E8%AF%A2%E5%B9%B6%E8%BF%94%E5%9B%9E%E7%BB%93%E6%9E%9C)
        - [select():array](#selectarray)
        - [column($field, string $key = null, bool $isDeleteIndexKey = false)](#columnfield-string-key--null-bool-isdeleteindexkey--false)
        - [chunk(int $count, Closure $callback, string $sortField = null, string $sortType = 'asc')](#chunkint-count-closure-callback-string-sortfield--null-string-sorttype--asc)
        - [insert(array datas):int](#insertarray-datasint)
        - [update(array datas):int](#updatearray-datasint)
        - [delete(int id=0):int](#deleteint-id0int)
        - [save(array datas):int](#savearray-datasint)
        - [get(\[int id = 0\]):array/string](#getint-id--0arraystring)
        - [has():boolean](#hasboolean)
        - [paginate(int page=1,int pageSize=15):array](#paginateint-page1int-pagesize15array)
        - [min(...string field):int/array](#minstring-fieldintarray)
        - [max(...string field):int/array](#maxstring-fieldintarray)
        - [avg(...string field):int/array](#avgstring-fieldintarray)
        - [sum(...string field):int/array](#sumstring-fieldintarray)
        - [count(string field):int](#countstring-fieldint)
    - [其它信息获取](#%E5%85%B6%E5%AE%83%E4%BF%A1%E6%81%AF%E8%8E%B7%E5%8F%96)
        - [getPK():string](#getpkstring)
        - [getPDO(bool isWrite = false): PDO](#getpdobool-iswrite--false-pdo)
        - [getQueryParams():array](#getqueryparamsarray)
        - [getFields():array](#getfieldsarray)
    - [执行原生SQL](#%E6%89%A7%E8%A1%8C%E5%8E%9F%E7%94%9Fsql)
        - [query(string sql,array params=\[\]):array](#querystring-sqlarray-paramsarray)
        - [exec(string sql,array params=\[\]):int](#execstring-sqlarray-paramsint)
    - [数据的增删改](#%E6%95%B0%E6%8D%AE%E7%9A%84%E5%A2%9E%E5%88%A0%E6%94%B9)
        - [添加数据](#%E6%B7%BB%E5%8A%A0%E6%95%B0%E6%8D%AE)
        - [更新数据](#%E6%9B%B4%E6%96%B0%E6%95%B0%E6%8D%AE)
        - [删除数据](#%E5%88%A0%E9%99%A4%E6%95%B0%E6%8D%AE)
    - [字段操作](#%E5%AD%97%E6%AE%B5%E6%93%8D%E4%BD%9C)
        - [setInc(string fiela,int num=1):int](#setincstring-fielaint-num1int)
        - [setDec(string field,int num=1):int](#setdecstring-fieldint-num1int)
        - [fieldOperation(string field,int num=0,string operation='+'):int](#fieldoperationstring-fieldint-num0string-operationint)
    - [事务处理](#%E4%BA%8B%E5%8A%A1%E5%A4%84%E7%90%86)
        - [beginTransaction()](#begintransaction)
        - [transaction(Closure callback)](#transactionclosure-callback)
    - [调试](#%E8%B0%83%E8%AF%95)
        - [fetchSql(bool bo=true)](#fetchsqlbool-botrue)
        - [setDebug(bool isDebug=false)](#setdebugbool-isdebugfalse)
        - [isDebug()](#isdebug)
        - [abort(bool isAbort=true)](#abortbool-isaborttrue)
        - [getLastSql():string](#getlastsqlstring)
        - [getLastError():string](#getlasterrorstring)
        - [log():array](#logarray)
        - [info():array](#infoarray)
    - [其它功能](#%E5%85%B6%E5%AE%83%E5%8A%9F%E8%83%BD)
        - [setCache(CacheInterface obj): void](#setcachecacheinterface-obj-void)
        - [setBindParam(array value): void](#setbindparamarray-value-void)
        - [getWhere(array data = \[\]):array](#getwherearray-data--array)
        - [addEventListener(string $eventType, $handler)](#addeventlistenerstring-eventtype-handler)
        - [removeEventListener(string $eventType, $handler)](#removeeventlistenerstring-eventtype-handler)
        - [trigger(string $eventType, array $eventData = \[\])](#triggerstring-eventtype-array-eventdata--)
        - [getConnections(): array](#getconnections-array)
    - [SQLite示例](#sqlite%E7%A4%BA%E4%BE%8B)

安装方法
----

[](#安装方法)

### composer

[](#composer)

```
# install mokuyu
composer require mokuyu/mokuyu
```

### 手动安装

[](#手动安装)

本库可以缓存字段等信息，使用psr标准缓存接口 Psr\\SimpleCache\\CacheInterface; 请自己引入缓存标准接口文件 [Psr\\SimpleCache\\CacheInterface 下载地址](https://github.com/php-fig/simple-cache/tree/master/src)

```
include __dir__.'/CacheInterface.php';
```

本数据库类的开发吸取medoo(符号查询)和thinkphp(连贯操作)的特点，集各家之所长,感谢以上两个开源库 \[toc\]

使用规则说明
------

[](#使用规则说明)

### 数据库表/字段

[](#数据库表字段)

- 表和字段名字全部小写,为方便阅读，尽量使用全名不要使用字母简写(名字长点其它无所谓)
- 字段名单词间用下划线分隔，或使用驼峰命名,不能混写
- 每个表都要有主键，主键名字格式为: 表名(不带前缀)\_id,

> 如果字段没有按下面的规范写,可以使用字段映射来一一对应，以上规范为强烈建议，非强制使用

### 特别注意/解析规则

[](#特别注意解析规则)

- 数据表解析时会把非首位的大写字母解析成下划线加小写字母，如userGroup/UserGroup 都会被解析为 db\_user\_group
- 字段风格默认为不转换,0:默认字段，1:转换为下划线风格，2:转换为驼峰风格,查询时会按这些规则转换成真实的数据库字段进行查询

### 功能亮点和要求

[](#功能亮点和要求)

- 进行添加或更新操作时可以自动过滤数据库不存在的字段
- 查询时可进行字段映射,前端字段映射到数据库真实字段
- 如果要加快查询速度，则可以设置缓存对象,数据库会把数据表字段等信息保存下来，加快查询速度，设置的缓存对象要实现 DbCache 接口

连接数据库
-----

[](#连接数据库)

### 连接mysql

[](#连接mysql)

```
$db = new \mokuyu\database\Mokuyu([
  // 必须配置项
  'database_type' => 'mysql',
  'database_name' => '******',
  //服务器 :w写数据 :r读数据，如果不设置标识则视为写,如果多个服务器则每次随机使用一条数据库配置
  'server'        => 'localhost,192.168.0.2:r',
  'username'      => '*****,****',//如果长度和server不够以最后一个为准
  'password'      => '******,****',//如果长度和server不够以最后一个为准
  'port'          => '3306,3306',//如果长度和server不够以最后一个为准
  'charset'       => 'utf8',
  'break_reconnect'=>false,//是否断线重连
  /**
   *  可选参数
   * 字段风格,把传入的字段转为下面,也可以在查询时使用fieldMode()设置临时风格
   * 0:默认字段，1:转换为下划线风格，2:转换为驼峰风格
   * @var null
   **/
  'field_mode'  =>0,
  /**
   * 数据表风格,把传入的表名(不带表前缀)转为下面格式,再加上表前缀(程序不会处理前缀的大小写)
   * 0:原样不动，1:转换为下划线风格，2:转换为驼峰风格, 3:转换为下划线然后转为大写(Oracle)
   * @var null
   */
  'table_mode'  =>1,
  // 可选参数，定义表的前缀
  'prefix'        => 'kl_',
]);
```

### 连接pgsql

[](#连接pgsql)

```
$db = new \mokuyu\database\Mokuyu([
    // 必须配置项
    'database_type' => 'pgsql',
    'database_name' => $newdataname,
    'server'        => 'localhost',
    'username'      => 'postgres',
    'password'      => 'adminrootkl',
    'charset'       => 'utf8',
    // 可选参数
    'port'          => 5432,
    'debug_mode'    => false,
    // 可选，定义表的前缀
    'prefix'        => 'kl_',
]);
```

### 连接sqlite

[](#连接sqlite)

```
$db = new \mokuyu\database\Mokuyu([
  // 必须配置项
  'database_type' => 'sqlite',
  'database_file' => 'stat.db',
  'charset'       => 'utf8',
  // 可选，定义表的前缀
  'prefix'        => 'kl_',
]);
```

查询条件连贯操作
--------

[](#查询条件连贯操作)

>

```
$db->table('user')
    ->field('user_id,username')
    ->where(['user_id'=>1])
    ->limit(1,10)
    ->order('user_id desc')
    ->select()
```

### fieldMap(array map)

[](#fieldmaparray-map)

字段映射 设置查询字段和数据库真实字段的映射

```
[
  //格式为 别名(查询)字段=>数据库真实字段
  // 'push_time' => 'create_time',
]
```

### fieldMode(int type=0)

[](#fieldmodeint-type0)

- 字段风格,把传入的字段转为下面类型，此方法为单次查询有效
- 0:原样不动，1:转换为下划线风格，2:转换为驼峰风格

### tableMode(int type=0)

[](#tablemodeint-type0)

- 数据表风格,把传入的表名(不带表前缀)转为下面格式,再加上表前缀,此方法为单次查询有效
- 0:原样不动，1:转换为下划线风格，2:转换为驼峰风格, 3:转换为下划线然后转为大写(Oracle)

### forceIndex(string field)

[](#forceindexstring-field)

强制使用索引,目前Mysql sqlite oracle中可用，其它数据库没有测试,目前只支持主表，join的表不支持，如需要使用请使用原生sql查询

### useWriteConn()

[](#usewriteconn)

强制使用写库连接来进行操作,在一些强一至性的读写分离项目中可以使用。

### field(string/array fields)

[](#fieldstringarray-fields)

字段可以直接使用原生格式，不用加反引号,会自动识别并添加上

```
$field=[
'distinct(username)',
'distinct(visitor.uuid)',
'password',
'nickname[nname]',//使用别名nname
'rcontact.alias[rc_alias]',给指定表中的字段设置别名
];
//sql: distinct(`username`),distinct(`visitor`.`uuid`) ,`password`,`nickname` as `nname`,`kl_rcontact`.`alias` AS `rc_alias`
```

也可以直接传字符串

```
$field='distinct(username),password,nickname[name]';

```

### where(string/array)

[](#wherestringarray)

如果是字符串的话请使用原生sql,包括数据表请用带前缀的表名，数组时其中的and和or键可以任意嵌套，顶层默认为and连接

```
$map=[
  'and'=>[
    'user_id'=>1,
    'user_name'=>'use'
  ],
  'or'=>[
    'nickname'=>'joke',
    //同一个字符多个or的情况后面加 __1234  累加数字就可以
    'nickname__1'=>'keli',
    'nickname__2'=>'keli2',
    'logintimes[]'=>1502365987
];
//sql: (user_id=1 and user_name='use') and (nickname='joke' or nickname='keli' or nickname='keli2' or logintimes1502365987
```

数组中添加原生sql

```
$map['_sql']='find_in_set(1,`tags`)';
//或数组形式添加多个
$map['_sql']=[
  'find_in_set(1,`tags`)',
  'find_in_set(1,`tags`)'
];
```

查询条件有两种方式添加 第一种在字段上添加标识符如下

>

- field=>100
- field\[>\]=>100 ==== field>100
- field\[>=\]=>100 ==== field>=100
- field\[!\]=>100 ==== field!=100
- field\[<>\]=>\[100,200\] ==== field BETWEEN 100 AND 200
- field\[><\]=>\[100,200\] ==== field NOT BETWEEN 100 AND 200
- field\[~\]=>'%stss' ==== field like '%stss'
- field\[~\]=>\['%stss','stss%'\] ==== field like '%stss' OR field like 'stss%'
- field\[>\]=>100 ==== field>100
- field\[>\]=>100 ==== field>100

第二种，使用数组中传标识符

```
$map=[
  'field'=>'1',
  'field'=>['in',['1','2','3']],
  'field'=>['gt',100],
  'field'=>['lt',100],
  'field'=>['egt',100],
  'field'=>['elt',100],
  'field'=>['eq',100],
  'field'=>['neq',100],
];
```

### whereOr(string/array)

[](#whereorstringarray)

where or连接的另一种添加方式

### limit(start,end=null)

[](#limitstartendnull)

参数为(1,10)或[10](0,10)

### order(string/array)

[](#orderstringarray)

参数为字符串(user\_id desc,username desc)也可以为数组 如果多表联合查询的时候有相同字段那么可以直接使用表名,如wechat.update\_time最终解析为kl\_wechat.update

### rand()

[](#rand)

没有参数 如果这个函数被调用则会覆盖上面的排序,会使用随机排序

### group(string data)

[](#groupstring-data)

参数为字符串(username)

### page(int page=1,int pageSize=15)

[](#pageint-page1int-pagesize15)

返回指定页码和分页大小的记录数

### debug(bool $debug=false)

[](#debugbool-debugfalse)

本次查询是否开启调试模式

### join(array data)

[](#joinarray-data)

```
主表就是使用table设置的表
// [>] == LEFT JOIN
// [ ['visitor_uuid'],
    //LEFT JOIN `kl_visitor` USING (`visitor_uuid`)

    //两个表两个字段都相同
    '[>]tongji'   => ['visitor_uuid', 'tongji_id'],
    //LEFT JOIN `kl_tongji` USING (`visitor_uuid`, `tongji_id`)

    //主表的uid和当前表的user_id相同,请注意:主表字段做为key,后面的值不需要加表名，会自动加上
    '[>]user'     => ['uid' => 'user_id'],
    //LEFT JOIN `kl_user` ON `kl_event_log`.`uid` = `kl_user`.`user_id`

    //多个条件相同
    '[>]visitor2' => [
      //主表的author_id等于visitor2.user_id
      "author_id"    => "user_id",
      //user.user_id=visitor2.user_id
      "user.user_id" => "user_id",
    ],
    //LEFT JOIN `kl_visitor2` ON `kl_event_log`.`author_id` = `kl_visitor2`.`user_id` AND `kl_user`.`user_id` = `kl_visitor2`.`user_id`
```

执行查询并返回结果
---------

[](#执行查询并返回结果)

### select():array

[](#selectarray)

从数据库取回指定数据返回一个多维数据

### column($field, string $key = null, bool $isDeleteIndexKey = false)

[](#columnfield-string-key--null-bool-isdeleteindexkey--false)

返回指定字段和指定索引

### chunk(int $count, Closure $callback, string $sortField = null, string $sortType = 'asc')

[](#chunkint-count-closure-callback-string-sortfield--null-string-sorttype--asc)

分批数据返回处理

### insert(array datas):int

[](#insertarray-datasint)

别名 **add()** ,添加数据,支持二维数组批量事务插入，失败会自动回滚

### update(array datas):int

[](#updatearray-datasint)

更新数据,如果where条件为空的话,更新的数组里如果有主键,则会自动提取主键为条件，如果没有主键也没有where条件则返回0 支持二维数组批量事务更新，更新数据数组中一定要有主键，不能有where条件，否则返回0

### delete(int id=0):int

[](#deleteint-id0int)

删除数据，必须有条件的情况下才能删除，没有条件的情况下请传入 1=1

### save(array datas):int

[](#savearray-datasint)

自动判断添加还是更新，首先判断如果有where条件，则会执行更新操作，没有where条件如果数据里有主键则执行更新操作,否则将插入数据，

### get(\[int id = 0\]):array/string

[](#getint-id--0arraystring)

从数据库中取回一条数据返回一维数组，如果只有一个字段就返回这个字段的值

### has():boolean

[](#hasboolean)

从数据库中查询数据存在不。返回true false

### paginate(int page=1,int pageSize=15):array

[](#paginateint-page1int-pagesize15array)

数据分页,第一个参数为当前页码，第二个为分页大小，返回结果为如下格式

```
return [
    'list'     => $query->fetchAll(PDO::FETCH_ASSOC),
    'count'    => $count,
    'page'     => $page,
    'pageSize' => $pageSize,
];
```

### min(...string field):int/array

[](#minstring-fieldintarray)

### max(...string field):int/array

[](#maxstring-fieldintarray)

### avg(...string field):int/array

[](#avgstring-fieldintarray)

### sum(...string field):int/array

[](#sumstring-fieldintarray)

### count(string field):int

[](#countstring-fieldint)

其它信息获取
------

[](#其它信息获取)

### getPK():string

[](#getpkstring)

返回表中的主键,调用前一定要先调用table设置表

### getPDO(bool isWrite = false): PDO

[](#getpdobool-iswrite--false-pdo)

返回pdo对象

### getQueryParams():array

[](#getqueryparamsarray)

返回组装sql连贯操作中的查询参数数组

### getFields():array

[](#getfieldsarray)

返回指定表中的字段

```
 [$this->queryParams['where'], $this->bindParam];
```

执行原生SQL
-------

[](#执行原生sql)

### query(string sql,array params=\[\]):array

[](#querystring-sqlarray-paramsarray)

查询记录集可以使用query,如果参数不为空则会覆盖where条件中绑定的参数

```
//执行sql后，会自动返回所有数据
$sql='select * from kl_event_log';
$db->query($sql);
```

### exec(string sql,array params=\[\]):int

[](#execstring-sqlarray-paramsint)

如果是一些更新插入操作使用exec，如果参数不为空则会覆盖where条件中绑定的参数

```
$db->exec("CREATE TABLE table (
  c1 INT STORAGE DISK,
  c2 INT STORAGE MEMORY
) ENGINE NDB;");
// 注意:有些语句是没有影响行数的,如上所示,这个时候会自动判断有没有错误,如果有错误会返回false,
// 可以使用 getLastError() 获取最后一次执行后的错误提示
```

数据的增删改
------

[](#数据的增删改)

### 添加数据

[](#添加数据)

成功返回自增id值,添加时要使用sql中的函数可在字段前面加个‘#’就可以使用,批量添加可以用多维数组，会自动使用事务进行操作，(表引擎要使用InnoDB),批量添加返回值不会返回自增id这点要注意

```
$db->table('log')->add([
'content'=>'neirong',
'#addtime'=>'NOW()'
  ]);
```

### 更新数据

[](#更新数据)

成功返回影响行数

```
$db->table('log')
    ->where(['id'=>1])
    ->update($data);
```

条件为空时不更新任何数据,确实是想更新全表请传 1=1 另外如果想在原有字段上执行算术运算可以用下面方法

```
$db->table('log')
->where(['id'=>1])
->update([
  'views[+]'=>2,
  'views[-]'=>2,
  'views[*]'=>2,
  'views[/]'=>2,
]);
```

### 删除数据

[](#删除数据)

成功返回影响行数,条件为空时不删除任何数据,确实想删除全表请传 1=1

```
$db->table('log')
    ->where(['id'=>1])
    ->delete();
//使用主键删除
$db->table('log')->delete(1);
```

字段操作
----

[](#字段操作)

对指定字段进行运算更新

### setInc(string fiela,int num=1):int

[](#setincstring-fielaint-num1int)

加法运算

### setDec(string field,int num=1):int

[](#setdecstring-fieldint-num1int)

减法运算

### fieldOperation(string field,int num=0,string operation='+'):int

[](#fieldoperationstring-fieldint-num0string-operationint)

\[字段\],\[数字\],\['+,-,\*,/'\]

事务处理
----

[](#事务处理)

### beginTransaction()

[](#begintransaction)

事务处理支持嵌套,子事务回滚只会回滚子事务中的操作，提交事务只会提交最外层事务的提交。内层子事务提交会被忽略

开启事务，这种方法需要手动提交和回滚

```
try {
  $db->beginTransaction(); // 开启一个事务
  $row = null;
  $row = $db->query("xxx"); // 执行第一个 SQL
  if (!$row)
    throw new PDOException('提示信息或执行动作'); // 如出现异常提示信息或执行动作
  $row = $db->table("xxx")->add(); // 执行第二个 SQL
  if (!$row)
    throw new PDOException('提示信息或执行动作');
  //这里的代码也可以随时调用 $pdo->rollback();回滚操作
  $db->commit();
} catch (PDOException $e) {
  $db->rollback(); // 执行失败，事务回滚
  exit($e->getMessage());
}
```

### transaction(Closure callback)

[](#transactionclosure-callback)

使用一个回调函数来执行事务,如果抛出异常则自动回滚操作，否则自动提交修改

```
$db->transaction(function()use($data){
  //执行一些操作
  //.......

  //出现错误跑出异常回滚
  throw new PDOException('add data error ', 1);
});
```

调试
--

[](#调试)

### fetchSql(bool bo=true)

[](#fetchsqlbool-botrue)

默认为true,结果集为当前执行的sql语句

### setDebug(bool isDebug=false)

[](#setdebugbool-isdebugfalse)

全局设置调试状态,会影响全部查询, 关闭后如果有缓存对象则会缓存主键,表字段等信息

### isDebug()

[](#isdebug)

数据库当前调试状态

### abort(bool isAbort=true)

[](#abortbool-isaborttrue)

默认为true，查询结果会直接中断，并输出sql语句

### getLastSql():string

[](#getlastsqlstring)

取最后一次执行的sql语句

### getLastError():string

[](#getlasterrorstring)

取最后一次执行的报错

### log():array

[](#logarray)

取所有执行的日志(sql语句)

### info():array

[](#infoarray)

取服务器信息

其它功能
----

[](#其它功能)

### setCache(CacheInterface obj): void

[](#setcachecacheinterface-obj-void)

设置缓存对象,可以加速数据库的访问,把常用的主键和字段信息保存到缓存中，缓存类需要实现接口 **Psr\\SimpleCache\\CacheInterface**

### setBindParam(array value): void

[](#setbindparamarray-value-void)

修改sql查询预处理后绑定的参数，这个可以配合**getWhere**来使用

### getWhere(array data = \[\]):array

[](#getwherearray-data--array)

返回生成的where条件，参数可以为空，不为空的话会覆盖原来条件，使用这个方法后查询的所有参数为重置，就不能使用select update..等查询语句，条件需要重新设置。返回结果为 **\[sql string,bind param\]**

### addEventListener(string $eventType, $handler)

[](#addeventlistenerstring-eventtype-handler)

添加事件监听器,具体事件可参数类常量

### removeEventListener(string $eventType, $handler)

[](#removeeventlistenerstring-eventtype-handler)

移除事件监听器

### trigger(string $eventType, array $eventData = \[\])

[](#triggerstring-eventtype-array-eventdata--)

触发指定事件,且会在eventData此数组前面插入当前数据库对象,然后当做参数传给事件处理器

### getConnections(): array

[](#getconnections-array)

返回所有pdo连接对象

SQLite示例
--------

[](#sqlite示例)

```
//创建一个表
$db->exec('
CREATE TABLE "kl_content" (
"id"  INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
"username"  INTEGER NOT NULL DEFAULT \'\',
"pwd"  INTEGER NOT NULL DEFAULT \'\',
"create_time"  INTEGER NOT NULL DEFAULT 0
);
');
$result = $db->table('content')->abort(false)->add([
  'username'    => 'testusername',
  'pwd'         => 'adminpwd',
  'create_time' => time(),
]);
echo $result;
$list = $db->table('content')->select();
var_dump($list);
$result = $db->table('content')->where(['id' => 1])->update(['username' => 'updateusername']);
echo $result;
$result = $db->table('content')->where(['id' => 2])->delete();
echo $result;
```

###  Health Score

30

—

LowBetter than 64% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity11

Limited adoption so far

Community7

Small or concentrated contributor base

Maturity69

Established project with proven stability

 Bus Factor1

Top contributor holds 100% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~10 days

Total

40

Last Release

1877d ago

Major Versions

1.0.33 → 2.0.02020-10-29

PHP version history (2 changes)1.0.19PHP >=7.1

2.0.8PHP >=7.4

### Community

Maintainers

![](https://www.gravatar.com/avatar/e531cf3f13357c2fc120a3c9335f05a92a88ac517a584dd7f0595865c4c129c7?d=identicon)[735579768](/maintainers/735579768)

---

Top Contributors

[![735579768](https://avatars.githubusercontent.com/u/2497797?v=4)](https://github.com/735579768 "735579768 (131 commits)")

---

Tags

mysqloracle-11gsqlite

###  Code Quality

TestsPHPUnit

### Embed Badge

![Health badge](/badges/mokuyu-mokuyu/health.svg)

```
[![Health](https://phpackages.com/badges/mokuyu-mokuyu/health.svg)](https://phpackages.com/packages/mokuyu-mokuyu)
```

###  Alternatives

[phpfastcache/phpfastcache

PHP Abstract Cache Class - Reduce your database call using cache system. Phpfastcache handles a lot of drivers such as Apc(u), Cassandra, CouchBase, Couchdb, Dynamodb, Firestore, Mongodb, Files, (P)redis, Leveldb, Memcache(d), Ravendb, Ssdb, Sqlite, Wincache, Xcache, Zend Data Cache.

2.4k5.0M130](/packages/phpfastcache-phpfastcache)[directorytree/ldaprecord

A fully-featured LDAP ORM.

5782.9M10](/packages/directorytree-ldaprecord)[kreait/firebase-bundle

Symfony Bundle for the Firebase Admin SDK

1534.7M2](/packages/kreait-firebase-bundle)[topthink/think-orm

the PHP Database&ORM Framework

4542.0M218](/packages/topthink-think-orm)[matthiasmullie/scrapbook

Scrapbook is a PHP cache library, with adapters for e.g. Memcached, Redis, Couchbase, APCu, SQL and additional capabilities (e.g. transactions, stampede protection) built on top.

3212.5M32](/packages/matthiasmullie-scrapbook)[jackalope/jackalope-doctrine-dbal

Jackalope Transport library for Doctrine DBAL

1503.0M214](/packages/jackalope-jackalope-doctrine-dbal)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)