尽量不要使用助手函数,助手函数每次调用都会实例化,DB调用属于单例操作。
1 链接数据库
1.1 方式一 :配置文件配置
常用的配置方式是在应用目录或者模块目录下面的datebase.php
(如果没有看下config.php
),按参数填写即可,参数就不做讲解,看文档。
1.2 方式二 :在控制器里面配置(适合链接外部数据库【可以多个】)
随便选择新建一个控制器,在头部引入DB类,use think\DB
(DB大写,小写就不报think\db找不到,不知道是不是版本问题),在方法中可以调用如下两种方法:
//链接数据库方法1
$db = Db::connect([
// 数据库类型
'type' => 'mysql',
// 数据库连接DSN配置
'dsn' => '',
// 服务器地址
'hostname' => '127.0.0.1',
// 数据库名
'database' => 'thinkphp',
// 数据库用户名
'username' => 'root',
// 数据库密码
'password' => '',
// 数据库连接端口
'hostport' => '',
// 数据库连接参数
'params' => [],
// 数据库编码默认采用utf8
'charset' => 'utf8',
// 数据库表前缀
'prefix' => 'think_',
]);
//方法2
/*
$db = Db::connect('mysql://root:1234@127.0.0.1:3306/thinkphp#utf8');(数据库类型://用户名:密码@数据库地址:数据库端口/数据库名#字符集)
/*
//进行插入操作
if($res = $db->table('cms_user')->insert($data)){
dd($res);//打印
}else{
dd('插入失败!');
}
1.3 模型类定义
如果在某个模型类里面定义了connection属性的话,则该模型操作的时候会自动连接给定的数据库连接,而不是配置文件中设置的默认连接信息,通常用于某些数据表位于当前数据库连接之外的其它数据库,例如下面两种方式:
//在模型里单独设置数据库连接信息
namespace app\index\model;
use think\Model;
class User extends Model
{
//方法一
protected $connection = [
// 数据库类型
'type' => 'mysql',
// 数据库连接DSN配置
'dsn' => '',
// 服务器地址
'hostname' => '127.0.0.1',
// 数据库名
'database' => 'thinkphp',
// 数据库用户名
'username' => 'root',
// 数据库密码
'password' => '',
// 数据库连接端口
'hostport' => '',
// 数据库连接参数
'params' => [],
// 数据库编码默认采用utf8
'charset' => 'utf8',
// 数据库表前缀
'prefix' => 'think_',
];
//方法二:DSN字符串定义
// protected $connection = 'mysql://root:1234@127.0.0.1:3306/thinkphp#utf8';
}
2 基本使用
2.1 查询
- query sql语句普通查询/占位符
- Db::query('select * from think_user where id=?',[8]); //"?"为占位符
- Db::connect($config)->query('select * from think_user where id=:id',['id'=>8]);//链接外部数据库操作
- find 查询单挑数据
- Db::table('think_user')->where('id',1)->find();
- select 查询结果集
- Db::table('think_user')->where('status',1)->select();
- 闭包查询
- Db::select(function($query){
$query->table('think_user')->where('status',1);
});
- 值和列查询(value,column)
// 返回某个字段的值
Db::table('think_user')->where('id',1)->value('name');
// 返回数组
Db::table('think_user')->where('status',1)->column('name');
// 指定索引
Db::table('think_user')->where('status',1)->column('name','id');
Db::table('think_user')->where('status',1)->column('id,name'); // 同tp3的getField
- 数据集分批处理chunk
如果你需要处理成千上百条数据库记录,可以考虑使用chunk方法,该方法一次获取结果集的一小块,然后填充每一小块数据到要处理的闭包,该方法在编写处理大量数据库记录的时候非常有用。
比如,我们可以全部用户表数据进行分批处理,每次处理 100 个用户记录:
Db::table('think_user')->chunk(100, function($users) {
foreach ($users as $user) {
//
if(){
return false;//结束查询
}
}
});
// 或者交给回调方法myUserIterator处理
Db::table('think_user')->chunk(100, 'myUserIterator');
3. 新增数据 insert
- 普通方式
$data = ['foo' => 'bar', 'bar' => 'foo'];
Db::table('think_user')->insert($data);
- 新增后返回新增id
Db::table('think_user')->getLastInsID();
- 或者直接使用
insertGetId
方法直接新增返回id
Db::table('think_user')->insertGetId($data);
- 添加多条数据
insertAll
$data = [
['foo' => 'bar', 'bar' => 'foo'],
['foo' => 'bar1', 'bar' => 'foo1'],
['foo' => 'bar2', 'bar' => 'foo2']
];
Db::table('think_user')->insertAll($data);
4. 更新数据
- 普通更新方式
Db::table('think_user')->where('id', 1)->update(['name' => 'thinkphp']);//无主键
Db::table('think_user')->update(['name' => 'thinkphp','id'=>1]);//有主键id
update 方法返回影响数据的条数,没修改任何数据返回 0
- 使用sql函数
Db::table('think_user')
->where('id', 1)
->update([
'login_time' => ['exp','now()'],
'login_times' => ['exp','login_times+1'],
]);
- 更新某个字段的值
Db::table('think_user')->where('id',1)->setField('name', 'thinkphp');
- 自增或自减一个字段的值
// score 字段加 1
Db::table('think_user')->where('id', 1)->setInc('score');
// score 字段加 5
Db::table('think_user')->where('id', 1)->setInc('score', 5);
// score 字段减 1
Db::table('think_user')->where('id', 1)->setDec('score');
// score 字段减 5
Db::table('think_user')->where('id', 1)->setDec('score', 5);
5. 删除数据表中的数据
// 条件删除
Db::table('think_user')->where('id',1)->delete();
Db::table('think_user')->where('id','<',10)->delete();