CodeIgniter 4 原生不支持读写分离,需手动定义 read/write 数据库组并在 BaseModel 中按 SQL 类型动态选择连接,事务不跨连接,SELECT FOR UPDATE 等特殊语句须人工标注走主库。

CodeIgniter 4 原生不支持读写分离,必须通过自定义数据库组 + 手动路由 SQL 类型来实现;它没有像 Yii2 那样内置 slave 属性或自动识别 SELECT / INSERT 的机制,所以“透明读写分离”只能靠代码层拦截和判断,不能靠框架自动切换。
怎么在 database.php 中定义主从连接组
CI4 的多库配置比 CI3 更清晰:每个连接组是独立数组,不依赖全局 $db 变量。你得在 app/Config/Database.php 的 public $default 类属性之外,显式声明新连接实例。
- 复制一份
MySQLiConnection或PDOConnection配置,改名为read和write(命名任意,但建议语义化) -
hostname、username、password、database必须分别指向从库和主库,不要复用同一套凭据 -
DB_DEBUG建议设为ENVIRONMENT !== 'production',避免生产环境暴露敏感错误 - 不要设
autoConnect => true—— 否则每次请求都会连两次库(主+从),哪怕只执行写操作
示例片段(放在 app/Config/Database.php 类内部):
public $read = [
'DSN' => '',
'hostname' => $_ENV['DB_READ_HOST'] ?? '192.168.1.10',
'username' => $_ENV['DB_READ_USER'] ?? 'reader',
'password' => $_ENV['DB_READ_PASS'] ?? '',
'database' => $_ENV['DB_READ_NAME'] ?? 'app_db',
'DBDriver' => 'MySQLi',
'DBPrefix' => '',
'pConnect' => false,
'DBDebug' => (ENVIRONMENT !== 'production'),
'charset' => 'utf8mb4',
'DBCollat' => 'utf8mb4_unicode_ci',
'swapPre' => '',
'encrypt' => false,
'compress' => false,
'strictOn' => false,
'failover' => [],
'port' => 3306,
];
public $write = [
'DSN' => '',
'hostname' => $_ENV['DB_WRITE_HOST'] ?? '192.168.1.5',
'username' => $_ENV['DB_WRITE_USER'] ?? 'writer',
'password' => $_ENV['DB_WRITE_PASS'] ?? '',
'database' => $_ENV['DB_WRITE_NAME'] ?? 'app_db',
'DBDriver' => 'MySQLi',
'DBPrefix' => '',
'pConnect' => false,
'DBDebug' => (ENVIRONMENT !== 'production'),
'charset' => 'utf8mb4',
'DBCollat' => 'utf8mb4_unicode_ci',
'swapPre' => '',
'encrypt' => false,
'compress' => false,
'strictOn' => false,
'failover' => [],
'port' => 3306,
];
如何在 Model 中按 SQL 类型动态选择连接
CI4 没有 $this->db->read() 这种语法,也不能靠重写 Loader 或 DB_driver(因为核心类已改为可注入式服务)。最稳妥的做法是:在基类 Model 中封装两个连接实例,并根据方法名或显式标记决定走哪条路。
- 在
app/Models/BaseModel.php构造函数中加载两个连接:$this->readDB = \Config\Database::connect('read');和$this->writeDB = \Config\Database::connect('write'); - 所有
insert()、update()、delete()、replace()必须调用$this->writeDB实例 - 所有
find()、findAll()、select()->get()默认走$this->readDB,除非显式传参['force_write' => true] - 避免在同一个事务里混用两个连接——CI4 的事务不跨连接,
$this->writeDB->transStart()对$this->readDB完全无效
简单判断逻辑示例(放在 BaseModel 的查询方法中):
protected function getQueryConnection(array $options = []): BaseConnection
{
if ($options['force_write'] ?? false) {
return $this->writeDB;
}
$backtrace = debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS, 2);
$caller = $backtrace[1]['function'] ?? '';
// 写操作方法名特征
if (in_array($caller, ['insert', 'update', 'delete', 'replace', 'save'], true)) {
return $this->writeDB;
}
return $this->readDB;
}
单元测试怎么验证读写分离是否生效
CI4 的测试默认只连 default 连接,而你定义的 read / write 组不会被自动加载。不 mock 连接对象的话,测试会直接连真实数据库,既慢又不可控。
- 在
tests/_support/DatabaseTestCase.php中重写setUp(),手动注册测试专用连接(比如都指向 SQLite 内存库) - 用
Mockery::mock()替换BaseConnection子类,断言query()被调用时传入的 SQL 是否含INSERT或SELECT - 关键点:不要断言“是否连了某 IP”,而要断言“某个 Model 方法是否调用了
$this->writeDB->query()” - 容易漏掉的场景:关联查询(
with())、子查询(subquery())、原生 SQL(query()直接调用)——这些必须显式指定连接,否则默认走default
测试片段示意:
public function testInsertUsesWriteConnection()
{
$writeMock = Mockery::mock(BaseConnection::class);
$writeMock->shouldReceive('query')->with(Mockery::pattern('/INSERT/i'))->once();
$model = new TestModel();
$model->writeDB = $writeMock; // 强制注入
$model->insert(['name' => 'test']);
}
真正麻烦的不是配置,而是当业务逻辑里出现 SELECT ... FOR UPDATE 或存储过程调用时——这类语句语义上是“读”,但行为上必须走主库。这种边界情况没法靠正则匹配 SQL 自动识别,必须人工标注或统一收口到特定 Service 方法里。别指望框架替你做这个判断。


















