Python 的 Databricks SQL 连接器 - 如何执行多个查询？

Question

我可以单独成功执行每个查询，并且可以运行在 databricks 环境中执行多个查询，但是我无法通过 Databricks SQL Connector for Python。下面python的一段；

query = '''
Drop table if exists Table_Name

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

会报如下错误；

mismatched input 'create' expecting

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

Answer 1

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

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

Answer 2

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

如果存在则删除 table Table_Name；

创建tableTable_Name( Field1 字符串， Field2 整数 );

Python 的 Databricks SQL 连接器 - 如何执行多个查询？

Databricks SQL Connector for Python - How to execute Multiple Queries?

python

sql

multi-query

databricks