1. Toy模板网首页
  2. > Toy博客

快速上手Flask(三) 在 Flask应用中使用Flask-SQLAlchemy（flask SQLAlchemy模型对象如何json序列化输出）

10月前 作者：西京刀客 分类：Toy博客 阅读(55) 违法举报

这篇具有很好参考价值的文章主要介绍了快速上手Flask(三) 在 Flask应用中使用Flask-SQLAlchemy（flask SQLAlchemy模型对象如何json序列化输出）。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

快速上手Flask(三) 在 Flask应用中使用Flask-SQLAlchemy

常见情况下对于只有一个 Flask 应用，所有您需要做的事情就是创建 Flask 应用，选择加载配置接着创建 SQLAlchemy 对象时候把 Flask 应用传递给它作为参数。

SQLAlchemy

官网：https://www.sqlalchemy.org/

参考本人 文章：python常用库之数据库orm框架之SQLAlchemy

什么是Flask-SQLAlchemy

官方文档：
中文：http://www.pythondoc.com/flask-sqlalchemy/index.html
[推荐]英文：https://flask-sqlalchemy.palletsprojects.com/en/3.1.x/

Flask-SQLAlchemy是一个Flask扩展，用于在Flask应用程序中简化与SQL数据库的交互。它提供了一个集成的ORM（对象关系映射）工具，使得在Flask应用程序中进行数据库操作更加方便和高效。

Flask-SQLAlchemy 和 SQLAlchemy的区别？

Flask-SQLAlchemy 是基于 SQLAlchemy 的 Flask 扩展，它提供了在 Flask 应用中更方便地使用 SQLAlchemy 的功能和特性。

  • 集成度：Flask-SQLAlchemy 是针对 Flask 框架的封装，提供了与 Flask 应用无缝集成的功能。它简化了在 Flask 应用中使用 SQLAlchemy 的配置和使用过程，提供了更简洁的接口和功能。

  • 配置：Flask-SQLAlchemy 提供了在 Flask 应用中配置 SQLAlchemy 的方式，可以直接在 Flask 配置中进行数据库相关的配置。而 SQLAlchemy 需要单独进行配置，通常使用一个独立的配置文件或模块。

  • 上下文管理：Flask-SQLAlchemy 自动处理了 SQLAlchemy 的上下文管理，确保在每个请求中使用正确的数据库会话。它与 Flask 的应用上下文和请求上下文无缝集成，提供了更方便的数据库操作方式。

  • 扩展功能：Flask-SQLAlchemy 提供了一些额外的功能和特性，如自动提交和回滚事务、自动创建数据库表、数据库迁移等。它还与 Flask-WTF 和 Flask-Admin 等其他 Flask 扩展集成得更紧密，提供了更丰富的功能和集成选项。

总结：

  1. SQLAlchemy：是一个独立的ORM框架，可以独立与Flask存在，也可以在其他项目中使用，比如在Django中。
  2. Flask-SQLAlchemy：对SQLAlchemy的一个封装，能够更适合在Flask中使用。

您仅需要知道与普通的 SQLAlchemy 不同之处:

  1. SQLAlchemy 允许您访问下面的东西:
    • sqlalchemy 和 sqlalchemy.orm 下所有的函数和类
    • 一个叫做 session 的预配置范围的会话(session)
    • metadata 属性
    • engine 属性
    • SQLAlchemy.create_all() 和 SQLAlchemy.drop_all()，根据模型用来创建以及删除表格的方法
    • 一个 Model 基类，即是一个已配置的声明(declarative)的基础(base)
  2. Model 声明基类行为类似一个常规的 Python 类，不过有个 query 属性，可以用来查询模型 (Model 和 BaseQuery)
  3. 您必须提交会话，但是没有必要在每个请求后删除它(session)，Flask-SQLAlchemy 会帮您完成删除操作。

Flask-SQLAlchemy基本使用

安装：

pip install -U Flask-SQLAlchemy

快速入门

快速入门
参考URL: http://www.pythondoc.com/flask-sqlalchemy/quickstart.html

from flask import Flask
from flask.ext.sqlalchemy import SQLAlchemy

app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:tmp/test.db'
db = SQLAlchemy(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

    def __repr__(self):
        return '<User %r>' % self.username

在 Flask 中使用 SQLAlchemy 进行数据库操作时，你应该在全局范围内创建一个 db 对象。

from flask_sqlalchemy import SQLAlchemy
from sqlalchemy import create_engine
from sqlalchemy.pool import QueuePool

db = SQLAlchemy()

# 数据库连接配置
DATABASE_URI = 'postgresql://username:password@localhost:5432/database_name'
DATABASE_TRACK_MODIFICATIONS = False

# SQLAlchemy配置
SQLALCHEMY_DATABASE_URI = DATABASE_URI
SQLALCHEMY_TRACK_MODIFICATIONS = DATABASE_TRACK_MODIFICATIONS
SQLALCHEMY_ENGINE_OPTIONS = {
    'poolclass': QueuePool,
    'pool_size': 10,
    'max_overflow': 5,
    'pool_pre_ping': True
}

# 创建数据库引擎
engine = create_engine(DATABASE_URI, poolclass=QueuePool, pool_size=10, max_overflow=5, pool_pre_ping=True)

SQLALCHEMY_ENGINE_OPTIONS：这是SQLAlchemy的引擎配置选项，用于配置连接池的相关参数，例如pool_size和max_overflow。
engine：这是使用create_engine函数创建的数据库引擎对象，可以在需要直接使用底层引擎的情况下使用。

在你的代码中，你已经正确地创建了一个 db 对象，并将其与 Flask 应用程序绑定。这样做可以确保在整个应用程序中使用相同的数据库实例。

from flask import Flask
from api import create_app
from sqlalchemy_db import db, SQLALCHEMY_DATABASE_URI, SQLALCHEMY_TRACK_MODIFICATIONS, SQLALCHEMY_ENGINE_OPTIONS

app = create_app(os.getenv('FLASK_CONFIG') or 'default')

# 配置数据库连接URI和选项
app.config['SQLALCHEMY_DATABASE_URI'] = SQLALCHEMY_DATABASE_URI
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = SQLALCHEMY_TRACK_MODIFICATIONS
app.config['SQLALCHEMY_ENGINE_OPTIONS'] = SQLALCHEMY_ENGINE_OPTIONS

# 将db对象与Flask应用程序关联
db.init_app(app)

在执行原生SQL语句时，使用engine对象。

以下是一个示例代码，演示了如何使用engine对象执行原生SQL查询：

from sqlalchemy_db import engine

def execute_native_sql(query):
    with engine.connect() as connection:
        result = connection.execute(query)
        for row in result:
            print(row)

# 示例查询
query = "SELECT * FROM users"
execute_native_sql(query)

在上面的代码中，我们创建了一个execute_native_sql函数，它使用engine对象执行原生SQL查询并打印结果。

请注意，在使用engine对象时，你需要根据具体的情况选择适当的上下文管理器（with语句）来保证连接的正确关闭。

如果你只是想使用SQLAlchemy的ORM功能（例如定义模型类、执行查询等），则可以直接使用db对象，而不需要直接使用engine对象。

创建模型

在使用SQLAlchemy之前，你需要先定义数据库模型类。模型类代表了数据库中的表结构，并提供了与表相关联的字段和方法。

from sqlalchemy_db import db

class User(db.Model):
    __tablename__ = 'users'
    
    id = db.Column(db.Integer, primary_key=True)
    username = db.Column(db.String(50), unique=True, nullable=False)
    email = db.Column(db.String(100), unique=True, nullable=False)
    
    def __repr__(self):
        return f'<User(id={self.id}, username={self.username}, email={self.email})>'

在上面的示例中，我们定义了一个名为User的模型类，它对应了数据库中的users表。User类继承了db.Model，这是SQLAlchemy提供的基类。

from sqlalchemy_db import db
from models import User

# 创建数据库表
db.create_all()

# 创建一个新用户
user = User(username='john', email='john@example.com')
db.session.add(user)
db.session.commit()

# 查询所有用户
users = User.query.all()
for user in users:
    print(user)

# 查询特定用户
user = User.query.filter_by(username='john').first()
print(user)

# 更新用户信息
user.email = 'newemail@example.com'
db.session.commit()

# 删除用户
db.session.delete(user)
db.session.commit()

我们使用db.session来进行数据库操作，例如添加、查询、更新和删除用户记录。

flask模型对象如何json序列化输出

[推荐]Flask 学习-36.Flask-RESTful 序列化输出对象
参考URL:https://www.cnblogs.com/yoyoketang/p/16648730.html

通过flask-SQLAlchemy这一ORM工具所构建的数据库表模型，通过其语句所取出的数据通常是object类型的，这一类型并不能直接在方法中return返回一个JSON格式，因此需要先对从数据库中取出的数据进行序列化，然后再return给前端。

在网络上找到的三种序列化方法如下：

在模型定义的时候给序列化的方法
继承改写 flask 里面的 JSONEncoder类以及default方法
使用Marshmallow
】

装饰器marshal_with实际上是获取您的数据对象并应用字段过滤。编组可以处理单个对象、字典或对象列表。

https://www.cnblogs.com/yoyoketang/p/16648730.html

使用Flask-RESTful 提供的 fields 模块序列化输出需要的字段

from flask_restful import Resource, fields, marshal_with

user_fields = {
‘id’: fields.Integer,
‘username’: fields.String,
‘is_active’: fields.Boolean
}

class UserInfo(Resource):

@marshal_with(user_fields)
def get(self):
    user = Users.query.get(1)
    print(f'查询到的数据：{user}')
    return user

marshal_with 装饰器只能对return的对象序列化，这里可以使用 marshal() 函数实现部分序列化

数据库的增删改查

Flask和SQLAlchemy的模型操作：增删改查方法详解
参考URL: https://www.51cto.com/article/757138.html

查询模型
在Flask和SQLAlchemy中，我们可以使用以下方法来查询模型：

查询所有模型：

users = User.query.all()

这将返回所有的用户模型对象。

查询单个模型：

user = User.query.filter_by(username='john').first()

这将返回一个用户名为’john’的用户模型对象。

使用复杂查询：

users = User.query.filter(User.email.endswith('@example.com')).all()

这将返回所有电子邮件以’@example.com’结尾的用户模型对象。

修改模型
在Flask和SQLAlchemy中，我们可以使用以下方法来修改模型：

修改单个属性：

user = User.query.filter_by(username='john').first()
user.email = 'newemail@example.com'
db.session.commit()

修改多个属性：

user = User.query.filter_by(username='john').first()
user.email = 'newemail@example.com'
user.password = 'newpassword'
db.session.commit()

这将修改用户名为’john’的用户的电子邮件和密码，并将更改保存到数据库。

删除模型
在Flask和SQLAlchemy中，我们可以使用以下方法来删除模型：

删除单个模型：

user = User.query.filter_by(username='john').first()
db.session.delete(user)
db.session.commit()

这将删除用户名为’john’的用户模型对象，并将更改保存到数据库。

删除多个模型：

users = User.query.filter_by(email='oldemail@example.com').all()
for user in users:
    db.session.delete(user)
db.session.commit()

完整的代码示例如下：

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///mydatabase.db'
db = SQLAlchemy(app)

class User(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    username = db.Column(db.String(80), unique=True, nullable=False)
    email = db.Column(db.String(120), unique=True, nullable=False)
    password = db.Column(db.String(120), nullable=False)

    def __repr__(self):
        return '<User %r>' % self.username

# create database tables
db.create_all()

# add a new user to the database
user = User(username='john', email='john@example.com', password='password')
db.session.add(user)
db.session.commit()

# query all users
users = User.query.all()
print(users)

# query a single user
user = User.query.filter_by(username='john').first()
print(user)

# modify a user's email
user = User.query.filter_by(username='john').first()
user.email = 'newemail@example.com'
user.password = 'newpassword'
db.session.commit()

# delete a user
user = User.query.filter_by(username='john').first()
db.session.delete(user)
db.session.commit()

首先定义了一个User模型类，并使用db.create_all()方法创建了数据库表格。接着，我们添加了一个新用户到数据库中，并使用User.query.all()和User.query.filter_by()方法查询了用户。然后，我们修改了用户的电子邮件和密码，并使用db.session.commit()方法将更改保存到数据库。最后，我们使用db.session.delete()方法删除了用户，并使用db.session.commit()方法将更改保存到数据库。

工作常用总结

在 SQLAlchemy 中,怎么判断删除是否成功？

官方文档：https://docs.sqlalchemy.org/en/14/orm/query.html#sqlalchemy.orm.Query.delete

在 SQLAlchemy 中，可以使用 execute() 方法执行 DELETE 语句，delete() 方法返回的是一个整数，表示被删除的记录数。文章来源地址https://www.toymoban.com/news/detail-823555.html

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
 
# 创建引擎和Session
engine = create_engine('sqlite:///test.db')
session = sessionmaker(bind=engine)()
 
try:
    # 定义模型类（这里以User为例）
    class User(Base):
        __tablename__ = 'users'
        
        id = Column(Integer, primary_key=True)
        name = Column(String)
    
    # 查询所有名字为"John"的用户
    users = session.query(User).filter(User.name == "John").all()
    
    if len(users) > 0:
        # 删除第一个找到的用户
        deleted_count = session.delete(users[0])
        print("已删除{}个用户".format(deleted_count))
        session.commit()
    else:
        print("未找到任何符合条件的用户")
except Exception as e:
    print("删除失败：", str(e))
finally:
    session.close()

到了这里，关于快速上手Flask(三) 在 Flask应用中使用Flask-SQLAlchemy（flask SQLAlchemy模型对象如何json序列化输出）的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处： 如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：
领支付宝红包 赞助服务器费用

相关文章

  • Flask数据库操作-Flask-SQLAlchemy

    Flask数据库操作-Flask-SQLAlchemy

    Flask中一般使用flask-sqlalchemy来操作数据库。flask-sqlalchemy的使用介绍如下： 一、SQLAlchemy SQLALchemy 实际上是对数据库的抽象，让开发者不用直接和 SQL 语句打交道，而是通过 Python 对象来操作数据库，在舍弃一些性能开销的同时，换来的是开发效率的较大提升。 SQLAlchemy是一个关

    2024年02月22日
    浏览(56)
  • python：使用Flask-SQLAlchemy对数据库增删改查的简单示例

    python：使用Flask-SQLAlchemy对数据库增删改查的简单示例

    以下将介绍Flask-SQLAlchemy对数据库增删改查的简单示例。 一、安装所需的库 pip install flask flask-sqlalchemy flask-mysql 二、创建数据表 本示例使用mysql创建数据库和表 CREATE TABLE `user` (   `id` int(11) NOT NULL AUTO_INCREMENT,   `name` varchar(255) DEFAULT NULL,   `age` int(11) DEFAULT NULL,   PRIMARY KEY (`id

    2024年02月07日
    浏览(67)
  • Flask-SQLAlchemy事件钩子介绍

    Flask-SQLAlchemy事件钩子介绍

    前几天在搜资料的时候无意中看到有介绍SQLAlchemy触发器，当时感觉挺奇怪的，触发器不是数据库层面的概念吗，怎么flask-SQLAlchemy这个ORM框架会有这玩意。 考虑到效率博客表中有两个字段，body用于存储markdown源文本，body_html存储转换成html的内容，这里就可以在保存数据时使用

    2024年02月06日
    浏览(51)
  • flask中的操作数据库的插件Flask-SQLAlchemy

    flask中的操作数据库的插件Flask-SQLAlchemy

    Web 开发中，一个重要的组成部分便是数据库了。Web 程序中最常用的莫过于关系型数据库了，也称 SQL 数据库。另外，文档数据库（如 mongodb）、键值对数据库（如 redis）近几年也逐渐在 web 开发中流行起来，我们习惯把这两种数据库称为 NoSQL 数据库。 大多数的关系型数据库引

    2024年02月09日
    浏览(60)
  • Flask-sqlalchemy更新数据库

    Flask-sqlalchemy更新数据库

    Flask开发过程中，难免不会在开发工程中修改数据库信息，如添加字段，修改字段类型等，Flask可以通过扩展库flask-migrate来更新DEBUG中的工程数据库，更新数据库步骤如下： 1、首先需要安装flask_migrate，pip install flask_migrate 2、因为flask_sqlalchemy是通过终端命令更新，所以需要f

    2023年04月08日
    浏览(40)
  • flask-sqlalchemy连接数据库

    flask-sqlalchemy连接数据库

    1、安装flask_sqlalchemy和pymysql包 2、进行配置 使用Flask-SQLAlchemy扩展操作数据库，首先需要通过URL建立数据库连接，必须保存到Flask配置对象的SQLALCHEMY_DATABASE_URI中。 其中HOSTNAME为路由地址 PORT为端口号，我在创建数据库时没有更改，所以用的默认的3306端口号 DATABASE为数据库名字

    2024年02月06日
    浏览(62)

  • 3.flask-sqlalchemy ORM库

    Flask-SQLAlchemy是一个用于Flask的扩展，它提供了一个便捷的方式来处理数据库操作。Flask-SQLAlchemy基于SQLAlchemy，一个功能强大的Python SQL工具包和对象关系映射（ORM）系统 官网文档: http://www.pythondoc.com/flask-sqlalchemy/ 一对多关系是指一个模型与另一个模型之间存在多对一的关系。在

    2024年02月10日
    浏览(44)

  • flask-sqlalchemy结合Blueprint遇到循环引入问题的解决方案

    想要用flask_sqlalchemy结合Blueprint分模块写一下SQL的增删改查接口，结果发现有循环引入问题。 一开始，我在app.py中使用db = SQLAlchemy(app)创建数据库对象；并且使用app.register_blueprint(db_bp, url_prefix=\\\'/db\\\')注册蓝图。 这使得我的依赖关系是这样的。db.py → app,py 中的db对象；app.py →

    2024年02月07日
    浏览(41)

  • flask---》更多查询方式/连表查询/原生sql(django-orm如何执行原生sql)/flask-sqlalchemy

    sqlalchemy执行原生sql django执行原生sql

    2024年02月13日
    浏览(37)

  • 【flask sqlalchmey】一次性将返回的列表对象或者 一行数据对象转成dict---flask-sqlalchemy输出json格式数据

    结果示例： 另外： res = Sysdict.query.all() 这种写法已经不被推荐了， 推荐的是scalar_one() 获取一行，scalars()获取多行 user = db.session.execute(db.select(User).filter_by(username=username)).scalar_one() users = db.session.execute(db.select(User).order_by(User.username)).scalars() 一般的 json.dumps(users) 或者 jsonify(use

    2024年02月13日
    浏览(55)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包，优惠每天领

二维码1

领取红包

二维码2

领红包