ThinkPHP 6 数据库操作指南：深入解析查询构建器与ORM244

 

在现代Web应用开发中，数据库操作是核心环节。ThinkPHP作为国内广泛使用的PHP框架，为开发者提供了强大、灵活且高效的数据库操作能力。无论是简洁的查询构建器（Query Builder）还是优雅的对象关系映射（ORM），ThinkPHP都能帮助开发者轻松实现数据交互。本文将深入探讨ThinkPHP 6中数据库查询的各种方式，从基础配置到高级特性，助您成为ThinkPHP数据库操作的行家里手。

一、ThinkPHP 6 数据库配置

在开始数据库查询之前，我们首先需要配置数据库连接。ThinkPHP 6的数据库配置文件通常位于 `config/`。以下是一个典型的配置示例：
return [
// 默认使用的数据库连接配置
'default' => env('', 'mysql'),
// MySQL数据库配置
'connections' => [
'mysql' => [
// 数据库类型
'type' => env('', 'mysql'),
// 服务器地址
'hostname' => env('', '127.0.0.1'),
// 数据库名
'database' => env('', 'tp6_demo'),
// 用户名
'username' => env('', 'root'),
// 密码
'password' => env('', 'root'),
// 端口
'hostport' => env('', '3306'),
// 连接DSN
'dsn' => '',
// 数据库连接参数
'params' => [],
// 数据库编码默认采用utf8mb4
'charset' => env('', 'utf8mb4'),
// 数据库表前缀
'prefix' => env('', 'tp_'),
// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
'deploy' => 0,
// 数据库读写是否分离 主从式有效
'rw_separate' => false,
// 读写分离后 主服务器数量
'master_num' => 1,
// 指定从服务器序号
'slave_no' => '',
// 是否严格检查字段是否存在
'fields_strict' => true,
// 数据集返回类型
'resultset_type' => 'array',
// 自动写入时间戳字段
'auto_timestamp' => false,
// 时间字段取出后的默认时间格式
'datetime_format' => 'Y-m-d H:i:s',
// 是否开启SQL监听
'sql_log' => false,
// SQL缓存
'sql_build_cache' => false,
// SQL缓存有效期（秒）
'sql_build_cache_expire' => 20,
// 开启断线重连
'break_reconnect' => true,
],
],
];

为了安全性与灵活性，建议将敏感信息（如数据库名、用户名、密码）存储在 `.env` 环境文件中，并通过 `env()` 函数读取。

二、核心查询方式概览

ThinkPHP 6主要提供两种核心的数据库查询方式：
查询构建器（Query Builder）：通过 `\think\facade\Db` 门面（Facade）提供，以链式操作构建SQL语句，灵活且功能强大。
模型（ORM）：通过继承 `\think\Model` 类，将数据库表映射为对象，以对象化的方式进行数据操作，更符合面向对象编程的习惯，尤其适用于复杂业务逻辑和关联操作。

接下来我们将详细介绍这两种方式的用法。

三、查询构建器（Query Builder）

查询构建器是ThinkPHP提供的一套轻量级、高性能的数据库操作接口。它通过链式操作构建SQL语句，支持各种复杂的查询条件、聚合函数、联表查询等。

3.1 链式操作基础

所有查询都从 `Db::table('表名')` 或 `Db::name('表名_不带前缀')` 开始。
use think\facade\Db;
// 查询tb_user表的所有数据（返回数组）
$users = Db::table('tp_user')->select();
// 等价于 Db::name('user')->select();
// 查询单条数据
$user = Db::table('tp_user')->where('id', 1)->find();
// 获取某个字段的值
$username = Db::table('tp_user')->where('id', 1)->value('username');
// 获取某个列的值
$usernames = Db::table('tp_user')->column('username');

3.2 WHERE 条件

`where()` 方法是构建查询条件的核心。
// 等值查询
Db::table('tp_user')->where('id', 1)->find();
Db::table('tp_user')->where(['id' => 1, 'status' => 1])->select(); // 多个条件，AND关系
// 表达式查询
Db::table('tp_user')->where('age', '>', 18)->select();
Db::table('tp_user')->where('name', 'like', '%think%')->select();
Db::table('tp_user')->where('create_time', 'between', ['2023-01-01', '2023-12-31'])->select();
Db::table('tp_user')->where('id', 'in', [1, 3, 5])->select();
Db::table('tp_user')->whereRaw('id = ? AND status = ?', [1, 1])->find(); // 原生表达式
// OR 条件
Db::table('tp_user')->where('id', 1)->whereOr('status', 0)->select();
// 更清晰的OR：使用闭包
Db::table('tp_user')
->where(function ($query) {
$query->where('id', '>', 10)->whereOr('status', 0);
})->select();

3.3 排序、限制与分页

// 排序
Db::table('tp_user')->order('create_time', 'desc')->select(); // 按创建时间倒序
Db::table('tp_user')->order(['age' => 'desc', 'id' => 'asc'])->select(); // 多个字段排序
// 限制数量
Db::table('tp_user')->limit(10)->select(); // 取前10条
Db::table('tp_user')->limit(5, 10)->select(); // 从第5条开始，取10条
// 分页（推荐）
$list = Db::table('tp_user')->paginate(10); // 每页10条数据，自动处理页码
// 手动分页
$page = request()->param('page', 1); // 获取当前页码
$list = Db::table('tp_user')->page($page, 10)->select();

3.4 字段操作

// 指定查询字段
Db::table('tp_user')->field('id, username, email')->select();
// 排除字段
Db::table('tp_user')->fieldRaw('*, password AS pwd')->select(); // 原生字段表达式

3.5 联表查询（JOIN）

// 假设用户表(tp_user)和个人资料表(tp_profile)通过user_id关联
Db::table('tp_user')
->alias('u') // 为user表设置别名
->join('tp_profile p', ' = p.user_id', 'LEFT') // 左连接profile表，并设置别名p
->field(', , ')
->select();

3.6 聚合查询与分组

// 统计总数
$count = Db::table('tp_user')->count();
// 计算平均值
$avgAge = Db::table('tp_user')->avg('age');
// 求和
$totalAmount = Db::table('tp_order')->where('user_id', 1)->sum('amount');
// 最大值、最小值
$maxId = Db::table('tp_user')->max('id');
// 分组查询
Db::table('tp_order')
->field('user_id, sum(amount) as total_amount')
->group('user_id')
->having('total_amount', '>', 1000) // 分组后条件
->select();

3.7 增删改操作

// 插入数据
$data = ['username' => 'testuser', 'password' => md5('123456'), 'create_time' => date('Y-m-d H:i:s')];
$userId = Db::table('tp_user')->insertGetId($data); // 插入并返回自增ID
Db::table('tp_user')->insert($data); // 仅插入，返回布尔值
// 批量插入
$dataList = [
['username' => 'user1', 'password' => '123'],
['username' => 'user2', 'password' => '456'],
];
Db::table('tp_user')->insertAll($dataList);
// 更新数据
Db::table('tp_user')
->where('id', 1)
->update(['username' => 'newname', 'email' => 'new@']);
// 删除数据
Db::table('tp_user')->where('id', 1)->delete();
Db::table('tp_user')->delete([1, 2, 3]); // 批量删除

四、模型（ORM）

ThinkPHP的ORM是基于ActiveRecord模式的，它将数据库表映射为PHP类，使开发者可以使用对象属性和方法进行数据库操作，极大地提高了开发效率和代码可读性。

4.1 定义模型

模型类通常放在 `app/model` 目录下，并继承 `\think\Model`。模型类名与数据库表名（不含前缀）对应，且采用大驼峰命名。
// app/model/
namespace app\model;
use think\Model;
class User extends Model
{
// 设置当前模型对应的完整数据表名称
protected $table = 'tp_user';
// 定义主键
protected $pk = 'id';
// 开启自动写入时间戳字段
protected $autoWriteTimestamp = true;
// 定义创建时间字段
protected $createTime = 'create_time';
// 定义更新时间字段
protected $updateTime = 'update_time';
// 定义时间戳字段名，如果数据库中是`create_at`和`update_at`，则可省略
// protected $dateFormat = 'Y-m-d H:i:s'; // 获取器中可定义

// 可以定义字段的获取器/修改器等
public function getStatusTextAttr($value, $data)
{
$status = [0 => '禁用', 1 => '启用'];
return $status[$data['status']];
}
}

4.2 CRUD 操作

一旦定义了模型，就可以使用静态方法或实例方法进行CRUD操作。
use app\model\User;
// 查询单条
$user = User::find(1); // 通过主键查询
if ($user) {
echo $user->username;
echo $user->status_text; // 访问获取器
}
// 查询多条
$users = User::where('status', 1)->limit(10)->order('create_time', 'desc')->select();
foreach ($users as $user) {
echo $user->username . "";
}
// 创建新数据（插入）
$newUser = User::create([
'username' => 'new_orm_user',
'password' => md5('password'),
'email' => 'orm@',
'status' => 1
]);
echo "新用户ID: " . $newUser->id;
// 更新数据
$user = User::find(1);
if ($user) {
$user->username = 'updated_orm_user';
$user->email = 'update@';
$user->save(); // 保存修改
}
// 删除数据
$user = User::find(2);
if ($user) {
$user->delete(); // 删除单条
}
User::destroy(3); // 通过主键删除
User::destroy([4, 5]); // 批量删除
User::where('status', 0)->delete(); // 条件删除

4.3 关联模型（Relation）

ORM的强大之处在于其对关联模型（一对一、一对多、多对多等）的支持，极大地简化了复杂数据结构的操作。例如，一个用户可能有一个个人资料（一对一）：
// app/model/
namespace app\model;
use think\Model;
class Profile extends Model
{
protected $table = 'tp_profile';
protected $pk = 'id';
// 定义与User模型的一对一关联，Profile属于User
public function user()
{
return $this->belongsTo(User::class);
}
}
// app/model/ (添加关联方法)
class User extends Model
{
// ...
// 定义与Profile模型的一对一关联，User有一个Profile
public function profile()
{
return $this->hasOne(Profile::class);
}
}
// 使用关联
$user = User::find(1);
if ($user && $user->profile) {
echo $user->profile->gender; // 访问关联模型的数据
}
// 预载入关联数据（避免N+1查询问题）
$users = User::with('profile')->select();
foreach ($users as $user) {
echo $user->profile->gender;
}

五、原生SQL查询

在某些复杂或特殊场景下，查询构建器或ORM可能无法满足需求，这时可以直接执行原生SQL语句。
use think\facade\Db;
// 执行查询语句，返回结果集
$result = Db::query('SELECT * FROM tp_user WHERE id = ? AND status = ?', [1, 1]);
print_r($result);
// 执行写入、更新、删除等非查询语句，返回影响的行数
$affectedRows = Db::execute('UPDATE tp_user SET username = ? WHERE id = ?', ['RawUser', 1]);
echo "影响行数：" . $affectedRows;

注意：使用原生SQL时，务必使用预处理语句（Prepare Statement）来绑定参数（如示例中的 `?`），以有效防止SQL注入攻击。

六、高级特性与最佳实践

6.1 事务处理

事务用于保证一组数据库操作的原子性，要么全部成功，要么全部失败回滚。
use think\facade\Db;
Db::transaction(function () {
Db::table('tp_user')->where('id', 1)->update(['score' => Db::raw('score - 100')]);
Db::table('tp_order')->insert(['user_id' => 1, 'amount' => 100]);
// 模拟一个错误，会触发回滚
// throw new \Exception("模拟错误，事务回滚");
});

也可以手动控制事务：
try {
Db::startTrans();
// 数据库操作1
Db::table('tp_user')->where('id', 1)->update(['score' => Db::raw('score - 100')]);
// 数据库操作2
Db::table('tp_order')->insert(['user_id' => 1, 'amount' => 100]);
Db::commit(); // 提交事务
} catch (\Exception $e) {
Db::rollback(); // 回滚事务
echo "操作失败：" . $e->getMessage();
}

6.2 SQL 注入防护

ThinkPHP的查询构建器和ORM默认使用参数绑定机制，可以有效防止SQL注入。当使用 `where()`、`insert()`、`update()` 等方法时，无需手动进行参数转义。

但当使用 `whereRaw()`、`query()`、`execute()` 等方法执行原生SQL时，必须使用参数绑定（如 `Db::query('SELECT * FROM user WHERE id = ?', [$id])`）而不是直接拼接用户输入，这是防止SQL注入的关键。

6.3 调试与日志

开启 `config/` 中的 `app_debug = true`，ThinkPHP会在页面底部显示当前请求执行的所有SQL语句及耗时，方便调试。也可以通过 `Db::getLastSql()` 获取最后一条执行的SQL语句。
// 执行一些查询
Db::table('tp_user')->where('id', 1)->find();
Db::table('tp_order')->select();
// 获取最后一条SQL
echo Db::getLastSql();

6.4 性能优化

合理使用索引：在 `WHERE`、`ORDER BY`、`JOIN` 条件中涉及的字段上创建索引。
避免N+1查询：对于关联查询，使用 `with()` 方法进行预载入（Eager Loading），避免在循环中重复查询关联数据。
按需选择字段：使用 `field()` 方法只查询需要的字段，减少数据传输量。
批量操作：对于大量数据的插入、更新、删除，尽量使用 `insertAll()`、批量 `update()` 等方式，减少数据库连接次数。

七、总结

ThinkPHP 6为数据库操作提供了全面且易用的解决方案。查询构建器以其灵活性和高性能，适用于各种常规查询和复杂的SQL构建；而ORM模型则以其面向对象的优雅，简化了业务逻辑的实现和维护，尤其在处理复杂数据关联时优势明显。

掌握这两种核心查询方式，结合事务处理、安全防护和性能优化等最佳实践，您将能够高效、安全地在ThinkPHP项目中进行数据库交互，构建出稳定可靠的Web应用。

2025-11-06

---

上一篇：深入解析：使用PHP自动获取并管理Bing每日精选壁纸

下一篇：PHP高效打包本地文件：从ZIP、TAR到PHAR，全方位实践指南