Python SQLAlchemy : Reflecting the database breaks default/onupdate methods?

Question

我有两个独立的 SQLAlchemy 接口(interface)连接到 Postgres 数据库。在 Flask 应用程序的上下文中，第一个接口(interface)包含此模型:

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)

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

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_at 和 updated_at 字段已适当更新。

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

我的问题:

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

Answer 1

default 和 onupdate 在 Python 中完全由客户端处理，因此无法从数据库反射(reflect)出来。参见 "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 扩展。