Laravel跨数据库关联子查询报错：表不存在问题求助

问题描述 #

我尝试用Laravel查询构建器将子查询关联到主查询，代码示例如下。原以为给子查询指定了数据库连接和表，主查询就能识别，结果抛出SQL错误：

SQLSTATE[42S02]: Base table or view not found: 1146 Table 'data_source2.data_table1' doesn't exist

试过给源查询加data_source1前缀，还是报同样的错。

原代码：

$source_query = DB::connection('data_source1')
    ->table('data_table1')
    ->select(DB::raw('
        SUM(data_table1.value) as value
    '))
   
$data = DB::connection('data_source2')
    ->table('data_table2')
    ->joinSub($source_query, 'source_query', function ($join) {
        $join->on('data_table2.hour', '=', 'source_query.hour');
    })
    ->where('date', '=', $date)
    ->select(DB::raw('
        source_query.value as value,
    '))
    ->get();

错误原因 #

Laravel的joinSub方法执行时，会把子查询嵌入到主查询的SQL语句中，全程使用主查询的数据库连接执行，子查询里单独设置的connection('data_source1')会被直接忽略。所以主查询会在data_source2数据库里找data_table1，自然找不到报错。

解决办法 #

办法一：子查询显式指定跨库表名

直接在子查询的table方法里用数据库名.表名的格式，让SQL明确指向目标数据库的表，不用依赖connection设置：

$source_query = DB::table('data_source1.data_table1') // 直接写跨库表名
    ->selectRaw('
        hour,
        SUM(value) as value
    ')
    ->groupBy('hour'); // 聚合查询必须按关联字段分组，否则结果无法匹配

$data = DB::connection('data_source2')
    ->table('data_table2')
    ->joinSub($source_query, 'source_query', function ($join) {
        $join->on('data_table2.hour', '=', 'source_query.hour');
    })
    ->where('date', '=', $date)
    ->select('source_query.value as value')
    ->get();

注意：子查询必须选中hour字段（关联用的字段），同时因为用了SUM聚合函数，必须按hour分组，否则子查询只会返回一条总合，无法和主表的多条记录关联。

办法二：先执行子查询再关联结果

如果两个数据库不在同一服务器，或者跨库查询权限受限，可以先单独执行子查询拿到数据，再用集合方法关联主查询结果：

// 先单独执行子查询，拿到hour对应的value总和
$source_data = DB::connection('data_source1')
    ->table('data_table1')
    ->selectRaw('hour, SUM(value) as value')
    ->groupBy('hour')
    ->pluck('value', 'hour'); // 得到键为hour、值为总和的数组

// 主查询后关联数据
$data = DB::connection('data_source2')
    ->table('data_table2')
    ->where('date', '=', $date)
    ->get()
    ->map(function ($item) use ($source_data) {
        // 给每条主查询结果添加上对应的value，没有则设为0
        $item->value = $source_data[$item->hour] ?? 0;
        return $item;
    });

这个方法适合子查询结果数据量不大的场景，避免跨库查询的兼容性问题。

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