SQLAlchemy Core 对表间公共列进行重复数据删除

Question

假设我要创建以下三个表：

a = db.Table(
    'a', metadata,
    db.Column('id', db.Integer, nullable=False, primary_key=True),
    db.Column('created', server_default=func.now()),
    db.Column('updated', server_default=func.now(), onupdate=func.current_timestamp()),

    db.Column('unique_to_a', db.INTEGER, nullable=True)
)

b = db.Table(
    'b', metadata,
    db.Column('id', db.Integer, nullable=False, primary_key=True),
    db.Column('created', server_default=func.now()),
    db.Column('updated', server_default=func.now(), onupdate=func.current_timestamp()),

    db.Column('unique_to_b', db.INTEGER, nullable=True)
)

c = db.Table(
    'c', metadata,
    db.Column('id', db.Integer, nullable=False, primary_key=True),
    db.Column('created', server_default=func.now()),
    db.Column('updated', server_default=func.now(), onupdate=func.current_timestamp()),


    db.Column('a_id', db.Integer, db.ForeignKey('a.id'), index=True, nullable=True),
    db.Column('unique_to_c', db.INTEGER, nullable=True)
)

id所有三个（ 、created和）之间都有公共列updated，也有各自独有的列。

有没有一种简单的方法来创建可以包含所有共享列的基表？

例如类似的东西

base_table = db.Table(
    'base', metadata,
    db.Column('id', db.Integer, nullable=False, primary_key=True),
    db.Column('created', server_default=func.now()),
    db.Column('updated', server_default=func.now(), onupdate=func.current_timestamp()),
)

a = db.Table(
    'a', metadata,
    base_table,

    db.Column('unique_to_a', db.INTEGER, nullable=True)
)

我们更愿意在 SQLAlchemy Core 中完成这一切（即不使用 ORM）。

我们之前使用过deepcopy( from copy import deepcopy)，但我们认为必须有更好的方法来在表之间共享列。

Answer 1

据我所知，Table不能继承，但declarative模型可以，您可以利用它来创建表对象：

engine = create_engine("sqlite://")
Base = declarative_base()
Base.metadata.bind = engine

class BaseColumn(object):
    id = Column('id', Integer, nullable=False, primary_key=True)
    created = Column('created', server_default=func.now())
    updated = Column('updated', server_default=func.now(), onupdate=func.current_timestamp())

class A(Base, BaseColumn):
    __tablename__ = "a"
    a_column = Column('unique_to_a', INTEGER, nullable=True)


print `A.__table__`

输出：

Table('a', MetaData(bind=Engine(sqlite://)), Column('id', Integer(), table=<a>, primary_key=True, nullable=False), Column('created', NullType(), table=<a>, server_default=DefaultClause(<sqlalchemy.sql.functions.now at 0x105bce490; now>, for_update=False)), Column('updated', NullType(), table=<a>, onupdate=ColumnDefault(<sqlalchemy.sql.functions.current_timestamp at 0x105bce750; current_timestamp>), server_default=DefaultClause(<sqlalchemy.sql.functions.now at 0x105bce610; now>, for_update=False)), Column('unique_to_a', INTEGER(), table=<a>), schema=None)