Spark JDBC连接SQL Server时含空格列的查询语法问题求助

问题根源 #

SQL Server不支持用反引号`包裹标识符（这是MySQL、PostgreSQL等数据库的语法），它的标准标识符包裹符是方括号[]。你之前用反引号报错就是这个原因，若用方括号无效，大概率是SQL语句的构造有误。

正确解决方案 #

将包含空格和减号的列名用方括号完整包裹，修改后的Spark代码如下：

spark.read.format("jdbc")
    .option("url", connectionUrl)
    .option("driver", "com.microsoft.sqlserver.jdbc.SQLServerDriver")
    .option("query", "SELECT [Customer ID - Source] FROM some_table")
    .option("user", localusername)
    .option("password", localpassword)
    .load()

关键说明 #

• 必须用方括号包裹整个列名，包括其中的空格和减号，避免SQL Server将列名中的-识别为减法运算符。
• 如果需要查询多列，每一个含特殊字符的列都单独用方括号包裹，比如：SELECT [Col 1], [Col 2 - Test] FROM some_table。
• 无需修改数据库配置，方括号是SQL Server原生支持的标识符转义方式，适配所有场景。

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