### Python3 中操作 MySQL 的封装方法 对于在 Python3 中操作 MySQL 数据库，`pymysql` 是一种常用的解决方案[^1]。此库允许开发者通过纯 Python 实现与 MySQL 数据库的交互。 #### 使用 `pymysql` 进行数据库连接和查询 为了简化对 MySQL 数据库的操作并处理可能出现的错误（如 OperationalError），可以创建一个简单的类来封装这些功能： ```python import pymysql.cursors class DatabaseConnection: """提供了一个用于管理数据库会话的方法""" def __init__(self, host='localhost', user='', password='', db=''): """ 初始化一个新的数据库连接实例 参数: host (str): 主机地址，默认为 'localhost' user (str): 用户名 password (str): 密码 db (str): 要使用的数据库名称 """ try: self.connection = pymysql.connect( host=host, user=user, password=password, database=db, cursorclass=pymysql.cursors.DictCursor ) except Exception as e: print(f"无法建立到 {db} 的连接: {e}") def execute_query(self, query): """ 执行给定 SQL 查询语句 参数: query (str): 需要执行的SQL命令字符串 返回: list(dict): 结果集作为字典列表返回 """ with self.connection.cursor() as cursor: cursor.execute(query) result = cursor.fetchall() return result def close_connection(self): """关闭当前打开的数据库连接""" if hasattr(self, 'connection'): self.connection.close() if __name__ == "__main__": # 创建数据库对象并尝试获取数据 my_db = DatabaseConnection(host="localhost", user="root", password="", db="test") results = my_db.execute_query("SELECT * FROM users LIMIT 5;") for row in results: print(row) # 关闭连接 my_db.close_connection() ``` 上述代码展示了如何定义一个名为 `DatabaseConnection` 的类，它能够安全地初始化、执行查询以及最终断开与 MySQL 数据库之间的连接。当遇到像提到的那种由于找不到套接字文件而产生的连接失败情况时，程序将会捕获异常并向用户提供反馈信息。