### 使用 Python 脚本连接 MySQL 数据库并执行 SQL 命令 为了使用 Python 连接到 MySQL 数据库并执行 SQL 命令，可以采用 `pymysql` 库来完成这一过程。以下是具体的操作方法： #### 导入必要的库 首先需要确保已经安装了 `pymysql` 模块，可以通过 pip 安装工具进行安装。之后，在脚本中导入此模块。 ```python import pymysql ``` #### 创建数据库连接 定义函数 `_create_connection()` 来建立与 MySQL 的连接，其中包含了主机名 (`host`)、用户名 (`user`)、密码 (`password`) 和目标数据库名称 (`database`) 参数设置。 ```python def _create_connection(): try: connection = pymysql.connect( host='localhost', user='root', password='password', database='mydatabase' ) print("Connection to MySQL DB successful") return connection except Exception as e: print(f"The error '{e}' occurred") return None ``` #### 执行查询语句 构建另一个名为 `_execute_query()` 函数用来接收 SQL 查询字符串作为参数，并通过之前创建好的连接对象中的游标(`cursor()`)去执行该命令。对于修改类操作（如 INSERT/UPDATE），记得调用 commit 方法保存变更；而对于 SELECT 类型的只读请求，则可以直接 fetch 结果集。 ```python def _execute_query(connection, query): cursor = connection.cursor() try: cursor.execute(query) connection.commit() print("Query executed successfully") except Exception as e: print(f"The error '{e}' occurred") def _fetch_data(connection, query): cursor = connection.cursor(dictionary=True) result = None try: cursor.execute(query) result = cursor.fetchall() return result except Exception as e: print(f"The error '{e}' occurred") return None ``` #### 关闭连接 当所有的交互完成后应当释放资源，即断开同服务器之间的会话链接。 ```python def close_connection(connection): if connection is not None and connection.open: connection.close() print('Database connection closed.') ``` #### 实际应用案例 这里给出一段完整的例子展示怎样运用上述封装的功能向表内插入一条记录以及检索全部数据条目。 ```python if __name__ == '__main__': cnx = _create_connection() create_table = """ CREATE TABLE IF NOT EXISTS users ( id INT AUTO_INCREMENT, name VARCHAR(255) NOT NULL, age INT, PRIMARY KEY (id) ) ENGINE=InnoDB; """ insert_user = "INSERT INTO users (name, age) VALUES ('John Doe', 30)" select_all_users = "SELECT * FROM users" # Create table _execute_query(cnx, create_table) # Insert a new record into the 'users' table. _execute_query(cnx, insert_user) # Fetch all records from the 'users' table. results = _fetch_data(cnx, select_all_users) for row in results: print(row) # Close the connection when done. close_connection(cnx) ``` 以上代码展示了如何利用 Python 编写程序以安全可靠的方式访问 MySQL 数据库并执行基本 CRUD 操作[^2]。