Flask-SQLALchemy基本使用方法
數(shù)據(jù)庫基本操作
在Flask-SQLAlchemy中,插入、修改、刪除操作,均由數(shù)據(jù)庫會話管理。會話用db.session表示。在準(zhǔn)備把數(shù)據(jù)寫入數(shù)據(jù)庫前,要先將數(shù)據(jù)添加到會話中然后調(diào)用commit()方法提交會話。
數(shù)據(jù)庫會話是為了保證數(shù)據(jù)的一致性,避免因部分更新導(dǎo)致數(shù)據(jù)不一致。提交操作把會話對象全部寫入數(shù)據(jù)庫,如果寫入過程發(fā)生錯(cuò)誤,整個(gè)會話都會失效。
數(shù)據(jù)庫會話也可以回滾,通過db.session.rollback()方法,實(shí)現(xiàn)會話提交數(shù)據(jù)前的狀態(tài)。
在Flask-SQLAlchemy中,查詢操作是通過query對象操作數(shù)據(jù)。最基本的查詢是返回表中所有數(shù)據(jù),可以通過過濾器進(jìn)行更精確的數(shù)據(jù)庫查詢。
將數(shù)據(jù)添加到會話中示例:
user = User(name='python') db.session.add(user) db.session.commit()
在視圖函數(shù)中定義模型類
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
#設(shè)置連接數(shù)據(jù)庫的URL
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@127.0.0.1:3306/Flask_test'
#設(shè)置每次請求結(jié)束后會自動提交數(shù)據(jù)庫中的改動
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
#查詢時(shí)會顯示原始SQL語句
app.config['SQLALCHEMY_ECHO'] = True
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)
us = db.relationship('User', backref='role')
#repr()方法顯示一個(gè)可讀字符串
def __repr__(self):
return 'Role:%s'% self.name
class User(db.Model):
__tablename__ = 'users'
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(64), unique=True, index=True)
email = db.Column(db.String(64),unique=True)
pswd = db.Column(db.String(64))
role_id = db.Column(db.Integer, db.ForeignKey('roles.id'))
def __repr__(self):
return 'User:%s'%self.name
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',pswd='123456',role_id=ro1.id)
us2 = User(name='zhang',email='zhang@189.com',pswd='201512',role_id=ro2.id)
us3 = User(name='chen',email='chen@126.com',pswd='987654',role_id=ro2.id)
us4 = User(name='zhou',email='zhou@163.com',pswd='456789',role_id=ro1.id)
db.session.add_all([us1,us2,us3,us4])
db.session.commit()
app.run(debug=True)常用的SQLAlchemy查詢過濾器
| 過濾器 | 說明 |
|---|---|
| filter() | 把過濾器添加到原查詢上,返回一個(gè)新查詢 |
| filter_by() | 把等值過濾器添加到原查詢上,返回一個(gè)新查詢 |
| limit | 使用指定的值限定原查詢返回的結(jié)果 |
| offset() | 偏移原查詢返回的結(jié)果,返回一個(gè)新查詢 |
| order_by() | 根據(jù)指定條件對原查詢結(jié)果進(jìn)行排序,返回一個(gè)新查詢 |
| group_by() | 根據(jù)指定條件對原查詢結(jié)果進(jìn)行分組,返回一個(gè)新查詢 |
常用的SQLAlchemy查詢執(zhí)行器
| 方法 | 說明 |
|---|---|
| all() | 以列表形式返回查詢的所有結(jié)果 |
| first() | 返回查詢的第一個(gè)結(jié)果,如果未查到,返回None |
| first_or_404() | 返回查詢的第一個(gè)結(jié)果,如果未查到,返回404 |
| get() | 返回指定主鍵對應(yīng)的行,如不存在,返回None |
| get_or_404() | 返回指定主鍵對應(yīng)的行,如不存在,返回404 |
| count() | 返回查詢結(jié)果的數(shù)量 |
| paginate() | 返回一個(gè)Paginate對象,它包含指定范圍內(nèi)的結(jié)果 |
創(chuàng)建表:
db.create_all()
刪除表
db.drop_all()
插入一條數(shù)據(jù)
ro1 = Role(name='admin') db.session.add(ro1) db.session.commit() #再次插入一條數(shù)據(jù) ro2 = Role(name='user') db.session.add(ro2) db.session.commit()
一次插入多條數(shù)據(jù)
us1 = User(name='wang',email='wang@163.com',pswd='123456',role_id=ro1.id) us2 = User(name='zhang',email='zhang@189.com',pswd='201512',role_id=ro2.id) us3 = User(name='chen',email='chen@126.com',pswd='987654',role_id=ro2.id) us4 = User(name='zhou',email='zhou@163.com',pswd='456789',role_id=ro1.id) db.session.add_all([us1,us2,us3,us4]) db.session.commit()
查詢:filter_by精確查詢
返回名字等于wang的所有人
User.query.filter_by(name='wang').all()
first()返回查詢到的第一個(gè)對象
User.query.first()
all()返回查詢到的所有對象
User.query.all()
filter模糊查詢,返回名字結(jié)尾字符為g的所有數(shù)據(jù)。
User.query.filter(User.name.endswith('g')).all()get(),參數(shù)為主鍵,如果主鍵不存在沒有返回內(nèi)容
User.query.get()
邏輯非,返回名字不等于wang的所有數(shù)據(jù)。
User.query.filter(User.name!='wang').all()
邏輯與,需要導(dǎo)入and,返回and()條件滿足的所有數(shù)據(jù)。
from sqlalchemy import and_
User.query.filter(and_(User.name!='wang',User.email.endswith('163.com'))).all()邏輯或,需要導(dǎo)入or_
from sqlalchemy import or_
User.query.filter(or_(User.name!='wang',User.email.endswith('163.com'))).all()not_ 相當(dāng)于取反
from sqlalchemy import not_ User.query.filter(not_(User.name=='chen')).all()
查詢數(shù)據(jù)后刪除
user = User.query.first() db.session.delete(user) db.session.commit() User.query.all()
更新數(shù)據(jù)
user = User.query.first() user.name = 'dong' db.session.commit() User.query.first()
使用update
User.query.filter_by(name='zhang').update({'name':'li'})關(guān)聯(lián)查詢示例
角色和用戶的關(guān)系是一對多的關(guān)系,一個(gè)角色可以有多個(gè)用戶,一個(gè)用戶只能屬于一個(gè)角色。
查詢角色的所有用戶:
#查詢r(jià)oles表id為1的角色 ro1 = Role.query.get(1) #查詢該角色的所有用戶 ro1.us
查詢用戶所屬角色:
#查詢users表id為3的用戶 us1 = User.query.get(3) #查詢用戶屬于什么角色 us1.role
到此這篇關(guān)于Flask-SQLALchemy基本使用方法的文章就介紹到這了,更多相關(guān)Flask SQLALchemy使用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
分析Python的Django框架的運(yùn)行方式及處理流程
這篇文章主要介紹了分析Python的Django框架的運(yùn)行方式及處理流程,本文對于Django框架的機(jī)制總結(jié)得非常之直觀精煉,極力推薦!需要的朋友可以參考下2015-04-04
opencv用VS2013調(diào)試時(shí)用Image Watch插件查看圖片
本文主要介紹了opencv用VS2013調(diào)試時(shí)用Image Watch插件查看圖片,直接以圖片形式可視化了opencv中的Mat變量。感興趣的可以了解下2021-07-07
python中elasticsearch_dsl模塊的使用方法
這篇文章主要介紹了python中elasticsearch_dsl模塊的使用方法,elasticsearch-dsl是基于elasticsearch-py封裝實(shí)現(xiàn)的,提供了更簡便的操作elasticsearch的方法2022-09-09
詳解tensorflow實(shí)現(xiàn)遷移學(xué)習(xí)實(shí)例
本篇文章主要介紹了詳解tensorflow實(shí)現(xiàn)遷移學(xué)習(xí)實(shí)例,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-02-02

