python - 如何在 pymssql 中执行 .sql 文件

标签 python database file pymssql

我正在尝试使用 pymssql 在 python 中执行一个 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 Server\nDB-Lib error message 102, severity 15:\nGeneral SQL Server error: Check messages from the SQL Server\nDB-Lib error message 102, severity 1
5:\nGeneral SQL Server error: Check messages from the SQL Server\nDB-Lib error message 102, severity 15:\nGeneral SQL Server error: Check messages from the SQL Server\nDB-Lib error message 102, severity 15:\nGeneral SQL Server error: Check messages from the SQL Server\nDB-Lib error message 102, severity     
15:\nGeneral SQL Server error: Check messages from the SQL Server\nDB-Lib error message 102, severity 15:\nGeneral SQL Server error: Check messages from the SQL Server\nDB-Lib error message 102, severity 15:\nGeneral SQL Server error: Check messages from the SQL Server\nDB-Lib error message 102,severity 
15:\nGeneral SQL Server error: Check messages from the SQL Server\nDB-Lib error message 102, severity 15:\nGeneral SQL Server error: Check messages from the SQL Server\nDB-Lib error message 102, severity 15:\nGeneral SQL Server error: Check messages from the SQL Server\n")

所以基本上我有两个问题:

  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

最佳答案

是的,这样做是可能的。 我经常这样做,在您的代码中硬编码 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 语句。 检查这个答案:Using "GO" within a transaction .

那应该没问题。

关于python - 如何在 pymssql 中执行 .sql 文件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30533508/

相关文章:

Python Tkinter : responsive grid

python - 使用 python 中数组的索引切片二维数组

python - 如何在 Django 模板中检测表单字段的类型

Python 子进程命令执行卡住

php - 如何避免硬编码数据库连接密码?

database - 失败 - 测试失败 : the network adapter could not establish the connection

php - 在同一页面上用 php 更新和选择如何

Java:在目录之间复制文件

file - 为什么我的 Go 程序使用打开文件的名称创建另一个 Go 进程,为什么它这么大?

c - 如何在 C 中清除文件的全部内容?