### 方法一：使用 `pymysql` 连接 MySQL 数据库 `pymysql` 是一个广泛使用的 Python 库，用于与 MySQL 数据库进行交互。它简单易用，并支持基本的数据库操作。 #### 示例代码： ```python import pymysql # 建立数据库连接 db = pymysql.connect( host='localhost', user='root', password='your_password', database='your_database', charset='utf8mb4' ) # 创建游标对象 cursor = db.cursor() # 执行 SQL 查询 cursor.execute("SELECT VERSION()") # 获取查询结果 data = cursor.fetchone() print(f"Database version: {data}") # 关闭数据库连接 db.close() ``` 该方法适用于大多数简单的数据库连接需求，并且可以结合 SSL 加密来增强安全性[^1]。 --- ### 方法二：使用 `mysql-connector-python` 连接 MySQL 数据库 `mysql-connector-python` 是由 MySQL 官方提供的连接器，支持更多高级功能，并且与 MySQL 服务器的兼容性更好。 #### 示例代码： ```python import mysql.connector # 建立数据库连接 cnx = mysql.connector.connect( host='localhost', user='root', password='your_password', database='your_database' ) # 创建游标对象 cursor = cnx.cursor() # 执行 SQL 查询 cursor.execute("SELECT VERSION()") # 获取查询结果 data = cursor.fetchone() print(f"Database version: {data}") # 关闭数据库连接 cnx.close() ``` 此方法在处理大型项目或需要更复杂数据库操作时表现良好，同时支持 SSL 连接以提升数据传输的安全性[^1]。 --- ### 方法三：使用 SQLAlchemy ORM 框架连接 MySQL 数据库 SQLAlchemy 提供了一个高层次的 ORM（对象关系映射）接口，使得开发者可以通过 Python 对象来操作数据库，而不必直接编写 SQL 语句。 #### 示例代码： ```python from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker # 创建数据库引擎 engine = create_engine('mysql+pymysql://root:your_password@localhost/your_database') # 创建会话类 Session = sessionmaker(bind=engine) session = Session() # 执行 SQL 查询 result = session.execute("SELECT VERSION()") for row in result: print(f"Database version: {row[0]}") ``` 这种方法适合需要构建复杂数据库模型的应用程序，能够有效提高开发效率和代码可维护性[^1]。 --- ### 方法四：使用 `PyMySQLPool` 实现连接池管理 对于高并发应用场景，建议使用连接池技术来优化数据库连接性能。`PyMySQLPool` 是基于 `pymysql` 的轻量级连接池实现。 #### 示例代码： ```python import pymysqlpool # 配置连接池 config = { 'host': 'localhost', 'user': 'root', 'password': 'your_password', 'database': 'your_database', 'charset': 'utf8mb4', 'autocommit': True, 'pool_size': 5 } pymysqlpool.ConnectionPool(**config) # 获取连接 with pymysqlpool.ConnectionPool(**config) as pool: with pool.connection() as conn: with conn.cursor() as cursor: cursor.execute("SELECT VERSION()") data = cursor.fetchone() print(f"Database version: {data}") ``` 通过连接池机制，可以显著减少频繁创建和销毁连接带来的性能损耗，适用于大规模并发访问场景[^1]。 --- ### 总结 上述四种方法分别适用于不同的使用场景： - `pymysql` 和 `mysql-connector-python` 适合基础的数据库操作； - SQLAlchemy 更适合复杂的业务逻辑和面向对象的设计； - `PyMySQLPool` 则适用于高性能、高并发的需求。 选择合适的连接方式将有助于提升应用程序的稳定性和执行效率。