### Flask连接MySQL并查询表数据的方法 在Flask中连接MySQL数据库并执行查询操作，通常需要使用`Flask-SQLAlchemy`或直接通过`pymysql`模块进行操作。以下是具体方法和示例代码： #### 1. 安装依赖模块 首先需要安装`Flask-SQLAlchemy`和`mysql-connector-python`（或`pymysql`）。可以通过以下命令完成安装： ```bash pip install flask-sqlalchemy pymysql ``` #### 2. 配置数据库连接 配置数据库连接信息时，需指定`SQLALCHEMY_DATABASE_URI`，该字符串包含数据库类型、用户名、密码、主机地址、端口以及数据库名称等信息。 示例配置如下： ```python from flask import Flask from flask_sqlalchemy import SQLAlchemy app = Flask(__name__) # 数据库连接URI配置 app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://用户名:密码@主机地址:3306/数据库名' app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True # 跟踪对象的修改 db = SQLAlchemy(app) ``` 上述代码中，`SQLALCHEMY_DATABASE_URI`定义了数据库连接信息[^1]。 #### 3. 定义模型类 使用`SQLAlchemy`的ORM功能，可以将数据库表映射为Python类。例如，定义一个用户表的模型类： ```python class User(db.Model): __tablename__ = 'user' id = db.Column(db.Integer, primary_key=True) username = db.Column(db.String(80), unique=True, nullable=False) email = db.Column(db.String(120), unique=True, nullable=False) def __repr__(self): return f'<User {self.username}>' ``` 此段代码定义了一个名为`User`的模型类，并将其映射到数据库中的`user`表[^4]。 #### 4. 查询表数据 通过`SQLAlchemy`提供的查询接口，可以轻松执行各种查询操作。以下是一些常见的查询示例： ##### (1) 查询所有用户 ```python @app.route('/users') def get_users(): users = User.query.all() # 查询所有用户 result = [{'id': user.id, 'username': user.username, 'email': user.email} for user in users] return {'users': result} ``` ##### (2) 根据用户名查询用户 ```python @app.route('/user/<username>') def get_user_by_name(username): user = User.query.filter_by(username=username).first() # 根据用户名查询单个用户 if user: return {'id': user.id, 'username': user.username, 'email': user.email} else: return {'message': 'User not found'}, 404 ``` ##### (3) 插入新用户 ```python @app.route('/add_user', methods=['POST']) def add_user(): data = request.json new_user = User(username=data['username'], email=data['email']) db.session.add(new_user) db.session.commit() return {'message': 'User added successfully'}, 201 ``` #### 5. 使用原生SQL查询 如果需要执行更复杂的查询，可以直接使用`session.execute()`方法： ```python @app.route('/execute_sql') def execute_sql(): sql = "SELECT * FROM user WHERE username LIKE '%ming%'" result = db.session.execute(sql) users = [{'id': row[0], 'username': row[1], 'email': row[2]} for row in result] return {'users': users} ``` #### 注意事项 - 确保数据库服务已启动，并且提供了正确的连接信息。 - 在生产环境中，建议对敏感信息（如用户名和密码）进行加密处理。 - 如果使用的是外键关系，需确保外键约束正确设置[^2]。 ---