1、ORM 框架

Web 開(kāi)發(fā)中，一個(gè)重要的組成部分便是數(shù)據(jù)庫(kù)了。Web 程序中最常用的莫過(guò)于關(guān)系型數(shù)據(jù)庫(kù)了，也稱(chēng) SQL 數(shù)據(jù)庫(kù)。另外，文檔數(shù)據(jù)庫(kù)（如 mongodb）、鍵值對(duì)數(shù)據(jù)庫(kù)（如 redis）近幾年也逐漸在 web 開(kāi)發(fā)中流行起來(lái)，我們習(xí)慣把這兩種數(shù)據(jù)庫(kù)稱(chēng)為 NoSQL 數(shù)據(jù)庫(kù)。

大多數(shù)的關(guān)系型數(shù)據(jù)庫(kù)引擎（比如 MySQL、Postgres 和 SQLite）都有對(duì)應(yīng)的 Python 包。在這里，我們不直接使用這些數(shù)據(jù)庫(kù)引擎提供的 Python 包，而是使用對(duì)象關(guān)系映射（Object-Relational Mapper, ORM）框架，它將低層的數(shù)據(jù)庫(kù)操作指令抽象成高層的面向?qū)ο蟛僮?。也就是說(shuō)，如果我們直接使用數(shù)據(jù)庫(kù)引擎，我們就要寫(xiě) SQL 操作語(yǔ)句，但是，如果我們使用了 ORM 框架，我們對(duì)諸如表、文檔此類(lèi)的數(shù)據(jù)庫(kù)實(shí)體就可以簡(jiǎn)化成對(duì) Python 對(duì)象的操作。

Python 中最廣泛使用的 ORM 框架是 SQLAlchemy，它是一個(gè)很強(qiáng)大的關(guān)系型數(shù)據(jù)庫(kù)框架，不僅支持高層的 ORM，也支持使用低層的 SQL 操作，另外，它也支持多種數(shù)據(jù)庫(kù)引擎，如 MySQL、Postgres 和 SQLite 等

2、Flask-SQLAlchemy

在 Flask 中，為了簡(jiǎn)化配置和操作，我們使用的 ORM 框架是 Flask-SQLAlchemy，這個(gè) Flask 擴(kuò)展封裝了 SQLAlchemy 框架。在 Flask-SQLAlchemy 中，數(shù)據(jù)庫(kù)使用 URL 指定，下表列出了常見(jiàn)的數(shù)據(jù)庫(kù)引擎和對(duì)應(yīng)的 URL

上面的表格中，username 和 password 表示登錄數(shù)據(jù)庫(kù)的用戶(hù)名和密碼，hostname 表示 SQL 服務(wù)所在的主機(jī)，可以是本地主機(jī)（localhost）也可以是遠(yuǎn)程服務(wù)器，database 表示要使用的數(shù)據(jù)庫(kù)。有一點(diǎn)需要注意的是，SQLite 數(shù)據(jù)庫(kù)不需要使用服務(wù)器，它使用硬盤(pán)上的文件名作為 database。

3、一個(gè)最小的應(yīng)用

創(chuàng)建數(shù)據(jù)庫(kù)

首先，我們使用 pip 安裝 Flask-SQLAlchemy:

pip install flask-sqlalchemy

接下來(lái)，我們配置一個(gè)簡(jiǎn)單的 SQLite 數(shù)據(jù)庫(kù)：

$ cat app.py
# -*- coding: utf-8 -*-
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///db/users.db'
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
db = SQLAlchemy(app)
class User(db.Model):
    """定義數(shù)據(jù)模型"""
    __tablename__ = 'users'
    id = db.Column(db.Integer, primary_key=True)
    username = db.Column(db.String(80), unique=True)
    email = db.Column(db.String(120), unique=True)
    def __init__(self, username, email):
        self.username = username
        self.email = email
    def __repr__(self):
        return '<User %r>' % self.username

這里有幾點(diǎn)需要注意的是：

• app 應(yīng)用配置項(xiàng) SQLALCHEMY_DATABASE_URI 指定了 SQLAlchemy 所要操作的數(shù)據(jù)庫(kù)，這里我們使用的是 SQLite，數(shù)據(jù)庫(kù) URL 以 sqlite:/// 開(kāi)頭，后面的 db/users.db 表示數(shù)據(jù)庫(kù)文件存放在當(dāng)前目錄的 db 子目錄中的 users.db 文件。當(dāng)然，你也可以使用絕對(duì)路徑，如 /tmp/users.db 等。
• db 對(duì)象是 SQLAlchemy 類(lèi)的實(shí)例，表示程序使用的數(shù)據(jù)庫(kù)。
• 我們定義的 User 模型必須繼承自 db.Model，這里的模型其實(shí)就對(duì)應(yīng)著數(shù)據(jù)庫(kù)中的表。其中，類(lèi)變量__tablename__ 定義了在數(shù)據(jù)庫(kù)中使用的表名，如果該變量沒(méi)有被定義，F(xiàn)lask-SQLAlchemy 會(huì)使用一個(gè)默認(rèn)名字。
  接著，我們創(chuàng)建表和數(shù)據(jù)庫(kù)。為此，我們先在當(dāng)前目錄創(chuàng)建 db 子目錄和新建一個(gè) users.db 文件，然后在交互式 Python shell 中導(dǎo)入 db 對(duì)象并調(diào)用 SQLAlchemy 類(lèi)的 create_all() 方法：

$ mkdir db
$ python
>>> from app import db
>>> db.create_all()

我們驗(yàn)證一下，”users” 表是否創(chuàng)建成功：

$ sqlite3 db/users.db    # 打開(kāi)數(shù)據(jù)庫(kù)文件
SQLite version 3.8.10.2 2015-05-20 18:17:19
Enter ".help" for usage hints.
sqlite> .schema users   # 查看 "user" 表的 schema
CREATE TABLE users (
        id INTEGER NOT NULL,
        username VARCHAR(80),
        email VARCHAR(120),
        PRIMARY KEY (id),
        UNIQUE (username),
        UNIQUE (email)
);

插入數(shù)據(jù)

我們創(chuàng)建一些用戶(hù)，通過(guò)使用 db.session.add()來(lái)添加數(shù)據(jù)：

@app.route('/adduser')
def add_user():
    user1 = User('ethan', 'ethan@example.com')
    user2 = User('admin', 'admin@example.com')
    user3 = User('guest', 'guest@example.com')
    user4 = User('joe', 'joe@example.com')
    user5 = User('michael', 'michael@example.com')
    db.session.add(user1)
    db.session.add(user2)
    db.session.add(user3)
    db.session.add(user4)
    db.session.add(user5)
    db.session.commit()
    return "<p>add succssfully!"

這里有一點(diǎn)要注意的是，我們?cè)趯?shù)據(jù)添加到會(huì)話(huà)后，在最后要記得調(diào)用 db.session.commit() 提交事務(wù)，這樣，數(shù)據(jù)才會(huì)被寫(xiě)入到數(shù)據(jù)庫(kù)。

查詢(xún)數(shù)據(jù)

查詢(xún)數(shù)據(jù)主要是用 query 接口，例如 all() 方法返回所有數(shù)據(jù)，filter_by() 方法對(duì)查詢(xún)結(jié)果進(jìn)行過(guò)濾，參數(shù)是鍵值對(duì)，filter 方法也可以對(duì)結(jié)果進(jìn)行過(guò)濾，但參數(shù)是布爾表達(dá)式，詳細(xì)的介紹請(qǐng)查看這里。

>>> from app import User
>>> users = User.query.all()
>>> users
[<User u'ethan'>, <User u'admin'>, <User u'guest'>, <User u'joe'>, <User u'michael'>]
>>>
>>> user = User.query.filter_by(username='joe').first()
>>> user
<User u'joe'>
>>> user.email
u'joe@example.com'
>>>
>>> user = User.query.filter(User.username=='ethan').first()
>>> user
<User u'ethan'>

如果我們想查看 SQLAlchemy 為查詢(xún)生成的原生 SQL 語(yǔ)句，只需要把 query 對(duì)象轉(zhuǎn)化成字符串：

>>> str(User.query.filter_by(username='guest'))
'SELECT users.id AS users_id, users.username AS users_username, users.email AS users_email \nFROM users \nWHERE users.username = :username_1'

分頁(yè)方法

分頁(yè)方法可以采用 limit() 和 offset() 方法，比如從第 3 條記錄開(kāi)始取(注意是從 0 開(kāi)開(kāi)始算起)，并最多取 1 條記錄，可以這樣：

users = User.query.limit(1).offset(3)

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

更新數(shù)據(jù)也用 add() 方法，如果存在要更新的對(duì)象，SQLAlchemy 就更新該對(duì)象而不是添加。

>>> from app import db
>>> from app import User
>>>
>>> admin = User.query.filter_by(username='admin').first()
>>>
>>> admin.email = 'admin@hotmail.com'
>>> db.session.add(admin)
>>> db.session.commit()
>>>
>>> admin = User.query.filter_by(username='admin').first()
>>> admin.email
u'admin@hotmail.com'

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

刪除數(shù)據(jù)用 delete() 方法，同樣要記得 delete 數(shù)據(jù)后，要調(diào)用 commit() 提交事務(wù)：

>>> from app import db
>>> from app import User
>>>
>>> admin = User.query.filter_by(username='admin').first()
>>> db.session.delete(admin)
>>> db.session.commit()

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

最新評(píng)論