python – sqlalchemy表架构自动加载

2023年3月24日 407次阅读

我正在创建一个像这样的SQL炼金术表：

myEngine = self.get_my_engine() # creates engine
metadata = MetaData(bind=myEngine)
SnapshotTable = Table("mytable", metadata, autoload=False, schema="my schema")

我必须使用自动加载假,因为表可能存在或可能不存在(并且该代码必须在创建表之前运行)

问题是,如果我使用autoload = False,当我尝试查询表(在由另一个进程创建之后)执行session.query(SnapshotTable)时,我得到一个：

InvalidRequestError: Query contains no columns with which to SELECT from.

错误;这是可以理解的,因为该表尚未加载.

我的问题是：如何在使用autoload = False定义表元数据后“加载”表元数据.

我查看了schema.py代码,似乎我可以这样做：

SnapshotTable._autoload(metadata, None, None)

但这对我来说并不合适……任何其他想法或想法？

谢谢

最佳答案 首先声明表模型：

class MyTable(Base):
    __table__ = Table('mytable', metadata)

或直接：

MyTable = Table("mytable", metadata)

然后,一旦准备加载它,请调用：

Table('mytable', metadata, autoload_with=engine, extend_existing=True)

其中的关键是extend_existing = True.

所有功劳都归功于SQLAlchemy邮件列表中的Mike Bayer.

点赞