Module postgres 

Postgres utilities for SQL purification.

Modules

privileges 🔒

replica_identity 🔒

Structs

PostgresExportStatementValues 🔒

PurifiedSourceExports 🔒

Functions

build_element_cast_expr 🔒

Build the element cast expression for container types (Array, List, Map, Range). The element expression operates on a single-column input row containing the text-encoded element at column 0.

generate_column_casts 🔒

generate_create_subsource_statements

generate_source_export_statement_values 🔒

map_column_refs 🔒

Map a list of column references to a map of table oids to column names.

pg_type_to_cast_func 🔒

Map a PG type to the corresponding CastFunc variant. Returns:

purify_source_exports 🔒

resolve_pg_type_to_scalar_type 🔒

Resolve a PG type to its corresponding SqlScalarType via the catalog.

validate_requested_references_privileges 🔒

Ensure that we have select permissions on all tables; we have to do this before we start snapshotting because if we discover we cannot COPY from a table while snapshotting, we break the entire source.