Azure Data Factory动态内容换行符替换：解决Azure Delta语法错误

问题背景 #

你在ADF中为了提升可读性给动态SQL添加了换行，但这些换行被带入最终SQL语句，导致Azure Delta Lake解析时抛出语法错误。

解决方案：用ADF内置replace()函数移除换行符 #

直接对CONCAT生成的完整SQL字符串执行替换操作，把所有换行符（包括\r\n和\n）替换为空格（避免关键字/字段连在一起引发新的语法问题），既保留原表达式的可读性，又能生成符合Delta要求的SQL。

修改后的动态表达式示例 #

@replace(replace(CONCAT('SELECT ',activity('Get Parameters').output.firstRow.SourceSelectFields,'
 FROM ',activity('Get Parameters').output.firstRow.SourceTable,' ',activity('Get Parameters').output.firstRow.CrossingTables,'
WHERE ',activity('Get Parameters').output.firstRow.Conditions,
' AND doc.status in (''Complete'',''Draft'')',
' AND PRJT.taskname IN ',variables('ListadoTareas'),
' AND (COALESCE (CAST(DATE_FORMAT(cw.begindate,''yyyy-MM-dd'') AS DATE )))> ''',activity('Get Parameters').output.firstRow.BeginDate,'''',
' AND ''',utcnow('yyyy-MM-dd'),''' <= 
CASE WHEN CAST(DATE_FORMAT(cw.expirationdate,''yyyy-MM-dd'') AS DATE)!=''1970-01-01'' THEN (CAST(ADD_MONTHS(DATE_FORMAT(cw.expirationdate,''yyyy-MM-dd''),4) AS DATE))
     ELSE CAST(ADD_MONTHS(DATE_FORMAT(DATE_ADD(cw.effectivedate,CAST(cw.cus_plazodias_wjcc2 AS INT)),''yyyy-MM-dd''),4)AS DATE)
END',
' AND SUBSTRING(doc.title,1,3) IN ',variables('ListadoDocumentos'),
' AND dl.projectid is null'), '\r', ''), '\n', ' ')

关键说明 #

• 嵌套replace()是为了同时处理Windows风格的\r\n和Unix风格的\n换行符
• 把换行符替换为空格而非空字符串，能避免SELECT和字段名、WHERE和条件直接拼接成连写的无效语法
• 原表达式里的换行、缩进格式可以保留，方便后续维护，最终生成的SQL会自动清理换行并补全必要空格

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