Expand description
SQL purification.
See the crate-level documentation for details.
Modules§
- error 🔒
- mysql
- MySQL utilities for SQL purification.
- postgres
- Postgres utilities for SQL purification.
- references 🔒
- source_
preparation 🔒 - sql_
server
Structs§
- Create
Source 🔒Preparation - CsrAvro
Preparation 🔒 - CsrProtobuf
Preparation 🔒 - Expr
Contains 🔒Temporal Visitor - Determines whether the AST involves
mz_now(). - Glue
Avro 🔒Preparation - MzNow
Purifier 🔒Visitor - Prepared
Create 🔒Source - Purified
Source Export - Requested
Source 🔒Export - Schema
- Schema
With 🔒References - Result of fetching a schema, including any referenced schemas.
- Source
Preparation - Statement-local external results, reusable only for matching current requests.
- Source
Preparation Request - An external request derived from the current catalog and submitted statement.
- Source
Preparation Response - An external completion whose success or failure must be checked against current inputs.
- Table
From 🔒Source Preparation
Enums§
- Alter
Source 🔒Preparation - Catalog-derived inputs of upstream reads for
ALTER SOURCE ... ADD SUBSOURCESandREFRESH REFERENCES. - Filter
Constraints 🔒 - Prepared
Source 🔒Connection - Purified
Export Details - Purified
Statement - Source
Format 🔒Options - Source
Preparation Status - The result of resolving source preparation against a catalog.
- Source
Reference 🔒Policy - Defines whether purification should enforce that at least one valid source reference is provided on the provided statement.
- Statement
Source - The existing source a statement drives, and how the statement uses it.
Constants§
Functions§
- compile_
proto 🔒 - Collect protobuf message descriptor from CSR and compile the descriptor.
- execute_
alter_ 🔒source_ preparation - execute_
create_ 🔒source_ preparation - execute_
table_ 🔒from_ source_ preparation - finish_
table_ 🔒from_ source - for_
each_ 🔒format - Runs a function on each format within the format specifier.
- generate_
progress_ subsource_ statement - Generates a progress subsource, choosing an available name in the supplied catalog.
- 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. - prepare_
alter_ 🔒source - prepare_
csr_ 🔒connection_ avro - prepare_
csr_ 🔒connection_ proto - prepare_
glue_ 🔒connection_ avro - prepare_
table_ 🔒from_ source - purify_
alter_ 🔒source_ add_ subsources - purify_
alter_ 🔒source_ refresh_ references - purify_
create_ materialized_ view_ options - Purifies a CREATE MATERIALIZED VIEW statement. Additionally, it adjusts
resolved_idsif 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 ONcomments into all Avro formats that are using a schema registry by finding all SQLCOMMENTs that are attached to the sink’s underlying materialized view (as well as any types referenced by that underlying materialized view). - 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
- statement_
source - Resolves the existing source that
stmtdrives, mirroring how the purification paths below resolve it themselves. - 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.