您可以使用 pip 輕松安裝 flask-sqlalchemy 和 flask-marshmallow，使用以下命令：

$ pip install flask_sqlalchemy
$ pip install flask_marshmallow
$ pip install marshmallow-sqlalchemy

3.2.準(zhǔn)備代碼

????????在名為 crud.py 的文件夾上創(chuàng)建新的flask_tutorial python文件。在 crud.py 中記下以下代碼。

from flask import Flask, request, jsonify
from flask_sqlalchemy import SQLAlchemy
from flask_marshmallow import Marshmallow
import os

app = Flask(__name__)
basedir = os.path.abspath(os.path.dirname(__file__))
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///' + os.path.join(basedir, 'crud.sqlite')
db = SQLAlchemy(app)
ma = Marshmallow(app)


class User(db.Model):
    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


class UserSchema(ma.Schema):
    class Meta:
        # Fields to expose
        fields = ('username', 'email')


user_schema = UserSchema()
users_schema = UserSchema(many=True)


# endpoint to create new user
@app.route("/user", methods=["POST"])
def add_user():
    username = request.json['username']
    email = request.json['email']
    
    new_user = User(username, email)

    db.session.add(new_user)
    db.session.commit()

    return jsonify(new_user)


# endpoint to show all users
@app.route("/user", methods=["GET"])
def get_user():
    all_users = User.query.all()
    result = users_schema.dump(all_users)
    return jsonify(result.data)


# endpoint to get user detail by id
@app.route("/user/<id>", methods=["GET"])
def user_detail(id):
    user = User.query.get(id)
    return user_schema.jsonify(user)


# endpoint to update user
@app.route("/user/<id>", methods=["PUT"])
def user_update(id):
    user = User.query.get(id)
    username = request.json['username']
    email = request.json['email']

    user.email = email
    user.username = username

    db.session.commit()
    return user_schema.jsonify(user)


# endpoint to delete user
@app.route("/user/<id>", methods=["DELETE"])
def user_delete(id):
    user = User.query.get(id)
    db.session.delete(user)
    db.session.commit()

    return user_schema.jsonify(user)


if __name__ == '__main__':
    app.run(debug=True)

????????對(duì)于短代碼，上面的代碼將具有 5 個(gè)端點(diǎn)，具有創(chuàng)建新記錄、從數(shù)據(jù)庫(kù)中獲取所有記錄、按 id 獲取記錄詳細(xì)信息、更新所選記錄和刪除所選記錄的功能。同樣在此代碼中，我們?yōu)閿?shù)據(jù)庫(kù)定義模型。

????????讓我們逐部分看一下代碼

from flask import Flask, request, jsonify
from flask_sqlalchemy import SQLAlchemy
from flask_marshmallow import Marshmallow
import os

????????在這一部分，我們導(dǎo)入應(yīng)用程序所需的所有模塊。我們導(dǎo)入 Flask 來(lái)創(chuàng)建 Web 應(yīng)用程序的實(shí)例，請(qǐng)求獲取請(qǐng)求數(shù)據(jù)，jsonify 將 JSON 輸出轉(zhuǎn)換為具有應(yīng)用程序/json?mimetype 的對(duì)象，從 flask_sqlalchemy 到 訪問(wèn)數(shù)據(jù)庫(kù)的 SQAlchemy，以及從flask_marshmallow到序列化對(duì)象的 Marshmallow。Response

app = Flask(__name__)
basedir = os.path.abspath(os.path.dirname(__file__))
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///' + os.path.join(basedir, 'crud.sqlite')

????????這部分創(chuàng)建我們的 Web 應(yīng)用程序的實(shí)例并設(shè)置我們的 SQLite uri 的路徑。

db = SQLAlchemy(app)
ma = Marshmallow(app)

????????在這一部分，我們將SQLAlchemy和棉花糖綁定到我們的燒瓶應(yīng)用程序中。

class User(db.Model):
    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

????????導(dǎo)入 SQLAlchemy 并將其綁定到我們的燒瓶應(yīng)用程序后，我們可以聲明我們的模型。在這里，我們聲明名為 User 的模型，并用它的屬性定義它的字段。

class UserSchema(ma.Schema):
    class Meta:
        # Fields to expose
        fields = ('username', 'email')


user_schema = UserSchema()
users_schema = UserSchema(many=True)

????????這部分定義了端點(diǎn)的響應(yīng)結(jié)構(gòu)。我們希望所有終結(jié)點(diǎn)都具有 JSON 響應(yīng)。在這里，我們定義我們的 JSON 響應(yīng)將有兩個(gè)鍵（用戶名和電子郵件）。此外，我們將user_schema定義為UserSchema的實(shí)例，user_schemas定義為UserSchema列表的實(shí)例。

# endpoint to create new user
@app.route("/user", methods=["POST"])
def add_user():
    username = request.json['username']
    email = request.json['email']
    
    new_user = User(username, email)

    db.session.add(new_user)
    db.session.commit()

    return jsonify(new_user)

????????在這一部分，我們定義端點(diǎn)以創(chuàng)建新用戶。首先，我們將路由設(shè)置為“/user”，并將HTTP方法設(shè)置為POST。設(shè)置路由和方法后，我們定義在訪問(wèn)此端點(diǎn)時(shí)將執(zhí)行的函數(shù)。在此函數(shù)中，我們首先從請(qǐng)求數(shù)據(jù)中獲取用戶名和電子郵件。之后，我們使用請(qǐng)求數(shù)據(jù)中的數(shù)據(jù)創(chuàng)建新用戶。最后，我們將新用戶添加到數(shù)據(jù)庫(kù)中，并以JSON形式顯示新用戶作為響應(yīng)。

# endpoint to show all users
@app.route("/user", methods=["GET"])
def get_user():
    all_users = User.query.all()
    result = users_schema.dump(all_users)
    return jsonify(result.data)

????????在這一部分中，我們定義端點(diǎn)以獲取所有用戶的列表，并將結(jié)果顯示為JSON響應(yīng)。

# endpoint to get user detail by id
@app.route("/user/<id>", methods=["GET"])
def user_detail(id):
    user = User.query.get(id)
    return user_schema.jsonify(user)

????????就像這部分的前一部分一樣，我們定義了端點(diǎn)來(lái)獲取用戶數(shù)據(jù)，但不是在這里獲取所有用戶，我們只是根據(jù) id 從一個(gè)用戶那里獲取數(shù)據(jù)。如果仔細(xì)查看路由，可以看到此終結(jié)點(diǎn)的路由上有不同的模式。像“<id>”這樣的父親是參數(shù)，所以你可以用你想要的一切來(lái)改變它。這個(gè)參數(shù)應(yīng)該放在函數(shù)參數(shù)上（在本例中為?def?user_detail（id）），這樣我們就可以在函數(shù)中獲取這個(gè)參數(shù)值。

# endpoint to update user
@app.route("/user/<id>", methods=["PUT"])
def user_update(id):
    user = User.query.get(id)
    username = request.json['username']
    email = request.json['email']

    user.email = email
    user.username = username

    db.session.commit()
    return user_schema.jsonify(user)

????????在這一部分中，我們定義端點(diǎn)以更新用戶。首先，我們調(diào)用與參數(shù)上的給定 id 相關(guān)的用戶。然后，我們使用請(qǐng)求數(shù)據(jù)中的值更新此用戶的用戶名和電子郵件值。

# endpoint to delete user
@app.route("/user/<id>", methods=["DELETE"])
def user_delete(id):
    user = User.query.get(id)
    db.session.delete(user)
    db.session.commit()

    return user_schema.jsonify(user)

????????最后，我們定義要?jiǎng)h除用戶的端點(diǎn)。首先，我們調(diào)用與參數(shù)上的給定 id 相關(guān)的用戶。然后我們刪除它。

四、 生成 SQLite 數(shù)據(jù)庫(kù)

????????在上一步中，您已經(jīng)編寫了代碼來(lái)處理SQLite的CRUD操作，但是如果您運(yùn)行此python文件并嘗試訪問(wèn)端點(diǎn)（您可以嘗試訪問(wèn)localhost：5000 /user），您將收到類似于以下內(nèi)容的錯(cuò)誤消息

操作錯(cuò)誤： （sqlite3.操作錯(cuò)誤） 沒有這樣的表： 用戶 [SQL： u'SELECT user.id AS user_id， user.username AS user_username， user.email AS user_email \nFROM user']

????????出現(xiàn)此錯(cuò)誤消息的原因是您嘗試從 SQLite 獲取數(shù)據(jù)，但您還沒有 SQLite 數(shù)據(jù)庫(kù)。因此，在此步驟中，我們將在運(yùn)行應(yīng)用程序之前先生成SQLite數(shù)據(jù)庫(kù)。您可以使用以下步驟在 crud.py 中基于您的模型生成 SQLite 數(shù)據(jù)庫(kù)。

1. 進(jìn)入 Python 交互式外殼

首先，您需要在終端中使用以下命令進(jìn)入python交互式shell：

$ 蟒蛇

2. 導(dǎo)入數(shù)據(jù)庫(kù)對(duì)象并生成SQLite數(shù)據(jù)庫(kù)

在 python 交互式 shell 中使用以下代碼

從原油導(dǎo)入數(shù)據(jù)庫(kù)
>>> db.create_all（）>>>

crud.sqlite將在您的flask_tutorial文件夾中生成。

五、?運(yùn)行flask應(yīng)用

????????現(xiàn)在，在生成 sqlite 數(shù)據(jù)庫(kù)后，我們就可以運(yùn)行我們的燒瓶應(yīng)用程序了。從終端運(yùn)行以下命令以運(yùn)行應(yīng)用程序。

$ python crud.py

????????我們已經(jīng)準(zhǔn)備好嘗試我們的燒瓶應(yīng)用。要在我們的燒瓶應(yīng)用程序中嘗試端點(diǎn)，我們可以使用 API 開發(fā)工具，例如 curl 或 postman。就我個(gè)人而言，我喜歡 api 開發(fā)的郵遞員（Postman）。在本文中，我將使用郵遞員來(lái)訪問(wèn)端點(diǎn)。

1. 創(chuàng)建新用戶

2. 獲取所有用戶

3. 通過(guò) id 獲取用戶

4. 更新用戶

5. 刪除用戶

六、后記

????????這就是本文的全部?jī)?nèi)容。接下來(lái)，我計(jì)劃使用 pytest 編寫小型測(cè)試。文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-640660.html