常見的操作語句

• db.session.add(obj) 新增物件
• db.session.add_all([obj1,obj2,..]) 新增多個物件
• db.session.delete(obj) 刪除物件
• db.session.commit() 提交會話
• db.session.rollback() 回滾
• db.session.remove() 移除會話

常用的SQLAlchemy查詢過濾器

常用的SQLAlchemy查詢執行器

練習

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

#配置資訊
app.config["SQLALCHEMY_DATABASE_URI"] = "mysql+pymysql://root:[email protected]:3306/basic8"
#設定壓制警告資訊,如果True會追蹤資料庫變化,會增加顯著開銷,所以建議設定為False
app.config["
 
SQLALCHEMY_TRACK_MODIFICATIONS"] = False

#建立SQLAlchemy類物件,關聯app
db = SQLAlchemy(app)

#編寫模型類,繼承db.Model
#角色,使用者之間的關係
class Role(db.Model):
    __tablename__ = "roles" #指定表名稱
    #引數1:表示整數型別,  引數2:表示主鍵
    id = db.Column(db.Integer,primary_key=True)
    #角色名唯一的
    name = db.Column(db.String(64),unique=True)


    #需要設定關係屬性relationship(不會產生欄位),設定在一方
    #給Role添加了users關係屬性, 查詢格式: role.users
    #給User添加了role關係屬性(反向引用),查詢格式: user.role
    users = db.relationship('User',backref='role')

    #為了方便的看到物件輸出的內容__repr__, 如果是普通類__str__
    def __repr__(self):
        return "<Role:%s>"%self.name

# 使用者(多方)
class User(db.Model):
    __tablename__ = "users"  # 指定表名稱
    #引數1:表示整數型別,  引數2:表示主鍵
    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(Role.id))

    #為了方便的看到物件輸出的內容__repr__, 如果是普通類__str__
    def __repr__(self):
        return "<User:%s,%s,%s,%s>"%(self.id,self.name,self.email,self.password)

if __name__ == '__main__':

    #為了演示方便,先刪除資料庫表,和模型類關聯的表
    db.drop_all()

    #建立表,所有繼承自dbModel的表
    db.create_all()

    #建立測試資料
    ro1 = Role(name='admin')
    db.session.add(ro1)
    db.session.commit()
    # 再次插入一條資料
    ro2 = Role(name='user')
    db.session.add(ro2)
    db.session.commit()

    #多條使用者資料
    us1 = User(name='wang', email='[email protected]', password='123456', role_id=ro1.id)
    us2 = User(name='zhang', email='[email protected]', password='201512', role_id=ro2.id)
    us3 = User(name='chen', email='[email protected]', password='987654', role_id=ro2.id)
    us4 = User(name='zhou', email='[email protected]', password='456789', role_id=ro1.id)
    us5 = User(name='tang', email='[email protected]', password='158104', role_id=ro2.id)
    us6 = User(name='wu', email='[email protected]', password='5623514', role_id=ro2.id)
    us7 = User(name='qian', email='[email protected]', password='1543567', role_id=ro1.id)
    us8 = User(name='liu', email='[email protected]', password='867322', role_id=ro1.id)
    us9 = User(name='li', email='[email protected]', password='4526342', role_id=ro2.id)
    us10 = User(name='sun', email='[email protected]', 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(debug=True)

增加

user = User(name='laowang')
db.session.add(user)
db.session.commit()

修改

user.name = 'xiaohua'
db.session.commit()

刪除

db.session.delete(user)
db.session.commit()

查詢　

特點:
模型.query: 得到了所有模型的資料的結果集物件
模型.query.過濾器: 過濾出了想要的資料,還是一個查詢結果集物件
模型.query.過濾器.執行器: 取出了結果集中的內容


查詢所有使用者資料
User.query.all() ==> [user1,user2]

查詢有多少個使用者
User.query.count()

查詢第1個使用者
User.query.first()

查詢id為4的使用者[3種方式]
User.query.get(4) (這裡面只能是數字 或 ‘4’) 查詢不到不會報錯
User.query.filter_by(id = 4).first() （一個等號）查詢不到不會報錯
User.query.filter(User.id == 4).first()  查詢不到不會報錯

查詢名字結尾字元為g的所有資料[開始/包含]
User.query.filter(User.name.endswith('g')).all()
User.query.filter(User.name.startswith('g')).all()
User.query.filter(User.name.contains('g')).all()

查詢名字不等於wang的所有資料[2種方式]
User.query.fliter(User.name != 'wang').all()
或者
from sqlalchemy import not_
User.qudry.filter(not_(User.name == 'wang'))
查詢名字和郵箱都以 li 開頭的所有資料[2種方式]
from sqlalchemy import and_
User.query.filter(User.name.startswith('li'),User.email.startswith('li')).all()
User.query.filter(and_(User.name.startswith('li'),User.email.startswith('li'))).all()

查詢password是 `123456` 或者 `email` 以 `itheima.com` 結尾的所有資料
from sqlalchemy import or_
User.query.filter(or_(User.password == '123456',User.email.endswith('itheima.com'))).all()

查詢id為 [1, 3, 5, 7, 9] 的使用者列表
User.query.filter(User.id.in_([1,3,5,7,9])).all()

查詢name為liu的角色資料
user = User.query.filter(User.name == 'liu').first()
role = Role.query.filter(Role.id == user.role_id).first()

查詢所有使用者資料，並以郵箱排序
User.query.order_by(User.email).all()
User.query.order_by(User.email.desc()).all()

每頁3個，查詢第2頁的資料
paginate = User.query.paginate(page, per_page,Error_out)
paginate = User.query.paginate(2,3,False)
page: 哪一個頁
per_page: 每頁多少條資料
Error_out: False 查不到不報錯

paginate .pages: 共有多少頁
paginate .items: 當前頁數的所有物件
paginate .page: 當前頁

sqlalchemy查詢常見的過濾方式

sqlalchemy查詢常見的過濾方式
filter過濾條件：
過濾是資料提取的一個很重要的功能，以下對一些常用的過濾條件進行解釋，並且這些過濾條件都是隻能通過filter方法實現的：
1. equals ： ==
    news= session.query(News).filter(News.title == "title1").first()
    query裡面是列查詢，欄位，傳入模型名錶示全欄位 。
    filter是行查詢，沒有filter表示全表查詢
2. not equals  :  !=
    query(User).filter(User.name != 'ed')

3. like[不區分大小寫]  & ilike[區分大小寫]：
    query(User).filter(User.name.like('%ed%··')) 
 query(User).filter(User.name.like('__ed%__')) _表示站位符

4. in：
    query(User).filter(User.name.in_(['ed','wendy','jack']))

5. not in：
    query(User).filter(~User.name.in_(['ed','wendy','jack']))

6.  is null：
    query(User).filter(User.name==None)
    # 或者是
    query(User).filter(User.name.is_(None))

7. is not null:
    query(User).filter(User.name != None)
    # 或者是
    query(User).filter(User.name.isnot(None))

8. and：
    query(User).filter(and_(User.name=='ed',User.fullname=='Ed Jones'))
    # 或者是傳遞多個引數
    query(User).filter(User.name=='ed',User.fullname=='Ed Jones')
    # 或者是通過多次filter操作
    query(User).filter(User.name=='ed').filter(User.fullname=='Ed Jones')

9. or：
    query(User).filter(or_(User.name=='ed',User.name=='wendy'))

如果想要檢視orm底層轉換的sql語句，可以在filter方法後面不要再執行任何方法直接列印就可以看到了。比如：
        news = session.query(News).filter(or_(News.title=='abc',News.content=='abc'))
        print(news)