目录
一、前言
1.1 之前在练习了Django的博客项目，前后端不分离的，现在就想着把Flask框架也再熟悉一下，后续把接口返回的数据用vue显示。python 比较流行的框架是Django 和Flask，重要性不言而喻
1.2 刚好是五一，发文符合劳动节精神，深圳又下雨，在家搬砖
二、环境准备
2.1 安装python
确保你的电脑安装了python，并正确配置好环境变量。查看版本命令：
python -V
本文内容运行在python 3.6.1
2.2 安装mysql
确保你的电脑安装了mysql，并正确设置账号和密码，本机账号和密码为 root/root
mysql -V
本文内容mysql 5.7中运行通过
三、工具准备
3.1 安装pycharm
确保你的电脑安装了pycharm，我这里用的是pycharm professional 2017.3（已pojie）
可视化数据库查询工具准备，工具很多，本文用的是拿手的Navicat
3.3 安装postman
postman是一款必会的工具，开发和测试都在用
四、mysql数据库准备
连接名起一个test，主机输入localhost或者127.0.0.1，默认端口3306，输入用户名和密码root/root，点击链接测试，链接成功
4.2 数据库准备
在链接上test数据源后，在test处右键，新建数据库，数据库名books，字符集utf-8，排序规则选择utf8_general_ci，点击确认，数据新建完成
注意：此处不新建表，从代码里面通过模型类建表
五、增删改查接口（服务）开发
开发前先做一些准备工作，新建flask项目，file ->new project
创建完成。我这里book是根目录，主文件我改名字app.py，不该也可以此时就可以右键启动了
控制台会打印 访问地址，点击访问 浏览器页面显示 Hello World!，我这里代码删了不贴图了。
安装一些用的库，点击file->settings，flask、PyMySQL、SQLAlchemy、flask-sqlalchemy等（注意有些库使用的时候的名字和导入的时候的名字不一样，比如导入flask-sqlalchemy，代码里面却是flask_sqlalchemy）
接着，逐步把以下代码添加到app.py文件中。先导入一些要用到的库
import pymysql
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
from flask import make_response,request
from flask_cors import CORS
pymysql.install_as_MySQLdb()
数据库设计，使用flask框架模型类添加，代码如下
先连接数据库，修改账号、密码、主机名、端口号、数据库名为你们使用的即可
app = Flask(__name__)
------------------database----------------------------
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:root@localhost:3306/books'
指定数据库文件
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
允许修改跟踪数据库
db = SQLAlchemy(app)
模型类代码：下面建立一个books表，字段有id、title、author、read_status，注意字段大小和类型，这些都是事先要把需求确定好，不然测试肯定有问题。比如：有需求说作者不能超过20个字，下面这种设计120大小就不合适。这就是实际开发和学习的区别
class Books(db.Model):
id = db.Column(db.Integer, primary_key=True, comment='自动递增id，唯一键')
title = db.Column(db.String(80), nullable=False, comment='书名')
author = db.Column(db.String(120), nullable=False, comment='作者')
read_status = db.Column(db.Boolean, comment='阅读状态，0未读，1已读')
通过下面这行代码把表创建好
db.create_all() # 创建表（表创建好后可注释掉）
查看数据库表DDL
5.1 表的增删改查操作
以下是增删改查方法代码：
增加数据
def insert_data(title, author, read_status):
book = Books(title=title, author=author, read_status=read_status)
db.session.add_all([book])
db.session.commit()
查询所有
def select_data_all():
book_list = []
books = Books.query.all()
# 类似于 select * from Books
for s in books:
dic = {}
dic['id'] = s.id
dic['title'] = s.title
dic['author'] = s.author
dic['read_status'] = s.read_status
book_list.append(dic)
return book_list
通过id查询
def select_data_by_id(id):
book = Books.query.get(id)
if not book:
return False
dic = {}
dic['id'] = book.id
dic['title'] = book.title
dic['author'] = book.author
dic['read_status'] = book.read_status
return dic
通过id删除数据
def delete_data(id):
# 类似于 select * from Books where id = id
delete_id = Books.query.get(id)
if not delete_id:
return False
db.session.delete(delete_id)
db.session.commit()
# 提交操作到数据库
修改数据
def update_data(id, title='', author='', read_status='', new_id=''):
book = Books.query.get(id)
if not title == '':
book.title = title
if not author == '':
book.author = author
if not read_status == '':
book.read_status = read_status
if not new_id == '':
book.id = new_id
db.session.commit()
插播，以下代码解决跨域问题（这是我为后面准备开发页面用的）
解决浏览器浏览器访问输出乱码问题
app.config['JSON_AS_ASCII'] = False
@app.after_request
def after(resp):
resp = make_response(resp)
resp.headers['Access-Control-Allow-Origin'] = '*' # 允许跨域地址
resp.headers['Access-Control-Allow-Methods'] = '*' # 请求 '*' 就是全部
resp.headers['Access-Control-Allow-Headers'] = 'x-requested-with,content-type' # 头部
resp.headers['Access-Control-Allow-Credentials'] = 'True'
return resp
CORS(app, resources=r'/*', supports_credentials=True)
5.2 增加接口服务
讲增加接口服务前，定义以下需要传的参数title、author、read_status，title不能重复，
title、author、read_status是必传参数，title、author不能为空，read_status阅读状态只能为0和1
后续测试场景就从这里来，后面的同理
前端通过传参title、author、read_status增加书籍
@app.route('/add', methods=['POST'])
def add():
response_object = {'status': 'success'}
if request.method == 'POST':
post_data = request.get_json()
print('调用add方传过来的参数是', post_data)
book_list = select_data_all()
for i in range(len(book_list)):
title_list = book_list[i]['title']
if post_data.get('title') in title_list:
response_object['message'] = '书名（title）重复!'
response_object["status"]= 'fail'
return response_object
if post_data.get('title') is None:
response_object['message'] = 'title是必传参数!'
response_object["status"]= 'fail'
return response_object
if post_data.get('author') is None:
response_object['message'] = 'author是必传参数!'
response_object["status"]= 'fail'
return response_object
if post_data.get('read_status') is None:
response_object['message'] = 'read_status是必传参数!'
response_object["status"]= 'fail'
return response_object
title = str(post_data.get('title')).strip(),
author = str(post_data.get('author')).strip(),
read_status = post_data.get('read_status')
if title[0] is None or title[0] is '':
response_object['message'] = 'title不能为空!'
response_object["status"] = 'fail'
return response_object
if author[0] is None or author[0] is '':
response_object['message'] = '作者不能为空!'
response_object["status"] = 'fail'
return response_object
if read_status != 0 and read_status != 1:
response_object['message'] = '阅读状态只能为0和1!'
response_object["status"] = 'fail'
return response_object
insert_data(title=title[0], author=author[0], read_status=read_status)
response_object['message'] = '图书添加成功!'
return response_object
代码点评：
- 使用
not in检查必需的参数是否存在，如果不存在则返回HTTP状态码400（Bad Request）。 - 对于空字符串的判断，使用
not title和not author，而不是与None进行比较。 - 使用
int(post_data['read_status'])将read_status转换为整数类型。 - 为了避免重复的书名，提取已存在的书名列表，并使用列表推导式构建
title_list。 - 在返回错误响应时，包含了HTTP状态码400。
@app.route('/add', methods=['POST'])
def add():
response_object = {'status': 'success'}
if request.method == 'POST':
post_data = request.get_json()
print('调用add方传过来的参数是', post_data)
if 'title' not in post_data:
response_object['message'] = 'title是必传参数!'
response_object['status'] = 'fail'
return response_object, 400
if 'author' not in post_data:
response_object['message'] = 'author是必传参数!'
response_object['status'] = 'fail'
return response_object, 400
if 'read_status' not in post_data:
response_object['message'] = 'read_status是必传参数!'
response_object['status'] = 'fail'
return response_object, 400
title = post_data['title'].strip()
author = post_data['author'].strip()
read_status = int(post_data['read_status'])
if not title:
response_object['message'] = 'title不能为空!'
response_object['status'] = 'fail'
return response_object, 400
if not author:
response_object['message'] = '作者不能为空!'
response_object['status'] = 'fail'
return response_object, 400
if read_status not in (0, 1):
response_object['message'] = '阅读状态只能为0和1!'
response_object['status'] = 'fail'
return response_object, 400
book_list = select_data_all()
title_list = [book['title'] for book in book_list]
if title in title_list:
response_object['message'] = '书名（title）重复!'
response_object['status'] = 'fail'
return response_object, 400
insert_data(title=title, author=author, read_status=read_status)
response_object['message'] = '图书添加成功!'
return response_object
5.3 删除接口服务
讲删除接口服务前，定义以下需要传的参数，id是必传参数，输入不存在的id删除报错图书不存在
前端通过传id删除书籍
@app.route('/delete', methods=['DELETE'])
def delete():
response_object = {'status': 'success'}
if request.method == 'DELETE':
post_data = request.get_json()
print('调用delete方传过来的参数是：', post_data)
if post_data.get('id') is None:
response_object['message'] = 'id是必传参数!'
response_object["status"]= 'fail'
return response_object
id = post_data.get('id')
result = delete_data(id) # 删除方法调用
if result is False:
response_object['message'] = '需要删除的图书不存在!'
response_object["status"] = 'fail'
return response_object
else:
response_object['message'] = '图书被删除!'
return response_object
代码点评：
- 不再使用
== None进行空值判断，而是使用not in检查键是否存在于字典中。 - 对于缺少必需的id参数，返回了HTTP状态码400（Bad Request）。
- 对于找不到需要删除的图书，返回了HTTP状态码404（Not Found）。
- 使用
not result判断删除方法的结果，而不是使用== False。 - 省略了不必要的
response_object["status"] = 'success'，因为默认状态就是成功。
@app.route('/delete', methods=['POST'])
def delete():
response_object = {'status': 'success'}
if request.method == 'POST':
post_data = request.get_json()
print('调用delete方传过来的参数是：', post_data)
if 'id' not in post_data:
response_object['message'] = 'id是必传参数!'
response_object['status'] = 'fail'
return response_object, 400
id = post_data['id']
result = delete_data(id) # 删除方法调用
if not result:# 这行代码有bug
response_object['message'] = '需要删除的图书不存在!'
response_object['status'] = 'fail'
return response_object, 404
response_object['message'] = '图书被删除!'
return response_object
上面的代码有bug，如果改为
if not result:
会导致的效果是调用删除接口，但是实际上返回 需要删除的图书不存在!
改为：原来的：
if result is False:
就OK了
但是我查chatgpt，又说是一样的。不是啥情况
5.4 修改接口服务
在讲修改接口服务前，定义以下需要传的参数id、title、author、read_status是必传参数，title、author不能为空，read_status阅读状态只能为0和1，输入不存在的id报错需要修改的书籍id不存在
前端通过传参title、author、read_status修改书籍
@app.route('/update', methods=['POST'])
def update():
response_object = {'status': 'success'}
if request.method == 'POST':
post_data = request.get_json()
print('调用update方传过来的参数是', post_data)
if post_data.get('id') is None:
response_object['message'] = 'id是必传参数!'
response_object["status"]= 'fail'
return response_object
if post_data.get('title') is None:
response_object['message'] = 'title是必传参数!'
response_object["status"]= 'fail'
return response_object
if post_data.get('author') is None:
response_object['message'] = 'author是必传参数!'
response_object["status"]= 'fail'
return response_object
if post_data.get('read_status') is None:
response_object['message'] = 'read_status是必传参数!'
response_object["status"]= 'fail'
return response_object
# 查询所有数据
book_list = select_data_all()
# 拼接所有的id到列表
for i in range(len(book_list)):
id_list = book_list[i]['id']
# 判断书籍id在不在列表内
if post_data.get('id') is not id_list and int(post_data.get('id')) is not id_list:
response_object['message'] = '需要修改的书籍id不存在!'
response_object["status"]= 'fail'
return response_object
title = str(post_data.get('title')).strip(),
author = str(post_data.get('author')).strip(),
read_status = post_data.get('read_status')
if title[0] is None or title[0] is '':
response_object['message'] = 'title不能为空!'
response_object["status"] = 'fail'
return response_object
if author[0] is None or author[0] is '':
response_object['message'] = '作者不能为空!'
response_object["status"] = 'fail'
return response_object
if read_status != 0 and read_status != 1:
response_object['message'] = '阅读状态只能为0和1!'
response_object["status"] = 'fail'
return response_object
books_id = post_data.get('id')
title = post_data.get('title')
author = post_data.get('author')
read_status = post_data.get('read_status')
update_data(id=books_id, title=title, author=author, read_status=read_status)
response_object['message'] = '图书已更新!'
return response_object
代码点评：
- 使用
required_fields列表来存储必传参数，遍历检查是否存在。 - 使用列表推导式生成
id_list，避免在循环中重复拼接。 - 使用
not title和not author的形式来检查是否为空，更简洁。 - 使用列表形式
[0, 1]来检查阅读状态，避免使用多个不等式判断。 - 删除不必要的
response_object变量。 - 不需要显式地指定 HTTP 响应状态码，Flask 会根据返回的 JSON 对象自动设置状态码
from flask import json
@app.route('/update', methods=['POST'])
def update():
if request.method == 'POST':
post_data = request.get_json()
print('调用update方传过来的参数是', post_data)
required_fields = ['id', 'title', 'author', 'read_status']
for field in required_fields:
if field not in post_data:
return json.dumps({
'status': 'fail',
'message': f'{field}是必传参数!'
}), 400
book_list = select_data_all()
id_list = [book['id'] for book in book_list]
if post_data['id'] not in id_list:
return json.dumps({
'status': 'fail',
'message': '需要修改的书籍id不存在!'
}), 404
title = str(post_data['title']).strip()
author = str(post_data['author']).strip()
#read_status = post_data['read_status']#这里需要强制转换不然前端代码报错
read_status = int(post_data['read_status'])
if not title:
return json.dumps({
'status': 'fail',
'message': 'title不能为空!'
}), 400
if not author:
return json.dumps({
'status': 'fail',
'message': '作者不能为空!'
}), 400
if read_status not in [0, 1]:
return json.dumps({
'status': 'fail',
'message': '阅读状态只能为0和1!'
}), 400
books_id = post_data['id']
update_data(id=books_id, title=title, author=author, read_status=read_status)
return json.dumps({
'status': 'success',
'message': '图书已更新!'
})
5.5 查询接口服务
在讲查询接口服务前，定义以下需要传的参数
不传id默认查询所有，传了id查询数据库为id的记录，传了id，id就不能为空
前端通过不传参默认查询所有书籍，传id查询对应书籍
@app.route('/query', methods=['POST'])
def query():
response_object = {'status': 'success'}
if request.method == 'POST':
post_data = request.get_json()
print('调用query方传过来的参数是', post_data)
if post_data.get('id') is None:
books = select_data_all()
response_object['message'] = '查询所有书籍成功!'
response_object['books'] = books
return response_object
id = str(post_data.get('id')).strip()
if id is None or id is '':
response_object['message'] = 'id不能为空!'
response_object["status"] = 'fail'
return response_object
book = select_data_by_id(id)
if book is False:
response_object['message'] = '需要查询的图书不存在!'
response_object["status"] = 'fail'
return response_object
else:
response_object['message'] = '查询书籍成功!'
response_object['books'] = book
return response_object
代码点评：
- 移除了冗余的条件判断和注释。
- 使用
is None进行空值检查，而不是与None进行比较。 - 将空字符串的判断条件改为
id == '' or id is None，使代码更加简洁。 - 在最后直接返回
response_object，避免重复的return语句。
@app.route('/query', methods=['POST'])
def query():
response_object = {'status': 'success'}
if request.method == 'POST':
post_data = request.get_json()
print('调用query方传过来的参数是', post_data)
id = str(post_data.get('id')).strip()
if id == '' or id is None:
books = select_data_all()
response_object['message'] = '查询所有图书成功!'
response_object['data'] = books
return response_object
book = select_data_by_id(id)
if book is False:
response_object['message'] = '需要查询的图书不存在!'
response_object["status"] = 'fail'
else:
response_object['message'] = '图书查询成功!'
response_object['data'] = book
return response_object
所有服务搞完了，启动项目
六、接口测试
接口写完，准备测试（实际开发中肯定是边开发边测试的，大家注意）
用以下代码：
insert_data("《水浒传》", "吴承恩", 1)
或者手工往数据库先加一些数据用来测试，现在往里面添加
6.1 测试增加接口服务
测试如下
请求参数，json格式的
{
"author": "保尔柯察金",
"read_status":0,
"title": "《钢铁是怎么炼成的》"
}
检查数据库，新增了记录
在这个基础上再次 send
书名重复，校验正确。其他的测试场景这里就不列了
6.2 测试删除接口服务
测试如下，我们把刚才新增的书删除掉
请求参数：
{
"id":60
}
删除成功
在这个基础上再次 send
图书不存在校验成功
数据库记录已被删除
6.3 测试修改接口服务
测试如下
我们修改第4本书
请求参数：
{
"id":4,
"author": "罗贯中1",
"read_status":0,
"title": "《三国演义1》"
}
更新成功
检查数据库
成功，其他的测试场景这里就不列了
6.4 测试查询接口服务
测试如下
请求参数不传默认查询所有
{
}
send
返回数据：
{
"books": [
{
"author": "施耐庵",
"id": 1,
"read_status": true,
"title": "《西游记》"
},
{
"author": "曹雪芹",
"id": 2,
"read_status": false,
"title": "《红楼梦》"
},
{
"author": "吴承恩",
"id": 3,
"read_status": true,
"title": "《水浒传》"
},
{
"author": "罗贯中1",
"id": 4,
"read_status": false,
"title": "《三国演义1》"
}
],
"message": "查询所有书籍成功!",
"status": "success"
}
与数据库一致
查询所有书籍成功
通过id查询对应书籍，选择查第4本书，请求参数
{
"id":4
}
结果 ，查询成功
对照返回信息与数据库信息一致，验证ok
其他的测试场景这里也不列了，大家可以试下 ，比如传不存在的图书id
七、总结
测试场景真的很多，测试不通过就加校验，测试不通过就加校验，如此反复（当然在这个过程中复习了很多基础知识），所以实际开发肯定是按照需求来做校验，不然时间肯定是不够的。因为现在的迭代很快，作为测试考虑开发，确实是想怎么简单怎么来，站在测试的角度，又会觉得，这个开发咋这又没做校验啊，那也没做校验啊。。。。。。做好本职工作，要做好角色转换，轻松拿捏职场
八、展望
后续根据技能学习目标和职业生涯发展规则会继续学习，flask是测试开发必知必会的内容，希望大家好好掌握，做一个优秀的测试工程师
九、附录（源代码）
-*- coding: utf-8 -*-
@Author : Liqiju
@Time : 2022/5/1 2:45
@File : app.py
@Software: PyCharm
import pymysql
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
from flask import make_response,request
from flask_cors import CORS
pymysql.install_as_MySQLdb()
app = Flask(__name__)
------------------database----------------------------
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:root@localhost:3306/books'
指定数据库文件
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
允许修改跟踪数据库
db = SQLAlchemy(app)
class Books(db.Model):
id = db.Column(db.Integer, primary_key=True, comment='自动递增id，唯一键')
title = db.Column(db.String(80), nullable=False, comment='书名')
author = db.Column(db.String(120), nullable=False, comment='作者')
read_status = db.Column(db.Boolean, comment='阅读状态，0未读，1已读')
增加数据
def insert_data(title, author, read_status):
book = Books(title=title, author=author, read_status=read_status)
db.session.add_all([book])
db.session.commit()
查询所有
def select_data_all():
book_list = []
books = Books.query.all()
# 类似于 select * from Books
for s in books:
dic = {}
dic['id'] = s.id
dic['title'] = s.title
dic['author'] = s.author
dic['read_status'] = s.read_status
book_list.append(dic)
return book_list
通过id查询
def select_data_by_id(id):
book = Books.query.get(id)
if not book:
return False
dic = {}
dic['id'] = book.id
dic['title'] = book.title
dic['author'] = book.author
dic['read_status'] = book.read_status
return dic
通过id删除数据
def delete_data(id):
# 类似于 select * from Books where id = id
delete_id = Books.query.get(id)
if not delete_id:
return False
db.session.delete(delete_id)
db.session.commit()
# 提交操作到数据库
修改数据
def update_data(id, title='', author='', read_status='', new_id=''):
book = Books.query.get(id)
if not title == '':
book.title = title
if not author == '':
book.author = author
if not read_status == '':
book.read_status = read_status
if not new_id == '':
book.id = new_id
db.session.commit()
解决浏览器浏览器访问输出乱码问题
app.config['JSON_AS_ASCII'] = False
@app.after_request
def after(resp):
resp = make_response(resp)
resp.headers['Access-Control-Allow-Origin'] = '*' # 允许跨域地址
resp.headers['Access-Control-Allow-Methods'] = '*' # 请求 '*' 就是全部
resp.headers['Access-Control-Allow-Headers'] = 'x-requested-with,content-type' # 头部
resp.headers['Access-Control-Allow-Credentials'] = 'True'
return resp
CORS(app, resources=r'/*', supports_credentials=True)
前端通过传参title、author、read_status增加书籍
@app.route('/add', methods=['POST'])
def add():
response_object = {'status': 'success'}
if request.method == 'POST':
post_data = request.get_json()
print('调用add方传过来的参数是', post_data)
book_list = select_data_all()
for i in range(len(book_list)):
title_list = book_list[i]['title']
if post_data.get('title') in title_list:
response_object['message'] = '书名（title）重复!'
response_object["status"]= 'fail'
return response_object
if post_data.get('title') is None:
response_object['message'] = 'title是必传参数!'
response_object["status"]= 'fail'
return response_object
if post_data.get('author') is None:
response_object['message'] = 'author是必传参数!'
response_object["status"]= 'fail'
return response_object
if post_data.get('read_status') is None:
response_object['message'] = 'read_status是必传参数!'
response_object["status"]= 'fail'
return response_object
title = str(post_data.get('title')).strip(),
author = str(post_data.get('author')).strip(),
read_status = post_data.get('read_status')
if title[0] is None or title[0] is '':
response_object['message'] = 'title不能为空!'
response_object["status"] = 'fail'
return response_object
if author[0] is None or author[0] is '':
response_object['message'] = '作者不能为空!'
response_object["status"] = 'fail'
return response_object
if read_status != 0 and read_status != 1:
response_object['message'] = '阅读状态只能为0和1!'
response_object["status"] = 'fail'
return response_object
insert_data(title=title[0], author=author[0], read_status=read_status)
response_object['message'] = '图书添加成功!'
return response_object
前端通过传id删除书籍
@app.route('/delete', methods=['DELETE'])
def delete():
response_object = {'status': 'success'}
if request.method == 'DELETE':
post_data = request.get_json()
print('调用delete方传过来的参数是：', post_data)
if post_data.get('id') is None:
response_object['message'] = 'id是必传参数!'
response_object["status"]= 'fail'
return response_object
id = post_data.get('id')
result = delete_data(id) # 删除方法调用
if result is False:
response_object['message'] = '需要删除的图书不存在!'
response_object["status"] = 'fail'
return response_object
else:
response_object['message'] = '图书被删除!'
return response_object
前端通过传参title、author、read_status修改书籍
@app.route('/update', methods=['POST'])
def update():
response_object = {'status': 'success'}
if request.method == 'POST':
post_data = request.get_json()
print('调用update方传过来的参数是', post_data)
if post_data.get('id') is None:
response_object['message'] = 'id是必传参数!'
response_object["status"]= 'fail'
return response_object
if post_data.get('title') is None:
response_object['message'] = 'title是必传参数!'
response_object["status"]= 'fail'
return response_object
if post_data.get('author') is None:
response_object['message'] = 'author是必传参数!'
response_object["status"]= 'fail'
return response_object
if post_data.get('read_status') is None:
response_object['message'] = 'read_status是必传参数!'
response_object["status"]= 'fail'
return response_object
# 查询所有数据
book_list = select_data_all()
# 拼接所有的id到列表
for i in range(len(book_list)):
id_list = book_list[i]['id']
# 判断书籍id在不在列表内
if post_data.get('id') is not id_list and int(post_data.get('id')) is not id_list:
response_object['message'] = '需要修改的书籍id不存在!'
response_object["status"]= 'fail'
return response_object
title = str(post_data.get('title')).strip(),
author = str(post_data.get('author')).strip(),
read_status = post_data.get('read_status')
if title[0] is None or title[0] is '':
response_object['message'] = 'title不能为空!'
response_object["status"] = 'fail'
return response_object
if author[0] is None or author[0] is '':
response_object['message'] = '作者不能为空!'
response_object["status"] = 'fail'
return response_object
if read_status != 0 and read_status != 1:
response_object['message'] = '阅读状态只能为0和1!'
response_object["status"] = 'fail'
return response_object
books_id = post_data.get('id')
title = post_data.get('title')
author = post_data.get('author')
read_status = post_data.get('read_status')
update_data(id=books_id, title=title, author=author, read_status=read_status)
response_object['message'] = '图书已更新!'
return response_object
前端通过不传参默认查询所有书籍，传id查询对应书籍
@app.route('/query', methods=['POST'])
def query():
response_object = {'status': 'success'}
if request.method == 'POST':
post_data = request.get_json()
print('调用query方传过来的参数是', post_data)
if post_data.get('id') is None:
books = select_data_all()
response_object['message'] = '查询所有书籍成功!'
response_object['books'] = books
return response_object
id = str(post_data.get('id')).strip()
if id is None or id is '':
response_object['message'] = 'id不能为空!'
response_object["status"] = 'fail'
return response_object
book = select_data_by_id(id)
if book is False:
response_object['message'] = '需要查询的图书不存在!'
response_object["status"] = 'fail'
return response_object
else:
response_object['message'] = '查询书籍成功!'
response_object['books'] = book
return response_object
if __name__ == '__main__':
# 默认是5000，这里设置5001避免本地冲突。打开debug方便调试
# db.create_all() # 创建表（表创建好后可注释掉）
# insert_data("《水浒传》", "吴承恩", 1) # 利用这个可以添加数据或者直接数据库手动加入
# 注意这个时候没开启校验title唯一性是因为不是前端过来的请求
app.run(debug=True, port=5001)
刚才试了在python 3.9版本中，”is” 要改为 “== “号，不然报错
有疑问评论区学习交流~
Original: https://blog.csdn.net/qq_29720657/article/details/124522898
Author: 软件测试李同学
Title: Flask+mysql 实现增删改查接口开发+测试（图文教程附源码）
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/813726/
转载文章受原作者版权保护。转载请注明原作者出处！