在Azure Data Factory中如何判断变量是否包含Insert或Update关键词？

实现步骤 #

• 在你的管道中添加 If Condition 活动，放置在需要执行的后续活动之前
• 打开 If Condition 活动的配置面板，在「表达式」输入框中填入以下判断逻辑：
  假设你存储SQL语句的变量名为sqlQuery，表达式如下：

  @not(or(contains(toLower(variables('sqlQuery')), 'insert'), contains(toLower(variables('sqlQuery')), 'update')))
  

  表达式逻辑说明：先将SQL变量统一转为小写，避免大小写差异导致的匹配遗漏，判断是否包含insert或update任意一个关键词，最终取反，即只有两个关键词都不包含时，条件返回真
• 配置 If Condition 的分支逻辑：
  把你需要执行的后续活动全部放到If true（条件为真）分支中，If false分支可以留空，也可以按需添加错误日志输出、自定义异常抛出等操作

可选优化（避免误判） #

如果你的SQL语句中可能出现表名、字段名、字符串内容包含insert/update连续字符的场景（例如表名InsertRecordLog），可以使用正则匹配单词边界的方式优化判断逻辑，替换表达式为：

@not(regexMatch(toLower(variables('sqlQuery')), '.*\\binsert\\b.*|.*\\bupdate\\b.*'))

\\b为正则单词边界标识符，只会匹配独立的insert、update单词，不会匹配和其他字符连在一起的内容

注意事项 #

该方案为基础的关键词拦截逻辑，生产环境使用时建议同时搭配数据库侧权限控制，给ADF使用的数据库账号仅授予查询权限，双重保障避免数据写入风险

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