在Python中可以使用`pymysql`库来创建一个用于连接MySQL数据库的链接包。下面是一个简单的示例，展示如何封装这个功能。 ### 示例代码 ```python import pymysql class MySQLConnector: def __init__(self, host='localhost', user='root', password='', database=''): self.host = host self.user = user self.password = password self.database = database self.connection = None def connect(self): """建立数据库连接""" try: self.connection = pymysql.connect( host=self.host, user=self.user, password=self.password, database=self.database ) print("成功连接到数据库") except Exception as e: print(f"无法连接到数据库: {e}") def disconnect(self): """关闭数据库连接""" if self.connection and self.connection.open: self.connection.close() print("已断开数据库连接") def execute_query(self, query): """执行查询操作并返回结果""" if not self.connection or not self.connection.open: return "尚未建立有效连接" try: with self.connection.cursor() as cursor: cursor.execute(query) result = cursor.fetchall() return result except Exception as e: return f"查询出错: {e}" # 使用示例 if __name__ == "__main__": db_config = { 'host': '127.0.0.1', 'user': 'your_user', 'password': 'your_password', 'database': 'test_db' } connector = MySQLConnector(**db_config) connector.connect() # 查询数据 data = connector.execute_query("SELECT * FROM your_table;") for row in data: print(row) connector.disconnect() ``` --- 上述代码提供了一个简单的包装类 `MySQLConnector` ，你可以通过它轻松管理对MySQL数据库的操作。 #### 功能说明： 1. **初始化配置**：传入主机名、用户名、密码以及目标数据库名称。 2. **连接和断开**：分别由`connect()` 和 `disconnect()` 方法处理。 3. **执行SQL查询**：使用`execute_query()` 执行自定义的 SQL 命令，并返回查询的结果集。 如果需要进一步优化该模块的功能，比如支持事务提交或者批量插入等复杂需求，可以根据实际场景进行扩展。