python - 如何向 sqlalchemy 中的表添加自定义的任意选项?

标签 python sqlalchemy cockroachdb

我正在尝试使用 sqlalchemy 的 declarative_base 创建一个表,我想添加 cockroachdbINTERLEAVE IN PARENT 选项:

CREATE TABLE orders (
    customer INT,
    id INT,
    total DECIMAL(20, 5),
    PRIMARY KEY (customer, id),
    CONSTRAINT fk_customer FOREIGN KEY (customer) REFERENCES customers
  ) INTERLEAVE IN PARENT customers (customer);

如何将它添加到 DDL 中?

最佳答案

等待 cockroachdb 方言的正式实现,您可以自己扩充它以实现所需的选项:

from sqlalchemy import Table, util
from sqlalchemy.schema import CreateTable
from sqlalchemy.ext.compiler import compiles

Table.argument_for("cockroachdb", "interleave_in_parent", None)

@compiles(CreateTable, "cockroachdb")
def compile_create_table(create, compiler, **kw):
    preparer = compiler.preparer
    stmt = compiler.visit_create_table(create, **kw)
    cockroachdb_opts = create.element.dialect_options["cockroachdb"]
    interleave = cockroachdb_opts.get("interleave_in_parent")

    if interleave:
        p_tbl, c_cols = interleave

        parent_tbl = preparer.format_table(p_tbl)
        child_cols = ", ".join([ 
            preparer.quote(c)
            if isinstance(c, util.string_types) else
            preparer.format_column(c)
            for c in c_cols
        ])

        stmt = stmt.rstrip()  # Prettier output, remove newlines
        stmt = f"{stmt} INTERLEAVE IN PARENT {parent_tbl} ({child_cols})\n\n"

    return stmt

然后像这样使用它:

class Customer(Base):
    ...

class Order(Base):
    customer = Column(...)
    ...
    __table_args__ = {
        "cockroachdb_interleave_in_parent": (Customer.__table__, [customer])
    }

关于python - 如何向 sqlalchemy 中的表添加自定义的任意选项?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56662626/

相关文章:

python - 如何从pyspark中的数组中提取元素

python - 如何在 SQLAlchemy 1.0 中使用 `__declare_last__`?

CockroachDB 两阶段提交有阻塞还是无阻塞?

cockroachdb - 每个节点是否需要能够保存完整的数据库?

cockroachdb - 如何删除 CockroachDB 中的所有数据库?

python - 在 Ubuntu 12.04 上设置 python 内存限制

python - 数组组合值

Python脚本读取一个目录中的多个excel文件并将它们转换为另一个目录中的.csv文件

Python Pandas SQL 风格左连接两个类列表

python - Flask-SQLAlchemy hybrid_property 中的多对多有序关系