Python??Flask框架操作數(shù)據(jù)庫的方法

更新時間：2024年02月01日 14:37:50 作者：程序猿知秋

Flask中最方便用的數(shù)據(jù)庫框架是flask_sqlalchamy,是對?SQLAlchamy?在?Flask?中的擴(kuò)展,它主要在于簡化Flask?中?sqlalchamy的使用,本篇文章給大家介紹Python??Flask的數(shù)據(jù)庫操作使用方法,感興趣的朋友一起看看吧

簡介

SQLAlchamy 是 Python 中一個通過 ORM 操作數(shù)據(jù)庫的框架

SQLAlchemy（對象關(guān)系映射器）提供了一種方法，用于將用戶定義的Python類與數(shù)據(jù)庫表相關(guān)聯(lián)，并將這些類（對象）的實(shí)例與其對應(yīng)表中的行相關(guān)聯(lián)。

簡單理解： 創(chuàng)建一個類，一個類對應(yīng)了一個數(shù)據(jù)庫中的一張表，類的屬性名對應(yīng)了表中的字段名，這個類稱為映射類

SQLAlchemy本身無法操作數(shù)據(jù)庫，其必須使用 pymsql 等第三方插件，從而實(shí)現(xiàn)對數(shù)據(jù)庫的操作，如：mysql數(shù)據(jù)庫

mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]

使用

flask_sqlalchamy

Flask 中最方便用的數(shù)據(jù)庫框架是 flask_sqlalchamy，是對 SQLAlchamy 在 Flask 中的擴(kuò)展，它主要在于簡化Flask 中 sqlalchamy的使用

安裝

pip install flask_sqlalchemy

初始化

為了方便管理數(shù)據(jù)庫相關(guān)的配置項(xiàng)，flask_sqlalchamy 中采用app.config進(jìn)行相關(guān)屬性配置

配置變量的名稱必須使用大寫，寫入配置的語句一般會放到擴(kuò)展類實(shí)例化語句之前

配置項(xiàng)	說明
SQLALCHEMY_DATABASE_URI	數(shù)據(jù)庫的鏈接地址
SQLALCHEMY_BINDS	訪問多個數(shù)據(jù)庫時，用于設(shè)置數(shù)據(jù)庫鏈接池地址
SQLALCHEMY_ECHO	是否打印底層執(zhí)行的SQL語句
SQLALCHEMY_RECORD_QUERIES	是否記錄執(zhí)行的查詢語句，用于慢查詢分析
SQLALCHEMY_TRACK_MODIFICATIONS	是否追蹤數(shù)據(jù)庫變化
SQLALCHEMY_ENGINE_OPTIONS	設(shè)置針對 sqlalchemy本體的配置項(xiàng)

設(shè)置數(shù)據(jù)庫鏈接

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
# 設(shè)置數(shù)據(jù)庫鏈接地址
app.config['SQLALCHEMY_DATABASE_URI']='mysql+pymysql://root:123456@127.0.0.1:3306/test'
# 設(shè)置顯示底層執(zhí)行的sql語句
app.config['SQLALCHEMY_ECHO'] = True
# 初始化組件對象，關(guān)聯(lián)flask應(yīng)用
db = SQLAlchemy(app)

構(gòu)建模型

模型簡單來說就是數(shù)據(jù)庫中的一張表定義，需要有名稱，字段，在 Python 中用一個類來表示，由于需要和數(shù)據(jù)庫的表對應(yīng)，模型必須繼承自 SQLAlchamy 的 Model 類

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import datetime
app = Flask(__name__)
# 設(shè)置數(shù)據(jù)庫鏈接地址
app.config['SQLALCHEMY_DATABASE_URI']='mysql+pymysql://root:123456@127.0.0.1:3306/test'
# 設(shè)置顯示底層執(zhí)行的sql語句
app.config['SQLALCHEMY_ECHO'] = True
# 初始化組件對象，關(guān)聯(lián)flask應(yīng)用
db = SQLAlchemy(app)
# 構(gòu)建模型類
class User(db.Model):
    # 設(shè)置表名，表名默認(rèn)為類名小寫
    __tablename__ = 'user'
    id = db.Column(db.Integer,primary_key=True)   # 設(shè)置主鍵，默認(rèn)自增
    name = db.Column(db.String(20))
    age = db.Column(db.Integer,default=20)  #設(shè)置默認(rèn)值
    createtime=db.Column(db.DateTime())
    def __repr__(self):  # 自定義 交互模式 & print() 的對象打印
      return "(%s, %s, %s, %s)" % (self.id, self.name, self.age,self.createtime)
if __name__ == '__main__':
    app.run(debug=True)

__repr__ 方法定義了一個對象的比較易讀的顯式方式

常用字段類

字段類型	說明
db.Integer	整數(shù)
db.String(size)	字符串 size 為字符串長度
db.DateTime	日期時間
db.Date	日期
db.Text	長文本，可以存放 CLOB (二進(jìn)制數(shù)據(jù))
db.Float	浮點(diǎn)數(shù)字
db.Boolean	布爾值

常用字段選項(xiàng)

字段類型	說明
primary_key	設(shè)置表的主鍵，默認(rèn)自增
unique	設(shè)置唯一索引
nullable	非空約束
default	設(shè)置默認(rèn)值
index	創(chuàng)建索引

創(chuàng)建庫表

@app.route("/initDB")
def init_db():
    # 刪除所有繼承睡在db.Model的表
    db.drop_all()
    # 創(chuàng)建所有繼承自 db.Model的表
    db.create_all()
    return "initdb"

注：db.drop_all() 和 db.create_all() 放在 main中不啟作用，所以單獨(dú)寫一個方法進(jìn)行初始化。

一般庫表的創(chuàng)建與應(yīng)用都是分開的，單獨(dú)創(chuàng)建庫表，沒必要將此類語句寫在應(yīng)用中

數(shù)據(jù)操作

增加數(shù)據(jù)

@app.route("/add")
def add():
    # 添加數(shù)據(jù)
    user1 = User(name='zhao', age=33, createtime=datetime.datetime.now())
    # 將模型添加到會話中
    db.session.add(user1)
    # 添加多條記錄
    # db.session.add_all([user1,user2,user3])
    # 提交會話， sqlalchemy會自動創(chuàng)建隱式事務(wù)，失敗會自動回滾
    db.session.commit()
    return "add"

注：

sqlalchemy會自動創(chuàng)建事務(wù)，并將數(shù)據(jù)的操作都包含在一個事務(wù)中，提交會話就會提交事務(wù)
session 是一個與數(shù)據(jù)庫通信的會話，是 SQLAlchamy 框架與數(shù)據(jù)庫交互的代理
可以調(diào)用 session.rollback() 回滾掉未提交的變化

查詢數(shù)據(jù)

簡單查詢

@app.route("/query")
def query():
    # 查詢所有用戶數(shù)據(jù), 返回User列表,
    data = User.query.all()
    for item in data:
        print(item.name,item.age)
    # 查詢有多少個用戶，返回結(jié)果數(shù)
    data = User.query.count()
    print(data)
    # 查詢第1個用戶 ， 返回User對象
    data = User.query.first()
    print(data)
    # 查詢id為4的用戶， 返回User對象
    data = User.query.get(4)
    print(data)
    return "query"

條件過濾查詢

@app.route("/query2")
def query2():
    # 查詢 name 等于 zhao 的記錄集中第一條記錄
    data = User.query.filter(User.name =='zhao').first()
    # 查詢 name 不等于 zhao 的所有記錄
    data = User.query.filter(User.name != 'zhao').all()
    # 前模糊查詢
    data = User.query.filter(User.name.like("%zhao")).all()
    print(data)
    # 查詢名字以 zhao 開頭的用戶
    data = User.query.filter(User.name.startswith('zhao')).all()
    # 查詢名字是 zhao，并且年齡是22歲的用戶
    from sqlalchemy import and_
    data = User.query.filter(and_(User.name=='zhao', User.age==22)).all()
    # 查詢名字是 zhao或者h(yuǎn)ong的用戶
    from sqlalchemy import or_
    data = User.query.filter(or_(User.name=='zhao', User.name=='hong')).all()
    # 查詢id為[1, 2, 3]的用戶
    data = User.query.filter(User.id.in_([1, 2, 3])).all()
    # 分頁查詢
    # 所有用戶先按年齡從小到大, 再按id從大到小排序, 取前5個
    data = User.query.order_by(User.age, User.id.desc()).limit(5).all()
    # 分頁查詢, 每頁1個, 查詢第2頁的數(shù)據(jù)  paginate(頁碼, 每頁條數(shù))
    pn = User.query.paginate(page=2, per_page=1)
    print("總頁數(shù):"+str(pn.pages)+" 當(dāng)前頁碼:"+str(pn.page)+"當(dāng)前頁的數(shù)據(jù)："+ str(pn.items)+" 總條數(shù):"+str(pn.total))
    # 分組查詢
    # 查詢每個年齡的人數(shù)    select age, count(name) from t_user group by age  分組聚合
    from sqlalchemy import func
    data = db.session.query(User.age, func.count(User.id).label("count")).group_by(User.age).all()
    return "query2"

常用查詢方法

方法名稱	說明
all()	返回所有查詢記錄的列表
first()	返回查詢的第一條記錄，如果未找到，則返回None
get(id)	傳入主鍵值作為參數(shù)，返回指定主鍵值的記錄，如果未找到，則返回None
count()	返回查詢結(jié)果的數(shù)量
paginate（)	返回一個Pagination對象，可以對記錄進(jìn)行分頁處理

更新數(shù)據(jù)

@app.route("/update")
def update():
    # 更新用戶年齡為44，條件是：用戶名=zhao
    # 相當(dāng)于：update user set age = 44 where name = 'zhao';
    User.query.filter(User.name == 'zhao').update({'age': 44})
    # 提交會話
    db.session.commit()
    return "update"

刪除數(shù)據(jù)

@app.route("/del")
def delete():
    # 刪除id=1的用戶
    # 相當(dāng)于：delete from user where id=1
    User.query.filter(User.id == 1).delete()
    # 提交會話
    db.session.commit()
    return "del"

多表關(guān)聯(lián)查詢

連接查詢

開發(fā)中有聯(lián)表查詢需求時, 一般會使用 join連接查詢

db.session.query(主表模型字段1, 主表模型字段2, 從表模型字段1, xx.. ).join(從表模型類, 主表模型類.主鍵 == 從表模型類.外鍵)

示例

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import datetime
app = Flask(__name__)
# 設(shè)置數(shù)據(jù)庫鏈接地址
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:123456@127.0.0.1:3306/test'
# 設(shè)置顯示底層執(zhí)行的sql語句
app.config['SQLALCHEMY_ECHO'] = True
# 初始化組件對象，關(guān)聯(lián)flask應(yīng)用
db = SQLAlchemy(app)
# 構(gòu)建模型類
class User(db.Model):
    # 設(shè)置表名，表名默認(rèn)為類名小寫
    __tablename__ = 'user'
    id = db.Column(db.Integer, primary_key=True)  # 設(shè)置主鍵，默認(rèn)自增
    name = db.Column(db.String(20))
    age = db.Column(db.Integer, default=20)  # 設(shè)置默認(rèn)值
    createtime = db.Column(db.DateTime())
    def __repr__(self):  # 自定義 交互模式 & print() 的對象打印
        return "(%s, %s, %s, %s)" % (self.id, self.name, self.age, self.createtime)
class Address(db.Model):
    __tablename__ = 'address'
    id = db.Column(db.Integer, primary_key=True)
    detail = db.Column(db.String(20))
    user_id = db.Column(db.Integer)  # 定義外鍵
if __name__ == '__main__':
    app.run(debug=True)
@app.route("/")
def index():
    return "index"
@app.route("/query")
def query():
    """ 查詢多表數(shù)據(jù)  需求: 查詢姓名為"hong" 的用戶id和地址信息"""
    # sqlalchemy的join查詢
    # 相當(dāng)于：SELECT user.id AS user_id, address.detail AS address_detail
    #           FROM user INNER JOIN address ON user.id = address.user_id
    data = db.session.query(User.id, Address.detail).join(Address, User.id == Address.user_id).filter(
        User.name == 'hong').all()
    for item in data:
        print(item.detail, item.id)
    return "query"

到此這篇關(guān)于Python Flask的數(shù)據(jù)庫操作的文章就介紹到這了,更多相關(guān)Python Flask操作數(shù)據(jù)庫內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: