Python Flask实现修改和删除数据
上一篇文章写了查询和添加数据，这篇文章继续写修改和删除数据。
一、数据准备和后端代码准备
继续使用查询和添加数据时的数据表和数据，新建一个 update_and_delete.py 文件，复制查询和添加数据的代码过来，代码如下：
from flask import Flask, render_template, request, redirect, flash
from flask_sqlalchemy import SQLAlchemy
import random
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://admin:Mysql!123@127.0.0.1:3306/MyDB_one'
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
app.config['SQLALCHEMY_ECHO'] = True
app.config['SECRET_KEY'] = 'NFAIOSDFHASOGHAOSPIGAOWE'
db = SQLAlchemy(app)
class Phone(db.Model):
__tablename__ = 'Phone_tb'
pid = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(32))
person_id = db.Column(db.Integer, db.ForeignKey('Person_tb.mid'))
def __repr__(self):
return 'Phone_name: {}'.format(self.name)
class Person(db.Model):
__tablename__ = 'Person_tb'
mid = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(64), unique=True)
age = db.Column(db.Integer)
phones = db.relationship('Phone', backref='person', lazy='dynamic')
def __repr__(self):
return 'Person_name: {}'.format(self.name)
@app.route('/', methods=['GET', 'POST'])
def index():
if request.method == 'GET':
persons = Person.query.all()
return render_template('update_and_delete.html', persons=persons)
if request.method == 'POST':
person_name = request.form.get('person')
if not person_name:
return redirect('/')
submit = request.form.get('search')
if submit == '查询':
persons = Person.query.filter_by(name=person_name)
return render_template('update_and_delete.html', persons=persons)
submit = request.form.get('add')
if submit == '添加':
phone_name = request.form.get('phone')
person = Person.query.filter_by(name=person_name).first()
if person:
if not phone_name:
return redirect('/')
phone = Phone.query.filter(Phone.name == phone_name, Phone.person_id == person.mid).first()
if phone:
flash('数据已存在！')
else:
phone = Phone(name=phone_name, person_id=person.mid)
add_data(phone)
else:
person = Person(name=person_name, age=random.randint(18, 25))
add_data(person)
if not phone_name:
return redirect('/')
phone = Phone(name=phone_name)
phone.person = person
add_data(phone)
return redirect('/')
def add_data(obj):
try:
db.session.add(obj)
db.session.commit()
except Exception as e:
print(e)
db.session.rollback()
flash("添加失败")
if __name__ == '__main__':
app.run(debug=True)
我提前在数据库中创建了数据表和添加数据，上面的代码实现了查询和添加数据。
代码复制过来后，将 render_template() 中返回的模板文件 search_and_add.html 改成 update_and_delete.html 。
二、前端模板文件准备
在模板文件夹 templates 中创建一个 update_and_delete.html 模板文件，复制查询和添加数据时的 HTML 代码过来并进行修改，修改后的代码如下。
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Person</title>
</head>
<body>
<form method="post">
<label>人名：</label> <input id="person" name="person" type="text" value=""><br/>
<label>手机：</label> <input id="phone" name="phone" type="text" value=""><br/><br/>
<input id="search" name="search" type="submit" value="查询">
<input id="add" name="add" type="submit" value="添加"><br/>
</form>
<br/>
{% for message in get_flashed_messages() %}
{{ message }}
{% endfor %}
<ul>
{% for person in persons %}
<li>{{ person.name }} <a href="/delete_person/{{ person.mid }}">删除</a>
<form method="post" action="/update_person/{{ person.mid }}"><input id="person_{{ person.mid }}" name="person_{{ person.mid }}" type="text" value=""> <input id="update_{{ person.mid }}" name="update_{{ person.mid }}" type="submit" value="修改"></form></li>
<ul>
{% for phone in person.phones %}
<li>{{ phone.name }} <a href="/delete_phone/{{ phone.pid }}">删除</a>
<form method="post" action="/update_phone/{{ phone.pid }}"><input id="phone_{{ phone.pid }}" name="phone_{{ phone.pid }}" type="text" value=""> <input id="update_{{ phone.pid }}" name="update_{{ phone.pid }}" type="submit" value="修改"></form></li>
{% else %}
<li>无</li>
{% endfor %}
</ul>
{% endfor %}
</ul>
</body>
</html>
这个 HTML 文件写得不好，不过能完成功能。
运行一下后端服务器，访问 http://127.0.0.1:5000/ ，初始的界面如下：
三、实现修改人名
需要实现的功能是：在对应人名下面输入修改后的人名，然后点击“修改”按钮，后端代码对数据库进行修改，然后将结果查询返回首页，展示所有数据。
在查询和添加数据的视图函数下面继续添加修改人名的视图函数。
@app.route("/update_person/<id>", methods=['GET', 'POST'])
def update_person(id):
person_name = request.form.get('person_{}'.format(id))
if not person_name:
flash("请输入修改后的人名")
return redirect('/')
person = Person.query.get(id)
if not person:
flash("人名不存在")
else:
person.name = person_name
try:
db.session.merge(person)
db.session.commit()
except Exception as e:
print(e)
db.session.rollback()
return redirect('/')
修改数据需要提交前端 form 表单中的数据到后端，所以请求方式需要使用 POST。修改数据库中的数据使用数据库会话的 merge() 方法： db.session.merge() 。
需要注意的是，因为人名是唯一字段，如果填一个已经存在的人名，后端不会做任何处理，修改不会成功。
添加代码后，重新运行后端服务器，访问 http://127.0.0.1:5000/ ，开始修改人名，如将 You 改成 Your ，点击“修改”按钮后，界面显示结果如下：
四、实现修改手机
需要实现的功能与人名相似：在对应手机下面输入修改后的手机，然后点击“修改”按钮，后端代码对数据库进行修改，然后将结果查询返回首页，展示所有数据。
继续添加修改手机的视图函数。
@app.route("/update_phone/<id>", methods=['GET', 'POST'])
def update_phone(id):
phone_name = request.form.get('phone_{}'.format(id))
if not phone_name:
flash("请输入修改后的手机")
return redirect('/')
phone = Phone.query.get(id)
if not phone:
flash("手机不存在")
else:
phone.name = phone_name
try:
db.session.merge(phone)
db.session.commit()
except Exception as e:
print(e)
db.session.rollback()
return redirect('/')
添加代码后，重新运行后端服务器，访问 http://127.0.0.1:5000/ ，开始修改手机，如将 Your 下的 VIVO 改成 OPPO ，点击“修改”按钮后，界面显示结果如下：
五、实现删除人名
需要实现的功能是：点击对应人名后面的“删除”标签，会将人名删除。同时，因为人名是父级，手机是子级，所以如果人名下有手机，该人名下的所有手机也全部一起删除。
继续添加删除人名的视图函数。
@app.route("/delete_person/<id>")
def delete_person(id):
person = Person.query.get(id)
if not person:
flash("人名不存在")
else:
try:
Phone.query.filter(Phone.person_id == person.mid).delete()
db.session.delete(person)
db.session.commit()
except Exception as e:
print(e)
db.session.rollback()
return redirect('/')
删除数据可以使用 GET 请求方式完成。删除数据库中的数据使用数据库会话的 delete() 方法：db.session.delete() 。可以根据关系字段查询出 Phone 中对应的关联数据，直接链式调用 delete() 方法删除数据。
添加代码后，重新运行后端服务器，访问 http://127.0.0.1:5000/ ，开始删除人名，如将除 Your 以外的人名全部删除，依次点击其他人名后面的“删除”标签，最终界面显示结果如下：
六、实现删除手机
需要实现的功能是：点击对应手机后面的“删除”标签，会将手机删除。
继续添加删除手机的视图函数。
@app.route("/delete_phone/<id>")
def delete_phone(id):
phone = Phone.query.get(id)
if not phone:
flash("手机不存在")
else:
try:
db.session.delete(phone)
db.session.commit()
except Exception as e:
print(e)
db.session.rollback()
return redirect('/')
添加代码后，重新运行后端服务器，访问 http://127.0.0.1:5000/ ，开始删除手机，如将 Your 下的 OPPO 删除，点击 OPPO 后面的“删除”标签，删除后界面显示结果如下：
在 update_and_delete.py 中，保留了查询和添加的功能，因为修改和删除数据后需要查询所有数据返回到首页展示。
这里面包含了完整的增删改查，可以反复进行添加、修改、删除来测试功能。
