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.

Structs

• ExprContainsTemporalVisitor 🔒
  Determines whether the AST involves mz_now().
• MzNowPurifierVisitor 🔒
• PurifiedSourceExport
• RequestedSourceExport 🔒
• Schema

Enums

• PurifiedExportDetails
• PurifiedStatement
• 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

• add_materialize_comments 🔒
  Updates the CREATE SINK statement with materialize comments
• compile_proto 🔒
  Collect protobuf message descriptor from CSR and compile the descriptor.
• 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 🔒
  Equivalent to purify_create_source but for AlterSourceStatement.
• 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_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_gen 🔒
  Generates appropriate source exports for a set of external references to export from a source.
• 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.