1.安装pymysql
进入cmd 输入pip install pymysql或者进入pycharm的settings安装。
2.测试连接
import pymysql #导入 pymysql ，如果编译未出错，即表示 pymysql 安装成功。
naviact示例表结构
注意：建数据库时要选utf8不然会报错。
3.插入操作。
写一个简单的form表用来提交数据。代码如下
form method ="post" >
<label>用户名</label><input type = "text" name="username"><br>
<label>密码</label><input type = "password" name ="password"><br>
<label>确认密码</label><input type ="password" name ="password1"><br>
<input type = "submit" value = "提交"><br>
</form>
试图函数代码
import pymysql
from flask import render_template, request
from . import admin_blue
@admin_blue.route(’/test1’,methods=[‘GET’,‘POST’])
def test1():
data = request.form
# 打开数据库连接
db = pymysql.connect("localhost", "root", "", "pytest")
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
sql = "INSERT INTO test (name,password,repassword)VALUES ('%s', %s,%s)" % (data['username'], data['password'],data['password1'])
cursor.execute(sql)
db.commit()
db.close()
return render_template('test/register.html')
浏览器中输入内容提交后
数据库表中数据插入成功
4.查询操作。
试图函数代码
@admin_blue.route('/mysqlindex',methods=['GET','POST'])
def mysqlindex():
db = pymysql.connect("localhost", "root", "", "luntan")
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
sql = "select * from test" # 选择数据表里所有的用户
cursor.execute(sql)
testdata = cursor.fetchall()
db.commit()
db.close()
return render_template('test/pytest.html', testdata=testdata)
pytest.html中代码
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Title</title>
</head>
<body>
<h1>所有人员</h1>
<table>
<tr>
<th>ID</th>
<th>姓名</th>
<th>操作</th>
</tr>
{% for test in testdata %}
<tr>
<td>{{ test[0] }}</td>
<td>{{ test[1] }}</td>
<td>{{ test[2] }}</td>
<td>
<a href="{{ url_for('admin.mysqldelete',uid=test[0]) }}">删除</a>
<a href="{{ url_for('admin.mysqlmodify',uid=test[0]) }}">修改</a>
</td>
</tr>
{% endfor %}
</table>
</body>
</html>
浏览器中运行结果
5.删除数据。当点击删除时，使数据被删除
@admin_blue.route('/mysqldelete',methods=['GET','POST'])
def mysqldelete():
# 获取url中传过来的uid
uid = request.args.get('uid')
# 打开数据库连接
db = pymysql.connect("localhost", "root", "", "luntan")
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
sql = "delete from test where id = %s" % (uid) # 删除该用户
cursor.execute(sql)
db.commit()
db.close()
# return'删除成功'
return redirect(url_for('admin.mysqlindex'))
6.修改数据
修改视图函数如下，当点击显示页面的修改键时，先触发该视图函数条件语句中的else，进行提交时触发该视图函数条件语句上面的代码。
代码
@admin_blue.route('/mysqlmodify',methods=['GET','POST'])
def mysqlmodify():
if request.method == 'POST':
data = request.form
# 打开数据库连接
db = pymysql.connect("localhost", "root", "", "luntan")
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
sql = "update test set name='%s',password='%s',repassword='%s' where id =%s" \
% (data['username'],data['password'],data['password1'],data['uid'])
cursor.execute(sql)
db.commit()
db.close()
return redirect(url_for('admin.mysqlindex'))
else:
uid = request.args.get('uid')
return render_template('test/modify.html',uid = uid)
modify.html
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Title</title>
</head>
<body>
<h1>修改页面</h1>
<form method="post" action="{{ url_for('admin.mysqlmodify') }}">
姓名：<input name="username"> <br>
密码：<input name="password" type="password"> <br><br>
重置密码：<input name="password1" type="password"><br>
<input hidden="hidden" name="uid" value="{{ uid }}">
<input value="修改" type="submit"><br>
</form>
</body>
</html>