Module mz_sql::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 🔒

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.