Spark中SELECT语句通过AND拼接空条件导致语法报错的解决方案

当前生成的SQL末尾出现and ()的无效语法结构，Spark SQL解析器检测到括号内没有任何有效逻辑表达式，后续语法匹配失败才抛出mismatched input的解析异常。
问题来源是硬编码了and ($UuidConditionSet)的固定SQL模板：当UuidConditionSet为空字符串时，最终就会生成and ()这种完全不符合SQL语法的片段。

不要把可选过滤条件硬嵌在固定SQL模板里，改为动态收集所有有效WHERE条件再拼接，从根源上避免空逻辑片段、多余连接符的问题：

• 把所有必选的WHERE条件先放进可变列表，比如record_type匹配、日期范围限制这类一定存在的过滤逻辑
• 判断UuidConditionSet非空时，再把对应的UUID过滤逻辑作为单独的元素追加到条件列表中，空的条件直接跳过，不参与拼接
• 把列表里的有效条件用and连接成完整的WHERE子句，再拼进最终SQL

修改后的参考实现代码：

// 初始化必选过滤条件列表
val whereConditions = scala.collection.mutable.ListBuffer[String](
  s"${SQLColumnHelper.EVENT_INFO_STRUCT_NAME} = '${RECORD_TYPE}'",
  s"date_format(${SQLColumnHelper.DATE}, '${Constant.STAY_DATE_FORMAT}') >= '${stayDateRangeTuple._1}'",
  s"date_format(${SQLColumnHelper.DATE}, '${Constant.STAY_DATE_FORMAT}') <= '${stayDateRangeTuple._2}'"
)

// 仅当UUID过滤逻辑有效时追加，空值直接跳过
if (UuidConditionSet.nonEmpty) {
  whereConditions.append(s"($UuidConditionSet)")
}

// 拼接生成最终SQL
val finalSql = s"""
SELECT
 ${SQLColumnHelper.STRUCT_NAME_ITEM},
 ${SQLColumnHelper.STRUCT_NAME_AMOUNT},
 ${SQLColumnHelper.DATE}
from ${sqlTableHelper.TABLE}
where ${whereConditions.mkString(" and ")}
"""

• 不要为了兼容空条件保留空括号结构：SQL语法不允许括号内无有效逻辑表达式，哪怕删掉前置的and只留()，一样会触发解析错误
• 检查UUID条件生成逻辑的变量引用：原代码的for循环中遍历变量名为Uuid，但拼接SQL字符串时引用的是eventUuid，需要确认变量名是否对应，避免条件满足时生成的过滤值不符合预期
• 不要用SQL生成完成后再做正则替换的方式处理空片段：这类方式容错性差，很容易因为格式差异（比如多了换行、空格）替换失效，从生成阶段就控制有效条件的加入才是可靠方案

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