Module pure

SQL purification.

See the crate-level documentation for details.

Modules

error 🔒

mysql

MySQL utilities for SQL purification.

postgres

Postgres utilities for SQL purification.

references 🔒

sql_server

Structs

ExprContainsTemporalVisitor 🔒

Determines whether the AST involves mz_now().

MzNowPurifierVisitor 🔒

PurifiedSourceExport

RequestedSourceExport 🔒

Schema

Enums

PurifiedExportDetails

PurifiedStatement

SourceFormatOptions 🔒

SourceReferencePolicy 🔒

Defines whether purification should enforce that at least one valid source reference is provided on the provided statement.

Constants

MZ_NOW_NAME 🔒

MZ_NOW_SCHEMA 🔒

Functions

compile_proto 🔒

Collect protobuf message descriptor from CSR and compile the descriptor.

for_each_format 🔒

Runs a function on each format within the format specifier.

generate_subsource_statements

get_remote_csr_schema 🔒

get_schema_with_strategy 🔒

materialized_view_option_contains_temporal

Returns true if the MaterializedViewOption either already involves mz_now() or will involve after purification.

purify_alter_source 🔒

On success, returns the details on new subsources and updated ‘options’ that sequencing expects for handling ALTER SOURCE statements.

purify_alter_source_add_subsources 🔒

Equivalent to purify_create_source but for AlterSourceStatement.

purify_alter_source_refresh_references 🔒

purify_create_materialized_view_options

Purifies a CREATE MATERIALIZED VIEW statement. Additionally, it adjusts resolved_ids if references to ids appear or disappear during the purification.

purify_create_sink 🔒

Checks that the sink described in the statement can connect to its external resources.

purify_create_sink_avro_doc_on_options 🔒

Injects DOC ON comments into all Avro formats that are using a schema registry by finding all SQL COMMENTs that are attached to the sink’s underlying materialized view (as well as any types referenced by that underlying materialized view).

purify_create_source 🔒

purify_create_table_from_source 🔒

purify_csr_connection_avro 🔒

purify_csr_connection_proto 🔒

purify_source_format 🔒

purify_source_format_single 🔒

purify_statement

Purifies a statement, removing any dependencies on external state.

source_export_name_gen 🔒

Generates a subsource name by prepending source schema name if present

validate_source_export_names 🔒

Validates the requested subsources do not have name conflicts with each other and that the same upstream table is not referenced multiple times.