如何在Python的PyPyODBC模块中使用FetchAll?

Question

我正在尝试使用 PyPyODBC，特别是参考这个 示例。不过，我并不想创建一个新表，我只是想读取数据（这些数据存储在SQL Server的数据库/表中），然后在Python中处理这些数据。

下面的代码运行得很好，除了以下这一部分 ( for row in cur.fetchall():).

from __future__ import print_function
import pypyodbc
from  pandas import *
import pandas as pd
con = pypyodbc.connect(driver = '{SQL Server}', server = 'WIN-SAV35R5AKCQ',database ='V2.0.6_X12_837I')

cur = con.cursor()
cur.execute('''SELECT * FROM TS837_2400;''')
cur.commit()

for d in cur.description: 
    print (d[0], end=" ")

print('')

for row in cur.fetchall():
    for field in row: 
        print (field, end=" ")
    print ('')

cur.close()
con.close()

但是，我遇到了这个错误。

---------------------------------------------------------------------------
Error                                     Traceback (most recent call last)
<ipython-input-70-c08d5a03056a> in <module>()
     14 print('')
     15 
---> 16 for row in cur.fetchall():
     17     for field in row:
     18         print (field, end=" ")

C:\Users\Administrator\Anaconda\lib\site-packages\pypyodbc.pyc in fetchall(self)
   1805         rows = []
   1806         while True:
-> 1807             row = self.fetchone()
   1808             if row is None:
   1809                 break

C:\Users\Administrator\Anaconda\lib\site-packages\pypyodbc.pyc in fetchone(self)
   1900                 return None
   1901             else:
-> 1902                 check_success(self, ret)
   1903 
   1904     def __next__(self):

C:\Users\Administrator\Anaconda\lib\site-packages\pypyodbc.pyc in check_success(ODBC_obj, ret)
    981     if ret not in (SQL_SUCCESS, SQL_SUCCESS_WITH_INFO, SQL_NO_DATA):
    982         if isinstance(ODBC_obj, Cursor):
--> 983             ctrl_err(SQL_HANDLE_STMT, ODBC_obj.stmt_h, ret, ODBC_obj.ansi)
    984         elif isinstance(ODBC_obj, Connection):
    985             ctrl_err(SQL_HANDLE_DBC, ODBC_obj.dbc_h, ret, ODBC_obj.ansi)

C:\Users\Administrator\Anaconda\lib\site-packages\pypyodbc.pyc in ctrl_err(ht, h, val_ret, ansi)
    959                 raise OperationalError(state,err_text)
    960             elif state[:2] in (raw_s('IM'),raw_s('HY')):
--> 961                 raise Error(state,err_text)
    962             else:
    963                 raise DatabaseError(state,err_text)

Error: (u'HY010', u'[HY010] [Microsoft][ODBC Driver Manager] Function sequence error')

问题： 最终，我想在Python中查看这些数据。该怎么做呢？

提前谢谢你。

Answer 1

把 cur.commit() 这一行去掉，因为在执行查询（SELECT）时并不需要它。

我用 pyodbc 复现了这个错误，所以我猜用 pypyodbc 也会有同样的问题。你可以把 pyodbc 的例子 应用到你的代码中，我觉得那些例子比 pypyodbc 现在提供的更完整。