完整代码放到了最后,时间紧张的话直接拉到最后或点击目录【🥩 完整代码】看完整代码
相信看过自己前期的博文python使用flask模块和前端交互基础以及python模块pymysql对数据库进行增删改查的小伙伴已经有了一定基础,这里我们在来对flask、pymsql、前端三个部分通过flask做一个整合。使用python来作为我们的后端来实现前后端的分离。
既然是作为基础,那我们这里主要实现通过前端对我们后端数据库实现增删改查就OK 了。下面我们开始。
后端:python(flask,pymsql)、MySQL、navicat、VScode
前端:VScode、Google浏览器
这里的截图的是navicat,里面的id做了主键自增
前端上样式没有去做过多的修饰,只是做一个大概样式,有兴趣的也可以自己去用CSS修改一下
可视化截图就截图这两张吧,接下来就是代码了
这里先提一下,这个是需要下载MySQL数据库的,再有一些MySQL数据库的增删改查的代码学习基础。要不然有的代码可能是看不明白的哈,特别是数据库那一块的。restful风格这里对于增删改查使用了不同的方式
增加数据库这里用的也是基本和其它常见后端所用的那种方式,使用了post请求方法,对于前端不是从URL请求上携带的参数,我们都可以使用flask模块中的request的**get_dada()**方法来获取,至于如何取在URL上的数据,可以看下关于【🛴 删除】那里的简介。
Document
新增数据
姓名:年龄:专业:爱好:
import pymysql
from flask import Flask,request
import json
from flask_cors import CORS
app = Flask(__name__)
CORS(app=app) # 跨域设置
app.debug=True # 开启debug模式
db = pymysql.connect(host='localhost',user='root',password='root',database='python') # 建立连接
cursor = db.cursor() #创建游标
@app.route('/add',methods=['post']) #设置请求头和请求方式
def add():req_data = request.get_data() # 获取data数据data = json.loads(req_data) # 需要使用json.loads来转换一下,返回的数据是字符码print(data)try:sql_data = (data['name'],int(data['age']),data['major'],data['hobby'])sql = "insert into userinfo(name,age,major,hobby) values (%s,%s,%s,%s)" #MySQL查询语句cursor.execute(sql,sql_data)db.commit()return {'code':200,'msg':'数据新增成功'}except:db.rollback() # 发生错误时回滚 return {'code':1000,'msg':"添加失败"}if __name__ == '__main__':app.run(host="localhost",port='8090')cursor.close() #关闭游标db.close() # 关闭数据库连接
删除使用的请求方式是delete。众所周知,前端发送给后端的数据要么在URL中,要么在请求体里面,这里的话,删除我就把数据放在了URL中,flask的request模块可以通过args.get()方法来接收前端放在URL中的数据。
Document
根据姓名删除数据
姓名:
import pymysql
from flask import Flask,request
import json
from flask_cors import CORS
app = Flask(__name__)
CORS(app=app)
app.debug=True
db = pymysql.connect(host='localhost',user='root',password='root',database='python')
cursor = db.cursor() #创建游标
@app.route('/del',methods=['delete'])
def delete():deleteName = request.args.get('name')sql=f'delete from `userinfo` where name="{deleteName}";' # 删除数据的sql语句try:cursor.execute(sql)db.commit()return {'code':200,'msg':'删除成功'}except:db.rollback() # 发生错误时回滚 return {'code':1000,'msg':"删除失败"}if __name__ == '__main__':app.run(host="localhost",port='8090')cursor.close() #关闭游标db.close() # 关闭数据库连接
修改数据这里就不多说了,直接看源码吧
Document
编辑数据
姓名:
import pymysql
from flask import Flask,request
import json
from flask_cors import CORS
app = Flask(__name__)
CORS(app=app)
app.debug=True
db = pymysql.connect(host='localhost',user='root',password='root',database='python')
cursor = db.cursor() #创建游标
@app.route('/edit',methods=['put'])
def edit():req_data = request.get_data()data = json.loads(req_data)print('修改消息:',data)try:sql = f"update userinfo set name='{data['afterName']}' where name='{data['beforeName']}'"cursor.execute(sql)db.commit()return {'code':200,'msg':'修改成功'}except:db.rollback() return {'code':1000,'msg':"修改失败"}if __name__ == '__main__':app.run(host="localhost",port='8090')cursor.close() #关闭游标db.close() # 关闭数据库连接
查看数据这里需要注意一下,修改的数据是需要替换或者新增到我们的表里面,所以需要先删除掉原来的表再替换上新修改或增加的数据。有点前端基础的应该都清楚怎么做。
Document
查询数据
ID 姓名 年龄 专业 爱好
import pymysql
from flask import Flask,request
import json
from flask_cors import CORS
app = Flask(__name__)
CORS(app=app)
app.debug=True
db = pymysql.connect(host='localhost',user='root',password='root',database='python')
cursor = db.cursor() #创建游标
@app.route('/select',methods=['get'])
def select():try:cursor.execute("SELECT * FROM userinfo")array = []data=()while isinstance(data,tuple):#循环遍历出data的数据data = cursor.fetchone() #fetchone方法用于取出数据库中查询的单个数据if(data == None): breakobj = {}obj['id'] = data[0]obj['name'] = data[1]obj['age'] = data[2]obj['major'] = data[3]obj['hobby'] = data[4]array.append(obj)return {'code':200,'msg':'查询成功','data':array}except:db.rollback() return {'code':1000,'msg':"查询失败"}if __name__ == '__main__':app.run(host="localhost",port='8090')cursor.close() #关闭游标db.close() # 关闭数据库连接
Document
查询数据
ID 姓名 年龄 专业 爱好
新增数据
姓名:年龄:专业:爱好:编辑数据
姓名:
根据姓名删除数据
姓名:
import pymysql
from flask import Flask,request
import json
from flask_cors import CORS
app = Flask(__name__)
CORS(app=app)
app.debug=True
db = pymysql.connect(host='localhost',user='root',password='root',database='python')
cursor = db.cursor() #创建游标
@app.route('/add',methods=['post'])
def add():req_data = request.get_data()data = json.loads(req_data)print(data)try:sql_data = (data['name'],int(data['age']),data['major'],data['hobby'])sql = "insert into userinfo(name,age,major,hobby) values (%s,%s,%s,%s)"cursor.execute(sql,sql_data)db.commit()return {'code':200,'msg':'数据新增成功'}except:db.rollback() # 发生错误时回滚 return {'code':1000,'msg':"添加失败"}@app.route('/del',methods=['delete'])
def delete():deleteName = request.args.get('name')sql=f'delete from `userinfo` where name="{deleteName}";'try:cursor.execute(sql)db.commit()return {'code':200,'msg':'删除成功'}except:db.rollback() # 发生错误时回滚 return {'code':1000,'msg':"删除失败"}
@app.route('/edit',methods=['put'])
def edit():req_data = request.get_data()data = json.loads(req_data)print('修改消息:',data)try:sql = f"update userinfo set name='{data['afterName']}' where name='{data['beforeName']}'"cursor.execute(sql)db.commit()return {'code':200,'msg':'修改成功'}except:db.rollback() return {'code':1000,'msg':"修改失败"}@app.route('/select',methods=['get'])
def select():try:cursor.execute("SELECT * FROM userinfo")array = []data=()while isinstance(data,tuple):#循环遍历出data的数据data = cursor.fetchone() #fetchone方法用于取出数据库中查询的单个数据if(data == None): breakobj = {}obj['id'] = data[0]obj['name'] = data[1]obj['age'] = data[2]obj['major'] = data[3]obj['hobby'] = data[4]array.append(obj)return {'code':200,'msg':'查询成功','data':array}except:db.rollback() return {'code':1000,'msg':"查询失败"}if __name__ == '__main__':app.run(host="localhost",port='8090')cursor.close()db.close()
最后这里忽然感觉也没什么好说的了
如果文章有什么不正确的地方,希望在评论区指出,我们共同进步。谢谢大家
上一篇:励志美文100字摘抄加60字赏析
下一篇:孙悟空在如来佛手指上撒尿打一成语