投稿
  1. 首页
  2. mysql

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

code • 2022-5-21 • mysql • 阅读 67

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

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 这个页面是把数据展示在网页上(只展示部分代码) 
<body>
<div>
    <h4>查询数据</h4>
    <table border="1" width="30%" weight="30%">
        <thead>
        <tr>
            <th>id</th>
            <th>name</th>
            <th>age</th>
        </tr>
        </thead>
        <tbody>
            {% for result in results %}
                <tr>
                    <td>{{ result[0]}}</td>
                    <td>{{ result[1]}}</td>
                    <td>{{ result[2]}}</td>
                    <td><a href="/delete?id={{ result[0] }}"><button>删除</button></a></td>
                    <td><a href="/submit_insert"><button>插入</button></a></td>
                    <td><a href="/submit_update"><button>修改</button></a></td>
                </tr>
            {% endfor %}
        </tbody>
    </table>
</div>
结果：打开网页：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 
<div>
    <h4>在该页面可以插入数据</h4>
    <!--通过改变form标签中method属性来改变数据请求的方式-->
    <form action="http://localhost:5000/insert" method="POST">
        name:<input type="text" name="name" autocomplete="off"><br/><br/>
        age:<input type="text" name="age" autocomplete="off"><br/><br/>
        <button onclick="myFunction()">提交</button>       <a href="/info"><button>查看数据</button></a>
        <p id="demo"></p>
    </form> 
    <script>
        function myFunction(){
            var txt;
            confirm("Successfully inserted data!");
            txt = "你已成功插入数据！点击查看数据可查看更新后的数据";
            document.getElementById("demo").innerHTML = txt;
        }
    </script>
</div>
result_insert.html 
<body>
   你已成功插入数据！点击查看数据可查看更新后的数据!
   <br>
   插入的name为：{{results['name']}}<br>
   插入的age为：{{results['age']}}<br>
   <br>
   <a href="/info"><button>查看数据</button></a>
</body>
结果：在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 
<div>
    <h4>在该页面修改你的数据</h4>
    <!--通过改变form标签中method属性来改变数据请求的方式-->
    <form action="http://localhost:5000/update" method="POST">
        请输入你需要修改的id:<input type="text" name="id" autocomplete="off"><br/>
        请输入修改的name:<input type="text" name="name" autocomplete="off"><br/>
        请输入修改的age:<input type="text" name="age" autocomplete="off"><br/>
        <input type="submit" value="Submit">
    </form> 
    <a href="/info"><button>查看数据</button></a>
</div>
result_update.html 
<body>
   你已成功修改数据！
   <br>
   点击查看数据可查看更新后的数据!
   <br>
   修改的的id为：{{results['id']}}<br>
   修改的name为：{{results['name']}}<br>
   修改的age为：{{results['age']}}<br>
   <br>
   <a href="/info"><button>查看数据</button></a>
</body>
结果参考插入数据效果 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 
<body>
   你已成功删除id为:{{id}}的数据!
   <br>
   点击查看数据看查询更新后的数据！
   <br>
   <br>
   <a href="/info"><button>查看数据</button></a>
</body>
在更新、修改、删除 *** 作里面的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);

欢迎分享，转载请注明来源：内存溢出

原文地址: http://outofmemory.cn/sjk/991834.html

赞 (0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
code code 管理员组
0 0
上一篇 2022-05-21
下一篇 2022-05-21

发表评论

登录后才能评论

评论列表（0条）

保存