### 使用 Flask 操作 MySQL 的示例 #### 创建 Flask 应用并配置 MySQL 数据库连接 为了使 Flask 能够与 MySQL 数据库交互，需先安装必要的 Python 包 `Flask` 和 `PyMySQL` 或者 `mysqlclient`。可以通过 pip 安装这些包： ```bash pip install Flask pymysql ``` 接着，在应用初始化部分建立到 MySQL 数据库的链接[^2]。 ```python from flask import Flask, request, jsonify import pymysql.cursors app = Flask(__name__) # 配置数据库参数 db_config = { "host": "localhost", "port": 3306, "user": "username", # 替换成实际用户名 "password": "password", # 替换成实际密码 "database": "dbname" # 替换成实际数据库名 } connection = pymysql.connect(**db_config) @app.route('/users', methods=['GET']) def get_users(): try: with connection.cursor() as cursor: sql = "SELECT * FROM users" cursor.execute(sql) result = cursor.fetchall() return jsonify(result), 200 except Exception as e: return str(e), 500 ``` 此段代码展示了如何创建一个简单的 RESTful API 来获取所有用户的列表。通过 GET 请求访问 `/users` URL 可返回存储于 MySQL 中的数据表内全部记录作为 JSON 响应给客户端。 #### 执行事务处理 当涉及到多个 SQL 指令时，应该考虑使用事务来保证数据的一致性和完整性。下面的例子说明了怎样在一个事务里更新两条不同的用户信息，并最终提交更改[^3]。 ```python @app.route('/update-users', methods=['POST']) def update_users(): try: with connection.cursor() as cursor: transaction_sql = [ ("UPDATE user SET age = age + 1 WHERE id = %s;", (1,)), ("UPDATE user SET gender = %s WHERE id = %s;", ('F', 2)) ] with connection.begin(): # 开始新事物 for query, params in transaction_sql: cursor.execute(query, params) connection.commit() # 提交事务 return '', 204 # 成功响应无内容状态码 except Exception as e: connection.rollback() # 出错则回滚 return str(e), 500 # 返回错误消息和服务器内部错误的状态码 ``` 这段代码实现了两个更新操作作为一个原子性的单元被执行；如果任何一个失败，则整个过程都将被撤销以保持一致性。