flask 数据库开发中级案例—PythonWeb框架应用

目录

第1关 查询操作

使用SQLAlchemy实现

config.py

__init__.py

models.py

test.py

头歌实验代码

第2关 增加操作

不使用SQLAlchemy实现

使用SQLAlchemy

头歌实验代码

第3关 删除操作

不使用SQLAlchemy实现

使用SQLAlchemy

使用 request 获取 get 请求的参数

头歌实验代码

第4关 修改操作

不使用SQLAlchemy实现

使用SQLAlchemy

获取POST请求提交的参数

头歌实验代码 

第1关 查询操作

本关任务：通过Flask连接Mysql数据库，完成下方编程要求的任务。

相关知识

文件结构：

flask_edu ├── app | ├── __init__.py | ├── models.py # 数据模型文件 | ├── templates # 用于存储html文件的文件夹 ├── config.py # 配置文件 └── test.py # 操作数据库的文件

Flask操作数据库有两种方式，一种是使用Flask-sqlalchemy模块实现，另一种是直接使用pymysql模块，通过编写sql语句操作数据库。 

使用SQLAlchemy实现

SQLAlchemy是一个基于Python实现的ORM框架。该框架建立在 DB API之上，使用关系对象映射进行数据库操作，简言之便是：将类和对象转换成SQL，然后使用数据API执行SQL并获取执行结果。而Flask-SQLAlchemy是Flask扩展，它将对SQLAlchemy的支持添加到Flask应用程序中。它比原始的操作数据库的方法更加方便简洁。使用该模块依然需要使用pymysql连接的数据库，建立连接需要从两部分入手：

通过修改配置文件config.py来连接到Mysql数据库 使配置生效，SQLAlchemy实例化数据库（本实训通过配置__init__.py实现）

示例表中的数据：

config.py

实现连接数据库功能：

class Config() SQLALCHEMY_DATABASE_URI = 'mysql+pymysql://root:123456@localhost:3306/database' # 'mysql+pymysql://用户名称:密码@ip:端口/数据库名称' SQLALCHEMY_TRACK_MODIFICATIONS = False #该配置项用于设置数据发生变更之后是否发送信号给应用

__init__.py

创建Flask实例，使config.py文件生效：

from flask import Flask from flask_sqlalchemy import SQLAlchemy from config import Configapp = Flask(__name__) # 创建Flask实例 db = SQLAlchemy(app) app.config.from_object(Config)

models.py

数据库表模型，实现关系对象映射：

from app import dbclass Demo(db.Model): __table__ = "demo" #表名 id = db.Column(db.Integer, primary_key=True) name = db.Column(db.String(255)) #id和name都为表中的字段名，

test.py

设置路由，以及编写查询语句等操作的文件：

from app import db from models import Demo#查询数据 Demo.query.all() #查询所有数据 Demo.query.all()[1:3] #查询第二到第四条数据 Demo.query.count() #查询有多少条数据 Demo.query.first() #查询第一条数据Demo.query.filter_by(id=3).first() Demo.query.filter(Demo.id==3).first() #这两条都用于查询id为3的数据，`filter_by`里面不能用`!= `还有`> <` 等等，所以`filter`用得更多,`filter_by`只能用`=`Demo.query.filter(and_(Demo.name.startwith("B"),Demo.id.endswith(1))).all() # 查询name以'B'开头，id以1结尾的所有数据，与操作用and_，或用or_ ，非用notDemo.query.order_by("id").all() #查询所有数据，并以id排序

常用的过滤器：

名称说明filter()把过滤器添加到原查询上，返回一个新查询filter_by()把等值过滤器添加到原查询上，返回一个新查询limit()使用指定的值限制原查询返回的结果数量，返回一个新查询offset()偏移原查询返回的结果，返回一个新查询order_by()根据指定条件对原查询结果进行排序，返回一个新查询group_by()根据指定条件对原查询结果进行分组，返回一个新查询

使用SQL语句实现

在Flask Web应用程序中也可以使用原始SQL对数据库执行增删改查操作。使用这种方法则不需要配置config.py文件和models.py文件，但是需要编写更多的SQL语句。

__init__.py

创建一个Flask实例，没有编写配置文件，所以不需要实现config.py：

from flask import Flaskapp = Flask(__name__) # 创建Flask实例

test.py

设置路由，以及编写查询语句等操作的文件：

import pymysqlconnect = pymysql.Connect(host='localhost', port=3306,user='root',passwd='123123',db='database',charset='utf8') #连接数据库 cursor = connnect.cursor() sql = "SELECT id,name FROM demo WHERE id = 2 " # sql语句 cursor.execute(sql) result = cursor.fetchone() # 查看查询结果

编程要求

message表结构与数据如下：

列名说明类型id表id（自动递增，主键）intprovincename省名varcharcityname省会名varcharct用户数量int

在Begin-End区域内进行代码补充，具体任务如下：

首先完成config.py文件，实现对数据库的连接，数据库名为web，Mysql用户名为root，密码为123123；完成models.py文件实现表模型的创建；完成test.py文件实现查询根据用户数量降序排序之后的结果，降序可以使用DESC方法。

提示：在代码栏左上角可以更换代码文件：

开始你的任务吧，祝你成功！

头歌实验代码

class Config(object):

#连接数据库

# ********* Begin *********#

SQLALCHEMY_DATABASE_URI = "mysql+pymysql://root:123123@localhost:3306/web"

SQLALCHEMY_TRACK_MODIFICATIONS = True

# ********* End *********#

from app import db

class Message(db.Model):

#表模型

#********* Begin *********#

id = db.Column(db.Integer,primary_key=True)

ct = db.Column(db.Integer)

provincename = db.Column(db.String(255))

cityname = db.Column(db.String(255))

#********* End *********#

from app import db,app

from models import Message

from flask import render_template

@app.route("/select")

def select():

# ********* Begin *********#

pro = Message.query.order_by(Message.ct.desc()).all()

city = list(map(lambda x: x.cityname, pro))

count = list(map(lambda x: x.ct, pro))

province = list(map(lambda x: x.provincename, pro))

# ********* End *********#

return render_template("index.html",city=city,count=count, province=province)

@app.route("/")

def home():

return render_template("home.html")

if __name__ == "__main__":

app.run(debug = True,host='0.0.0.0',port=8080)

第2关 增加操作

本关任务：通过Flask连接Mysql数据库，并对数据库进行增加数据操作，完成编程要求的任务。

相关知识

不使用SQLAlchemy实现

给demo表添加一条数据，只需要更改test.py文件：

import pymysqlconnect = pymysql.Connect(host='localhost', port=3306,user='root',passwd='123123',db='database',charset='utf8') cursor = connect.cursor()sql = "INSERT INTO (id, name) VALUES (%d, '%s')" # sql语句 data = (10,"Y") cursor.execute(sql,data) connect.commit()

使用SQLAlchemy

因为数据库没有变化，所以只需要更改test.py文件，其它文件配置与第一关相同：

from app import db from models import Demo# 增加数据 u = Demo(id=4, name="D") #参数对应表模型中的对象 db.session.add(u) db.session.commit() #提交事项

编程要求

提示：数据库表信息同第一关。

message表结构：

列名说明类型id表id（自动递增，主键）intprovincename省名varcharcityname省会名varcharct用户数量int

 代码补充，具体任务如下：

按照要求完成config.py文件的连接数据库以及models.py文件表模型的创建；在test.py文件中使用request.form()获取POST请求的表单数据（后台会自动发送一个POST请求，表单内容为纽约州 纽约市 1205）；将获取下来的数据添加到数据库中。

测试说明

点击测评，平台会部署你的应用，并测试你的程序，尝试访问你编写的insert()方法。

预期输出：

id provincename cityname ct 39 纽约州 纽约市 1205 38 湖南省 长沙市 1999 36 湖南省 株洲市 123 34 澳门 澳门 1894 33 新疆维吾尔自治区 乌鲁木齐 1808 32 青海省 西宁市 1890 31 湖北省 武汉市 1851 30 广东省 广州市 1911 29 浙江省 杭州市 1905 28 台湾省 台北市 1820 27 福建省 福州市 1874 26 河北省 石家庄市 1841 25 吉林省 长春市 1867 24 四川省 成都市 1861 23 湖南省 株洲市 1924 22 云南省 昆明市 1850 21 河南省 郑州市 1787 20 贵州省 贵阳市 1814 19 上海市 上海市 1955 18 重庆市 重庆市 1821 17 江苏省 南京市 1884 16 山东省 济南市 1864 15 宁夏回族自治区 银川 1886 14 甘肃省 兰州市 1883 13 香港 九龙 1877 12 天津市 天津市 1816 11 北京市 北京市 1826 10 安徽省 合肥市 1848 9 西藏自治区 拉萨 1830 8 海南省 海口市 1919 7 陕西省 西安市 1816 6 山西省 太原市 1886 5 江西省 南昌市 1898 4 广西壮族自治区 南宁 1841 3 黑龙江省 哈尔滨市 1863 2 辽宁省 沈阳市 1864 1 内蒙古自治区 呼和浩特 1903

头歌实验代码

class Config(object):

#连接数据库

###### Begin ######

SQLALCHEMY_DATABASE_URI = "mysql+pymysql://root:123123@localhost:3306/web?charset=utf8"

SQLALCHEMY_TRACK_MODIFICATIONS = True

###### End ######

from app import db

class Message(db.Model):

#表模型

###### Begin ######

id = db.Column(db.Integer, primary_key=True)

ct = db.Column(db.Integer)

provincename = db.Column(db.String(255))

cityname = db.Column(db.String(255))

###### End ######

from app import app,db

from models import Message

from flask import Flask,render_template,request,redirect

@app.route('/insert',methods=['GET','POST'])

def insert():

#进行添加操作

# ********* Begin ********* #

province = request.form['province']

city = request.form['city']

number = request.form['number']

u = Message(provincename=province,cityname=city,ct=number)

db.session.add(u)

db.session.commit()

# ********* End ********* #

return redirect('/')

@app.route("/insert_page")

def insert_page():

#跳转至添加页面

return render_template("insert.html")

@app.route("/")

def home():

listCity = Message.query.order_by(Message.id.desc()).all()

return render_template("home.html",city_list = listCity)

if __name__ == "__main__":

app.run(debug=True,host="0.0.0.0", port=8080)

第3关 删除操作

本关任务：通过Flask连接Mysql数据库，并对数据库进行删除数据操作。

相关知识

不使用SQLAlchemy实现

给demo表删除一条数据，只需要修改test.py文件：

import pymysqlconnect = pymysql.Connect(host='localhost', port=3306,user='root',passwd='123123',db='database',charset='utf8') #连接数据库 cursor = connnect.cursor()sql = "DELETE FROM trade WHERE name = 'B'" # sql语句 cursor.execute(sql) connect.commit()

使用SQLAlchemy

因为数据库没有变化，所以只需要更改test.py文件，其它文件配置与第一关相同：

from app import db from models import Demo# 删除数据 u2 = Demo.query.filter_by(name='D').first() #先定位到删除数据的那一行 db.session.delete(u2) db.session.commit()

使用 request 获取 get 请求的参数

使用request的args方法即可获取get请求提交的参数。 示例：

@app.route("/demo",methods=['GET']) def demo(): info = request.args.get("info") #获取get请求的info参数

编程要求

提示：数据库表信息同第一关

message表结构：

列名说明类型id编号(自动递增，主键)intprovincename省名varcharcityname省会名varcharct用户数量int

编写代码完成删除功能，根据方法内的提示，在Begin-End区域内进行代码补充。

测试说明

点击测评，平台会部署你的服务器，并尝试调用你补全的delete()方法，传入参数为 id = 1。

预期输出： 成功删除id为1的记录则算通关

id provincename cityname ct 2 辽宁省 沈阳市 1864 3 黑龙江省 哈尔滨市 1863 4 广西壮族自治区 南宁 1841 5 江西省 南昌市 1898 6 山西省 太原市 1886 7 陕西省 西安市 1816 8 海南省 海口市 1919 9 西藏自治区 拉萨 1830 10 安徽省 合肥市 1848 11 北京市 北京市 1826 12 天津市 天津市 1816 13 香港 九龙 1877 14 甘肃省 兰州市 1883 15 宁夏回族自治区 银川 1886 16 山东省 济南市 1864 17 江苏省 南京市 1884 18 重庆市 重庆市 1821 19 上海市 上海市 1955 20 贵州省 贵阳市 1814 21 河南省 郑州市 1787 22 云南省 昆明市 1850 23 湖南省 株洲市 1924 24 四川省 成都市 1861 25 吉林省 长春市 1867 26 河北省 石家庄市 1841 27 福建省 福州市 1874 28 台湾省 台北市 1820 29 浙江省 杭州市 1905 30 广东省 广州市 1911 31 湖北省 武汉市 1851 32 青海省 西宁市 1890 33 新疆维吾尔自治区 乌鲁木齐 1808 34 澳门 澳门 1894 36 湖南省 株洲市 123 38 湖南省 长沙市 1999

头歌实验代码

from app import db,app

from models import Message

from flask import render_template,redirect,request

@app.route("/delete",methods=['GET'])

def delete():

#操作数据库得到目标数据，before_number表示删除之前的数量，after_name表示删除之后的数量

# ********* Begin *********#

id = request.args.get("id")

message = Message.query.filter_by(id=id).first()

db.session.delete(message)

db.session.commit()

# ********* End *********#

return redirect('/')

@app.route("/")

def home():

listCity = Message.query.order_by(Message.id.desc()).all()

return render_template("home.html",city_list = listCity)

if __name__ == "__main__":

app.run(debug = True,host="0.0.0.0",port=8080)

第4关 修改操作

本关任务：通过Flask连接Mysql数据库，并对数据库进行修改数据操作。

相关知识

不使用SQLAlchemy实现

给demo表修改一条数据，只需要修改test.py文件：

import pymysqlconnect = pymysql.Connect(host='localhost', port=3306,user='root',passwd='123123',db='database',charset='utf8') #连接数据库 cursor = connect.cursor()sql = "UPDATE demo SET id=10 WHERE name = 'A'" # sql语句 cursor.execute(sql,data) connect.commit()

使用SQLAlchemy

因为数据库没有变化，所以只需要更改test.py文件，其它文件配置与第一关相同：

from app import db from models import Demo# 删除数据 u1 = Demo.query.filter_by(name='A').first() #定位到name='A'的行 u1.id = 10 #将这一行的id改为10 db.session.commit()

获取POST请求提交的参数

在 Flask 中通过 request 对象可以获取，例如一个登陆方法中需要获取前端表单使用POST请求提交的用户名和密码数据。

from flask import request@app.route("/alter",methods=['POST']) def login(): #接收参数，修改数据 # ********* Begin *********# username = request.form["username"] password = request.form['password']

编程要求

提示：数据库表信息同第一关，数据库名为web

message表结构：

列名说明类型id表id(自动递增，主键)intprovincename省名varcharcityname省会名varcharct用户数量int

使用普通**sql**语句完成任务，在Begin-End区域内进行代码补充，具体任务如下：

首先使用request.form()获取表单数据中的id、provincename、cityname、ct、id是不可以修改的；使用sql语句将湖南省的省会改为长沙市。

测试说明

点击测评，平台会部署你的web应用，并尝试调用更新方法，将内蒙古呼和浩特市的用户数修改为10万。

预期输出：

(1, '内蒙古自治区', '呼和浩特', 100000) (2, '辽宁省', '沈阳市', 1864) (3, '黑龙江省', '哈尔滨市', 1863) (4, '广西壮族自治区', '南宁', 1841) (5, '江西省', '南昌市', 1898) (6, '山西省', '太原市', 1886) (7, '陕西省', '西安市', 1816) (8, '海南省', '海口市', 1919) (9, '西藏自治区', '拉萨', 1830) (10, '安徽省', '合肥市', 1848) (11, '北京市', '北京市', 1826) (12, '天津市', '天津市', 1816) (13, '香港', '九龙', 1877) (14, '甘肃省', '兰州市', 1883) (15, '宁夏回族自治区', '银川', 1886) (16, '山东省', '济南市', 1864) (17, '江苏省', '南京市', 1884) (18, '重庆市', '重庆市', 1821) (19, '上海市', '上海市', 1955) (20, '贵州省', '贵阳市', 1814) (21, '河南省', '郑州市', 1787) (22, '云南省', '昆明市', 1850) (23, '湖南省', '株洲市', 1924) (24, '四川省', '成都市', 1861) (25, '吉林省', '长春市', 1867) (26, '河北省', '石家庄市', 1841) (27, '福建省', '福州市', 1874) (28, '台湾省', '台北市', 1820) (29, '浙江省', '杭州市', 1905) (30, '广东省', '广州市', 1911) (31, '湖北省', '武汉市', 1851) (32, '青海省', '西宁市', 1890) (33, '新疆维吾尔自治区', '乌鲁木齐', 1808) (34, '澳门', '澳门', 1894) (36, '湖南省', '株洲市', 123) (38, '湖南省', '长沙市', 1999)

头歌实验代码 

from app import app,db

from models import Message

from flask import render_template

from flask import redirect,request

import pymysql

@app.route("/alter",methods=['POST'])

def alter():

#接收参数，修改数据

# ********* Begin *********#

id = request.form["id"]

province = request.form['province']

city = request.form['city']

number = request.form['number']

message = Message.query.filter_by(id = id).first()

message.provincename = province

message.cityname = city

message.ct = number

db.session.commit()

# ********* End *********#

return redirect('/')

#修改页面

@app.route("/alter_page",methods=['GET'])

def alter_page():

id = request.args.get("id")

province = request.args.get("provincename")

cityname = request.args.get("cityname")

ct = request.args.get("ct")

message = Message(id = id,provincename=province,cityname=cityname,ct=ct)

print(message)

return render_template("alter.html",message = message)

@app.route("/")

def home():

listCity = Message.query.order_by(Message.id.desc()).all()

return render_template("home.html",city_list = listCity)

if __name__ == "__main__":

app.run(debug=True, host="0.0.0.0", port=8080)

相关文章

 您阅读本篇文章共花了：