当前位置:   article > 正文

Flask 使用Flask-SQLAlchemy操作数据库_flask-sqlalchemy 多数据获取指定数据库session

flask-sqlalchemy 多数据获取指定数据库session

上面给roles表中添加了五条数据,下面这个视图函数给users表添加一条数据,关联roles表。

添加用户表数据

@app.route(“/addUser”)

def addUser():

user = User(username = “admin1”, password=“admin”, role_id=6)

db.session.add(user);

db.session.commit();

return “添加成功”

上面视图函数中是直接给出的roles表中的id值的,开发中可以根据某一属性查询出roles某一条数据进行关联。访问视图函数后,效果如下:

在这里插入图片描述

查询全部结果

定义一个视图查询出roles表中的所有数据。

查询表中全部数据

@app.route(“/findAll”)

def findAll():

返回一个列表,all()函数返回所有结果

result = Role.query.all();

print(result)

for item in result:

print(item.id, item.name)

return “查询成功”

查询结果如下:

在这里插入图片描述

上述中查询使用了all()函数,返回查询的所有结果,下表是SQLAlchemy查询一些常用的函数。

| 方法 | 说明 |

| — | — |

| all() | 以列表形式返回查询的所有结果 |

| first() | 返回查询的第一个结果,如果没有结结果,则返回None |

| frist_or_404 | 返回查询的第一个结果,如果没有结果,则重则请求,返回404错误响应 |

| get() | 返回指定主键对应的行,如果没有对应的行,则返回None |

| get_or_404 | 返回指定主键对应的行,如果没找到指定的主键,则终止请求,返回404错误响应 |

| count() | 返回查询结果的数量 |

| paginate() | 返回一个Paginate对象,它包含指定范围内的结果 |

根据条件查询

在上述查询全部数据中,使用filter进行条件查询

如下视图函数根据username属性查询。

根据用户名查询数据

@app.route(“/findByUsername/”)

def findByUsername(username):

filter过滤器,根据条件查询

obj = User.query.filter(User.username == username).all();

print(obj);

return “查询成功”;

在SQLAlchemy中除了filter过滤器还有一些其他的查询过滤器。如下

| 过滤器 | 说明 |

| — | — |

| filter() | 把过滤器添加到原查询上,返回一个新查询 |

| filter_by() | 把等值过滤器添加到原查询上,返回一个新查询 |

| limit() | 使用指定的值限制原查询返回的结果数量,返回一个新查询 |

| offset() | 偏移原查询返回的结果,返回一个新查询 |

| order_by() | 根据指定条件对原查询结果进行排序,返回一个新查询 |

| group_by() | 根据指定条件对原查询结果进行分组,返回一个新查询 |

删除

先根据id查询出需要参数的数据,在使用delete进行删除。

根据条件删除

@app.route(“/deleteById/”)

def deleteById(id):

根据id查询数据,filter条件查询

role = Role.query.filter(Role.id == id).first();

db.session.delete(role);

db.session.commit();

return “删除成功”;

修改

查询出表中的第一条数据,对其name属性进行修改,之后在保存。

修改

@app.route(“/update”)

def update():

role = Role.query.first();

role.name = “系统管理员”;

db.session.commit();

return “修改成功”

上述案例完整代码如下:

from flask import Flask

from flask_sqlalchemy import SQLAlchemy

app = Flask(name)

配置链接数据库信息

mysql://账号:密码@链接地址:端口/数据库名

app.config[‘SQLALCHEMY_DATABASE_URI’] = “mysql+pymysql://root:root@localhost:3306/flaskdemo”

设置是否跟踪数据库的修改情况

app.config[‘SQLALCHEMY_TRACK_MODIFICATIONS’] = True

数据库操作时是否显示原始SQL语句,日志

app.config[‘SQLALCHEMY_ECHO’] = True

链接超时时间

app.config[‘SQLALCHEMY_POOL_TIMEOUT’] = 3000

实例SQLAlchemy类,use_native_unicode='utf8’设置编码,必须设置

db = SQLAlchemy(app, use_native_unicode=‘utf8’);

@app.route(‘/’)

def hello_world():

return ‘Hello World!’

定义Role和User两个类

class Role(db.Model):

定义表名

tablename = ‘roles’;

db.Column定义属性,db.Integer设置类型,

Primary_key = True设置主键

unique = True设置唯一索引

index = True创建索引,提示查询效率

nullable = True允许为空值

default为这列设置默认值

autoincrement = True自动递增

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

name = db.Column(db.String(64), nullable=False)

定义一个User类

class User(db.Model):

tablename = ‘users’;

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

username = db.Column(db.String(64), unique=True, index=True);

password = db.Column(db.String(64));

这一列的值为roles表中的id值

如果是多对多关系就建一张表,关联两个表的id

role_id = db.Column(db.Integer, db.ForeignKey(‘roles.id’))

‘’’

帮助作关联查询

relationship()把两个表关联在一起,不添加也是可以的,根据自己的需求

backref : 在关系的另一模型中添加反向引用

相当于给要关联的表添加一个role属性

不添加也是可以的,根据自己的需求

‘’’

rol = db.relationship(‘Role’, backref=‘use’)

新增一条数据

@app.route(‘/add’)

def createOne():

构造模型,使用关键字参数指定的模型属性初始值

role = Role(name = “管理员1”);

把准备写入数据库的对象,先添加到会话中

db.session.add(role);

调用commit()方法提交会话

db.session.commit();

return “添加成功!”;

添加多条数据

@app.route(“/adds”)

def createAll():

role = Role(name = “管理员2”);

roles = [

Role(name=“管理员3”),

Role(name=“管理员4”),

Role(name=“管理员5”)

]

db.session.add_all(roles);

db.session.add(role);

db.session.commit();

return “添加成功”

查询表中全部数据

@app.route(“/findAll”)

def findAll():

返回一个列表

result = Role.query.all();

print(result)

for item in result:

print(item.id, item.name)

return “查询成功”

根据条件删除

@app.route(“/deleteById/”)

def deleteById(id):

根据id查询数据,filter条件查询

role = Role.query.filter(Role.id == id).first();

db.session.delete(role);

db.session.commit();

return “删除成功”;

修改

@app.route(“/update”)

def update():

role = Role.query.first();

role.name = “系统管理员”;

db.session.commit();

return “修改成功”

添加用户表数据

先自我介绍一下,小编13年上海交大毕业,曾经在小公司待过,也去过华为、OPPO等大厂,18年进入阿里一直到现在。

深知大多数初中级Java工程师,想要提升技能,往往是自己摸索成长或者是报班学习,但对于培训机构动则近万的学费,着实压力不小。自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前!

因此收集整理了一份《Java开发全套学习资料》送给大家,初衷也很简单,就是希望能够帮助到想自学提升又不知道该从何学起的朋友,同时减轻大家的负担。

img

img

img

由于文件比较大,这里只是将部分目录截图出来,每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频

如果你觉得这些内容对你有帮助,可以扫码领取!

img

技术学习总结

学习技术一定要制定一个明确的学习路线,这样才能高效的学习,不必要做无效功,既浪费时间又得不到什么效率,大家不妨按照我这份路线来学习。

最后面试分享

大家不妨直接在牛客和力扣上多刷题,同时,我也拿了一些面试题跟大家分享,也是从一些大佬那里获得的,大家不妨多刷刷题,为金九银十冲一波!

mg.cn/images/e5c14a7895254671a72faed303032d36.jpg" alt=“img” style=“zoom: 33%;” />

技术学习总结

学习技术一定要制定一个明确的学习路线,这样才能高效的学习,不必要做无效功,既浪费时间又得不到什么效率,大家不妨按照我这份路线来学习。

[外链图片转存中…(img-ttjR8T9c-1711365960173)]

[外链图片转存中…(img-4DaZi2oB-1711365960173)]

[外链图片转存中…(img-6N7iwUWT-1711365960173)]

最后面试分享

大家不妨直接在牛客和力扣上多刷题,同时,我也拿了一些面试题跟大家分享,也是从一些大佬那里获得的,大家不妨多刷刷题,为金九银十冲一波!

[外链图片转存中…(img-sFMUloBl-1711365960174)]

[外链图片转存中…(img-hNw5Zweu-1711365960174)]

需要更多Java资料的小伙伴可以帮忙点赞+关注,点击传送门,即可免费领取!

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/我家自动化/article/detail/619306
推荐阅读
相关标签
  

闽ICP备14008679号