如何在CakePHP 3自定义查询构建器中使用QueryExpression查询belongsToMany关联的User数据

你遇到的错误核心原因是：contains('Users')是延迟处理关联表连接的，它会在查询构建的后期才把关联表加入到SQL语句中，但你的where闭包中提前引用了Users.id这一列，此时Users表还没有被添加到查询的JOIN列表里，数据库自然找不到这个列。

由于你必须使用QueryExpression而不能用matching()，我们需要手动提前构建关联表的JOIN操作，确保在WHERE条件之前就把Users表（通过中间表TasksUsers）连接到主查询中。

修正后的代码实现 #

public function process(): bool {
    $query = $this->getQuery();
    
    // 手动添加belongsToMany关联的JOIN语句
    $query->join([
        'TasksUsers' => [
            'table' => 'tasks_users',
            'type' => 'INNER',
            'conditions' => 'TasksUsers.task_id = Tasks.id',
        ],
        'Users' => [
            'table' => 'users',
            'type' => 'INNER',
            'conditions' => 'Users.id = TasksUsers.user_id',
        ]
    ]);
    
    // 使用QueryExpression构建WHERE条件，此时Users表已经被JOIN进来
    $query->where(function (QueryExpression $exp) {
        return $exp->eq('Users.id', 621048);
    });
    
    return true;
}

关键细节说明 #

• 手动JOIN的顺序：必须先连接中间表TasksUsers（关联表），再连接目标表Users，因为中间表是Task和User之间的桥梁，要保证关联条件的逻辑正确。
• 表名与别名：注意代码中使用的表名（tasks_users、users）要和数据库中的实际表名一致，别名（TasksUsers、Users）要和后续WHERE条件中的引用保持一致。
• 避免重复JOIN：如果你的查询构建器可能多次处理这个关联，可以先检查查询中是否已经存在对应的JOIN，再决定是否添加，比如：

  $hasUsersJoin = collect($query->clause('join'))->some(function($join) {
      return isset($join['Users']);
  });
  if (!$hasUsersJoin) {
      // 执行上面的JOIN操作
  }
  

为什么不用contains()？ #

contains()本质是封装了JOIN和字段选择的快捷方法，但它的执行时机晚于你当前的WHERE条件构建，所以无法在QueryExpression中直接引用关联表的列。手动JOIN能让我们完全控制表连接的时机，确保WHERE条件可以正确关联到Users表的字段。

内容的提问来源于stack exchange，提问作者space97