flask-sqlalchemy

配置和鏈接

  • 安裝 pip install flask-sqlalchemy
    • ModuleNotFoundError: No module named 'MySQLdb' : pip install mysqlclient

建立鏈接

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
# 設置數據庫的鏈接地址
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@127.0.0.1:3306/test28'
# 設置是否追蹤數據庫變化   通常不會開啓, 影響性能
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
# 設置是否打印底層執行的SQL語句
app.config['SQLALCHEMY_ECHO'] = True

# 建立數據庫鏈接對象
db = SQLAlchemy(app)

# 類->表  類屬性->字段  對象->記錄
class User(db.Model):
    __tablename__ = 't_user'  # 設置表名, 表名默認爲類名小寫
    id = db.Column(db.Integer, primary_key=True)  # 主鍵, 默認自增
    name = db.Column(db.String(20), unique=True)  # 設置惟一
    age = db.Column(db.Integer)


@app.route('/')
def index():
    """增長數據"""
    # sqlalchemy會自動建立一個隱式事務, 並將sql操做添加到事務中

    # 建立模型對象
    user1 = User(name='zs', age=20)
    # user1.name = 'zs'  # 另外一種設置數據的方式

    # 將對象添加到會話中 轉換對應的sql語句
    db.session.add(user1)
    # db.session.add_all([user1, user2, user3])  # 批量添加數據

    # 提交會話    就會提交事務, 並且事務失敗會自動回滾
    db.session.commit()

    return "index"


if __name__ == '__main__':
    # 刪除全部繼承自db.Model的表
    db.drop_all()
    # 建立全部繼承自db.Model的表
    db.create_all()
    app.run(debug=True)

增長數據

查詢數據

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
# 設置數據庫鏈接地址
app.config["SQLALCHEMY_DATABASE_URI"] = "mysql://root:mysql@127.0.0.1:3306/test28"
# 設置是否跟蹤數據庫改變
app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = False
app.config["SQLALCHEMY_ECHO"] = True
# 建立數據庫鏈接
db = SQLAlchemy(app)

# 自定義類 繼承db.Model  對應 表
class User(db.Model):
    __tablename__ = "users"  # 表名 默認使用類名的小寫
    # 定義類屬性 記錄字段
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64))
    email = db.Column(db.String(64))
    age = db.Column(db.Integer)

    def __repr__(self):  # 自定義 交互模式 & print() 的對象打印
        return "(%s, %s, %s, %s)" % (self.id, self.name, self.email, self.age)


@app.route('/')
def index():
    """
    查詢全部用戶數據
    User.query.all()  返回列表,裏邊包含的是數據對象

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

    查詢第1個用戶
    User.query.first()  返回對象

    查詢id爲4的用戶[3種方式]
    User.query.get(4)  # 根據id查詢  返回對象

    BaseQuery類型 容許續接其餘具體的查詢條件 如all/first/count等
    User.query.filter_by(id=4).all()  # 簡單查詢器  關鍵字實參的方式來匹配字段  返回BaseQuery對象
    User.query.filter(User.id==4).first()  # 複雜查詢器  恆等式/函數形式來匹配   返回BaseQuery對象

    查詢名字結尾字符爲g的全部用戶[開始 / 包含]
    User.query.filter(User.name.endswith('g')).all()
    User.query.filter(User.name.startswith('w')).all()
    User.query.filter(User.name.contains('n')).all()
    User.query.filter(User.name.like('w%n%g')).all()  # 模擬查詢

    查詢名字和郵箱都以li開頭的全部用戶[2種方式]
    User.query.filter(User.name.startswith('li'), User.email.startswith('li')).all()
    from sqlalchemy import and_
    User.query.filter(and_(User.name.startswith('li'), User.email.startswith('li'))).all()

    查詢age是25 或者 `email`以`itheima.com`結尾的全部用戶
    from sqlalchemy import or_
    User.query.filter(or_(User.age==25, User.email.endswith("itheima.com"))).all()

    查詢名字不等於wang的全部用戶[2種方式]
    from sqlalchemy import not_
    User.query.filter(not_(User.name=='wang')).all()
    User.query.filter(User.name!='wang').all()

    查詢id爲[1, 3, 5, 7, 9]的用戶
    User.query.filter(User.id.in_([1, 3, 5, 7, 9])).all()

    全部用戶先按年齡從小到大, 再按id從大到小排序, 取前5個
    User.query.order_by(User.age, User.id.desc()).limit(5).all()

    查詢年齡從小到大第2-5位的數據
    User.query.order_by(User.age).offset(1).limit(4).all()

    分頁查詢, 每頁3個, 查詢第2頁的數據
    pn = User.query.paginate(2, 3)
    pn.pages 總頁數 pn.page 當前頁數  pn.items 當前頁的數據

    查詢每一個年齡的人數    select age, count(name) from t_user group by age  分組聚合
    from sqlalchemy import func
    db.session.query(User.age, func.count(User.name)).group_by(User.age).all()

    只查詢全部人的姓名和郵箱  優化查詢   默認使用select *
    from sqlalchemy.orm import load_only
    users = User.query.options(load_only(User.name, User.email)).all()  # 返回對象列表
    # for user in users:
    #     print(user.name, user.email)

    data = db.session.query(User.name, User.email).all()  # 返回元組列表

    """
    return 'index'


if __name__ == '__main__':
    # 刪除全部表
    db.drop_all()
    # 建立全部表
    db.create_all()
    # 添加測試數據
    user1 = User(name='wang', email='wang@163.com', age=20)
    user2 = User(name='zhang', email='zhang@189.com', age=33)
    user3 = User(name='chen', email='chen@126.com', age=23)
    user4 = User(name='zhou', email='zhou@163.com', age=29)
    user5 = User(name='tang', email='tang@itheima.com', age=25)
    user6 = User(name='wu', email='wu@gmail.com', age=25)
    user7 = User(name='qian', email='qian@gmail.com', age=23)
    user8 = User(name='liu', email='liu@itheima.com', age=30)
    user9 = User(name='li', email='li@163.com', age=28)
    user10 = User(name='sun', email='sun@163.com', age=26)

    # 一次添加多條數據
    db.session.add_all([user1, user2, user3, user4, user5, user6, user7, user8, user9, user10])
    db.session.commit()
    app.run(debug=True)

更新和刪除數據

@app.route('/')
def index():
    """更新數據"""
    # 方式1: 先查詢數據, 再更新數據
    # user = User.query.filter_by(name='zs').first()
    # user.age = 30
    # 提交會話
    # db.session.commit()

    # 方式2: update子查詢    update t_order set count=count-1 where count > 0;
    # User.query.filter_by(name='zs').update({'age': 30})
    # 提交會話
    # db.session.commit()

    """刪除數據"""
    # 方式1: 先查詢數據, 再刪除數據
    # user = User.query.filter_by(name='zs').first()
    # db.session.delete(user)
    # db.session.commit()

    # 方式2: delete子查詢
    User.query.filter_by(name='zs').delete()
    # 提交會話
    db.session.commit()

    return "index"
相關文章
相關標籤/搜索