Flask入門資料庫框架flask-SQLAlchemy(十)

来源:https://www.cnblogs.com/why957/archive/2018/06/05/9137936.html
-Advertisement-
Play Games

​ Web程式開發中最重要的莫過於關係型資料庫,即SQL 資料庫,另外文檔資料庫（如 mongodb）、鍵值對資料庫（如 redis）慢慢變得流行. 原因 : 我們不直接使用這些資料庫引擎提供的 Python 包，而是使用對象關係映射（Object Relational Mapper, ORM）框架 ...


​ Web程式開發中最重要的莫過於關係型資料庫,即SQL 資料庫,另外文檔資料庫（如 mongodb）、鍵值對資料庫（如 redis）慢慢變得流行.

原因 : 我們不直接使用這些資料庫引擎提供的 Python 包，而是使用對象關係映射（Object-Relational Mapper, ORM）框架，是因為它將低層的資料庫操作指令抽象成高層的面向對象操作。也就是說，如果我們直接使用資料庫引擎，我們就要寫 SQL 操作語句，但是，如果我們使用了 ORM 框架，我們對諸如表、文檔此類的資料庫實體就可以簡化成對 Python 對象的操作。

(1) Flask - SQLAlchemy

Flask使用的ORM框架為 SQLAlchemy,資料庫採用了URL指定,下麵我們列舉幾種資料庫引擎:

資料庫引擎 URL指定
MySQL mysql://username:password@hostname/database
Postgres postgresql://username:password@hostname/database
SQLite (Unix) sqlite:////absolute/path/to/database
SQLite (Windows) sqlite:///c:/absolute/path/to/database

註意:

  1. username 和 password 表示登錄資料庫的用戶名和密碼
  2. hostname 表示 SQL 服務所在的主機，可以是本地主機（localhost）也可以是遠程伺服器
  3. database 表示要使用的資料庫 , SQLite 資料庫不需要使用伺服器，它使用硬碟上的文件名作為 database

ORM使用的優點:

  1. 增加少sql的重覆使用率
  2. 使表更加的可讀性
  3. 可移植性

(2) SQLAlchemy操作sql原生

安裝操作資料庫的模塊

pip3 install pymysql

安裝 flask-sqlalchemy

sudo pip3 install flask-sqlalchemy

配置路徑

DB_URI = 'mysql+pymysql://root:password@host:port/database'

下麵先看下sqlalchemy操作的寫法：

from sqlalchemy import create_engine

HOST = '127.0.0.1'
USERNAME = 'root'
PASSWORD = '123456'
DATABASE = 'demo'  #資料庫名
PORT = 3306
DB_URI = 'mysql+pymysql://{}:{}@{}:{}/{}'.format(USERNAME,PASSWORD,HOST,PORT,DATABASE)
#創建引擎
engine = create_engine(DB_URI)

with engine.connect() as db:
    data = db.execute('select * from user') #從user表中獲取全部數據
    db.execute('delete from user where id=1')  #刪除id=1的數據

(3) 設計數據表

1 欄位類型

類型名 python中的類型 說明
Integer int 存儲整形 32位
SmallInteger int 小整形 16為
BigInteger int 大整形
Float float 浮點數
String str 字元串 varchar
Text str 長文本
Boolean bool bool值
Date datetimedate 日期
Time datetime.time 時間
datetime datetime.datetime 時間日期

2 可選條件

選項 說明
primary_key 主鍵, 如果設為True，表示主鍵
unique 唯一索引 ,如果設為True，這列唯一
index 常規索引, 如果設為True，創建索引，提升查詢效率
nullable 是否可以為null 預設True
default 預設值

（4）在flask中使用ORM模型

下麵我們使用ORM模型

from flask import Flask
from flask_script import Manager
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:[email protected]:3306/demo'
db = SQLAlchemy(app)  #

manager = Manager(app)

#創建User用戶，表名為user
class User(db.Model):
    __table__name = 'user'
    id = db.Column(db.Integer,primary_key=True)
    username = db.Column(db.String(20),index=True)
    sex = db.Column(db.Boolean,default=True)
    info = db.Column(db.String(50))

# 定義一個視圖函數
@app.route('/create')
def create():
    # db.drop_all()  #刪除僅為模型表
    db.create_all()  #創建模型表
    return '創建成功'

if __name__ == '__main__':
    manager.run()

（5）增加數據

添加數據方式1

#方式1
# sqlalchemy預設開啟了事務處理
@app.route('/insert/')
def insert():
    try:
        u = User(username='WANGWU',info='personal WANGWU message')
        db.session.add(u)  #添加數據對象
        db.session.commit()  #事務提交
    except:
        db.session.rollback()#事務回滾
    return '添加單條數據!'

@app.route('/insertMany/')
def insertMany():
    u1 = User(username='name1',info='personal name1 message')
    u2 = User(username='name2',info='personal name2 message')
    db.session.add_all([u1,u2]) #以add_all(數據對象列表)
    db.session.commit() #
    return '添加多條數據！'

添加數據方式2

#方式2
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True  #在app設置里開啟自動提交
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False  #關閉數據追蹤，避免記憶體資源浪費

@app.route('/insertMany/')
def insertMany():
    u1 = User(username='name1',info='personal name1 message')
    u2 = User(username='name2',info='personal name2 message')
    db.session.add_all([u1,u2])
    return '提交多條數據'

（6）更新與刪除

# 類名.query  返回對應的查詢集
# 類名.query.get(查詢條件)  返回對應的查詢對象
@app.route('/update/')
def update():
    u = User.query.get(1)
    u.username = 'update name'  #更新內容
    db.session.add(u)   #進行添加
    return 'update'

# 刪除數據
@app.route('/delete/')
def delete():
    u = User.query.get(2)  #找到對應的查詢集對象
    db.session.delete(u)  # 刪除對應的u對象
    return 'delete id=2'

(7) 拆分MVT

目錄結構

project/
    manage.py  #啟動項存放
    ext.py  #作為當前sqlalchemy擴展
    settings.py  #配置存放
    app/
        __init__.py
        models.py  #應用models.py
        views.py   #應用視圖views.py
    templates/     #模板目錄
    static/  #靜態文件目錄

ext.py SQLAlchemy擴展

from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy()   #實例化db對象

藍本view view.py視圖函數

from flask import Blueprint
from .models import User
from ext import db
#創建藍本view
view = Blueprint('view',__name__)
#定義視圖函數
@view.route('/')
def index():
    return 'index'

@view.route('/insert/')
def insert():
    u = User(username='張三',info='個人信息')
    db.session.add(u)
    return 'insert success'

藍本view models.py模型類

from ext import db  #導入db
#構建User模型類
class User(db.Model,Base):
    __table__name = 'user'
    id = db.Column(db.Integer,primary_key=True)
    username = db.Column(db.String(20),index=True)
    sex = db.Column(db.Boolean,default=True)
    info = db.Column(db.String(50))

manage.py啟動項

from flask import Flask
from flask_script import Manager
from ext import db
import settings
from app.view import view

app = Flask(__name__)
#將系統配置項Config類載入到app
app.config.from_object(settings.Config)
#通過db對象將app初始化
db.init_app(app)
#將藍圖view註冊進app
app.register_blueprint(view)
manager = Manager(app)

if __name__ == '__main__':
    manager.run()

setting.py配置文件

class Config:
    #設置mysql+pymysql的連接
    SQLALCHEMY_DATABASE_URI = 'mysql+pymysql://root:[email protected]:3306/demo'
    #加密設置
    SECRETE_KEY = 'secret_key'
    #關閉數據追蹤
    SQLALCHEMY_TRACK_MODIFICATIONS = False
    #開啟提交
    SQLALCHEMY_COMMIT_ON_TEARDOWN = True

前面我們採用系統的每次自動提交session 即SQLALCHEMY_COMMIT_ON_TEARDOWN

但是如果想自己定義提交方式，同時不想傳入關鍵字參數，那麼該怎樣入手呢？這裡提供一種思路

(8) 自定義增刪改類

我們對模型類進行了修改，models.py 內容如下：

from ext import db
#定義了base基類
class Base:
    def save(self):
        try:
            db.session.add(self)  #self實例化對象代表就是u對象
            db.session.commit()  
        except:
            db.session.rollback()
    #定義靜態類方法接收List參數        
    @staticmethod
    def save_all(List):
        try:
            db.session.add_all(List)
            db.session.commit()
        except:
            db.session.rollback()
    #定義刪除方法
    def delete(self):
        try:
            db.session.delete(self)  
            db.session.commit()  
        except:
            db.session.rollback()
#定義模型user類
class User(db.Model,Base):
    __table__name = 'user'
    id = db.Column(db.Integer,primary_key=True)
    username = db.Column(db.String(20),index=True)
    sex = db.Column(db.Boolean,default=True)
    info = db.Column(db.String(50))
    #
    def __init__(self,username='',info='',sex=True):
        self.username = username
        self.info = info
        self.sex = sex
#註意：
#原實例化:  u = User(username='張三',info='個人信息')
#現實例化： u = User('李四'，'李四個人信息')

在views.py中使用

from flask import Blueprint
from .models import User
from ext import db

view = Blueprint('view',__name__)

@view.route('/')
def index():
    return 'index'
#插入單條數據
@view.route('/insert/')
def insert():
    # u = User(username='test',info='default')
    u = User('xiaomeng','default')
    u.save()
    db.session.add(u)
    return 'insert success'
#保存多條數據
@view.route('/saveMany/')
def saveMany():
    u1 = User('zhan123','default123')
    u2 = User('li123','default message')
    User.save_all([u1,u2])
    return 'add many'
#刪除數據
@view.route('/delete/')
def delete():
    u = User.query.get(1)  #獲取查詢集
    u.delete()
    return 'delete message'

其他都不做改變，基本思路是封裝到類，通過多繼承來實現方法的調用。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 關於判斷時間大小！
    由於產品要求，需要添加時間排序，然後後臺又懶得做，只有交給我了。 最開始，我的打算是，轉化成時間軸然後判斷，亦或者將所有字元串刪除，轉化成Int類型進行比較。 比如。 然後做成一個方法。 雖然做出來了，但總感覺有些彆扭，一直到某一天，無意間看到一個函數。 localeCompare()； 地址：ht ...
  • HTML&CSS 問題
    1.子div使用浮動，父div高度自適應(個人感覺好用) 方法： css: <style> .clear{ clear:both} </style> html：在父div關閉之前添加<div class="clear"></div> ...
  • 一個有意思的CSS樣式庫--BUTTONS
    我最近發現了一個有意思的CSS樣式庫，和Bootstrap相似，但是它是專門的一個高度可定製的，免費的並且開源的按鈕CSS樣式庫，這裡附上它的網址：http://www.bootcss.com/p/buttons/ 接下來介紹怎麼使用這個CSS樣式庫，如上圖，進入網址後，點擊下載，會出現一個全是代碼 ...
  • 千萬級流量的優化策略實戰
    摘要 性能優化涉及面很廣。一般而言，性能優化指降低響應時間和提高系統吞吐量兩個方面，但在流量高峰時候，性能問題往往會表現為服務可用性下降，所以性能優化也可以包括提高服務可用性。在某些情況下，降低響應時間、提高系統吞吐量和提高服務可用性三者相互矛盾，不可兼得。例如：增加緩存可以降低平均響應時間，但是處 ...
  • 搜索引擎概述之倒排索引
    說到提高檢索效率，就必然提到索引。今天就來為大家講述搜索引擎中最常見的索引方式——倒排索引。 ...
  • 編寫你的第一個Django應用程式，第二部分
    恢復內容開始 從上個隨筆停止的地方開始，我們將設置資料庫，創建第一個模型。並快速介紹django自動生成的管理站點。 資料庫設置： 打開文件mysite/settings.py 預設情況下，配置使用SQLite。這是新手最簡單的選擇。 雖然你不暫時不用其他資料庫，但是還是要說明一下的： ENGINE ...
  • Java 中的偽共用詳解及解決方案
    1. 什麼是偽共用 CPU 緩存系統中是以緩存行（cache line）為單位存儲的。目前主流的 CPU Cache 的 Cache Line 大小都是 64 Bytes。在多線程情況下，如果需要修改“共用同一個緩存行的變數”，就會無意中影響彼此的性能，這就是偽共用（False Sharing）。 ...
  • 恭喜"微微軟"喜當爹，Github嫁入豪門。
    今天是 Github 嫁入豪門的第 2 天，炒得沸沸揚揚的微軟 Github 收購事件於昨天（06月04日）塵埃落定，微軟最終以 75 億美元正式收購 Github。 隨後，Gitlab 趁勢帶了一波節奏，在其官網上祝賀 Github 被微軟收購，並表示此次收購代表著軟體開發者的影響力的日漸增長，將 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類