MSSQL2008 - Pyodbc - 以前的 SQL 不是查询

Question

我无法弄清楚以下代码有什么问题， 语法没问题（用 SQL Management Studio 检查），我可以按照我应该的方式访问，这样也可以工作..但由于某种原因，一旦我尝试通过 PyODBC 创建表，它就会停止工作。

import pyodbc

def SQL(QUERY, target = '...', DB = '...'):
    cnxn = pyodbc.connect('DRIVER={SQL Server};SERVER=' + target + DB+';UID=user;PWD=pass')
    cursor = cnxn.cursor()
    cursor.execute(QUERY)
    cpn = []

    for row in cursor:
        cpn.append(row)
    return cpn

print SQL("CREATE TABLE dbo.Approvals (ID SMALLINT NOT NULL IDENTITY PRIMARY KEY, HostName char(120));")

它失败了：

Traceback (most recent call last):
  File "test_sql.py", line 25, in <module>
    print SQL("CREATE TABLE dbo.Approvals (ID SMALLINT NOT NULL IDENTITY PRIMARY KEY, HostName char(120));")
  File "test_sql.py", line 20, in SQL
    for row in cursor:
pyodbc.ProgrammingError: No results.  Previous SQL was not a query.

有人知道这是为什么吗？ 我安装了“SQL Server”驱动程序（默认），在 Windows 2008 SQL Server 环境（不是 Express 数据库）上运行 Windows 7。

Answer 1

以防万一一些孤独的网络游牧者遇到这个问题，Torxed 的解决方案对我不起作用。但以下内容对我有用。

我正在调用一个 SP，它将一些值插入到表中，然后返回一些数据。只需将以下内容添加到 SP 中即可：

SET NOCOUNT ON

它会正常工作:)

Python 代码：

    query = "exec dbo.get_process_id " + str(provider_id) + ", 0"
    cursor.execute(query)

    row = cursor.fetchone()
    process_id = row[0]

SP ：

USE [DBNAME]
GO
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
ALTER procedure [dbo].[GET_PROCESS_ID](
    @PROVIDER_ID INT,
    @PROCESS_ID INT OUTPUT
)
AS
BEGIN
    SET NOCOUNT ON
    INSERT INTO processes(provider_id) values(@PROVIDER_ID)
    SET @PROCESS_ID= SCOPE_IDENTITY()
    SELECT @PROCESS_ID AS PROCESS_ID
END

Answer 2

使用脚本顶部的“SET NOCOUNT ON”值并不总是足以解决问题。

就我而言，还需要删除这一行：

Use DatabaseName;

数据库是 SQL Server 2012，
Python 3.7，
SQL Alchemy 1.3.8

希望这对某人有帮助。

Answer 3

我得到这个是因为我重复使用了循环的游标：

rows = cursor.execute(...)
for row in rows:
    # run query that returns nothing
    cursor.execute(...)
    # next iteration of this loop will throw 'Previous SQL' error when it tries to fetch next row because we re-used the cursor with a query that returned nothing

使用 2 个不同的游标代替

rows = cursor1.execute(...)
for row in rows:
    cursor2.execute(...)

，或者在再次使用第一个游标之前获取第一个游标的所有结果：

使用 2 个不同的游标代替

rows = cursor.execute(...)
for row in list(rows):
    cursor.execute(...)

Answer 4

正如 Travis 和其他人所提到的，其他事情也可能导致 SET NOCOUNT ON 无法阻止的额外输出。

我在程序开始时设置了 SET NOCOUNT ON，但在结果集中收到警告消息。

我在脚本开头设置了 ansi 警告，以删除错误消息。

SET ANSI_WARNINGS OFF

希望这对某人有帮助。

Answer 5

正如其他人所介绍的，SET NOCOUNT ON 将处理存储过程中的额外结果集，但是其他事情也可能导致 NOCOUNT 无法阻止的额外输出（并且 pyodbc 将视为结果集），例如忘记在调试存储过程后删除打印语句。

Answer 6

脚本中的每个语句都可以产生一些输出作为数据集或/和作为消息。

select 1 as id

上面最后一行

id
-----------
1

(1 row affected)

是“messages”。如果我对此运行 cursor.fetchall() ，我将得到一个没有任何错误的结果。

但是，如果我的查询是 insert .. into .. 或对不返回数据集的存储过程的调用，则对其执行 fetchall() 会给我一个错误。

有一种方法可以知道获取是否会给我pyodbc.ProgrammingError：

if cursor.description:
    cursor.fetchall()

cursor.description具有数据集的所有字段定义它将是None 如果那里什么都没有。

如果脚本中有多个语句，我可以使用 nextset() 迭代数据集。这是阅读完整响应的方法：

def print_current_results(cursor):
    if cursor.messages:
        print(cursor.messages)
    if cursor.description:
        print(cursor.fetchall())

cursor.execute(some_script)
print_current_results(cursor)
while cursor.nextset():
   print_current_results(cursor)

要减少循环数量并最小化总体输出，请使用几乎所有其他答案中提到的 SET NOCOUNT ON 。如果 sql 语句没有生成数据集或消息，那么它会在输出中跳过，这就是您只需 cursor.fetchall() 而不是上面更长的脚本的方法

Answer 7

如果您的存储过程调用 RAISERROR，pyodbc 可能会为该消息创建一个集合。

CREATE PROCEDURE some_sp
AS
BEGIN
    RAISERROR ('Some error!', 1, 1) WITH NOWAIT
    RETURN 777
END

在 python 中，您需要跳过第一组，直到找到包含一些结果的组（请参阅 https://github.com/mkleehammer/pyodbc/issues/673#issuecomment-631206107 了解详细信息）。

sql = """
    SET NOCOUNT ON;
    SET ANSI_WARNINGS OFF;
    DECLARE @ret int;
    EXEC @ret = some_sp;
    SELECT @ret as ret;
    """
cursor = con.cursor()
cursor.execute(sql)

rows = None
#this section will only return the last result from the query
while cursor.nextset():
    try:
        rows = cursor.fetchall()
    except Exception as e:
        print("Skipping non rs message: {}".format(e))
    continue

row = rows[0]
print(row[0])  # 777.

Answer 8

我认为上述问题的根本原因可能与以下事实有关：当您执行例如不会返回结果的 DELETE 查询时，您会收到相同的错误消息。因此，如果您运行，

 result = cursor.fetchall()

您会收到此错误，因为根据定义，DELETE 操作不会返回任何内容。尝试按照此处的建议捕获异常：如何检查结果集为空？

Answer 9

如果您的 SQL 不是存储过程。

在查询中使用“xyz！= NULL”，将给出相同的错误，即“pyodbc.ProgrammingError：没有结果。以前的 SQL 不是查询。”

请改用“不为空”。

Answer 10

首先：

如果您运行的是 Windows SQL Server 2008，请使用 SQL 软件安装中附带的“本机客户端”（它随数据库和工具包一起安装，因此您需要安装 Microsoft 的 SQL 管理应用程序） ）

第二：
在 SQL 连接语句中使用 "Trusted_Connection=yes"：

cnxn = pyodbc.connect('DRIVER={SQL Server Native Client 10.0};SERVER=ServerAddress;DATABASE=my_db;Trusted_Connection=yes')

这应该可以解决问题！

Answer 11

我通过将使用数据库和sql查询分成两个执行语句解决了这个问题。