如何在Synapse管道中实现跨数据库查询关联表？

针对你需要在Database A的查询中关联Database B的city表（约20行）过滤结果的场景，以下是两种可行的实现方案，替代你之前尝试的Lookup+临时表的错误方式：

方案一：直接跨库查询（权限允许时优先用） #

如果两个数据库处于同一Synapse SQL池/同一SQL服务器下，且执行查询的账号拥有访问Database B的权限，直接使用你提供的原始查询即可，无需Pipeline额外处理：

select * from DatabaseA.city a  
inner join DatabaseB.city b on a.[ID] = b.[ID]  
where b.ID = 3 and b.City = 'Tampa'

将这段SQL放在Pipeline的Execute SQL activity中，数据源选择Database A即可执行。

方案二：Lookup+批量生成INSERT语句（权限受限/跨服务器场景） #

当无法直接跨库访问时，利用Lookup读取小表数据，批量生成INSERT语句写入Database A的临时表，再执行关联查询，避免笛卡尔积和索引取值问题：

具体步骤： #

1. Lookup活动读取Database B的city表

   • 新建Lookup activity，数据源选择Database B的city表，取消勾选「First row only」，确保返回所有行数据。

2. 创建临时表（Execute SQL活动）

   • 新增Execute SQL activity，数据源选择Database A，执行SQL创建临时表：

     DROP TABLE IF EXISTS #TempCity;
     CREATE TABLE #TempCity (ID INT, City NVARCHAR(100))
     

3. 生成批量INSERT语句（Set Variable活动）

   • 新建字符串类型的变量（比如var_InsertSQL），变量值用动态表达式拼接批量插入语句，自动处理字符串单引号转义：

     @concat(
         'INSERT INTO #TempCity (ID, City) VALUES ',
         join(
             map(
                 activity('Lookup City').output.value,
                 item() => concat('(', item().ID, ', ''', replace(item().City, '''', ''''''), ''')')
             ),
             ', '
         )
     )
     

4. 执行批量插入（Execute SQL活动）

   • 新增Execute SQL activity，数据源选Database A，SQL语句选择「动态内容」，引用变量@variables('var_InsertSQL')

5. 执行关联过滤查询（Execute SQL活动）

   • 最后添加Execute SQL activity，执行关联查询：

     select * from DatabaseA.city a  
     inner join #TempCity b on a.[ID] = b.[ID]  
     where b.ID = 3 and b.City = 'Tampa'
     

方案三：Lookup+ForEach循环插入（适合新手快速实现） #

如果批量SQL拼接觉得复杂，用ForEach循环逐行插入临时表，20行数据的循环开销可忽略：

1. 同方案二步骤1，Lookup读取所有行
2. 同方案二步骤2，创建临时表
3. ForEach活动遍历Lookup结果
   • 新建ForEach activity，设置Items为@activity('Lookup City').output.value
   • 内部添加Execute SQL activity，SQL语句用动态内容：

     @concat('INSERT INTO #TempCity (ID, City) VALUES (', item().ID, ', ''', replace(item().City, '''', ''''''), ''')')
     

4. 同方案二步骤5，执行关联查询

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