Databricks Spark JDBC连接NetSuite报SQL语法错误求助

1. 修正Schema指定格式 #

你的Schema名称FL - Accounting包含空格和特殊字符，必须用双引号包裹后放在表名前，否则驱动会解析错误：

(SELECT TOP 10 * FROM "FL - Accounting".Customer) AS t

2. 规范Spark JDBC参数使用 #

Spark JDBC中query和dbtable是互斥参数，不能同时设置，以下是两种正确用法：

方式一：用dbtable传入子查询

确保子查询格式紧凑，避免多余换行导致驱动解析失败：

jdbc_url = "jdbc:ns://xxxx.connect.api.netsuite.com:1708;ServerDataSource=NetSuite2.com;Encrypted=1;NegotiateSSLClose=false;CustomProperties=(AccountID=xxxx;RoleID=xxx)"

netsuite_query = """(SELECT TOP 10 * FROM "FL - Accounting".Customer) AS t"""

df = spark.read \
    .format("jdbc") \
    .option("url", jdbc_url) \
    .option("dbtable", netsuite_query) \
    .option("user", "xxxx") \
    .option("password", "xxx") \
    .option("driver", "com.netsuite.jdbc.openaccess.OpenAccessDriver") \
    .load()

display(df)

方式二：用query参数直接写SQL（推荐）

无需包装子查询，直接传入SQL语句即可：

jdbc_url = "jdbc:ns://xxxx.connect.api.netsuite.com:1708;ServerDataSource=NetSuite2.com;Encrypted=1;NegotiateSSLClose=false;CustomProperties=(AccountID=xxxx;RoleID=xxx)"

netsuite_query = "SELECT TOP 10 * FROM \"FL - Accounting\".Customer"

df = spark.read \
    .format("jdbc") \
    .option("url", jdbc_url) \
    .option("query", netsuite_query) \
    .option("user", "xxxx") \
    .option("password", "xxx") \
    .option("driver", "com.netsuite.jdbc.openaccess.OpenAccessDriver") \
    .load()

display(df)

3. 适配NetSuite SQL语法 #

部分NetSuite JDBC驱动对TOP支持有限，可尝试替换为LIMIT语法：

SELECT * FROM "FL - Accounting".Customer LIMIT 10

4. 验证基础连接 #

先执行极简查询确认连接本身无问题，排除表名/Schema以外的错误：

test_query = "SELECT 1 AS test_col"

df = spark.read \
    .format("jdbc") \
    .option("url", jdbc_url) \
    .option("query", test_query) \
    .option("user", "xxxx") \
    .option("password", "xxx") \
    .option("driver", "com.netsuite.jdbc.openaccess.OpenAccessDriver") \
    .load()

display(df)

5. 检查URL配置 #

确保CustomProperties内的参数格式正确，若RoleID为字符串类型需加引号：

jdbc_url = "jdbc:ns://xxxx.connect.api.netsuite.com:1708;ServerDataSource=NetSuite2.com;Encrypted=1;NegotiateSSLClose=false;CustomProperties=(AccountID=xxxx;RoleID=\"xxx\")"

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