【问题标题】:Python SQLAlchemy: Reflecting the database breaks default/onupdate methods?Python SQLAlchemy:反映数据库会破坏默认/onupdate 方法吗?
【发布时间】:2017-04-12 02:20:19
【问题描述】:

我对 Postgres 数据库有两个独立的 SQLAlchemy 接口。第一个接口,在 Flask App 的上下文中,包含这个模型:

app = create_app() # sets the SQLAlchemy Database URI, etc.
db = SQLAlchemy(app)

class User(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    created_at = db.Column(db.DateTime, default=datetime.datetime.utcnow)
    updated_at = db.Column(db.DateTime, onupdate=datetime.datetime.utcnow)
    name = db.Column(db.String, nullable=False)

第二个接口不是通过 Flask 实现的——相反,它是一个侦听特定事件的脚本,在这种情况下,它旨在执行一些计算并更新数据库中的一行。为此,我让 SQLAlchemy 反映现有数据库:

from sqlalchemy import create_engine, MetaData, Table
from sqlalchemy.orm import mapper, sessionmaker
from sqlalchemy.ext.automap import automap_base
from os import environ

dbPath = "postgresql://" + ...
engine = create_engine(dbPath)

Base = automap_base()
Base.prepare(engine, reflect=True)

metadata = MetaData(engine)

class User(object):
    pass

users = Table('user', metadata, autoload=True, autoload_with=engine)
mapper(User, users)

Session = sessionmaker(bind=engine)
session = Session()

我现在遇到的问题是:当我使用第一个界面创建新条目或更新条目时,一切正常,created_atupdated_at 字段已适当更新。

但是,当我使用第二个界面——导入代码并使用session.query(User) 获取条目并更新它时,updated_at 字段不会改变。此外,当我使用此接口创建新用户时,虽然它按预期创建了新行,但它既不填充 created_at 也不填充 updated_at 字段。

我的问题:

  1. 为什么会这样?为什么反射似乎破坏了default/onupdate 方法?
  2. 我该如何解决这个问题?

【问题讨论】:

  • 尽管脚本与flask app没有关联,但你也可以复用flask中用户模型的定义。
  • @stamaimer 是那种很好的形式吗?这种方法似乎会产生技术债务。
  • 你听什么活动? event符合您的要求吗?
  • @stamaimer 不,我正在听一个与 sqlalchemy 无关的事件。我提供的代码是一个最小的工作示例。

标签: python postgresql flask sqlalchemy flask-sqlalchemy


【解决方案1】:

defaultonupdate 在 Python 中完全由客户端处理,因此无法从数据库中反映出来。见"Limitations of Reflection"。如果是default,您可以使用server_default

class User(db.Model):
    ...
    created_at = db.Column(db.DateTime,
                           server_default=text("now() at time zone 'UTC'"))

对于onupdate,您必须编写一个数据库触发器并使用server_onupdate=FetchedValue()

另一方面,您可以避免所有这些,只需将模型与应用程序代码分离到一个模块中,供您的 Flask 应用程序和脚本使用。这当然会涉及更多,因为您必须使用 vanilla SQLAlchemy 声明性而不是 Flask-SQLAlchemy 的自定义 db.Model 基础。或者,您可以使用 custom commands 和 Flask 来实现您的脚本,这将允许使用 Flask-SQLAlchemy 扩展。

【讨论】:

    猜你喜欢
    • 2011-04-23
    • 2017-10-06
    • 2015-11-17
    • 1970-01-01
    • 1970-01-01
    • 2013-05-14
    • 1970-01-01
    • 1970-01-01
    • 2017-03-03
    相关资源
    最近更新 更多