1

我有一组动态数据库表（带有 PostGIS 的 Postgres 9.3），我正在使用 python 元类进行映射：

cls = type(str(tablename), (db.Model,), {'__tablename__':tablename})

其中，db.Model 是通过 flask-sqlalchemy 生成的 db 对象，而 tablename 是一些 unicode。然后将 cls 添加到应用程序范围的字典current_app.class_references（使用 Flask 的 current_app）以避免尝试多次实例化该类。

每个表都包含一个几何列，wkb_geometry存储在 Well Known Binary 中。我想将这些映射到使用geoalchemy2，最终目标是检索 GeoJSON。

如果我先验地声明该表，我将使用：

class GeoPoly():
    __tablename__ = 'somename'
    wkb_geometry = db.Column(Geometry("POLYGON"))
    #more columns...

由于我试图动态地执行此操作，因此我需要能够cls1使用已知类型覆盖反射。

尝试：

  1. 使用反射覆盖语法显式定义列。

    cls = type(str(tablename), (db.Model,), {'__tablename__':tablename,
    'wkb_geometry':db.Column(Geometry("POLYGON"))})

它在重新启动时返回以下内容，即尚未实例化该类： InvalidRequestError: Table 'tablename' is already defined for this MetaData instance。指定 'extend_existing=True' 以重新定义现有 Table 对象上的选项和列

  1. 对上面定义的类使用 mixins（无表名）：

    cls = type(str(tablename), (GeoPoly, db.Model), {'__tablename__':tablename})

再次元数据问题。

  1. 类实例化后覆盖列定义属性：

    cls = type(str(tablename), (db.Model,), {'__tablename__':tablename})
current_app.class_references[tablename] = cls
cls.wkb_geometry = db.Column(Geometry("POLYGON"))

结果是：

InvalidRequestError：在属性“wkb_geometry”下将列 tablename.wkb_geometry 与列 tablename.wkb_geometry 隐式组合。请为这些同名列显式配置一个或多个属性。

是否可以使用元数据构造来支持动态反射**和* *覆盖一个已知的列将在所有表上可用？

4

2 回答 2

0

我不确定我是否完全按照你在做什么，但我过去在我自己的__init__ 方法中覆盖了反射列，该方法继承自DeclarativeMeta. 每当使用新基类时，它都会检查“wkb_geometry”列名，并将其替换为您创建的（的副本）。

import sqlalchemy as sa
from sqlalchemy.ext.declarative import DeclarativeMeta, declarative_base

wkb_geometry = db.Column(Geometry("POLYGON"))

class MyMeta(DeclarativeMeta):
    def __init__(cls, clsname, parents, dct):
        for key, val in dct.iteritems():
            if isinstance(sa.Column) and key is 'wkb_geometry':
                dct[key] = wkb_geometry.copy()

MyBase = declarative_base(metaclass=MyMeta)

cls = type(str(tablename), (MyBase,), {'__tablename__':tablename})

这可能不完全适合您，但这是一个想法。例如，您可能需要添加db.Model到MyBase元组中。

于 2014-09-29T15:38:18.007 回答
0

这是我用来自定义特定列的同时依赖于autoload其他所有内容的方法。Base下面的代码假定一个名为 的表的现有声明性对象my_table。它加载所有列的元数据，但覆盖名为 的列的定义polygon：

class MyTable(Base):
    __tablename__ = 'my_table'
    __table_args__ = (Column(name='polygon', type=Geometry("POLYGON"),
                      {'autoload':True})

构造函数的其他参数Table可以在字典中提供。请注意，字典必须出现在列表的最后！

SQLAlchemy 文档使用混合方法__table__提供了更多详细信息和示例。

于 2019-09-29T06:38:51.210 回答