### Python连接MySQL数据库并执行函数的示例 在Python中，可以通过多种库（如`mysql-connector-python`、`PyMySQL`或`MySQLdb`）来连接MySQL数据库，并执行各种SQL操作。以下是一个使用`mysql-connector-python`库连接MySQL数据库并执行函数的完整示例。 #### 示例代码 ```python import mysql.connector from mysql.connector import Error def connect_to_mysql(host, user, password, database): """ 连接到MySQL数据库 参数: host (str): MySQL服务器的主机名或IP地址 user (str): 用于连接到数据库的用户名 password (str): 用户的密码 database (str): 要连接的数据库名 返回: mysql.connector.connection: 如果连接成功，则返回一个连接对象；否则返回None """ try: connection = mysql.connector.connect( host=host, user=user, password=password, database=database ) if connection.is_connected(): print("成功连接到数据库") return connection except Error as e: print(f"错误: {e}") return None def execute_query(connection, query): """ 执行SQL查询 参数: connection (mysql.connector.connection): 数据库连接对象 query (str): 要执行的SQL查询语句 返回: list: 查询结果的列表 """ if connection: try: cursor = connection.cursor() cursor.execute(query) result = cursor.fetchall() cursor.close() return result except Error as e: print(f"查询执行失败: {e}") return None # 主程序入口 if __name__ == "__main__": # 替换为你的数据库信息 HOST = "localhost" USER = "your_username" PASSWORD = "your_password" DATABASE = "your_database" # 连接数据库 connection = connect_to_mysql(HOST, USER, PASSWORD, DATABASE) if connection: # 定义要执行的SQL查询 QUERY = "SELECT * FROM your_table" # 执行查询 results = execute_query(connection, QUERY) if results: for row in results: print(row) # 关闭连接 connection.close() ``` 上述代码展示了如何通过`mysql-connector-python`库连接到MySQL数据库，并执行SQL查询[^1]。此外，还提供了错误处理机制以确保程序的健壮性。 #### 注意事项 1. **库安装**：需要确保已安装`mysql-connector-python`库。可以使用以下命令进行安装： ```bash pip install mysql-connector-python ``` 2. **安全性**：避免在代码中直接暴露敏感信息（如用户名和密码）。建议使用环境变量或配置文件来管理这些信息。 3. **异常处理**：在实际开发中，应更加细致地处理异常情况，例如网络问题或数据库锁定等[^3]。 ### 数据库连接与执行函数的其他实现方式 除了`mysql-connector-python`，还可以使用`PyMySQL`库来实现类似功能。以下是基于`PyMySQL`的示例： ```python import pymysql def connect_to_mysql(host, user, password, database): try: connection = pymysql.connect( host=host, user=user, password=password, db=database, charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor ) print("成功连接到数据库") return connection except pymysql.MySQLError as e: print(f"错误: {e}") return None def execute_query(connection, query): if connection: try: with connection.cursor() as cursor: cursor.execute(query) result = cursor.fetchall() return result except pymysql.MySQLError as e: print(f"查询执行失败: {e}") return None if __name__ == "__main__": HOST = "localhost" USER = "your_username" PASSWORD = "your_password" DATABASE = "your_database" connection = connect_to_mysql(HOST, USER, PASSWORD, DATABASE) if connection: QUERY = "SELECT * FROM your_table" results = execute_query(connection, QUERY) if results: for row in results: print(row) connection.close() ``` 此示例展示了如何使用`PyMySQL`库连接到MySQL数据库并执行查询[^2]。 ---