# Python 创建数据库连接的核心方法与实战 在 Python 中进行数据库操作，核心遵循 **DB-API 2.0** 规范。该规范定义了一套标准的接口，使得 Python 代码可以在不同的数据库系统（如 MySQL、SQLite、SQL Server）之间进行移植，而无需大幅修改逻辑 [1][2]。创建数据库连接的核心在于获取 `connection` 对象，随后通过该对象创建 `cursor` 游标来执行 SQL 语句 [1]。 ### 1. 常见数据库驱动模块对比 Python 本身不直接内置所有数据库驱动，通常需要安装第三方模块。以下是主流数据库对应的连接模块及特点： | 数据库类型 | 推荐模块 | 安装命令 | 特点说明 | 参考资料 | | :--- | :--- | :--- | :--- | :--- | | **MySQL** | `pymysql` 或 `mysql-connector-python` | `pip install pymysql` | 纯 Python 实现，兼容性好，广泛用于 Web 开发 | [ref_5] | | **SQLite** | `sqlite3` | 内置无需安装 | 轻量级，文件型数据库，适合本地测试或小型应用 | [ref_3] | | **SQL Server** | `pymssql` 或 `pyodbc` | `pip install pymssql` | 适用于企业级微软数据库环境，支持事务处理 | [ref_3] | | **PostgreSQL** | `psycopg2` | `pip install psycopg2` | 功能强大，支持高级 PostgreSQL 特性 | [ref_1] | ### 2. 标准连接流程详解 无论使用哪种数据库，创建连接的标准流程通常包含以下六个步骤：引入模块、建立连接、创建游标、执行 SQL、提交事务、关闭连接 [4]。 1. **引入模块**：导入对应的数据库驱动库。 2. **建立连接**：调用 `connect()` 方法，传入主机、用户、密码等参数，返回连接对象 [5]。 3. **创建游标**：通过连接对象的 `cursor()` 方法获取游标，用于执行 SQL [2]。 4. **执行 SQL**：使用游标的 `execute()` 方法运行查询或更新语句。 5. **提交事务**：对于增删改操作，必须调用 `commit()` 否则数据不会保存 [6]。 6. **关闭资源**：操作完成后，依次关闭游标和连接，释放资源 [4]。 ### 3. 代码实战示例 #### 示例一：连接 MySQL 数据库 以下代码展示了如何使用 `pymysql` 连接 MySQL，并包含异常处理机制以确保连接安全关闭 [6]。 ```python import pymysql def connect_mysql(): connection = None cursor = None try: # 建立数据库连接，需替换为实际配置信息 connection = pymysql.connect( host='localhost', # 数据库主机地址 user='root', # 数据库用户名 password='password', # 数据库密码 database='test_db', # 数据库名称 charset='utf8mb4' # 编码设置 ) # 创建游标对象 cursor = connection.cursor() # 执行查询语句 cursor.execute("SELECT VERSION()") data = cursor.fetchone() print(f"Database version : {data}") # 提交事务（如果是写操作） connection.commit() except pymysql.Error as e: print(f"Error connecting to MySQL: {e}") if connection: connection.rollback() # 出错则回滚 finally: # 确保关闭游标和连接 if cursor: cursor.close() if connection: connection.close() if __name__ == "__main__": connect_mysql() ``` #### 示例二：连接 SQLite 数据库 SQLite 是 Python 标准库的一部分，无需额外安装，适合快速原型开发 [3]。 ```python import sqlite3 def connect_sqlite(): try: # 连接本地文件，若不存在则自动创建 conn = sqlite3.connect('example.db') cursor = conn.cursor() # 创建表操作 cursor.execute('''CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT)''') # 插入数据 cursor.execute("INSERT INTO users (name) VALUES ('Alice')") conn.commit() # 必须提交事务 print("SQLite connection successful") except sqlite3.Error as e: print(f"SQLite error: {e}") finally: if conn: conn.close() ``` ### 4. 最佳实践与安全建议 在实际开发中，建议采用 **上下文管理器（with 语句）** 来管理数据库连接，这样可以自动处理资源的关闭，避免忘记关闭连接导致的资源泄露 [5]。此外，执行 SQL 语句时务必使用 **参数化查询**，严禁使用字符串拼接来构建 SQL，以防止 SQL 注入攻击 [6]。例如，使用 `cursor.execute("SELECT * FROM users WHERE id = %s", (user_id,))` 而非直接拼接字符串。通过遵循 DB-API 规范，开发者可以轻松地在不同数据库后端之间切换，同时保证代码的健壮性和安全性 [2]。