如何用Python操作Access数据库？pyodbc连接

星夢妙者

发布时间：2025-07-15 15:35:02

523人浏览过

来源于php中文网

原创

python连接access数据库主要使用pyodbc库，1.需安装pyodbc；2.构建包含数据库路径和驱动信息的连接字符串；3.使用try-except-finally处理连接与错误；4.通过cursor执行sql查询并处理结果；5.注意参数化查询防止sql注入；6.确保安装匹配版本的microsoft access database engine驱动以解决“驱动程序未找到”问题；7.读写日期时间时自动转换为datetime对象；8.优化性能可通过连接池、指定检索列、索引、批量操作及定期压缩数据库实现。

如何用Python操作Access数据库？pyodbc连接

直接操作Access数据库，Python提供了几种选择，其中pyodbc库是相对稳定和广泛使用的方式。它允许你通过ODBC（开放数据库互连）连接到Access数据库，执行SQL查询，并处理结果。

解决方案

要使用pyodbc连接Access数据库，你需要以下步骤：

安装 pyodbc:

立即学习“Python免费学习笔记（深入）”；
```
pip install pyodbc
```
构建连接字符串:

连接字符串是告诉pyodbc如何找到并连接到你的Access数据库的关键。它通常包括数据库文件的路径和ODBC驱动程序的信息。
```
import pyodbc

# 数据库文件路径
db_file = r"C:\path\to\your\database.accdb"  # 注意使用原始字符串，避免转义问题

# 构建连接字符串
conn_str = (
    r"DRIVER={Microsoft Access Driver (*.mdb, *.accdb)};"
    r"DBQ=" + db_file + ";"
)

# 尝试连接
try:
    cnxn = pyodbc.connect(conn_str)
    cursor = cnxn.cursor()
    print("连接成功！")

    # 在这里执行你的SQL查询
    # 例如：
    # cursor.execute("SELECT * FROM YourTable")
    # rows = cursor.fetchall()
    # for row in rows:
    #     print(row)

except pyodbc.Error as ex:
    sqlstate = ex.args[0]
    if sqlstate == '01000':
        print("驱动程序可能未正确安装。请检查ODBC驱动程序管理器。")
    else:
        print("数据库连接失败：", ex)

finally:
    # 关闭连接
    if cnxn:
        cnxn.close()
        print("连接已关闭。")
```
关键点：
- DRIVER: 指定用于连接Access数据库的ODBC驱动程序。 {Microsoft Access Driver (*.mdb, *.accdb)} 通常适用于.accdb格式的Access数据库。如果你的数据库是.mdb格式，也应该适用。
- DBQ: 指定Access数据库文件的完整路径。 务必使用原始字符串（r"..."），避免反斜杠转义问题。
- 错误处理： 使用try...except...finally块来处理连接过程中可能出现的错误，并在最后确保关闭连接。这对于避免资源泄漏至关重要。
- ODBC驱动程序： 如果出现“驱动程序未找到”的错误，你需要确保已安装Microsoft Access Database Engine驱动程序。你可以从Microsoft官方网站下载并安装。注意选择与你的Python解释器（32位或64位）相匹配的版本。
执行SQL查询:

一旦连接成功，你就可以使用cursor对象执行SQL查询。
```
cursor.execute("SELECT * FROM YourTable WHERE SomeColumn = ?", (some_value,))  # 使用参数化查询
rows = cursor.fetchall()
for row in rows:
    print(row)
```
重要提示：
- 参数化查询： 使用参数化查询（?占位符）来防止SQL注入攻击，并正确处理包含特殊字符的值。
- fetchall(): fetchall() 方法将返回所有匹配的行作为元组列表。对于大型数据集，使用 fetchone() 逐行获取可能更有效。
- 提交更改： 如果执行了INSERT、UPDATE或DELETE语句，需要调用cnxn.commit()来提交更改。

如何解决“驱动程序未找到”的错误？

当使用pyodbc连接Access数据库时，最常见的错误之一是“驱动程序未找到”。这通常意味着你的系统缺少正确的ODBC驱动程序，或者pyodbc无法找到它。

检查驱动程序是否已安装：
- 打开“ODBC数据源管理器”（在Windows搜索栏中输入“ODBC”）。
- 切换到“驱动程序”选项卡。
- 确认列表中是否存在“Microsoft Access Driver (.mdb, .accdb)”。
安装正确的驱动程序：
- 如果驱动程序未找到，你需要下载并安装Microsoft Access Database Engine。
- 重要： 确保下载与你的Python解释器（32位或64位）相匹配的版本。例如，如果你的Python是32位的，即使你的操作系统是64位的，也需要安装32位的Access Database Engine。
检查连接字符串：
- 确保连接字符串中的DRIVER参数正确拼写，并且与ODBC数据源管理器中显示的驱动程序名称完全匹配。
环境变量（不常见）：
- 在极少数情况下，可能需要设置或修改环境变量来帮助pyodbc找到驱动程序。但这通常不是必需的。

如何处理Access数据库中的日期和时间？

Access数据库通常以特定格式存储日期和时间值。在使用pyodbc读取这些值时，你可能需要将其转换为Python可以理解的格式。

读取日期/时间值：

当使用cursor.fetchall() 或 cursor.fetchone() 读取包含日期/时间的列时，pyodbc 通常会将这些值作为datetime对象返回。

import pyodbc
import datetime

# ... (连接代码) ...

cursor.execute("SELECT OrderDate FROM Orders")
row = cursor.fetchone()

if row:
    order_date = row[0]  # 假设 OrderDate 是第一列

    if isinstance(order_date, datetime.datetime):
        print("订单日期:", order_date.strftime("%Y-%m-%d %H:%M:%S"))  # 格式化输出
    else:
        print("订单日期不是datetime对象:", order_date)

格式化日期/时间字符串：

使用strftime()方法可以将datetime对象格式化为字符串，以便于显示或存储。例如，"%Y-%m-%d %H:%M:%S" 将日期/时间格式化为 YYYY-MM-DD HH:MM:SS 的格式。
将Python日期/时间值写入数据库：

要将Python的datetime对象写入Access数据库，可以直接将其作为参数传递给cursor.execute()。 pyodbc会自动将其转换为Access数据库可以理解的格式。

ShopEx助理
一个类似淘宝助理、ebay助理的客户端程序，用来方便的在本地处理商店数据，并能够在本地商店、网上商店和第三方平台之间实现数据上传下载功能的工具。功能说明如下：1.连接本地商店：您可以使用ShopEx助理连接一个本地安装的商店系统，这样就可以使用助理对本地商店的商品数据进行编辑等操作，并且数据也将存放在本地商店数据库中。默认是选择“本地未安装商店”，本地还未安

下载
```
import pyodbc
import datetime

# ... (连接代码) ...

new_order_date = datetime.datetime.now()
cursor.execute("INSERT INTO Orders (OrderDate) VALUES (?)", (new_order_date,))
cnxn.commit()
```
处理特定日期/时间格式：

如果你的Access数据库使用非标准的日期/时间格式，你可能需要在SQL查询中使用Format()函数来显式地将日期/时间值转换为字符串，或者在Python代码中使用适当的解析函数来处理。

如何优化pyodbc连接Access数据库的性能？

虽然Access数据库通常用于小型应用程序，但优化pyodbc连接的性能仍然很重要，尤其是在处理大量数据时。

使用连接池：

频繁地打开和关闭数据库连接会消耗大量资源。使用连接池可以重用现有的连接，从而提高性能。pyodbc本身不提供内置的连接池，但你可以使用第三方库（例如PooledDB）来实现。

import pyodbc
from DBUtils.PooledDB import PooledDB

# 数据库连接信息
db_file = r"C:\path\to\your\database.accdb"
conn_str = (
    r"DRIVER={Microsoft Access Driver (*.mdb, *.accdb)};"
    r"DBQ=" + db_file + ";"
)

# 创建连接池
pool = PooledDB(
    creator=pyodbc,  # 使用 pyodbc 作为连接创建器
    maxconnections=5,  # 最大连接数
    mincached=2,       # 最小缓存连接数
    maxcached=3,       # 最大缓存连接数
    maxshared=3,
    blocking=True,     # 连接池满时是否阻塞
    setsession=[],
    connstr=conn_str
)

# 从连接池获取连接
conn = pool.connection()
cursor = conn.cursor()

# 执行查询
cursor.execute("SELECT * FROM YourTable")
rows = cursor.fetchall()
for row in rows:
    print(row)

# 关闭游标和连接 (连接将返回到连接池)
cursor.close()
conn.close()

使用参数化查询：

如前所述，使用参数化查询不仅可以防止SQL注入，还可以提高性能。 pyodbc可以缓存参数化查询的执行计划，从而加快后续查询的速度。
仅检索需要的列：

避免使用SELECT *，而是显式地指定你需要的列。这可以减少网络传输的数据量，并提高查询速度。
使用索引：

在Access数据库中，确保在经常用于查询的列上创建索引。索引可以显著提高查询速度。

批量操作：

如果需要插入、更新或删除大量数据，考虑使用批量操作。 pyodbc支持使用executemany()方法执行批量操作。

import pyodbc

# ... (连接代码) ...

data = [
    (1, "Name1", "Address1"),
    (2, "Name2", "Address2"),
    (3, "Name3", "Address3")
]

cursor.executemany("INSERT INTO YourTable (ID, Name, Address) VALUES (?, ?, ?)", data)
cnxn.commit()