\think\dbConnection

__construct()

__construct(array  $config = array()) 

架构函数 读取数据库配置信息

Parameters

instance()

instance(mixed  $config = array(), boolean|string  $name = false) : \think\db\Connection

取得数据库连接类实例

Parameters

Throws

\think\Exception

Returns

getBuilderClass()

getBuilderClass() : string

获取当前连接器类对应的Builder类

Returns

getBuilder()

getBuilder() : \think\db\Builder

获取当前的builder实例对象

Returns

getFields()

getFields(string  $tableName) : array

取得数据表的字段信息

Parameters

Returns

getTables()

getTables(string  $dbName) : array

取得数据库的表信息

Parameters

Returns

fieldCase()

fieldCase(array  $info) : array

对返数据表字段信息进行大小写转换出来

Parameters

Returns

getFieldBindType()

getFieldBindType(string  $type) : integer

获取字段绑定类型

Parameters

Returns

parseSqlTable()

parseSqlTable(string  $sql) : string

将SQL语句中的__TABLE_NAME__字符串替换成带前缀的表名（小写）

Parameters

Returns

getTableInfo()

getTableInfo(mixed  $tableName, string  $fetch = '') : mixed

获取数据表信息

Parameters

Returns

getPk()

getPk(string  $tableName) : string|array

获取数据表的主键

Parameters

Returns

getTableFields()

getTableFields(string  $tableName) : array

获取数据表字段信息

Parameters

Returns

getFieldsType()

getFieldsType(string  $tableName, string  $field = null) : array|string

获取数据表字段类型

Parameters

Returns

getFieldsBind()

getFieldsBind(string  $tableName) : array

获取数据表绑定信息

Parameters

Returns

getConfig()

getConfig(string  $config = '') : mixed

获取数据库的配置参数

Parameters

Returns

setConfig()

setConfig(string|array  $config, mixed  $value = '') : void

设置数据库的配置参数

Parameters

connect()

connect(array  $config = array(), integer  $linkNum, array|boolean  $autoConnection = false) : \PDO

连接数据库方法

Parameters

Throws

\think\Exception

Returns

free()

free() 

释放查询结果

getPdo()

getPdo() : \PDO|false

获取PDO对象

Returns

getCursor()

getCursor(string  $sql, array  $bind = array(), boolean  $master = false, \think\db\Model  $model = null, array  $condition = null, mixed  $relation = null) : \Generator

执行查询 使用生成器返回数据

Parameters

Returns

query()

query(string  $sql, array  $bind = array(), boolean  $master = false, boolean  $pdo = false) : array

执行查询 返回数据集

Parameters

Throws

\think\db\exception\BindParamException

\PDOException

\Exception

\Throwable

Returns

execute()

execute(string  $sql, array  $bind = array(), \think\db\Query  $query = null) : integer

执行语句

Parameters

Throws

\think\db\exception\BindParamException

\PDOException

\Exception

\Throwable

Returns

find()

find(\think\db\Query  $query) : array|null|\PDOStatement|string

查找单条记录

Parameters

Throws

\think\db\DbException

\think\db\ModelNotFoundException

\think\db\DataNotFoundException

Returns

cursor()

cursor(\think\db\Query  $query) : \Generator

使用游标查询记录

Parameters

Returns

select()

select(\think\db\Query  $query) : array|\PDOStatement|string

查找记录

Parameters

Throws

\think\db\DbException

\think\db\ModelNotFoundException

\think\db\DataNotFoundException

Returns

insert()

insert(\think\db\Query  $query, boolean  $replace = false, boolean  $getLastInsID = false, string  $sequence = null) : integer|string

插入记录

Parameters

Returns

insertAll()

insertAll(\think\db\Query  $query, mixed  $dataSet = array(), boolean  $replace = false, integer  $limit = null) : integer|string

批量插入记录

Parameters

Throws

\Exception

\Throwable

Returns

selectInsert()

selectInsert(\think\db\Query  $query, string  $fields, string  $table) : integer|string

通过Select方式插入记录

Parameters

Throws

\think\exception\PDOException

Returns

update()

update(\think\db\Query  $query) : integer|string

更新记录

Parameters

Throws

\think\Exception

\think\exception\PDOException

Returns

delete()

delete(\think\db\Query  $query) : integer

删除记录

Parameters

Throws

\think\Exception

\think\exception\PDOException

Returns

value()

value(\think\db\Query  $query, string  $field, mixed  $default = null, boolean  $one = true) : mixed

得到某个字段的值

Parameters

Returns

aggregate()

aggregate(\think\db\Query  $query, string  $aggregate, mixed  $field) : mixed

得到某个字段的值

Parameters

Returns

column()

column(\think\db\Query  $query, string  $field, string  $key = '') : array

得到某个列的数组

Parameters

Returns

pdo()

pdo(\think\db\Query  $query) : \PDOStatement|string

执行查询但只返回PDOStatement对象

Parameters

Returns

getRealSql()

getRealSql(string  $sql, array  $bind = array()) : string

根据参数绑定组装最终的SQL语句 便于调试

Parameters

Returns

transaction()

transaction(callable  $callback) : mixed

执行数据库事务

Parameters

Throws

\think\exception\PDOException

\Exception

\Throwable

Returns

startTransXa()

startTransXa(string  $xid) : void

启动XA事务

Parameters

prepareXa()

prepareXa(string  $xid) : void

预编译XA事务

Parameters

commitXa()

commitXa(string  $xid) : void

提交XA事务

Parameters

rollbackXa()

rollbackXa(string  $xid) : void

回滚XA事务

Parameters

startTrans()

startTrans() : void

启动事务

Throws

\PDOException

\Exception

commit()

commit() : void

用于非自动提交状态下面的查询提交

Throws

\think\exception\PDOException

rollback()

rollback() : void

事务回滚

Throws

\think\exception\PDOException

batchQuery()

batchQuery(array  $sqlArray = array(), array  $bind = array()) : boolean

批处理执行SQL语句 批处理的指令都认为是execute操作

Parameters

Returns

getQueryTimes()

getQueryTimes(boolean  $execute = false) : integer

获得查询次数

Parameters

Returns

getExecuteTimes()

getExecuteTimes() : integer

获得执行次数

Returns

close()

close() : $this

关闭数据库（或者重新连接）

Returns

getLastSql()

getLastSql() : string

获取最近一次查询的sql语句

Returns

getLastInsID()

getLastInsID(string  $sequence = null) : string

获取最近插入的ID

Parameters

Returns

getNumRows()

getNumRows() : integer

获取返回或者影响的记录数

Returns

getError()

getError() : string

获取最近的错误信息

Returns

listen()

listen(callable  $callback) : void

监听SQL执行

Parameters

log()

log(  $log,   $type = 'sql') 

Parameters

__destruct()

__destruct() 

析构方法

initialize()

initialize() : void

初始化

setBuilder()

setBuilder(\think\db\Builder  $builder) : void

设置当前的数据库Builder对象

Parameters

parseDsn()

parseDsn(array  $config) : string

解析pdo连接的dsn信息

Parameters

Returns

getExplain()

getExplain(string  $sql) : array

SQL性能分析

Parameters

Returns

bindValue()

bindValue(array  $bind = array()) : void

参数绑定 支持 ['name'=>'value','id'=>123] 对应命名占位符 或者 ['value',123] 对应问号占位符

Parameters

Throws

\think\db\exception\BindParamException

bindParam()

bindParam(array  $bind) : void

存储过程的输入输出参数绑定

Parameters

Throws

\think\db\exception\BindParamException

getResult()

getResult(boolean  $pdo = false, boolean  $procedure = false) : array

获得数据集数组

Parameters

Returns

procedure()

procedure() : array

获得存储过程数据集

Returns

supportSavepoint()

supportSavepoint() : boolean

是否支持事务嵌套

Returns

parseSavepoint()

parseSavepoint(  $name) : string

生成定义保存点的SQL

Parameters

Returns

parseSavepointRollBack()

parseSavepointRollBack(  $name) : string

生成回滚到保存点的SQL

Parameters

Returns

isBreak()

isBreak(\PDOException|\Exception  $e) : boolean

是否断线

Parameters

Returns

debug()

debug(boolean  $start, string  $sql = '', boolean  $master = false) : void

数据库调试 记录当前SQL及分析性能

Parameters

triggerSql()

triggerSql(string  $sql, float  $runtime, mixed  $explain = array(), boolean  $master = false) : void

触发SQL事件

Parameters

initConnect()

initConnect(boolean  $master = true) : void

初始化数据库连接

Parameters

multiConnect()

multiConnect(boolean  $master = false) : \PDO

连接分布式服务器

Parameters

Returns

cacheData()

cacheData(string  $key, mixed  $data, array  $config = array()) 

缓存数据

Parameters

getCacheData()

getCacheData(\think\db\Query  $query, mixed  $cache,   $data,   $key = null) : mixed

获取缓存数据

Parameters

Returns

getCacheKey()

getCacheKey(\think\db\Query  $query, mixed  $value) : string

生成缓存标识

Parameters

Returns