如何在通用ADF管道中向SQL查询传递参数并解决报错？

能否针对单数据库构建通用管道传递不同参数？ #

完全可以实现。你可以把管道设计成参数化模板，通过外部JSON配置文件为每个feed（如emp、dept）传入专属参数（比如查询语句、过滤条件、标识字段等），管道读取JSON后动态执行对应的数据查询逻辑。

举两个配置示例：

• 员工数据feed配置（emp_config.json）：

{
  "feed_name": "employee",
  "base_query": "SELECT emp_id, emp_name, dept_id FROM employees WHERE emp_id = @emp_id",
  "params": {
    "emp_id": 1001
  }
}

• 部门数据feed配置（dept_config.json）：

{
  "feed_name": "department",
  "base_query": "SELECT dept_id, dept_name, location FROM departments WHERE dept_id = @dept_id",
  "params": {
    "dept_id": 20
  }
}

解决Lookup/Script活动中参数报错的问题 #

你遇到的“必须声明标量变量 '@'”错误，是因为直接在JSON查询字符串中嵌入@{pipeline.parameters.emp_id}时，SQL引擎无法识别管道表达式，把它当成了未定义的SQL变量。以下是两种可行的解决方法：

方法1：Lookup活动用参数化查询（推荐） #

不要在JSON里硬编码管道表达式，而是用SQL占位符，再通过Lookup的参数面板绑定管道参数：

1. 在主管道中定义参数（比如emp_id，类型设为int）
2. Lookup活动的SQL查询写为：SELECT emp_id, emp_name, dept_id FROM employees WHERE emp_id = ?
3. 切换到Lookup的参数标签，添加一行参数，值选择pipeline().parameters.emp_id，对应SQL里的?占位符

这种方式不仅能避免变量未声明错误，还能自动处理参数类型，同时防范SQL注入风险。

方法2：Script活动动态拼接SQL（需注意安全） #

如果必须基于JSON中的查询模板生成SQL，可以通过管道变量先完成参数替换，再传入Script活动：

1. 用Lookup活动读取目标feed的JSON配置文件，获取base_query和params
2. 添加Set Variable活动，设置变量dynamic_sql，值为：

   replace(string(activity('Lookup_Config').output.firstRow.base_query), '@emp_id', string(pipeline().parameters.emp_id))
   

3. 在Script活动的SQL脚本中引用这个变量：@{variables('dynamic_sql')}

⚠️ 注意：这种方式要确保参数值是可信来源，避免SQL注入风险。

批量处理扩展 #

如果要一次性处理多个feed，可以先读取所有配置文件的列表，用ForEach活动循环调用通用子管道，每个迭代传入对应feed的参数（从JSON中提取），实现批量自动化处理。

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