连接数据库是许多Python应用程序的核心部分，尤其是当涉及到与数据库交互时。`pyodbc` 是一个非常流行的库，它允许Python程序通过ODBC（开放式数据库连接）与各种数据库进行通信。以下是一个详细的教程和示例，帮助你使用 `pyodbc` 连接到数据库。 ### 安装 pyodbc 首先，确保你已经安装了 `pyodbc` 库。你可以使用 `pip` 来安装它： ```bash pip install pyodbc ``` ### 连接到数据库 `pyodbc` 提供了一个 `connect` 函数，用于建立与数据库的连接。连接字符串的格式取决于你要连接的数据库类型。以下是一些常见的数据库连接示例。 #### 连接到 SQL Server 如果你要连接到 Microsoft SQL Server，可以使用以下连接字符串： ```python import pyodbc # 连接到SQL Server cnxn = pyodbc.connect('DRIVER={SQL Server};SERVER=localhost;PORT=1433;DATABASE=testdb;UID=me;PWD=pass') cursor = cnxn.cursor() # 执行查询 cursor.execute("SELECT * FROM your_table") # 获取所有行 rows = cursor.fetchall() for row in rows: print(row) # 关闭连接 cnxn.close() ``` #### 连接到 MySQL 如果你要连接到 MySQL 数据库，可以使用以下连接字符串： ```python import pyodbc # 连接到MySQL cnxn = pyodbc.connect('DRIVER={MySQL ODBC 8.0 Driver};SERVER=localhost;DATABASE=testdb;USER=root;PASSWORD=yourpassword;PORT=3306') cursor = cnxn.cursor() # 执行查询 cursor.execute("SELECT * FROM your_table") # 获取所有行 rows = cursor.fetchall() for row in rows: print(row) # 关闭连接 cnxn.close() ``` #### 连接到 PostgreSQL 如果你要连接到 PostgreSQL 数据库，可以使用以下连接字符串： ```python import pyodbc # 连接到PostgreSQL cnxn = pyodbc.connect('DRIVER={PostgreSQL};SERVER=localhost;PORT=5432;DATABASE=testdb;UID=postgres;PWD=yourpassword') cursor = cnxn.cursor() # 执行查询 cursor.execute("SELECT * FROM your_table") # 获取所有行 rows = cursor.fetchall() for row in rows: print(row) # 关闭连接 cnxn.close() ``` ### 连接到 InterSystems IRIS 如果你要连接到 InterSystems IRIS 数据库，可以使用以下连接字符串： ```python import pyodbc # 连接到InterSystems IRIS driver = '/usr/irisodbc/bin/libirisodbc35.so' server = 'xxx' database = 'xxx' username = 'xxx' password = 'xxx' port = '1927' cnxn = pyodbc.connect(Driver=driver, Server=server, Database=database, UID=username, PWD=password, Port=port) cursor = cnxn.cursor() # 执行查询 cursor.execute("SELECT * FROM your_table") # 获取所有行 rows = cursor.fetchall() for row in rows: print(row) # 关闭连接 cnxn.close() ``` ### 备份数据库 `pyodbc` 还可以用于执行数据库备份操作。以下是一个备份 SQL Server 数据库的示例： ```python import pyodbc # 建立数据库连接 pyobdcStr = "DRIVER={SQL SERVER};SERVER=%s;UID=%s;PWD=%s;DATABASE=%s" % (server, user, password, DBname) conn = pyodbc.connect(pyobdcStr) # 设置自动提交 conn.autocommit = True # 执行备份语句 path = 'D:/schedual_task.bak' sql = f"BACKUP DATABASE ZQGL TO DISK=N'{path}' WITH INIT" cur = conn.cursor() cur.execute(sql) # 等待备份完成 while cur.nextset(): pass # 提交事务 conn.commit() # 关闭连接 conn.autocommit = False conn.close() ``` ### 注意事项 - **DSN 配置**：如果你使用的是 DSN（数据源名称），确保在 ODBC 数据源管理器中正确配置了 DSN。 - **驱动程序**：确保你使用的驱动程序与数据库版本兼容。 - **安全性**：避免在代码中硬编码敏感信息，如用户名和密码。可以使用环境变量或其他安全机制来存储这些信息。 ###