web应用框架——Flask中的SQLAlchemy数据库

一、数据库

1.安装数据库

安装sqlalchemy
pip install sqlalchemy
安装mysqlclient
pip install mysqlclient

  • 安装这个mysqlclient的时候出了一些问题：



  • 解决这个问题：
    https://www.lfd.uci.edu/~gohlke/pythonlibs/#
    进入这个网站，下载mysqlclient安装包
    为了大家方便我已经下好放入百度云中：

mysqlclient各个版本安装包链接：https://pan.baidu.com/s/1Te8AowKKCSDmWyWSpWUVog
提取码：lfxl

  • 下载安装包
pip install F:\Pycharm\pycharm-2019.3.3\pycharm\mysqlclient-1.3.13-cp35-cp35m-win_amd64.whl
  • 下载mysqlclient
pip install mysqlclient

安装完成

安装pymysql
pip install pymysql
安装flask_sqlalchemy
pip install flask_sqlalchemy
查看所有安装目录
pip list

二、创建数据库

方式一：

  • 新建一个db_demo.html文件
from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
# 设置数据库连接
app.config['SQLALCHEMY_DATABASE_URI'] ='mysql://root:root@127.0.0.1:3306/test11'
# 动态追踪设置
app.config['SQLALCHEMY_TRACK_MODUFICATIONS'] = True
# 显示原始sql
app.config['SQLALCHEMY_ECHO'] = True


# 数据库要和 app关联
db = SQLAlchemy(app)

class Role(db.Model):
    # 定义表名
    __tablename__ = 'roles'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)




@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    # 删除表
    db.drop_all()
    # 创建表
    db.create_all()
    ro1 = Role(name='admin')
    ro2 = Role(name='user')
    db.session.add_all([ro1, ro2])
    db.session.commit()
    app.run()

  • 打开PHPstudy


  • 打开MySQL数据库，新建数据库


  • 运行程序



    会显示创建表的过程

  • 刷新数据库


方式二：

  • 新建一个db_demo2.html文件
from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

host = 'localhost'
port = 3306
username = 'root'
password = 'root'
db = 'flask2'
connect_str = 'mysql+pymysql://{}:{}@{}:{}/{}'.format(username,password,host,port,db)
# 设置数据库连接
app.config['SQLALCHEMY_DATABASE_URI'] = connect_str
# 设置每次请求结束后自动提交数据库的改动
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
# 动态追踪设置
app.config['SQLALCHEMY_TRACK_MODUFICATIONS'] = True
# 显示原始sql
app.config['SQLALCHEMY_ECHO'] = True
# 数据库要和 app关联
db = SQLAlchemy(app)

class Role(db.Model):
    # 定义表名
    __tablename__ = 'roles'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)

@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    # 删除表
    db.drop_all()
    # 创建表
    db.create_all()
    ro1 = Role(name='admin')
    ro2 = Role(name='user')
    db.session.add_all([ro1, ro2])
    db.session.commit()
    app.run()

  • 打开MySQL数据库新建一个数据库flask2


  • 运行程序


  • 刷新数据库


三、插入数据

  • 创建表名：
class Role(db.Model):
    # 定义表名，角色表
    __tablename__ = 'roles'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)
    db.relationship('User',backref='role')
    def __repr__(self):
        return 'Role:{}'.format(self.name)

class User(db.Model):
    # 定义表名，用户表
    __tablename__ = 'users'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)
    email = db.Column(db.String(64), unique=True)
    password = db.Column(db.String(64))
    role_id = db.Column(db.Integer,db.ForeignKey('roles.id'))
    def __repr__(self):
        return 'User:{}'.format(self.name)
  • 添加数据：
us1 = User(name='wang', email='wang@163.com', password='123456', role_id=ro1.id)
    us2 = User(name='zhang', email='zhang@189.com', password='201512', role_id=ro2.id)
    us3 = User(name='chen', email='chen@126.com', password='987654', role_id=ro2.id)
    us4 = User(name='zhou', email='zhou@163.com', password='456789', role_id=ro1.id)
    us5 = User(name='tang', email='tang@neuedu.com', password='158104', role_id=ro2.id)
    us6 = User(name='wu', email='wu@gmail.com', password='5623514', role_id=ro2.id)
    us7 = User(name='qian', email='qian@gmail.com', password='1543567', role_id=ro1.id)
    us8 = User(name='liu', email='liu@neuedu.com', password='867322', role_id=ro1.id)
    us9 = User(name='li', email='li@163.com', password='4526342', role_id=ro2.id)
    us10 = User(name='sun', email='sun@163.com', password='235523', role_id=ro2.id)
    db.session.add_all([us1, us2, us3, us4, us5, us6, us7, us8, us9, us10])
    db.session.commit()
  • 完整代码：
from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

host = 'localhost'
port = 3306
username = 'root'
password = 'root'
db = 'flask2'
connect_str = 'mysql+pymysql://{}:{}@{}:{}/{}'.format(username,password,host,port,db)
# 设置数据库连接
app.config['SQLALCHEMY_DATABASE_URI'] = connect_str
# 设置每次请求结束后自动提交数据库的改动
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
# 动态追踪设置
app.config['SQLALCHEMY_TRACK_MODUFICATIONS'] = True
# 显示原始sql
app.config['SQLALCHEMY_ECHO'] = True
# 数据库要和 app关联
db = SQLAlchemy(app)

class Role(db.Model):
    # 定义表名，角色表
    __tablename__ = 'roles'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)
    db.relationship('User',backref='role')
    def __repr__(self):
        return 'Role:{}'.format(self.name)

class User(db.Model):
    # 定义表名，用户表
    __tablename__ = 'users'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)
    email = db.Column(db.String(64), unique=True)
    password = db.Column(db.String(64))
    role_id = db.Column(db.Integer,db.ForeignKey('roles.id'))
    def __repr__(self):
        return 'User:{}'.format(self.name)


@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    # 删除表
    db.drop_all()
    # 创建表
    db.create_all()
    ro1 = Role(name='admin')
    ro2 = Role(name='user')
    db.session.add_all([ro1, ro2])
    db.session.commit()
    us1 = User(name='wang', email='wang@163.com', password='123456', role_id=ro1.id)
    us2 = User(name='zhang', email='zhang@189.com', password='201512', role_id=ro2.id)
    us3 = User(name='chen', email='chen@126.com', password='987654', role_id=ro2.id)
    us4 = User(name='zhou', email='zhou@163.com', password='456789', role_id=ro1.id)
    us5 = User(name='tang', email='tang@neuedu.com', password='158104', role_id=ro2.id)
    us6 = User(name='wu', email='wu@gmail.com', password='5623514', role_id=ro2.id)
    us7 = User(name='qian', email='qian@gmail.com', password='1543567', role_id=ro1.id)
    us8 = User(name='liu', email='liu@neuedu.com', password='867322', role_id=ro1.id)
    us9 = User(name='li', email='li@163.com', password='4526342', role_id=ro2.id)
    us10 = User(name='sun', email='sun@163.com', password='235523', role_id=ro2.id)
    db.session.add_all([us1, us2, us3, us4, us5, us6, us7, us8, us9, us10])
    db.session.commit()
    app.run()

  • 运行程序


  • 刷新数据库


四、查找数据

  • 进入flask shell界面
flask shell
  • 导入user表
from db_demo2 import User





条件查询

@app.route('/')
def index():
    # 1、返回名字等于wang 的所有人
    print(User.query.filter_by(name='wang').all())
    # 2返回查询的第一个对象
    print(User.query.first())
    # 3. 返回所有查询对象
    print(User.query.all())
    # 4. 返回名字结尾字符为g的所有数据
    print(User.query.filter(User.name.endswith('g')).all())
    # 5. 返回user中id = 1的数据
    print(User.query.get(1))
    # 6. 返回名字不等于wang的所有数据
    print(User.query.filter(User.name != 'wang').all())
    # 7 返回名字不等于 wang 且 邮箱 以 163.com结尾的所有
    print(User.query.filter(and_(User.name != 'wang',User.email.endswith('163.com'))).all())
    # 8 返回名字不等于 wang 或 邮箱 以 163.com结尾的所有
    print(User.query.filter(or_(User.name != 'wang', User.email.endswith('163.com'))).all())

    # 删除数据
    # 删除user中的第一条
    # user = User.query.first()
    # db.session.delete(user)
    # print("删除user中的第一条")
    # print(User.query.all())

    # 更新数据
    #user = User.query.first()
    #user.name = 'eric'
    #db.session.commit()
    #print("更新数据user中的第一条")
    #print(User.query.first())

    # 查询所有用户数据
    print(User.query.all())
    # 查询有多少个用户
    print(User.query.count())
    # 查询第1个用户
    print(User.query.first())
    print(User.query.get(1))
    # 查询id为4的用户[3种方式]
    print(User.query.get(4))
    print(User.query.filter_by(id=4).all())
    print(User.query.filter(User.id == 4).all())
    # 查询名字结尾字符为g的所有数据[开始/包含]
    print(User.query.filter(User.name.endswith('g')).all())
    # 查询名字不等于wang的所有数据[2种方式]
    print(User.query.filter(User.name != 'wang').all())
    print(User.query.filter(or_(User.name == 'wang')).all())
    # 查询名字和邮箱都以 li 开头的所有数据[2种方式]
    print(User.query.filter(and_(User.name == 'li', User.email.startswith('li'))).all())
    print(User.query.filter(User.name.startswith('li'), User.email.startswith('li')).all())
    # 查询password是 `123456` 或者 `email` 以 `neuedu.com` 结尾的所有数据
    print(User.query.filter(or_(User.password == '123456', User.email.endswith('neuedu.com'))).all())
    # 查询id为 [1, 3, 5, 7, 9] 的用户列表
    print(User.query.filter(User.id.in_([1,3,4,7,9])).all())
    # 查询name为liu的角色数据
    print(User.query.filter(User.name == 'liu').all())
    # 查询所有用户数据，并以邮箱排序
    print(User.query.order_by(User.email).all())
    # 每页3个，查询第2页的数据
    pn=User.query.paginate(2,3)
    print(pn)
    return 'index'





（此文章仅作为个人学习笔记使用，如有错误欢迎指正~）

©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 216,039评论 6赞 498
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 92,223评论 3赞 392
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 161,916评论 0赞 351
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 58,009评论 1赞 291
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 67,030评论 6赞 388
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 51,011评论 1赞 295
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,934评论 3赞 416
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 38,754评论 0赞 271
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 45,202评论 1赞 309
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,433评论 2赞 331
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,590评论 1赞 346
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 35,321评论 5赞 342
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,917评论 3赞 325
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,568评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,738评论 1赞 268
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 47,583评论 2赞 368
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 44,482评论 2赞 352