airflow.providers.postgres.dialects.postgres

类

PostgresDialect

Postgres 方言实现。

模块内容

class airflow.providers.postgres.dialects.postgres.PostgresDialect(hook, **kwargs)[source]

Bases: airflow.providers.common.sql.dialects.dialect.Dialect

Postgres 方言实现。

property name: str[source]
get_primary_keys(table, schema=None)[source]

获取表的 primary key。

参数:

  • table (str) – 目标表的名称

  • schema (str | None) – 目标 schema 的名称，默认为 public

返回值:

Primary key 列列表

返回类型:

list[str] | None

generate_replace_sql(table, values, target_fields, **kwargs)[source]

生成 REPLACE SQL 语句。

参数:

  • table – 目标表的名称

  • values – 要插入到表中的行

  • target_fields – 要填充到表中的列的名称

  • replace – 是替换而不是插入

  • replace_index – 用作 ON CONFLICT 子句索引的列或列名列表

返回值:

生成的 INSERT 或 REPLACE SQL 语句

返回类型:

str

这条目有帮助吗？