python中的flask_sqlalchemy的使用及示例詳解
@orm.reconstructor
sqlalchemy創(chuàng)建實(shí)例的時(shí)候并不是像我們普通通過構(gòu)造函數(shù)這樣創(chuàng)建的方式來(lái)創(chuàng)建的， 而是通過元類的方式動(dòng)態(tài)的創(chuàng)建實(shí)例對(duì)象。在python里面絕大多數(shù)的ORM都是通過元類的方式來(lái)創(chuàng)建對(duì)象，而不是通過普通實(shí)例化方式來(lái)創(chuàng)建的。那么通過元類的方式創(chuàng)建至少在sqlalchemy里面是不會(huì)通過構(gòu)造函數(shù)來(lái)創(chuàng)建的。
如果我們就想在模型對(duì)象實(shí)例化的時(shí)候執(zhí)行__init__，我們就需要用到sqlalchemy比較高級(jí)的機(jī)制，通過下面的官方文檔我們知道是明確不會(huì)執(zhí)行__init__的
但是可以通過裝飾器來(lái)解決，如果我們?cè)赺_init__打上這個(gè)裝飾器，那么在模型對(duì)象實(shí)例化的時(shí)候，sqlalchemy就會(huì)去執(zhí)行被打上裝飾器這樣的方法，
我們需要先導(dǎo)入orm
上圖如果報(bào)錯(cuò)就使用下面的代碼
或者
或者
db = SQLAlchemy(app)需要注意app對(duì)象能不能在當(dāng)前.py文件中獲取到
sqlalchemy會(huì)嘗試為我們創(chuàng)建一個(gè)Base表，但是我們不需要他幫我們創(chuàng)建這個(gè)數(shù)據(jù)表，因?yàn)槲覀兊腂ase是基類，是為了讓所有的子類繼承的，從而實(shí)現(xiàn)軟刪除（通過狀態(tài)來(lái)標(biāo)注數(shù)據(jù)是否可用，進(jìn)而達(dá)到刪除的目的）
只需要加入__abstract__=True
這樣sqlalchemy就不會(huì)認(rèn)為你要?jiǎng)?chuàng)建的是這樣的表了
這里補(bǔ)充說明一下，類是可以多繼承的。
#!/usr/bin/python
# -*- coding: UTF-8 -*-
# *************************************
# author: jenrey
# create: 2019/1/27 22:29
# filename: user.py
# usage:測(cè)試SQLAlchemy
#
#
# *************************************
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
from sqlalchemy import Column, Integer, String
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:root@localhost:3306/sqlalchemy' # 用于連接數(shù)據(jù)庫(kù)
app.config[
'SQLALCHEMY_TRACK_MODIFICATIONS'] = True # 如果設(shè)置成True(默認(rèn)情況)，F(xiàn)lask-SQLAlchemy 將會(huì)追蹤對(duì)象的修改并且發(fā)送信號(hào)。這需要額外的內(nèi)存， 如果不必要的可以禁用它。如果你不顯示的調(diào)用它，在最新版的運(yùn)行環(huán)境下，會(huì)顯示警告。
db = SQLAlchemy(app) # 注意這里要寫app，因?yàn)闆]有通過請(qǐng)求訪問的話是會(huì)報(bào)一個(gè)找不到上下文對(duì)象的錯(cuò)誤的，而且不能采用上面是的三種方式。原因不詳
class User(db.Model):
# __tablename__ = 'Hehe' # 指定表名，不寫默認(rèn)就是類名
id = Column(Integer, primary_key=True, autoincrement=True)
name = Column(String(50), nullable=False)
age = Column(Integer, default=18)
def __init__(self, id, name, age):
self.id = id
self.name = name
self.age = age
def __str__(self): # print(實(shí)例對(duì)象)
return "heihie"
def __repr__(self): # print(repr(實(shí)例對(duì)象))
return "hehe"
db.init_app(app)
db.create_all() # https://blog.csdn.net/JENREY/article/details/86607343
u1 = User(123, 'wangwu', 99) # 也可以不寫def __init__(self)方法，傳入值就需要指定u1 = User(id=123, name='wangwu')
db.session.add(u1)
db.session.commit()
if __name__ == '__main__':
app.run()
# pass
SQLAlchemy的回滾
上面的代碼可以看出我們是沒有進(jìn)行事務(wù)的操作的，但是SQLAlchemy天然的是支持事務(wù)的，所以我們?cè)赾ommit之前的代碼都不會(huì)被真正的執(zhí)行添加到數(shù)據(jù)庫(kù)中的。但是上面代碼還是有問題的，我們是沒有進(jìn)行數(shù)據(jù)的回滾（rollback）
為什么一定要執(zhí)行db.session.rollback()，是因?yàn)槿绻覀兊某绦驁?zhí)行到db.session.commit()這里出現(xiàn)了錯(cuò)誤，又沒有執(zhí)行rollback的話，那么不僅僅是這次的插入失敗了，后續(xù)的其他操作SQLAlchemy也是會(huì)失敗的。所以建議大家一定要回滾起來(lái)！
所以以后只要使用db.session.commit()就一定要用try except給包裹起來(lái)并在except里面執(zhí)行db.session.rollback()
關(guān)聯(lián)其他模型
數(shù)據(jù)庫(kù)基本操作
在Flask-SQLAlchemy中，插入、修改、刪除操作，均由數(shù)據(jù)庫(kù)會(huì)話管理。會(huì)話用db.session表示。在準(zhǔn)備把數(shù)據(jù)寫入數(shù)據(jù)庫(kù)前，要先將數(shù)據(jù)添加到會(huì)話中然后調(diào)用commit()方法提交會(huì)話。
數(shù)據(jù)庫(kù)會(huì)話是為了保證數(shù)據(jù)的一致性，避免因部分更新導(dǎo)致數(shù)據(jù)不一致。提交操作把會(huì)話對(duì)象全部寫入數(shù)據(jù)庫(kù)，如果寫入過程發(fā)生錯(cuò)誤，整個(gè)會(huì)話都會(huì)失效。
數(shù)據(jù)庫(kù)會(huì)話也可以回滾，通過db.session.rollback()方法，實(shí)現(xiàn)會(huì)話提交數(shù)據(jù)前的狀態(tài)。
在Flask-SQLAlchemy中，查詢操作是通過query對(duì)象操作數(shù)據(jù)。最基本的查詢是返回表中所有數(shù)據(jù)，可以通過過濾器進(jìn)行更精確的數(shù)據(jù)庫(kù)查詢。
將數(shù)據(jù)添加到會(huì)話中示例：
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ù)庫(kù)的URL
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@127.0.0.1:3306/Flask_test'
#設(shè)置每次請(qǐng)求結(jié)束后會(huì)自動(dòng)提交數(shù)據(jù)庫(kù)中的改動(dòng)
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
#查詢時(shí)會(huì)顯示原始SQL語(yǔ)句
app.config['SQLALCHEMY_ECHO'] = True
db = SQLAlchemy(app)
class Role(db.Model):
# 定義表名
__tablename__ = 'roles'
# 定義列對(duì)象
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ù)指定條件對(duì)原查詢結(jié)果進(jìn)行排序，返回一個(gè)新查詢 group_by() 根據(jù)指定條件對(duì)原查詢結(jié)果進(jìn)行分組，返回一個(gè)新查詢
常用的SQLAlchemy查詢執(zhí)行器
方法 說明 all() 以列表形式返回查詢的所有結(jié)果 first() 返回查詢的第一個(gè)結(jié)果，如果未查到，返回None first_or_404() 返回查詢的第一個(gè)結(jié)果，如果未查到，返回404 get() 返回指定主鍵對(duì)應(yīng)的行，如不存在，返回None get_or_404() 返回指定主鍵對(duì)應(yīng)的行，如不存在，返回404 count() 返回查詢結(jié)果的數(shù)量 paginate() 返回一個(gè)Paginate對(duì)象，它包含指定范圍內(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è)對(duì)象
User.query.first()
all()返回查詢到的所有對(duì)象
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)系是一對(duì)多的關(guān)系，一個(gè)角色可以有多個(gè)用戶，一個(gè)用戶只能屬于一個(gè)角色。
查詢角色的所有用戶：
#查詢r(jià)oles表id為1的角色 ro1 = Role.query.get(1) #查詢?cè)摻巧乃杏脩? ro1.us
查詢用戶所屬角色：
?#查詢users表id為3的用戶 us1 = User.query.get(3) #查詢用戶屬于什么角色 us1.role
到此這篇關(guān)于python中的flask_sqlalchemy的使用及示例詳解的文章就介紹到這了,更多相關(guān)python flask_sqlalchemy使用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
- python flask sqlalchemy連接數(shù)據(jù)庫(kù)流程介紹
- Python?flask?sqlalchemy的簡(jiǎn)單使用及常用操作
- Python使用Flask-SQLAlchemy連接數(shù)據(jù)庫(kù)操作示例
- Python利用flask sqlalchemy實(shí)現(xiàn)分頁(yè)效果
- Python的Flask框架中使用Flask-SQLAlchemy管理數(shù)據(jù)庫(kù)的教程
- 在Python程序和Flask框架中使用SQLAlchemy的教程
- Python的Flask框架中SQLAlchemy使用時(shí)的亂碼問題解決
相關(guān)文章
python實(shí)現(xiàn)數(shù)通設(shè)備tftp備份配置文件示例
這篇文章主要介紹了python實(shí)現(xiàn)數(shù)通設(shè)備tftp備份配置文件示例,需要的朋友可以參考下2014-04-04
在本篇文章里小編給大家整理了關(guān)于python中rc1的基礎(chǔ)知識(shí)點(diǎn)內(nèi)容，需要的朋友們可以學(xué)習(xí)下。2020-06-06
python?針對(duì)在子文件夾中的md文檔實(shí)現(xiàn)批量md轉(zhuǎn)word
這篇文章主要介紹了python?針對(duì)在子文件夾中的md文檔實(shí)現(xiàn)批量md轉(zhuǎn)word，但是自己保存的md文檔在不同的文件夾，而大部分只能實(shí)現(xiàn)同一文件夾內(nèi)的轉(zhuǎn)換，得出下列總結(jié),需要的朋友可以參考一下2022-04-04
這篇文章主要介紹了linux下python抓屏實(shí)現(xiàn)方法,涉及Python操作屏幕截取的相關(guān)技巧,需要的朋友可以參考下2015-05-05
這篇文章主要介紹了Python解決八皇后問題,簡(jiǎn)單描述了八皇后問題的原理并結(jié)合實(shí)例形式分析了Python基于遞歸算法解決八皇后問題的相關(guān)操作技巧,需要的朋友可以參考下2018-04-04
這篇文章主要介紹了python 三種方法提取pdf中的圖片，幫助大家更好的理解和使用python，感興趣的朋友可以了解下2021-02-02
python裝飾器類方法classmethod的使用場(chǎng)景
這篇文章主要為大家介紹了python裝飾器類方法classmethod的使用場(chǎng)景，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-06-06
python爬蟲 批量下載zabbix文檔代碼實(shí)例
這篇文章主要介紹了python爬蟲 批量下載zabbix文檔代碼實(shí)例,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-08-08
Django對(duì)接elasticsearch實(shí)現(xiàn)全文檢索的示例代碼
搜索是很常用的功能，如果是千萬(wàn)級(jí)的數(shù)據(jù)應(yīng)該怎么檢索，本文主要介紹了Django對(duì)接elasticsearch實(shí)現(xiàn)全文檢索的示例代碼，感興趣的可以了解一下2021-08-08
這篇文章主要介紹了python自動(dòng)下載圖片的方法示例，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-03-03