如何在pymssql中执行.sql文件

Question

我试图在python中使用pymssql执行sql文件，该文件包含一个BEGIN TRANSACTION，一个COMMIT TRANSACTION和一个END，以及之前和之后的一些安全网。

我正在尝试打开内存中的文件并执行内容:

file = open(options.sqlFile, 'r')
sqlFileContents = file.read()
file.close()
cursor.execute(sqlFileContents)
conn.commit()

但是它返回错误:

pymssql.ProgrammingError: (102, "Incorrect syntax near 'GO'.DB-Lib error message 102, severity 15:nGeneral SQL Server error: Check messages from the SQL ServernDB-Lib error message 102, severity 15:nGeneral SQL Server error: Check messages from the SQL ServernDB-Lib error message 102, severity 1
5:nGeneral SQL Server error: Check messages from the SQL ServernDB-Lib error message 102, severity 15:nGeneral SQL Server error: Check messages from the SQL ServernDB-Lib error message 102, severity 15:nGeneral SQL Server error: Check messages from the SQL ServernDB-Lib error message 102, severity     
15:nGeneral SQL Server error: Check messages from the SQL ServernDB-Lib error message 102, severity 15:nGeneral SQL Server error: Check messages from the SQL ServernDB-Lib error message 102, severity 15:nGeneral SQL Server error: Check messages from the SQL ServernDB-Lib error message 102,severity 
15:nGeneral SQL Server error: Check messages from the SQL ServernDB-Lib error message 102, severity 15:nGeneral SQL Server error: Check messages from the SQL ServernDB-Lib error message 102, severity 15:nGeneral SQL Server error: Check messages from the SQL Servern")

基本上我有两个问题:

1. 是否可以按照我的方式执行查询?
2. 是sql查询文件本身的问题?

谢谢你的帮助。

编辑:这里是SQL:

SQL:

SET NUMERIC_ROUNDABORT OFF
GO
SET ANSI_PADDING, ANSI_WARNINGS, CONCAT_NULL_YIELDS_NULL, ARITHABORT,             QUOTED_IDENTIFIER, ANSI_NULLS ON
GO
IF EXISTS (SELECT * FROM tempdb..sysobjects WHERE     id=OBJECT_ID('tempdb..#tmpErrors')) DROP TABLE #tmpErrors
GO
CREATE TABLE #tmpErrors (Error int)
GO
SET XACT_ABORT ON
GO
SET TRANSACTION ISOLATION LEVEL SERIALIZABLE
GO
BEGIN TRANSACTION
PRINT N'Adding Release Version to [admin].[ReleaseHistory]'
GO
INSERT INTO [admin].[ReleaseHistory] VALUES (GetUTCDate(), '1.7')
GO
IF @@ERROR<>0 AND @@TRANCOUNT>0 ROLLBACK TRANSACTION
GO
IF @@TRANCOUNT=0 BEGIN INSERT INTO #tmpErrors (Error) SELECT 1 BEGIN     TRANSACTION END
GO
IF EXISTS (SELECT * FROM #tmpErrors) ROLLBACK TRANSACTION
GO
IF @@TRANCOUNT>0 BEGIN
PRINT 'The database update succeeded'
COMMIT TRANSACTION
END
ELSE PRINT 'The database update failed'
GO
DROP TABLE #tmpErrors
GO

Answer 1

是的，这样做是可能的。我经常这样做，这是更干净的硬编码SQL在你的代码。

你能把SQL添加到你的帖子吗?可能有个字符搞错了。

我是这样做的(使用pyodbc):

with open('%smysql.sql' % SQL_DIR) as f: 
            sql = f.read() % params # Don't do that with untrusted inputs
            cursor.execute(sql)
            cursor.commit()
            cursor.close()

编辑:删除所有的GO，它不是一个真正的SQL语句。检查一下这个答案:使用"go"在事务中。