在SQLAlchemy中处理查询批次：执行存储过程遇GO语法错误

GO 不是SQL Server数据库引擎支持的SQL语法，它是SQL Server Management Studio（SSMS）等客户端工具专属的批处理分隔符。当你在SSMS里执行带GO的脚本时，是SSMS自动将脚本拆分成多个独立的SQL批次，逐个发送给数据库执行；而SQLAlchemy会把包含GO的整个脚本直接发给数据库，数据库无法识别GO语法，因此报错。

另外，CREATE PROCEDURE这类DDL语句要求必须是查询批次中的第一条语句，这也是原SQL用GO分隔的原因——确保存储过程的创建语句单独成为一个批次。

把原脚本拆分成多个独立的SQL批次，分别执行即可。

修改后的Python代码 #

from sqlalchemy import create_engine, text

# 创建引擎
my_engine = create_engine(f"mssql+pyodbc://{self.db_server}/{self.db_name}?trusted_connection=yes&driver={self.db_driver}")

# 将原脚本拆分为两个独立批次
use_db_query = "USE my_database;"
create_proc_query = """
CREATE PROCEDURE test.test_procedure  
AS   
    SELECT TOP 10 * FROM my_other_database.my_schema.my_table;   
"""

# 逐个执行批次
with my_engine.connect() as con:
    # 切换数据库
    con.execute(text(use_db_query))
    # 单独执行存储过程创建语句（必须为独立批次）
    con.execute(text(create_proc_query))
    # DDL操作需要提交事务才能生效
    con.commit()

• 所有要求单独作为批次的DDL语句（如CREATE PROCEDURE、ALTER PROCEDURE、CREATE FUNCTION等）都需要单独执行，不能和其他SQL语句放在同一个execute调用中。
• 执行DDL操作后必须调用commit()，否则数据库不会持久化这些更改。

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