flask数据库序列化操作实例探究

pip install marshmallow_sqlalchemy,marshmallow

from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy()
# 定义一个数据库表结构的数据模型
class AssetModel(db.Model):
    __tablename__ = 'asset'
    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    init_date = db.Column(db.String(30), nullable=False)
    username = db.Column(db.String(20), nullable=False)
    account = db.Column(db.String(20), nullable=False)
    update_time = db.Column(db.DateTime, nullable=False)
    def __init__(self, username, init_date,account, update_time):
        self.username = username
        self.init_date = init_date
        self.account = account
        self.update_time = str(update_time)
3、接着我们开始定义一个序列化器
from models.assetmodel import AssetModel
from marshmallow_sqlalchemy import SQLAlchemyAutoSchema
from marshmallow import EXCLUDE,validate,fields
class AssetSerializer(SQLAlchemyAutoSchema):
    class Meta:
        model = AssetModel   # 配置对应的模型
        ordered = True       # 设置是否排序
        include_fk = True    # 是否包含外键
        unknown = EXCLUDE    # 未知字段序列化选项
        # exclude = ("name",)  # 序列化不需要的字段，反之对应的是include

from models.assetmodel import AssetModel
from marshmallow_sqlalchemy import SQLAlchemyAutoSchema
from marshmallow import EXCLUDE,validate,fields
class AssetSerializer(SQLAlchemyAutoSchema):
    class Meta:
        model = AssetModel   # 配置对应的模型
        ordered = True       # 设置是否排序
        include_fk = True    # 是否包含外键
        unknown = EXCLUDE    # 未知字段序列化选项
        # exclude = ("name",)  # 序列化不需要的字段，反之对应的是include

from models.assetmodel import AssetModel,AssetSerializer
testdata_blueprint = Blueprint('testdata', __name__, url_prefix='/TestData')
@testdata_blueprint.route('/testdata', methods=['GET'])
def get_testdata_list():
    # 获取当前查询页码，默认为：1
    page = request.args.get('page',1,type=int)
    # 获取每页显示记录数，默认是20
    limit = request.args.get('limit',20,type=int)
    # 获取查询的资产账号
    account = request.args.get('account',type=int)
    # 计算当前页，开始的记录编号
    start = (page - 1) * limit
    # 计算当前页，结束的记录编号；
    end = start + limit
    # 分页查询
    items = AssetModel.query.slice(start, end)
    # 获取记录总数
    total = AssetModel.query.count()
    # 将查询结果进行序列化
    items = AssetSerializer().dump(items,many=True)  # 记得带上many=True参数，否则查询结果为空
    # 将结果转成json结构进行返回
    return jsonify({
        'code': 20000,
        'msg': 'success',
        'data': {
            'items': items,
            'total':total
        }
    })