Python+Flask对MySQL数据库进行增删查改并在页面展示数据

• 一、python连接mysql数据库
• • 1. 安装pymysql驱动
  • 2. 数据库表测试数据
  • 3. 连接数据库
• 二、Flask+Python对数据库数据的操作
• • 1. 查询数据
  • 2. 插入数据
  • 3. 修改数据
  • 4. 删除数据

一、python连接mysql数据库

1. 安装pymysql驱动

PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库，Python2中则使用mysqldb。

pip install pymysql

2. 数据库表测试数据

可以使用navicat也可以使用命令行，创建一张表

3. 连接数据库

import pymysql
#打开数据库连接
db = pymysql.connect(host="localhost",user="root",password="123456",database="test")
#使用cursor()方法获取操作游标 
cursor = db.cursor()
#sql语句
sql = "select * from info"
try:
    #执行sql语句
    cursor.execute(sql)
    #查询中的一个操作，获取所有记录
    result = cursor.fetchall()
    #打印表数据
    for row in result:
        id = row[0]
        name = row[1]
        age = row[2]
        print(id,name,age)
except:
    print("Error!")
#关闭数据库
db.close()

二、Flask+Python对数据库数据的操作

Flask相关知识点：Flask框架学习笔记

1. 查询数据

这一部分的操作是分了两个py文件来写，一个是专门写对数据库操作的，一个是专门flask操作

• sql_lianjie.py 定义一个类，对数据库进行操作

  import pymysql
  class Mysql(object):
  def init(self):
  try:
  self.db = pymysql.connect(host=“localhost”,user=“root”,password=“123456”,database=“test”)
  #游标对象
  self.cursor = self.db.cursor()
  print(“连接成功！”)
  except:
  print(“连接失败！”)
  #查询数据函数
  def getdata(self):
  sql = “select * from info”
  #执行sql语句
  self.cursor.execute(sql)
  #获取所有的记录
  results = self.cursor.fetchall()
  return results
  #关闭
  def del(self):
  self.db.close()

• sql_flask.py 是使用flask路由对数据进行展示
  千万不要忘记导入对数据库操作的类

  from flask import Flask,render_template,request
  import pymysql
  #导入数据库操作类
  from sql_lianjie import Mysql
  app = Flask(name)

  @app.route(“/info”,methods=[‘GET’,‘POST’])
  def info():
  #调用
  db = Mysql()
  results = db.getdata()
  return render_template(“sql_select.html”,results=results)

  if name == “main”:
  app.run(app.run(debug=True,port=5000,host=‘127.0.0.1’))

• sql_select.html 这个页面是把数据展示在网页上(只展示部分代码)

  查询数据

  {% for result in results %} {% endfor %}

  id	name	age
  {{ result[0]}}	{{ result[1]}}	{{ result[2]}}	删除	插入	修改

• 结果：打开网页：http://localhost:5000/info
  

2. 插入数据

• sql_lianjie.py

  def insertdata(self,results):
  sql = “insert into info(name,age)values(‘%s’,‘%s’)” % (results[‘name’],results[‘age’])
  sql1 = “ALTER TABLE info DROP id”
  sql2 = “ALTER TABLE info ADD id int NOT NULL FIRST”
  sql3 = “ALTER TABLE info MODIFY COLUMN id int NOT NULL AUTO_INCREMENT,ADD PRIMARY KEY(id)”
  try:
  self.cursor.execute(sql)
  self.cursor.execute(sql1)
  self.cursor.execute(sql2)
  self.cursor.execute(sql3)
  self.db.commit()
  except:
  # 如果发生错误就回滚，建议使用这样发生错误就不会对表数据有影响
  self.db.rollback()
  return

• sql_flask.py

  @app.route(“/submit_insert”)
  def submit_insert():
  return render_template(“sql_insert.html”)

  @app.route(“/insert”,methods=[‘GET’,‘POST’])
  def insert():
  if request.method == “POST”:
  results = request.form
  db = Mysql()
  db.insertdata(results)
  return render_template(“result_insert.html”,results=results)

• sql_insert.html

  在该页面可以插入数据

  name:
  
  age:
  
  提交 查看数据

• result_insert.html

  你已成功插入数据！点击查看数据可查看更新后的数据!
  插入的name为：{{results['name']}}
  插入的age为：{{results['age']}}
  
  查看数据

• 结果：在info这个页面点击插入按钮就可以跳转到插入数据页面，在这个页面输入要插入的数据(id不需要输入，因为设置了自增)
  
  点击提交按钮，就可以看到数据已经成功插入
  
  再点击查看数据按钮，就可以成功看到插入后的数据
  

3. 修改数据

• sql_lianjie.py

  def updatedata(self,results):
  sql = “update info set name=‘%s’,age=‘%s’ where id=‘%s’” % (results[‘name’],results[‘age’],results[‘id’])
  sql1 = “ALTER TABLE info DROP id”
  sql2 = “ALTER TABLE info ADD id int NOT NULL FIRST”
  sql3 = “ALTER TABLE info MODIFY COLUMN id int NOT NULL AUTO_INCREMENT,ADD PRIMARY KEY(id)”
  try:
  self.cursor.execute(sql)
  self.cursor.execute(sql1)
  self.cursor.execute(sql2)
  self.cursor.execute(sql3)
  self.db.commit()
  except:
  # 如果发生错误就回滚，建议使用这样发生错误就不会对表数据有影响
  self.db.rollback()
  return

• sql_flask.py

  @app.route(“/submit_update”)
  def submit_update():
  return render_template(“sql_update.html”)

  @app.route(“/update”,methods=[‘GET’,‘POST’])
  def update():
  if request.method == “POST”:
  results = request.form
  db = Mysql()
  db.updatedata(results)
  return render_template(“result_update.html”,results=results)

• sql_update.html

  在该页面修改你的数据

  请输入你需要修改的id:
  请输入修改的name:
  请输入修改的age:
  查看数据

• result_update.html

  你已成功修改数据！
  点击查看数据可查看更新后的数据!
  修改的的id为：{{results['id']}}
  修改的name为：{{results['name']}}
  修改的age为：{{results['age']}}
  
  查看数据

• 结果参考插入数据效果

4. 删除数据

• sql_lianjie.py

  def deletedata(self,id):
  sql = “delete from info where id=” + str(id)
  sql1 = “ALTER TABLE info DROP id”
  sql2 = “ALTER TABLE info ADD id int NOT NULL FIRST”
  sql3 = “ALTER TABLE info MODIFY COLUMN id int NOT NULL AUTO_INCREMENT,ADD PRIMARY KEY(id)”
  try:
  # 执行sql语句
  self.cursor.execute(sql)
  self.cursor.execute(sql1)
  self.cursor.execute(sql2)
  self.cursor.execute(sql3)
  # 提交数据
  self.db.commit()
  except:
  # 如果发生错误就回滚，建议使用这样发生错误就不会对表数据有影响
  self.db.rollback()
  return

• sql_flask.py

  @app.route(“/delete”)
  def delete():
  id = request.args.get(“id”)
  db = Mysql()
  db.deletedata(id)
  return render_template(“result_delete.html”,id=id)

• result_dalete.html

  你已成功删除id为:{{id}}的数据!
  点击查看数据看查询更新后的数据！
  
  查看数据

1. 在更新、修改、删除操作里面的sql1-3的作用是当我表中数据发生改变时，id会自动更新排序，即如果不加这三行，当我删除中间的数据，中间那些数据的id无法自动重新排序
   代码：
   删除原有主键：ALTER TABLE news DROP NewsID;
   添加新的主键：ALTER TABLE news ADD NewsID int NOT NULL FIRST;
   设置新的主键：ALTER TABLE news MODIFY COLUMN NewsID int NOT NULL AUTO_INCREMENT,ADD PRIMARY KEY(NewsID);