MySQL flask连接MySQL

1. 引言

MySQL是一种开源的关系型数据库管理系统，广泛应用于互联网领域和企业级应用中。在开发Web应用时，我们通常需要将应用程序与数据库进行连接，以实现数据的持久化存储和读写操作。

Flask是一个使用Python编写的轻量级Web应用框架，它提供了一些简单而易用的工具，方便我们快速开发Web应用程序。结合MySQL数据库和Flask框架，我们可以高效地构建功能强大的Web应用。

本文将详细介绍如何在Flask应用中连接MySQL数据库，并进行一些基本的数据库操作。我们将涵盖以下内容：

安装和配置MySQL数据库
安装Flask和相关扩展模块
创建Flask应用
连接MySQL数据库
执行数据库操作
- 创建表
- 插入数据
- 查询数据
- 更新数据
- 删除数据
总结和注意事项

2. 安装和配置MySQL数据库

如需在本地环境中使用MySQL数据库，我们需要首先安装并配置MySQL。可以从MySQL官方网站(https://www.mysql.com/)下载并安装MySQL Community Server。

安装完成后，我们需要进行一些基本配置，包括设置root用户密码、创建新的数据库等。可以通过MySQL提供的命令行工具或图形化界面工具（如Navicat）进行配置。

3. 安装Flask和相关扩展模块

在连接MySQL数据库之前，我们需要安装Flask框架及其相关的扩展模块。可以使用pip命令安装Flask和MySQL相关的扩展模块：

$ pip install flask
$ pip install flask-mysql

4. 创建Flask应用

在开始之前，我们先创建一个简单的Flask应用，作为示例演示。首先，我们创建一个名为app.py的文件，并编写以下代码：

from flask import Flask

app = Flask(__name__)

@app.route('/')
def index():
    return 'Hello, Flask!'

if __name__ == '__main__':
    app.run()

这段代码创建了一个名为app的Flask应用对象，并定义了一个路由处理函数index()，当访问根路径”/”时，返回”Hello, Flask!”。最后通过app.run()启动Flask应用。

可以通过运行以下命令启动应用：

$ python app.py

在浏览器中访问http://localhost:5000，即可看到”Hello, Flask!”的输出。

5. 连接MySQL数据库

在Flask应用中连接MySQL数据库，我们需要首先配置数据库连接信息。可以在Flask应用的配置文件中添加以下配置项：

# app.py

# ...

app.config['MYSQL_HOST'] = 'localhost'
app.config['MYSQL_USER'] = 'root'
app.config['MYSQL_PASSWORD'] = 'your_password'
app.config['MYSQL_DB'] = 'your_database_name'

其中，MYSQL_HOST为MySQL服务器主机地址，MYSQL_USER为MySQL用户名，MYSQL_PASSWORD为MySQL用户密码，MYSQL_DB为要连接的数据库名称。

然后，我们需要创建MySQL连接对象。可以使用flaskext.mysql模块提供的MySQL类来实现：

# app.py

from flaskext.mysql import MySQL

# ...

mysql = MySQL()
mysql.init_app(app)

在上述代码中，我们创建了一个名为mysql的MySQL对象，并通过mysql.init_app(app)方法将其与Flask应用关联起来。

6. 执行数据库操作

6.1 创建表

在进行数据库操作之前，我们首先需要在MySQL数据库中创建相应的表。可以使用CREATE TABLE语句进行创建，也可以使用ORM工具（如SQLAlchemy）进行创建。

下面是一个创建名为users的表的示例：

# app.py

# ...

@app.route('/create_table')
def create_table():
    conn = mysql.connect()
    cursor = conn.cursor()

    query = '''
    CREATE TABLE IF NOT EXISTS users (
        id INT AUTO_INCREMENT PRIMARY KEY,
        name VARCHAR(100) NOT NULL
    ) ENGINE=InnoDB
    '''

    cursor.execute(query)
    conn.commit()

    cursor.close()
    conn.close()

    return 'Table created successfully!'

在上述代码中，我们通过mysql.connect()方法创建数据库连接，并通过conn.cursor()获取游标对象。然后，我们定义了一个创建表的SQL语句，并使用cursor.execute(query)方法执行该语句。

最后，通过调用conn.commit()方法提交事务，并通过cursor.close()和conn.close()关闭游标和数据库连接。返回”Table created successfully!”表示创建表成功。

可以通过访问http://localhost:5000/create_table来执行创建表的操作。

6.2 插入数据

在创建表之后，我们可以向表中插入数据。可以使用INSERT INTO语句进行插入操作。

下面是一个向users表插入一条数据的示例：

# app.py

# ...

@app.route('/insert_data')
def insert_data():
    conn = mysql.connect()
    cursor = conn.cursor()

    query = '''
    INSERT INTO users (name)
    VALUES ('Alice')
    '''

    cursor.execute(query)
    conn.commit()

    cursor.close()
    conn.close()

    return 'Data inserted successfully!'

在上述代码中，我们通过INSERT INTO语句将一条数据插入users表中。

可以通过访问http://localhost:5000/insert_data来执行数据插入操作。

6.3 查询数据

在插入数据之后，我们可以使用SELECT语句从表中查询数据。

下面是一个从users表中查询所有数据的示例：

# app.py

# ...

@app.route('/query_data')
def query_data():
    conn = mysql.connect()
    cursor = conn.cursor()

    query = '''
    SELECT * FROM users
    '''

    cursor.execute(query)
    data = cursor.fetchall()

    cursor.close()
    conn.close()

    return str(data)

在上述代码中，我们通过SELECT * FROM users语句查询users表中的所有数据，并使用cursor.fetchall()方法获取查询结果。

可以通过访问http://localhost:5000/query_data来执行数据查询操作。

6.4 更新数据

在查询数据之后，我们可以使用UPDATE语句更新表中的数据。

下面是一个将users表中name为Alice的记录更新为Bob的示例：

# app.py

# ...

@app.route('/update_data')
def update_data():
    conn = mysql.connect()
    cursor = conn.cursor()

    query = '''
    UPDATE users
    SET name = 'Bob'
    WHERE name = 'Alice'
    '''

    cursor.execute(query)
    conn.commit()

    cursor.close()
    conn.close()

    return 'Data updated successfully!'

在上述代码中，我们通过UPDATE语句将name为Alice的记录更新为Bob。

可以通过访问http://localhost:5000/update_data来执行数据更新操作。

6.5 删除数据

在更新数据之后，我们可以使用DELETE语句删除表中的数据。

下面是一个删除users表中name为Bob的记录的示例：

# app.py

# ...

@app.route('/delete_data')
def delete_data():
    conn = mysql.connect()
    cursor = conn.cursor()

    query = '''
    DELETE FROM users
    WHERE name = 'Bob'
    '''

    cursor.execute(query)
    conn.commit()

    cursor.close()
    conn.close()

    return 'Data deleted successfully!'

在上述代码中，我们通过DELETE FROM语句删除name为Bob的记录。

可以通过访问http://localhost:5000/delete_data来执行数据删除操作。