尝试使用 PYODBC 将 Access 数据库表读入 Pandas 时出错

Question

我想执行一项简单的任务，将 MS Access 数据库中的表数据以数据框的形式导入 Pandas。我最近工作得很好，现在我不知道为什么它不再工作了。我记得在最初对连接进行故障排除时，我需要围绕安装具有正确位数的新 Microsoft 数据库驱动程序做一些工作，所以我重新审视了它并重新安装了驱动程序。以下是我用于设置的内容。

笔记本电脑安装记录：

• 操作系统：Windows 7 Professional 64 位（2017 年 9 月 6 日验证）
• 访问版本：Access 2016 32bit（2017 年 9 月 6 日验证）
• Python 版本：使用 >Python -V（2017 年 9 月 11 日验证）找到的 Python 3.6.1（64 位）
• 所需的 AccessDatabaseEngine 将基于上述 Python 位数
• 使用 >AccessDatabaseEngine_X64.exe /passive（已于 2017 年 9 月 11 日验证）与 2010 版 AccessDatabaseEngine_X64.exe 一起安装的 Windows 数据库引擎驱动程序

我正在运行以下简单的测试代码来尝试连接到测试数据库。

import pyodbc
import pandas as pd

[x for x in pyodbc.drivers() if x.startswith('Microsoft Access Driver')]

返回：

['Microsoft Access Driver (*.mdb, *.accdb)']

设置连接字符串。

dbpath = r'Z:\1Users\myfiles\software\JupyterNotebookFiles\testDB.accdb'
conn_str = (r'Driver={Microsoft Access Driver (*.mdb, *.accdb)};''DBQ=%s;' %(dbpath))
cnxn = pyodbc.connect(conn_str)
crsr = cnxn.cursor()

正在验证我是否已连接到数据库...

for table_info in crsr.tables(tableType='TABLE'):
    print(table_info.table_name)

返回：

TestTable1

尝试连接到 TestTable1 会出现以下错误。

dfTable = pd.read_sql_table(TestTable1, cnxn)

---------------------------------------------------------------------------
NameError                                 Traceback (most recent call last)
<ipython-input-14-a24de1550834> in <module>()
----> 1 dfTable = pd.read_sql_table(TestTable1, cnxn)
      2 #dfQuery = pd.read_sql_query("SELECT FROM [TestQuery1]", cnxn)

NameError: name 'TestTable1' is not defined

用单引号再次尝试会出现以下错误。

dfTable = pd.read_sql_table('TestTable1', cnxn)

---------------------------------------------------------------------------
NotImplementedError                       Traceback (most recent call last)
<ipython-input-15-1f89f9725f0a> in <module>()
----> 1 dfTable = pd.read_sql_table('TestTable1', cnxn)
      2 #dfQuery = pd.read_sql_query("SELECT FROM [TestQuery1]", cnxn)

C:\Users\myfiles\Anaconda3\lib\site-packages\pandas\io\sql.py in read_sql_table(table_name, con, schema, index_col, coerce_float, parse_dates, columns, chunksize)
    250     con = _engine_builder(con)
    251     if not _is_sqlalchemy_connectable(con):
--> 252         raise NotImplementedError("read_sql_table only supported for "
    253                                   "SQLAlchemy connectable.")
    254     import sqlalchemy

NotImplementedError: read_sql_table only supported for SQLAlchemy connectable.

我尝试返回驱动程序问题并重新安装 32 位版本，但没有任何运气。

有人有什么想法吗？

Answer 1

根据pandas.read_sql_table 的文档：

给定一个表名和一个 SQLAlchemy 可连接对象，返回一个 DataFrame。 此函数不支持 DBAPI 连接。

由于 pyodbc 是一个 DBAPI，请使用查询方法 pandas.read_sql，其中 con 参数确实支持 DBAPI：

dfTable = pd.read_sql("SELECT * FROM TestTable1", cnxn)

Answer 2

仅使用 table_name 读取 db 表

import pandas
from sqlalchemy import create_engine

engine=create_engine('postgresql+psycopg2://user:password@localhost/db_name')
df=pandas.read_sql_table("table_name",engine)