CodeIgniter 4 中执行复杂 UNION 查询的正确方式-php教程-PHP中文网

CodeIgniter 4 中执行复杂 UNION 查询的正确方式

在 CodeIgniter 4 中，直接通过 select($sql, false) 构造 UNION 查询时，必须显式调用 get() 获取查询对象，再调用 getResult() 才能执行并返回结果；仅链式调用 select(...)->get()->getResult() 是可行的，但需确保 SQL 安全与语法完整。

在 codeigniter 4 中，直接通过 `select($sql, false)` 构造 union 查询时，必须显式调用 `get()` 获取查询对象，再调用 `getresult()` 才能执行并返回结果；仅链式调用 `select(...)->get()->getresult()` 是可行的，但需确保 sql 安全与语法完整。

CodeIgniter 4 的 Query Builder 并不原生支持多 UNION 子句的链式构建（如 union(), unionAll() 方法仅在较新版本 v4.4.0+ 有限引入，且不适用于嵌套或混合 SELECT 场景），因此对于复杂 UNION 查询，推荐采用原生 SQL + 查询构造器组合的方式，但务必规避字符串拼接带来的 SQL 注入风险。

✅ 正确写法（安全、可执行）：

// 使用 Query Builder 初始化，再注入自定义 SQL（禁用自动转义）
$builder = $this->builder();
$builder->select(
    "SELECT acnt_id, acnt_opbal AS sum_amount 
     FROM accounts 
     WHERE acnt_id = ? 
     UNION 
     SELECT txn_acnt_id_dr AS acnt_id, SUM(txn_amount_dr) AS sum_amount 
     FROM transactions 
     WHERE txn_acnt_id_dr = ? AND txn_date get([$acnt_id, $acnt_id, $fdate, $acnt_id, $fdate])->getResult();

⚠️ 注意事项：

参数绑定是强制要求：切勿使用字符串拼接（如 '" . $acnt_id . "'），这会导致严重 SQL 注入漏洞。CI4 的 get($binds) 支持位置占位符 ? 绑定，安全可靠；
select($sql, false) 仅设置 SELECT 部分，不会自动添加 FROM 或其他子句，因此传入的 $sql 必须是语法完整的 SELECT ... 语句（含 UNION）；
get() 方法在此场景中不接收表名参数（因 SQL 已含完整表引用），但可传入绑定参数数组；
若需获取关联数组而非对象，使用 getResultArray() 替代 getResult()；
建议将该逻辑封装进模型方法，并配合数据库事务（如涉及多步一致性校验）。

? 替代方案（更现代、推荐）：
若项目已升级至 CodeIgniter 4.4+，可尝试使用实验性 union() 方法分步构建（需手动处理字段对齐）：

$builder1 = $this->builder('accounts')->select('acnt_id, acnt_opbal as sum_amount')->where('acnt_id', $acnt_id);
$builder2 = $this->builder('transactions')
    ->select('txn_acnt_id_dr as acnt_id, SUM(txn_amount_dr) as sum_amount')
    ->where('txn_acnt_id_dr', $acnt_id)
    ->where('txn_date groupBy('txn_acnt_id_dr');
$builder3 = $this->builder('transactions')
    ->select('txn_acnt_id_cr as acnt_id, -SUM(txn_amount_cr) as sum_amount')
    ->where('txn_acnt_id_cr', $acnt_id)
    ->where('txn_date groupBy('txn_acnt_id_cr');

$query = $builder1->union($builder2)->union($builder3);
$result = $query->get()->getResult();