适用于 Python 的 Databricks SQL 连接器 - 如何执行多个查询？答案

【问题标题】：Databricks SQL Connector for Python - How to execute Multiple Queries?适用于 Python 的 Databricks SQL 连接器 - 如何执行多个查询？
【发布时间】：2022-01-18 21:25:01
【问题描述】：

我可以成功地单独执行每个查询，并且可以在 databricks 环境中运行多个，但是我无法通过 Databricks SQL Connector for Python 让它用于多查询语句。下面是一条蟒蛇；

query = '''
Drop table if exists Table_Name

create table Table_Name (
Field1 String,
Field2 Int
 )
 '''
cursor.execute(query)

这将给出以下错误；

不匹配的输入'create'期待

是否可以使用多查询语句，如果可以，我缺少什么？

【问题讨论】：

标签： python sql databricks multi-query

【解决方案1】：

可能在每个语句之后缺少;？

query1 = '''Drop table if exists Table_Name; '''
query2= '''
create table Table_Name (
Field1 String,
Field2 Int
 );
 '''
cursor.execute(query1)
cursor.execute(query2)

【讨论】：

是的，我不知道为什么这个包不喜欢';'但是如果我删除分号，我只能让单个语句运行，并且让它们用于多语句会产生与 op 相同的错误。不知道这个库有没有限制pypi.org/project/databricks-sql-connector。单语句分号错误：“无关输入';'期待 "
阅读文档，它只谈论一次执行一个命令。所以恐怕你必须在单独的命令中完成它们

【解决方案2】：

请在每个查询后添加分号：

如果存在 Table_Name 则删除表；

创建表 Table_Name ( 字段 1 字符串，字段 2 整数 );

【讨论】：

是的，我不知道为什么这个包不喜欢';'但是如果我删除分号，我只能让单个语句运行，并且让它们用于多语句会产生与 op 相同的错误。不知道这个库是否受限 pypi.org/project/databricks-sql-connector 。单语句分号错误：“无关输入';'期待 "