Db 数据库辅助类

Db类提供封装和简化了数据库相关操作的调用,提高简单的静态调用接口。

接口和方法列表

快速创建ORM对象

可以通过table方法创建一个Orm对象,映射到数据库表,快速查询。 table方法返回的是一个Orm对象

table()方法快速查询

function table(string $name [,string $pk, [string $prefix]]):Orm
  • 参数:
    1. string $name[必填] :数据库表名
    2. string $pk[选填]: 主键值,默认orm而定为id
    3. string $prefix[选填]: 前缀,默认读取配置
  • 返回:Orm 对象
  • 如果需要对同一张表进行多次操作,可以创建赋值给一个变量,每次调用此变量提高性能
//快速查询
$name=Db::table('user')->where('id',2)->get('name');

//添加数据使用field进行字段过滤和别名设置
Db::table('feedback')
    ->field('user','name')
    ->field('content,call AS phone')
    ->insert($_POST);//快速插入数据,只是示例,对于写入用户数据进行检查是必要的

数据库管理

Db 类会根据需要自动创建数据库连接,并在生命周期类保存这些了连接资源。 单数据库默认不需要使用数据库管理和切换操作。

Db 操作同时提供多数据库操作接口。

Db 默认会自动使用配置中的默认的数据库进行调用,不会自动的进行读写分离或者切换。

Db切换数据库不会影响Model或者Orm中数据库的调用,table()方法使用的数据会按照Orm数据库切换规则切换。

current()方法:获取当前数据库

current返回当前正在使用的数据库对象

function current() :Database
  • 返回当前数据连接对象
  • 示例代码
$db=Db::current();
//切换数据库,等各种操作
//继续原来的$db
$db->query('some thing');

set()方法:设定并切换数据库

set方法手动切换设置数据库。

此方法不会影响直接查询对数据库的选择,但是会影响

注意:如果修改保留名称,此方法会影响 ModelOrm中默认读写数据库的调用.

function $name(string $name,mixed $config,[string $username,[string $password]]) :Database
  • 参数 $name(string): 数据库配置名称如果无则创建,有则覆盖
  • 参数 $config (必填): 可以是下列三项之一
    • string 数据库配置名称如 "_read","mydb",只要在[database] 下配置了即可;
    • string dsn设置 如: "sqlite:/tmp/sql.db";
    • array 数据库链接配置,包括dsn,username,password;
  • 参数 $username string: 数据库账号 (当$cofnig为dsn时选填)
  • 参数 $password string: 数据库密码 (当$cofnig为dsn时选填)
  • tips :

    • $name_ 会修改 Db,ModelOrm 等数据库操作使用的默认数据库
    • $name_read会修改 Db, ModelOrm 等数据库读取操作的数据库
    • $name_write会修改 Db, ModelOrm 等数据库写入操作的数据库
  • 返回 : 数据库对象

  • 示例代码

/*配置名称切换数据库,'_','_read','_write'三个是保留数据库名*/
Db::set('_','_read')->query('query something');//切换到读数据库
Db::set('_write','mydb')->exec($sql);//执行

Db::exec($sql2);//此时仍然使用mydb写

/*dsn*/
Db::set('temp','sqlite:/tmp/sql.db')->query($sql);
/*多参数设置*/
Db::set('_write','mysql:host=localhost;port=3306;dbname=yyf;charset=utf8','root','root');
/*array*/
Db::set('test',[
   'dsn'=>'mysql:host=localhost;port=3306;dbname=yyf;charset=utf8',
   'username'=>'root'
 ]);

connect()方法:建立数据库

connect方法建立数据库,而不影响之后或者其他的数据调用

注意: 此方法为临时调用,不会影响之后数据库切换

function connect(mixed $config):Database
  • 参数 $config (必填): 可以是下列两项之一
    • string 数据库配置名称如 "_read","mydb",只要在[database] 下配置了即可;
    • array 数据库链接配置,包括dsn,username,password;
  • 返回: 数据库Database对象
  • tips: 此方法不会影响之后数据库调用使用的数据库连接
  • 示例代码
/*配置名称连接*/
Db::use('_read')->query('query something');//切换到读数据库

/*新建一个数据库连接*/
Db::connect('mysql:host=localhost;port=3306;dbname=yyf;charset=utf8','root','root');
/*array方式连接*/
Db::connect([
    'dsn'=>'mysql:host=localhost;port=3306;dbname=yyf;charset=utf8',
    'username'=>'root'
 ])->exec($sql);

//使用默认数据库
Db::query($sql);//此时任然是_read数据库

sql语句查询

Db根据需要自动建立数据库连接,可以调用Database的所有方法接口

可以直接执行或者调用sql语句.但是对于新手或者对安全不太了解的,不推荐这么使用,因为这样容易造成潜在的SQL注入风险,如果确实要这么做,务必使用参数分离的方式进行查询。

同时,常用的数据方法使用静态方式加速,并自动读写分离.

query()查询sql语句(读):

数据库读取(select)查询,是对 Database::query()的快速调用。

示例代码

//原生sql查询
$list=Db::query('select id,name from user');
//键值对参数分离
$data=Db::query('select * from user where id=:id',['id'=>2]);

column()查询sql语句(读):

数据库单条读取(select)查询,是对 Database::column()的快速调用。

示例代码

//键值对参数分离
$name=Db::column('select name from user where id=?',[123]);

execute()执行sql语句:

execute是exec的别名,用来覆盖Db方法的私有方法execute。

建议尽量exec来调用,因为Database提供了exec接口而不是execute。

Db::execute($sql)可以执行,等效Db::exec($sql);

但是Db::current()->execute($sql)会出错,应该使用`Db::current()->exec($sql);

exec()执行sql语句(写):

数据库写操作执行,是对 Database::exec()的快速调用。

示例代码:

//执行sql语句,参数绑定
Db::exec('UPDATE`user`SET(`time`=?)WHERE(`id`=?)',[date('Y-m-d h:i:s'),2]);

Database 静态方式调用

Db 类会根据需要自动创建数据库连接,并在生命周期类保存这些了连接资源

支持所有Database接口

如预处理:

//预处理方式查询
Db::prepare('UPDATE`user`SET(`time`=?)WHERE(`id`=?)')
    ->execute([date('Y-m-d h:i:s'),2]);

如原生事务:

Db::beginTransaction();//开始事务
try{
    Db::exec('do something ...');
    Db::query('do something ...');
    Db::exec('do something ...');
    /*更多查询...*/
    Db::commit();//事务成提交
} catch (Exception $e) {
    Db::rollBack();//出错回滚
}

注意:对于多数据库的情况,事务调用过程中不能切换数据库

对ORM或者model的操作,建议使用orm封装的事务操作transact();

或者使用数据库transact方法

Copyright © NewFuture 2016 all right reserved,powered by Gitbook上次修改时间: 2019-10-06 07:22:49

results matching ""

    No results matching ""