sqlalchemy 表架构自动加载

Question

我正在创建一个 sql 炼金术表，如下所示：

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

我必须使用 autoload false 因为表可能存在也可能不存在（并且该代码必须在创建表之前运行）

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

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

错误; 这是可以理解的，因为表尚未加载。

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

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

SnapshotTable._autoload(metadata, None, None)

但这对我来说似乎不正确......还有其他想法或想法吗？

谢谢

Answer 1

我昨晚刚刚处理这个问题，结果发现您所需要做的就是借助metadat.reflect. 这与@fgblomqvist 的解决方案非常相似。主要区别在于您不必重新创建表。从本质上讲，以下内容应该有所帮助：

SnapshotTable.metadata.reflect(extend_existing=True, only=['mytable'])

这里的无名英雄就是extend_existing参数。它基本上确保SnapshotTable重新加载相关的架构和其他信息。这里使用该参数only来限制检索的信息量。如果您正在处理大型数据库，这将为您节省大量时间

我希望这在未来能发挥作用。

Answer 2

首先声明表模型：

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。

Answer 3

我想问题出在未反映的元数据上。您可以尝试在执行任何查询之前使用此调用的方法加载元数据：

metadata.reflect() 

它将重新加载表的定义，因此框架将知道如何构建正确的SELECT。然后打电话

if SnapshotTable.exists :
     SnapshotTable._init_existing()