目录

一、项目背景

1.1 技术栈

1.2 总结

二、源码

2.1 sever.py

2.2 server_conf.py

三、运行演示（图文教程）

3.1 数据准备

3.2 启动服务

3.3 测试GET : select_data

3.4 测试PATCH: update_data

3.5 测试DELETE : delete_data

3.6 测试POST : insert_data

---

一、项目背景

1.1 技术栈

python版本是，python3.10.11，其他的包用python对应的版本即可，框架：flask2.3.2 ，IDEA是pycharm，使用postman模拟前端，数据库：mysql

1.2 总结

只是一个快速上手flask和前后端交互性的一个小案例，优化空间非常大，如：代码的健壮性，可读性，格式的标准，代码不简洁等等，并且实现的不够灵活，很多地方都是写死的，并且对数据库的操作要小心，尤其是删除插入修改，一定要把所有场景考虑好，以免发生事故，此代码在真实运用场景并不提倡，ps:读者也可以学习下flask_resrless的使用

二、源码

在本地新建一个文件夹如：sql_platform，将2.1和2.2两个源码存成两个py文件，都放在sql_platform下面。

2.1 sever.py

"""
Author : rebeccayanhan
Time   : 2023/5/22 下午5:45
File   : server.py
"""
from flask import Flask, jsonify, request
from service_conf import *
import pymysql
import json
app = Flask(__name__)
def create_mysql_conn():
    # pymysql连接rebecca数据库
    conn = pymysql.connect(host=mysql_params['host'],
                           port=mysql_params['port'],
                           user=mysql_params['user'],
                           passwd=mysql_params['passwd'],
                           db=mysql_params['db'],
                           charset=mysql_params['charset'])
    return conn
@app.route("/")
def hi():
    return "Hi!"
@app.route("/select_data")
def select():
    conn = create_mysql_conn()
    # 创建一个游标
    cursor = conn.cursor()
    query_sql = "select * from student;"
    n = cursor.execute(query_sql)
    ls = ['Sno', 'Sname', 'Sex', 'Sage', 'Sdept']
    result_dic = {'count': n, 'table_name': 'student'}
    ls_2 = []
    for row in cursor:
        temp = {}
        for i in range(len(row)):
            temp[ls[i]] = row[i]
        ls_2.append(temp)
    result_dic['info'] = ls_2
    cursor.close()
    return json.dumps(result_dic)
@app.route("/insert_data", methods=["POST"])
def insert():
    conn = create_mysql_conn()
    # 创建一个游标
    cursor = conn.cursor()
    # 这个info_list = request.form.get("info")通过url
    # 下面这个通过body
    info_list = request.json.get("info")
    for info in info_list:
        sno = info['Sno']
        sname = info['Sname']
        sex = info['Sex']
        sage = info['Sage']
        sdept = info['Sdept']
        query_sql = "insert into student(Sno, Sname, Sex, Sage, Sdept) values({}, {}, {}, {}, {});".format(sno,
             repr(sname),
             repr(sex),
             sage,
             repr(sdept))
        cursor.execute(query_sql)
    cursor.close()
    conn.commit()
    ret_message = {"code": 0, "status": "successful"}
    return ret_message
@app.route("/update_data", methods=['PATCH'])
def update():
    conn = create_mysql_conn()
    cursor = conn.cursor()
    info_list = request.json.get("info")
    for info in info_list:
        sname = info['Sname']
        if sname == '李勇':
            query_sql = "update student set sage=90 where sname='{}';".format(sname)
            print(query_sql)
            cursor.execute(query_sql)
    # 修改后需要commit
    cursor.close()
    conn.commit()
    ret_message = {"code": 0, "status": "successful"}
    return ret_message
@app.route("/delete_data", methods=['DELETE'])
def delete():
    conn = create_mysql_conn()
    cursor = conn.cursor()
    info_list = request.json.get("info")
    for info in info_list:
        sno = info['Sno']
        query_sql = "delete from student where Sno={};".format(sno)
        cursor.execute(query_sql)
    # 删除后需要commit
    cursor.close()
    conn.commit()
    ret_message = {"code": 0, "status": "successful"}
    return ret_message
if __name__ == "__main__":
    app.run()

2.2 server_conf.py

"""
Author : rebeccayanhan
Time   : 2023/5/22 下午5:45
File   : server_conf.py
"""
# 读写参数
mysql_params = {
    'host': '127.0.01', 
    'user': 'root',          #数据库用户名
    'passwd': '********',    #用户密码
    'db': 'rebecca',         #数据库的名字
    'port': 3306,            #端口号
    'charset': 'utf8'        #编码方式
}

三、运行演示（图文教程）

3.1 数据准备

先创建一个database，这里我使用的是自己创建的rebecca

 再往数据库里面先存入几条数据，如下表所示。

查看数据库的端口号

show global variables like 'port';

 3.2 启动服务

启动server.py文件

启动成功，如下图所示， 点击http://127.0.0.1:5000/

 出现，服务运行成功

3.3 测试get : select_data

 对应代码为select函数（def select():那行开始）

选择GET，URL输入

http://127.0.0.1:5000/select_data

选择json结构

3.4 测试PATCH: update_data

 对应代码为updata函数（def update():那行开始）

通过这个函数我希望把李勇的年龄改为90，现在的数据是，李勇的年龄是20 

select * from student where sname='李勇';

 输入 http://127.0.0.1:5000/update_date，和body

{
    "info": [
        {
            "Sno": 201215121,
            "Sname": "李勇",
            "Sex": "男",
            "Sage": 20,
            "Sdept": "CS"
        }
    ]
}

点击send，如下图，显示已经成功 

 再次查看数据，已经修改成功

3.5 测试DELETE : delete_data

 对应代码为delete函数（def delete():那行开始）

代码实现是通过学号sno来删除,将学号等于201215123的人删除，

postman进行如下输入和选择

{
    "info": [
        {
            "Sno": 201215123,
            "Sname": "李勇",
            "Sex": "男",
            "Sage": 20,
            "Sdept": "CS"
        }
    ]
}

 输入http://127.0.0.1:5000/delete_data，点击send，如下图，显示已经成功 

删除结果

3.6 测试POST : insert_data

 对应代码为insert函数（def insert():那行开始）

插入一个全新数据，postman进行如下输入和选择

{
    "info": [
        {
            "Sno": 112873981211,
            "Sname": "rebecca",
            "Sex": "女",
            "Sage": 18,
            "Sdept": "CS"
        }
    ]
}

输入http://127.0.0.1:5000/insert_data ，点击send，如下图，显示已经成功 

查看数据库是否插入成功，如图所示已经成功。（也可以通过get来查看）