mz_sql_pretty/

doc.rs

// Copyright Materialize, Inc. and contributors. All rights reserved.
//
// Use of this software is governed by the Business Source License
// included in the LICENSE file.
//
// As of the Change Date specified in that file, in accordance with
// the Business Source License, use of this software will be governed
// by the Apache License, Version 2.0.

//! Functions that convert SQL AST nodes to pretty Docs.

use itertools::Itertools;
use mz_sql_parser::ast::display::{AstDisplay, FormatMode, escape_single_quote_string};
use mz_sql_parser::ast::*;
use pretty::{Doc, RcDoc};

use crate::util::{
    bracket, bracket_doc, comma_separate, comma_separated, intersperse_line_nest, nest,
    nest_comma_separate, nest_title, title_comma_separate,
};
use crate::{Pretty, TAB};

impl Pretty {
    // Use when we don't know what to do.
    pub(crate) fn doc_display<'a, T: AstDisplay>(&self, v: &T, _debug: &str) -> RcDoc<'a, ()> {
        #[cfg(test)]
        eprintln!(
            "UNKNOWN PRETTY TYPE in {}: {}, {}",
            _debug,
            std::any::type_name::<T>(),
            v.to_ast_string_simple()
        );
        self.doc_display_pass(v)
    }

    // Use when the AstDisplay trait is what we want.
    fn doc_display_pass<'a, T: AstDisplay>(&self, v: &T) -> RcDoc<'a, ()> {
        RcDoc::text(v.to_ast_string(self.config.format_mode))
    }

    pub(crate) fn doc_create_source<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateSourceStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = Vec::new();
        let title = format!(
            "CREATE SOURCE{}",
            if v.if_not_exists {
                " IF NOT EXISTS"
            } else {
                ""
            }
        );
        let mut doc = self.doc_display_pass(&v.name);
        let mut names = Vec::new();
        names.extend(v.col_names.iter().map(|name| self.doc_display_pass(name)));
        names.extend(v.key_constraint.iter().map(|kc| self.doc_display_pass(kc)));
        if !names.is_empty() {
            doc = nest(doc, bracket("(", comma_separated(names), ")"));
        }
        docs.push(nest_title(title, doc));
        if let Some(cluster) = &v.in_cluster {
            docs.push(nest_title("IN CLUSTER", self.doc_display_pass(cluster)));
        }
        docs.push(nest_title("FROM", self.doc_display_pass(&v.connection)));
        if let Some(format) = &v.format {
            docs.push(self.doc_format_specifier(format));
        }
        if !v.include_metadata.is_empty() {
            docs.push(nest_title(
                "INCLUDE",
                comma_separate(|im| self.doc_display_pass(im), &v.include_metadata),
            ));
        }
        if let Some(envelope) = &v.envelope {
            docs.push(nest_title("ENVELOPE", self.doc_display_pass(envelope)));
        }
        if let Some(references) = &v.external_references {
            docs.push(self.doc_external_references(references));
        }
        if let Some(progress) = &v.progress_subsource {
            docs.push(nest_title(
                "EXPOSE PROGRESS AS",
                self.doc_display_pass(progress),
            ));
        }
        if !v.with_options.is_empty() {
            docs.push(bracket(
                "WITH (",
                comma_separate(|wo| self.doc_display_pass(wo), &v.with_options),
                ")",
            ));
        }
        RcDoc::intersperse(docs, Doc::line()).group()
    }

    pub(crate) fn doc_create_webhook_source<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateWebhookSourceStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = Vec::new();

        let mut title = "CREATE ".to_string();
        if v.is_table {
            title.push_str("TABLE");
        } else {
            title.push_str("SOURCE");
        }
        if v.if_not_exists {
            title.push_str(" IF NOT EXISTS");
        }
        docs.push(nest_title(title, self.doc_display_pass(&v.name)));

        // IN CLUSTER (only for sources, not tables)
        if !v.is_table {
            if let Some(cluster) = &v.in_cluster {
                docs.push(nest_title("IN CLUSTER", self.doc_display_pass(cluster)));
            }
        }

        docs.push(RcDoc::text("FROM WEBHOOK"));
        docs.push(nest_title(
            "BODY FORMAT",
            self.doc_display_pass(&v.body_format),
        ));

        if !v.include_headers.mappings.is_empty() || v.include_headers.column.is_some() {
            let mut header_docs = Vec::new();

            // Individual header mappings
            for mapping in &v.include_headers.mappings {
                header_docs.push(self.doc_display_pass(mapping));
            }

            // INCLUDE HEADERS column
            if let Some(filters) = &v.include_headers.column {
                if filters.is_empty() {
                    header_docs.push(RcDoc::text("INCLUDE HEADERS"));
                } else {
                    header_docs.push(bracket(
                        "INCLUDE HEADERS (",
                        comma_separate(|f| self.doc_display_pass(f), filters),
                        ")",
                    ));
                }
            }

            if !header_docs.is_empty() {
                docs.extend(header_docs);
            }
        }

        if let Some(check) = &v.validate_using {
            docs.push(self.doc_webhook_check(check));
        }

        RcDoc::intersperse(docs, Doc::line()).group()
    }

    fn doc_webhook_check<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateWebhookSourceCheck<T>,
    ) -> RcDoc<'a> {
        let mut inner = Vec::new();

        if let Some(options) = &v.options {
            let mut with_items = Vec::new();

            for header in &options.headers {
                with_items.push(self.doc_display_pass(header));
            }
            for body in &options.bodies {
                with_items.push(self.doc_display_pass(body));
            }
            for secret in &options.secrets {
                with_items.push(self.doc_display_pass(secret));
            }

            if !with_items.is_empty() {
                inner.push(bracket("WITH (", comma_separated(with_items), ")"));
                inner.push(RcDoc::line());
            }
        }

        inner.push(self.doc_display_pass(&v.using));

        bracket_doc(
            RcDoc::text("CHECK ("),
            RcDoc::concat(inner),
            RcDoc::text(")"),
            RcDoc::line(),
        )
    }

    pub(crate) fn doc_create_table<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateTableStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = Vec::new();

        // CREATE [TEMPORARY] TABLE [IF NOT EXISTS] name
        let mut title = "CREATE ".to_string();
        if v.temporary {
            title.push_str("TEMPORARY ");
        }
        title.push_str("TABLE");
        if v.if_not_exists {
            title.push_str(" IF NOT EXISTS");
        }

        // Table name and columns/constraints
        let mut col_items = Vec::new();
        col_items.extend(v.columns.iter().map(|c| self.doc_display_pass(c)));
        col_items.extend(v.constraints.iter().map(|c| self.doc_display_pass(c)));

        let table_def = nest(
            self.doc_display_pass(&v.name),
            bracket("(", comma_separated(col_items), ")"),
        );
        docs.push(nest_title(title, table_def));

        // WITH options
        if !v.with_options.is_empty() {
            docs.push(bracket(
                "WITH (",
                comma_separate(|wo| self.doc_display_pass(wo), &v.with_options),
                ")",
            ));
        }

        RcDoc::intersperse(docs, Doc::line()).group()
    }

    pub(crate) fn doc_create_table_from_source<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateTableFromSourceStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = Vec::new();

        // CREATE TABLE [IF NOT EXISTS] name
        let mut title = "CREATE TABLE".to_string();
        if v.if_not_exists {
            title.push_str(" IF NOT EXISTS");
        }

        let mut table_def = self.doc_display_pass(&v.name);

        let has_columns_or_constraints = match &v.columns {
            TableFromSourceColumns::NotSpecified => false,
            _ => true,
        } || !v.constraints.is_empty();

        if has_columns_or_constraints {
            let mut items = Vec::new();

            match &v.columns {
                TableFromSourceColumns::NotSpecified => {}
                TableFromSourceColumns::Named(cols) => {
                    items.extend(cols.iter().map(|c| self.doc_display_pass(c)));
                }
                TableFromSourceColumns::Defined(cols) => {
                    items.extend(cols.iter().map(|c| self.doc_display_pass(c)));
                }
            }

            items.extend(v.constraints.iter().map(|c| self.doc_display_pass(c)));

            if !items.is_empty() {
                table_def = nest(table_def, bracket("(", comma_separated(items), ")"));
            }
        }

        docs.push(nest_title(title, table_def));

        // FROM SOURCE
        let mut from_source = nest_title("FROM SOURCE", self.doc_display_pass(&v.source));
        if let Some(reference) = &v.external_reference {
            from_source = nest(
                from_source,
                bracket("(REFERENCE = ", self.doc_display_pass(reference), ")"),
            );
        }
        docs.push(from_source);

        if let Some(format) = &v.format {
            docs.push(self.doc_format_specifier(format));
        }

        if !v.include_metadata.is_empty() {
            docs.push(nest_title(
                "INCLUDE",
                comma_separate(|im| self.doc_display_pass(im), &v.include_metadata),
            ));
        }

        if let Some(envelope) = &v.envelope {
            docs.push(nest_title("ENVELOPE", self.doc_display_pass(envelope)));
        }

        if !v.with_options.is_empty() {
            docs.push(bracket(
                "WITH (",
                comma_separate(|wo| self.doc_display_pass(wo), &v.with_options),
                ")",
            ));
        }

        RcDoc::intersperse(docs, Doc::line()).group()
    }

    pub(crate) fn doc_create_connection<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateConnectionStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = Vec::new();

        let mut title = "CREATE CONNECTION".to_string();
        if v.if_not_exists {
            title.push_str(" IF NOT EXISTS");
        }
        docs.push(nest_title(title, self.doc_display_pass(&v.name)));

        let connection_with_values = nest(
            RcDoc::concat([
                RcDoc::text("TO "),
                self.doc_display_pass(&v.connection_type),
            ]),
            bracket(
                "(",
                comma_separate(|val| self.doc_display_pass(val), &v.values),
                ")",
            ),
        );
        docs.push(connection_with_values);

        if !v.with_options.is_empty() {
            docs.push(bracket(
                "WITH (",
                comma_separate(|wo| self.doc_display_pass(wo), &v.with_options),
                ")",
            ));
        }

        RcDoc::intersperse(docs, Doc::line()).group()
    }

    pub(crate) fn doc_create_sink<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateSinkStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = Vec::new();

        // CREATE SINK [IF NOT EXISTS] [name]
        let mut title = "CREATE SINK".to_string();
        if v.if_not_exists {
            title.push_str(" IF NOT EXISTS");
        }

        if let Some(name) = &v.name {
            docs.push(nest_title(title, self.doc_display_pass(name)));
        } else {
            docs.push(RcDoc::text(title));
        }

        if let Some(cluster) = &v.in_cluster {
            docs.push(nest_title("IN CLUSTER", self.doc_display_pass(cluster)));
        }

        docs.push(nest_title("FROM", self.doc_display_pass(&v.from)));
        docs.push(nest_title("INTO", self.doc_display_pass(&v.connection)));

        if let Some(format) = &v.format {
            docs.push(self.doc_format_specifier(format));
        }

        if let Some(envelope) = &v.envelope {
            docs.push(nest_title("ENVELOPE", self.doc_display_pass(envelope)));
        }

        if let Some(mode) = &v.mode {
            docs.push(nest_title("MODE", self.doc_display_pass(mode)));
        }

        if !v.with_options.is_empty() {
            docs.push(bracket(
                "WITH (",
                comma_separate(|wo| self.doc_display_pass(wo), &v.with_options),
                ")",
            ));
        }

        RcDoc::intersperse(docs, Doc::line()).group()
    }

    pub(crate) fn doc_create_subsource<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateSubsourceStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = Vec::new();

        // CREATE SUBSOURCE [IF NOT EXISTS] name
        let mut title = "CREATE SUBSOURCE".to_string();
        if v.if_not_exists {
            title.push_str(" IF NOT EXISTS");
        }

        // Table name with columns/constraints
        let mut col_items = Vec::new();
        col_items.extend(v.columns.iter().map(|c| self.doc_display_pass(c)));
        col_items.extend(v.constraints.iter().map(|c| self.doc_display_pass(c)));

        let table_def = nest(
            self.doc_display_pass(&v.name),
            bracket("(", comma_separated(col_items), ")"),
        );
        docs.push(nest_title(title, table_def));

        // OF SOURCE
        if let Some(of_source) = &v.of_source {
            docs.push(nest_title("OF SOURCE", self.doc_display_pass(of_source)));
        }

        // WITH options
        if !v.with_options.is_empty() {
            docs.push(bracket(
                "WITH (",
                comma_separate(|wo| self.doc_display_pass(wo), &v.with_options),
                ")",
            ));
        }

        RcDoc::intersperse(docs, Doc::line()).group()
    }

    pub(crate) fn doc_create_cluster<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateClusterStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = Vec::new();

        // CREATE CLUSTER [IF NOT EXISTS] name
        let mut title = "CREATE CLUSTER".to_string();
        if v.if_not_exists {
            title.push_str(" IF NOT EXISTS");
        }
        docs.push(nest_title(&title, self.doc_display_pass(&v.name)));

        // OPTIONS (...)
        if !v.options.is_empty() {
            docs.push(bracket(
                "(",
                comma_separate(|o| self.doc_display_pass(o), &v.options),
                ")",
            ));
        }

        // FEATURES (...)
        if !v.features.is_empty() {
            docs.push(bracket(
                "FEATURES (",
                comma_separate(|f| self.doc_display_pass(f), &v.features),
                ")",
            ));
        }

        RcDoc::intersperse(docs, Doc::line()).group()
    }

    pub(crate) fn doc_create_cluster_replica<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateClusterReplicaStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = Vec::new();

        // CREATE CLUSTER REPLICA [IF NOT EXISTS] cluster.replica
        let mut title = "CREATE CLUSTER REPLICA".to_string();
        if v.if_not_exists {
            title.push_str(" IF NOT EXISTS");
        }
        let replica_name = RcDoc::concat([
            self.doc_display_pass(&v.of_cluster),
            RcDoc::text("."),
            self.doc_display_pass(&v.definition.name),
        ]);
        docs.push(nest_title(&title, replica_name));

        // OPTIONS (...)
        docs.push(bracket(
            "(",
            comma_separate(|o| self.doc_display_pass(o), &v.definition.options),
            ")",
        ));

        RcDoc::intersperse(docs, Doc::line()).group()
    }

    pub(crate) fn doc_create_network_policy<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateNetworkPolicyStatement<T>,
    ) -> RcDoc<'a> {
        let docs = vec![
            // CREATE NETWORK POLICY name
            nest_title("CREATE NETWORK POLICY", self.doc_display_pass(&v.name)),
            // OPTIONS (...)
            bracket(
                "(",
                comma_separate(|o| self.doc_display_pass(o), &v.options),
                ")",
            ),
        ];

        RcDoc::intersperse(docs, Doc::line()).group()
    }

    pub(crate) fn doc_create_index<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateIndexStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = Vec::new();

        // CREATE [DEFAULT] INDEX [IF NOT EXISTS] [name]
        let mut title = "CREATE".to_string();
        if v.key_parts.is_none() {
            title.push_str(" DEFAULT");
        }
        title.push_str(" INDEX");
        if v.if_not_exists {
            title.push_str(" IF NOT EXISTS");
        }

        if let Some(name) = &v.name {
            // A bare `in` index name re-lexes as the start of the optional
            // `IN CLUSTER` clause, so force it quoted (matching the
            // `CreateIndexStatement` AstDisplay impl). `in` is fine bare in a
            // required-name position, so this isn't a `can_be_printed_bare` case.
            let name_doc = if name.as_str().eq_ignore_ascii_case("in") {
                RcDoc::text(format!("\"{}\"", name.as_str()))
            } else {
                self.doc_display_pass(name)
            };
            docs.push(nest_title(title, name_doc));
        } else {
            docs.push(RcDoc::text(title));
        }

        // IN CLUSTER
        if let Some(cluster) = &v.in_cluster {
            docs.push(nest_title("IN CLUSTER", self.doc_display_pass(cluster)));
        }

        // ON table_name [(key_parts)]
        let on_clause = if let Some(key_parts) = &v.key_parts {
            nest(
                self.doc_display_pass(&v.on_name),
                bracket(
                    "(",
                    comma_separate(|k| self.doc_display_pass(k), key_parts),
                    ")",
                ),
            )
        } else {
            self.doc_display_pass(&v.on_name)
        };
        docs.push(nest_title("ON", on_clause));

        // WITH options
        if !v.with_options.is_empty() {
            docs.push(bracket(
                "WITH (",
                comma_separate(|wo| self.doc_display_pass(wo), &v.with_options),
                ")",
            ));
        }

        RcDoc::intersperse(docs, Doc::line()).group()
    }

    fn doc_format_specifier<T: AstInfo>(&self, v: &FormatSpecifier<T>) -> RcDoc<'_> {
        match v {
            FormatSpecifier::Bare(format) => nest_title("FORMAT", self.doc_display_pass(format)),
            FormatSpecifier::KeyValue { key, value } => {
                let docs = vec![
                    nest_title("KEY FORMAT", self.doc_display_pass(key)),
                    nest_title("VALUE FORMAT", self.doc_display_pass(value)),
                ];
                RcDoc::intersperse(docs, Doc::line()).group()
            }
        }
    }

    fn doc_external_references<'a>(&'a self, v: &'a ExternalReferences) -> RcDoc<'a> {
        match v {
            ExternalReferences::SubsetTables(subsources) => bracket(
                "FOR TABLES (",
                comma_separate(|s| self.doc_display_pass(s), subsources),
                ")",
            ),
            ExternalReferences::SubsetSchemas(schemas) => bracket(
                "FOR SCHEMAS (",
                comma_separate(|s| self.doc_display_pass(s), schemas),
                ")",
            ),
            ExternalReferences::All => RcDoc::text("FOR ALL TABLES"),
        }
    }

    pub(crate) fn doc_copy<'a, T: AstInfo>(&'a self, v: &'a CopyStatement<T>) -> RcDoc<'a> {
        let relation = match &v.relation {
            CopyRelation::Named { name, columns } => {
                let mut relation = self.doc_display_pass(name);
                if !columns.is_empty() {
                    relation = bracket_doc(
                        nest(relation, RcDoc::text("(")),
                        comma_separate(|c| self.doc_display_pass(c), columns),
                        RcDoc::text(")"),
                        RcDoc::line_(),
                    );
                }
                RcDoc::concat([RcDoc::text("COPY "), relation])
            }
            CopyRelation::Select(query) => bracket("COPY (", self.doc_select_statement(query), ")"),
            CopyRelation::Subscribe(query) => bracket("COPY (", self.doc_subscribe(query), ")"),
        };
        let mut docs = vec![
            relation,
            RcDoc::concat([
                self.doc_display_pass(&v.direction),
                RcDoc::text(" "),
                self.doc_display_pass(&v.target),
            ]),
        ];
        if !v.options.is_empty() {
            docs.push(bracket(
                "WITH (",
                comma_separate(|o| self.doc_display_pass(o), &v.options),
                ")",
            ));
        }
        RcDoc::intersperse(docs, Doc::line()).group()
    }

    pub(crate) fn doc_subscribe<'a, T: AstInfo>(
        &'a self,
        v: &'a SubscribeStatement<T>,
    ) -> RcDoc<'a> {
        let doc = match &v.relation {
            SubscribeRelation::Name(name) => {
                let title = if v.relation.needs_explicit_to(matches!(
                    self.config.format_mode,
                    FormatMode::Simple | FormatMode::SimpleRedacted
                )) {
                    "SUBSCRIBE TO"
                } else {
                    "SUBSCRIBE"
                };
                nest_title(title, self.doc_display_pass(name))
            }
            SubscribeRelation::Query(query) => bracket("SUBSCRIBE (", self.doc_query(query), ")"),
        };
        let mut docs = vec![doc];
        if !v.options.is_empty() {
            docs.push(bracket(
                "WITH (",
                comma_separate(|o| self.doc_display_pass(o), &v.options),
                ")",
            ));
        }
        if let Some(as_of) = &v.as_of {
            docs.push(self.doc_as_of(as_of));
        }
        if let Some(up_to) = &v.up_to {
            docs.push(nest_title("UP TO", self.doc_expr(up_to)));
        }
        match &v.output {
            SubscribeOutput::Diffs => {}
            SubscribeOutput::WithinTimestampOrderBy { order_by } => {
                docs.push(nest_title(
                    "WITHIN TIMESTAMP ORDER BY ",
                    comma_separate(|o| self.doc_order_by_expr(o), order_by),
                ));
            }
            SubscribeOutput::EnvelopeUpsert { key_columns } => {
                docs.push(bracket(
                    "ENVELOPE UPSERT (KEY (",
                    comma_separate(|kc| self.doc_display_pass(kc), key_columns),
                    "))",
                ));
            }
            SubscribeOutput::EnvelopeDebezium { key_columns } => {
                docs.push(bracket(
                    "ENVELOPE DEBEZIUM (KEY (",
                    comma_separate(|kc| self.doc_display_pass(kc), key_columns),
                    "))",
                ));
            }
        }
        RcDoc::intersperse(docs, Doc::line()).group()
    }

    fn doc_as_of<'a, T: AstInfo>(&'a self, v: &'a AsOf<T>) -> RcDoc<'a> {
        let (title, expr) = match v {
            AsOf::At(expr) => ("AS OF", expr),
            AsOf::AtLeast(expr) => ("AS OF AT LEAST", expr),
        };
        nest_title(title, self.doc_expr(expr))
    }

    pub(crate) fn doc_create_view<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateViewStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = vec![];
        docs.push(RcDoc::text(format!(
            "CREATE{}{} VIEW{}",
            if v.if_exists == IfExistsBehavior::Replace {
                " OR REPLACE"
            } else {
                ""
            },
            if v.temporary { " TEMPORARY" } else { "" },
            if v.if_exists == IfExistsBehavior::Skip {
                " IF NOT EXISTS"
            } else {
                ""
            },
        )));
        docs.push(self.doc_view_definition(&v.definition));
        intersperse_line_nest(docs)
    }

    pub(crate) fn doc_create_materialized_view<'a, T: AstInfo>(
        &'a self,
        v: &'a CreateMaterializedViewStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = vec![];
        docs.push(RcDoc::text(format!(
            "CREATE{}{} MATERIALIZED VIEW{} {}",
            if v.if_exists == IfExistsBehavior::Replace {
                " OR REPLACE"
            } else {
                ""
            },
            if v.replacement_for.is_some() {
                " REPLACEMENT"
            } else {
                ""
            },
            if v.if_exists == IfExistsBehavior::Skip {
                " IF NOT EXISTS"
            } else {
                ""
            },
            v.name,
        )));
        if !v.columns.is_empty() {
            docs.push(bracket(
                "(",
                comma_separate(|c| self.doc_display_pass(c), &v.columns),
                ")",
            ));
        }
        if let Some(target) = &v.replacement_for {
            docs.push(RcDoc::text(format!(
                "FOR {}",
                target.to_ast_string_simple()
            )));
        }
        match (&v.in_cluster, &v.in_cluster_replica) {
            (Some(cluster), Some(replica)) => {
                docs.push(RcDoc::text(format!(
                    "IN CLUSTER {} REPLICA {}",
                    cluster.to_ast_string_simple(),
                    replica.to_ast_string_simple(),
                )));
            }
            (Some(cluster), None) => {
                docs.push(RcDoc::text(format!(
                    "IN CLUSTER {}",
                    cluster.to_ast_string_simple(),
                )));
            }
            (None, Some(replica)) => {
                docs.push(RcDoc::text(format!(
                    "IN REPLICA {}",
                    replica.to_ast_string_simple(),
                )));
            }
            (None, None) => {}
        }
        if !v.with_options.is_empty() {
            docs.push(bracket(
                "WITH (",
                comma_separate(|wo| self.doc_display_pass(wo), &v.with_options),
                ")",
            ));
        }
        docs.push(nest_title("AS", self.doc_query(&v.query)));
        // `AS OF` is internal syntax that follows the query; the generic AstDisplay
        // emits it, so we must too, otherwise it is silently dropped.
        if let Some(time) = &v.as_of {
            docs.push(RcDoc::text(format!("AS OF {time}")));
        }
        intersperse_line_nest(docs)
    }

    pub(crate) fn doc_create_role<'a>(&'a self, v: &'a CreateRoleStatement) -> RcDoc<'a> {
        let mut docs = vec![RcDoc::text(format!(
            "CREATE ROLE {}",
            v.name.to_ast_string_simple()
        ))];
        for option in &v.options {
            docs.push(self.doc_role_attribute(option));
        }
        intersperse_line_nest(docs)
    }

    pub(crate) fn doc_alter_role<'a, T: AstInfo>(
        &'a self,
        v: &'a AlterRoleStatement<T>,
    ) -> RcDoc<'a> {
        let mut docs = vec![RcDoc::text(format!(
            "ALTER ROLE {}",
            v.name.to_ast_string_simple()
        ))];
        match &v.option {
            AlterRoleOption::Attributes(attrs) => {
                for attr in attrs {
                    docs.push(self.doc_role_attribute(attr));
                }
            }
            // `SET`/`RESET` variables carry no password-like data, so the generic
            // AstDisplay is already lossless here.
            AlterRoleOption::Variable(var) => docs.push(self.doc_display_pass(var)),
        }
        intersperse_line_nest(docs)
    }

    /// Like the generic AstDisplay for `RoleAttribute`, but preserves the `PASSWORD`
    /// value instead of dropping it (the AstDisplay redaction is a global safety net
    /// for logs/catalog; a pretty-printer that round-trips user SQL must keep it).
    fn doc_role_attribute<'a>(&'a self, attr: &'a RoleAttribute) -> RcDoc<'a> {
        match attr {
            RoleAttribute::Password(Some(password)) => RcDoc::text(format!(
                "PASSWORD '{}'",
                escape_single_quote_string(password)
            )),
            RoleAttribute::Password(None) => RcDoc::text("PASSWORD NULL"),
            other => self.doc_display_pass(other),
        }
    }

    /// `DECLARE <name> CURSOR FOR <stmt>`. The inner statement is printed via the
    /// recursive doc printer (not the redacting AstDisplay fallback) so a secret
    /// it carries — e.g. `CURSOR FOR ALTER ROLE r PASSWORD '…'` — survives the
    /// round trip instead of becoming `'<REDACTED>'`.
    pub(crate) fn doc_declare<'a, T: AstInfo<NestedStatement = Statement<Raw>>>(
        &'a self,
        v: &'a DeclareStatement<T>,
    ) -> RcDoc<'a> {
        RcDoc::text(format!(
            "DECLARE {} CURSOR FOR ",
            v.name.to_ast_string_simple()
        ))
        .append(self.to_doc(&v.stmt))
    }

    /// `PREPARE <name> AS <stmt>`. Recurses into the inner statement for the same
    /// reason as [`Self::doc_declare`].
    pub(crate) fn doc_prepare<'a, T: AstInfo<NestedStatement = Statement<Raw>>>(
        &'a self,
        v: &'a PrepareStatement<T>,
    ) -> RcDoc<'a> {
        RcDoc::text(format!("PREPARE {} AS ", v.name.to_ast_string_simple()))
            .append(self.to_doc(&v.stmt))
    }

    fn doc_view_definition<'a, T: AstInfo>(&'a self, v: &'a ViewDefinition<T>) -> RcDoc<'a> {
        let mut docs = vec![RcDoc::text(v.name.to_string())];
        if !v.columns.is_empty() {
            docs.push(bracket(
                "(",
                comma_separate(|c| self.doc_display_pass(c), &v.columns),
                ")",
            ));
        }
        docs.push(nest_title("AS", self.doc_query(&v.query)));
        RcDoc::intersperse(docs, Doc::line()).group()
    }

    pub(crate) fn doc_insert<'a, T: AstInfo>(&'a self, v: &'a InsertStatement<T>) -> RcDoc<'a> {
        let mut first = vec![RcDoc::text(format!(
            "INSERT INTO {}",
            v.table_name.to_ast_string_simple()
        ))];
        if !v.columns.is_empty() {
            first.push(bracket(
                "(",
                comma_separate(|c| self.doc_display_pass(c), &v.columns),
                ")",
            ));
        }
        let sources = match &v.source {
            InsertSource::Query(query) => self.doc_query(query),
            InsertSource::DefaultValues => self.doc_display(&v.source, "insert source"),
        };
        let mut doc = intersperse_line_nest([intersperse_line_nest(first), sources]);
        if !v.returning.is_empty() {
            doc = nest(
                doc,
                nest_title(
                    "RETURNING",
                    comma_separate(|r| self.doc_display_pass(r), &v.returning),
                ),
            )
        }
        doc
    }

    pub(crate) fn doc_select_statement<'a, T: AstInfo>(
        &'a self,
        v: &'a SelectStatement<T>,
    ) -> RcDoc<'a> {
        let query = self.doc_query(&v.query);
        // A query whose rendering begins with `SHOW` (a bare `SHOW` body or a
        // set operation whose leftmost operand is one) only reparses when
        // parenthesized — a top-level leading `SHOW` is dispatched directly and
        // terminates the statement. Mirror `AstDisplay for SelectStatement`.
        let mut doc = if v.query.body.starts_with_show() {
            bracket("(", query, ")")
        } else {
            query
        };
        if let Some(as_of) = &v.as_of {
            doc = intersperse_line_nest([doc, self.doc_as_of(as_of)]);
        }
        doc.group()
    }

    fn doc_order_by<'a, T: AstInfo>(&'a self, v: &'a [OrderByExpr<T>]) -> RcDoc<'a> {
        title_comma_separate("ORDER BY", |o| self.doc_order_by_expr(o), v)
    }

    fn doc_order_by_expr<'a, T: AstInfo>(&'a self, v: &'a OrderByExpr<T>) -> RcDoc<'a> {
        let doc = self.doc_expr(&v.expr);
        let doc = match v.asc {
            Some(true) => nest(doc, RcDoc::text("ASC")),
            Some(false) => nest(doc, RcDoc::text("DESC")),
            None => doc,
        };
        match v.nulls_last {
            Some(true) => nest(doc, RcDoc::text("NULLS LAST")),
            Some(false) => nest(doc, RcDoc::text("NULLS FIRST")),
            None => doc,
        }
    }

    fn doc_query<'a, T: AstInfo>(&'a self, v: &'a Query<T>) -> RcDoc<'a> {
        let mut docs = vec![];
        if !v.ctes.is_empty() {
            match &v.ctes {
                CteBlock::Simple(ctes) => {
                    docs.push(title_comma_separate("WITH", |cte| self.doc_cte(cte), ctes))
                }
                CteBlock::MutuallyRecursive(mutrec) => {
                    let mut doc = RcDoc::text("WITH MUTUALLY RECURSIVE");
                    if !mutrec.options.is_empty() {
                        doc = nest(
                            doc,
                            bracket(
                                "(",
                                comma_separate(|o| self.doc_display_pass(o), &mutrec.options),
                                ")",
                            ),
                        );
                    }
                    docs.push(nest(
                        doc,
                        comma_separate(|c| self.doc_mutually_recursive(c), &mutrec.ctes),
                    ));
                }
            }
        }
        docs.push(self.doc_set_expr(&v.body));
        if !v.order_by.is_empty() {
            docs.push(self.doc_order_by(&v.order_by));
        }

        let offset = if let Some(offset) = &v.offset {
            vec![RcDoc::concat([nest_title("OFFSET", self.doc_expr(offset))])]
        } else {
            vec![]
        };

        if let Some(limit) = &v.limit {
            if limit.with_ties {
                docs.extend(offset);
                docs.push(RcDoc::concat([
                    RcDoc::text("FETCH FIRST "),
                    self.doc_expr(&limit.quantity),
                    RcDoc::text(" ROWS WITH TIES"),
                ]));
            } else {
                docs.push(nest_title("LIMIT", self.doc_expr(&limit.quantity)));
                docs.extend(offset);
            }
        } else {
            docs.extend(offset);
        }

        RcDoc::intersperse(docs, Doc::line()).group()
    }

    fn doc_cte<'a, T: AstInfo>(&'a self, v: &'a Cte<T>) -> RcDoc<'a> {
        RcDoc::concat([
            RcDoc::text(format!("{} AS", v.alias)),
            RcDoc::line(),
            bracket("(", self.doc_query(&v.query), ")"),
        ])
    }

    fn doc_mutually_recursive<'a, T: AstInfo>(&'a self, v: &'a CteMutRec<T>) -> RcDoc<'a> {
        let mut docs = Vec::new();
        if !v.columns.is_empty() {
            docs.push(bracket(
                "(",
                comma_separate(|c| self.doc_display_pass(c), &v.columns),
                ")",
            ));
        }
        docs.push(bracket("AS (", self.doc_query(&v.query), ")"));
        nest(
            self.doc_display_pass(&v.name),
            RcDoc::intersperse(docs, Doc::line()).group(),
        )
    }

    fn doc_set_expr<'a, T: AstInfo>(&'a self, v: &'a SetExpr<T>) -> RcDoc<'a> {
        match v {
            SetExpr::Select(v) => self.doc_select(v),
            SetExpr::Query(v) => bracket("(", self.doc_query(v), ")"),
            SetExpr::SetOperation {
                op,
                all,
                left,
                right,
            } => {
                let all_str = if *all { " ALL" } else { "" };
                RcDoc::concat([
                    self.doc_set_expr(left),
                    RcDoc::line(),
                    RcDoc::concat([
                        RcDoc::text(format!("{}{}", op, all_str)),
                        RcDoc::line(),
                        self.doc_set_expr(right),
                    ])
                    .nest(TAB)
                    .group(),
                ])
            }
            SetExpr::Values(v) => self.doc_values(v),
            SetExpr::Show(v) => self.doc_display(v, "SHOW"),
            SetExpr::Table(v) => nest(RcDoc::text("TABLE"), self.doc_display_pass(v)),
        }
        .group()
    }

    fn doc_values<'a, T: AstInfo>(&'a self, v: &'a Values<T>) -> RcDoc<'a> {
        let rows =
            v.0.iter()
                .map(|row| bracket("(", comma_separate(|v| self.doc_expr(v), row), ")"));
        RcDoc::concat([RcDoc::text("VALUES"), RcDoc::line(), comma_separated(rows)])
            .nest(TAB)
            .group()
    }

    fn doc_table_with_joins<'a, T: AstInfo>(&'a self, v: &'a TableWithJoins<T>) -> RcDoc<'a> {
        let mut docs = vec![self.doc_table_factor(&v.relation)];
        for j in &v.joins {
            docs.push(self.doc_join(j));
        }
        intersperse_line_nest(docs)
    }

    fn doc_join<'a, T: AstInfo>(&'a self, v: &'a Join<T>) -> RcDoc<'a> {
        let (constraint, name) = match &v.join_operator {
            JoinOperator::Inner(constraint) => (constraint, "JOIN"),
            JoinOperator::FullOuter(constraint) => (constraint, "FULL JOIN"),
            JoinOperator::LeftOuter(constraint) => (constraint, "LEFT JOIN"),
            JoinOperator::RightOuter(constraint) => (constraint, "RIGHT JOIN"),
            JoinOperator::CrossJoin => return self.doc_display(v, "join operator"),
        };
        let constraint = match constraint {
            JoinConstraint::On(expr) => nest_title("ON", self.doc_expr(expr)),
            JoinConstraint::Using { columns, alias } => {
                let mut doc = bracket(
                    "USING(",
                    comma_separate(|c| self.doc_display_pass(c), columns),
                    ")",
                );
                if let Some(alias) = alias {
                    doc = nest(doc, nest_title("AS", self.doc_display_pass(alias)));
                }
                doc
            }
            JoinConstraint::Natural => return self.doc_display(v, "join constraint"),
        };
        intersperse_line_nest([
            RcDoc::text(name),
            self.doc_table_factor(&v.relation),
            constraint,
        ])
    }

    fn doc_table_factor<'a, T: AstInfo>(&'a self, v: &'a TableFactor<T>) -> RcDoc<'a> {
        match v {
            TableFactor::Derived {
                lateral,
                subquery,
                alias,
            } => {
                let prefix = if *lateral { "LATERAL (" } else { "(" };
                let mut docs = vec![bracket(prefix, self.doc_query(subquery), ")")];
                if let Some(alias) = alias {
                    docs.push(RcDoc::text(format!("AS {}", alias)));
                }
                intersperse_line_nest(docs)
            }
            TableFactor::NestedJoin { join, alias } => {
                let mut doc = bracket("(", self.doc_table_with_joins(join), ")");
                if let Some(alias) = alias {
                    doc = nest(doc, RcDoc::text(format!("AS {}", alias)));
                }
                doc
            }
            TableFactor::Table { name, alias } => {
                let mut doc = self.doc_display_pass(name);
                if let Some(alias) = alias {
                    doc = nest(doc, RcDoc::text(format!("AS {}", alias)));
                }
                doc
            }
            _ => self.doc_display(v, "table factor variant"),
        }
    }

    fn doc_distinct<'a, T: AstInfo>(&'a self, v: &'a Distinct<T>) -> RcDoc<'a> {
        match v {
            Distinct::EntireRow => RcDoc::text("DISTINCT"),
            Distinct::On(cols) => bracket(
                "DISTINCT ON (",
                comma_separate(|c| self.doc_expr(c), cols),
                ")",
            ),
        }
    }

    fn doc_select<'a, T: AstInfo>(&'a self, v: &'a Select<T>) -> RcDoc<'a> {
        let mut docs = vec![];
        let mut select = RcDoc::text("SELECT");
        if let Some(distinct) = &v.distinct {
            select = nest(select, self.doc_distinct(distinct));
        }
        docs.push(nest_comma_separate(
            select,
            |s| self.doc_select_item(s),
            &v.projection,
        ));
        if !v.from.is_empty() {
            docs.push(title_comma_separate(
                "FROM",
                |t| self.doc_table_with_joins(t),
                &v.from,
            ));
        }
        if let Some(selection) = &v.selection {
            docs.push(nest_title("WHERE", self.doc_expr(selection)));
        }
        if !v.group_by.is_empty() {
            docs.push(title_comma_separate(
                "GROUP BY",
                |e| self.doc_expr(e),
                &v.group_by,
            ));
        }
        if let Some(having) = &v.having {
            docs.push(nest_title("HAVING", self.doc_expr(having)));
        }
        if let Some(qualify) = &v.qualify {
            docs.push(nest_title("QUALIFY", self.doc_expr(qualify)));
        }
        if !v.options.is_empty() {
            docs.push(bracket(
                "OPTIONS (",
                comma_separate(|o| self.doc_display_pass(o), &v.options),
                ")",
            ));
        }
        RcDoc::intersperse(docs, Doc::line()).group()
    }

    fn doc_select_item<'a, T: AstInfo>(&'a self, v: &'a SelectItem<T>) -> RcDoc<'a> {
        match v {
            SelectItem::Expr { expr, alias } => {
                let mut doc = self.doc_expr(expr);
                if let Some(alias) = alias {
                    doc = nest(
                        doc,
                        RcDoc::concat([RcDoc::text("AS "), self.doc_display_pass(alias)]),
                    );
                }
                doc
            }
            SelectItem::Wildcard => self.doc_display_pass(v),
        }
    }

    pub fn doc_expr<'a, T: AstInfo>(&'a self, v: &'a Expr<T>) -> RcDoc<'a> {
        match v {
            Expr::Op { op, expr1, expr2 } => {
                if let Some(expr2) = expr2 {
                    RcDoc::concat([
                        self.doc_expr(expr1),
                        RcDoc::line(),
                        RcDoc::text(format!("{} ", op)),
                        self.doc_expr(expr2).nest(TAB),
                    ])
                } else {
                    // See the AstDisplay `Expr::Op` comment (`prefix_operand_needs_parens`):
                    // a prefix op binds tighter than `COLLATE`/the binary ops but
                    // looser than the postfix `::`/`[…]`, and `- <number>` folds, so
                    // peel the tight postfixes and parenthesize when the chain
                    // bottoms out at a numeric literal or a non-self-delimiting /
                    // `COLLATE` operand.
                    let needs_parens = {
                        let mut e = expr1.as_ref();
                        let mut saw_postfix = false;
                        loop {
                            match e {
                                Expr::Cast { expr, .. } | Expr::Subscript { expr, .. } => {
                                    saw_postfix = true;
                                    e = expr.as_ref();
                                }
                                Expr::Value(Value::Number(_)) => break saw_postfix,
                                // Another prefix operator stacks directly (no
                                // re-association, no `- <number>` fold) — safe,
                                // and avoids exploding deep unary chains.
                                Expr::Op { expr2: None, .. } | Expr::Not { .. } => break false,
                                Expr::Value(_)
                                | Expr::Identifier(_)
                                | Expr::QualifiedWildcard(_)
                                | Expr::Parameter(_)
                                | Expr::Function(_)
                                | Expr::HomogenizingFunction { .. }
                                | Expr::NullIf { .. }
                                | Expr::Subquery(_)
                                | Expr::Exists(_)
                                | Expr::Nested(_)
                                | Expr::Array(_)
                                | Expr::ArraySubquery(_)
                                | Expr::List(_)
                                | Expr::ListSubquery(_)
                                | Expr::Map(_)
                                | Expr::MapSubquery(_)
                                | Expr::Case { .. }
                                | Expr::Row { .. } => break false,
                                _ => break true,
                            }
                        }
                    };
                    let operand = if needs_parens {
                        bracket("(", self.doc_expr(expr1), ")")
                    } else {
                        self.doc_expr(expr1)
                    };
                    RcDoc::concat([RcDoc::text(format!("{} ", op)), operand])
                }
            }
            Expr::Case {
                operand,
                conditions,
                results,
                else_result,
            } => {
                let mut docs = Vec::new();
                if let Some(operand) = operand {
                    docs.push(self.doc_expr(operand));
                }
                for (c, r) in conditions.iter().zip_eq(results) {
                    let when = nest_title("WHEN", self.doc_expr(c));
                    let then = nest_title("THEN", self.doc_expr(r));
                    docs.push(nest(when, then));
                }
                if let Some(else_result) = else_result {
                    docs.push(nest_title("ELSE", self.doc_expr(else_result)));
                }
                let doc = intersperse_line_nest(docs);
                bracket_doc(RcDoc::text("CASE"), doc, RcDoc::text("END"), RcDoc::line())
            }
            Expr::Cast { expr, data_type } => {
                let doc = self.doc_expr(expr);
                RcDoc::concat([
                    doc,
                    RcDoc::text(format!("::{}", data_type.to_ast_string_simple())),
                ])
            }
            Expr::Nested(ast) => bracket("(", self.doc_expr(ast), ")"),
            Expr::Function(fun) => self.doc_function(fun),
            Expr::Subquery(ast) => bracket("(", self.doc_query(ast), ")"),
            Expr::Identifier(_)
            | Expr::Value(_)
            | Expr::QualifiedWildcard(_)
            | Expr::WildcardAccess(_)
            | Expr::FieldAccess { .. } => self.doc_display_pass(v),
            Expr::And { left, right } => bracket_doc(
                self.doc_expr(left),
                RcDoc::text("AND"),
                self.doc_expr(right),
                RcDoc::line(),
            ),
            Expr::Or { left, right } => bracket_doc(
                self.doc_expr(left),
                RcDoc::text("OR"),
                self.doc_expr(right),
                RcDoc::line(),
            ),
            Expr::Exists(s) => bracket("EXISTS (", self.doc_query(s), ")"),
            Expr::IsExpr {
                expr,
                negated,
                construct,
            } => bracket_doc(
                self.doc_expr(expr),
                RcDoc::text(if *negated { "IS NOT" } else { "IS" }),
                self.doc_display_pass(construct),
                RcDoc::line(),
            ),
            Expr::Not { expr } => {
                RcDoc::concat([RcDoc::text("NOT"), RcDoc::line(), self.doc_expr(expr)])
            }
            Expr::Between {
                expr,
                negated,
                low,
                high,
            } => RcDoc::intersperse(
                [
                    self.doc_expr(expr),
                    RcDoc::text(if *negated { "NOT BETWEEN" } else { "BETWEEN" }),
                    RcDoc::intersperse(
                        [self.doc_expr(low), RcDoc::text("AND"), self.doc_expr(high)],
                        RcDoc::line(),
                    )
                    .group(),
                ],
                RcDoc::line(),
            ),
            Expr::InSubquery {
                expr,
                subquery,
                negated,
            } => RcDoc::intersperse(
                [
                    self.doc_expr(expr),
                    RcDoc::text(if *negated { "NOT IN (" } else { "IN (" }),
                    self.doc_query(subquery),
                    RcDoc::text(")"),
                ],
                RcDoc::line(),
            ),
            Expr::InList {
                expr,
                list,
                negated,
            } => RcDoc::intersperse(
                [
                    self.doc_expr(expr),
                    RcDoc::text(if *negated { "NOT IN (" } else { "IN (" }),
                    comma_separate(|e| self.doc_expr(e), list),
                    RcDoc::text(")"),
                ],
                RcDoc::line(),
            ),
            Expr::Row { exprs } => {
                bracket("ROW(", comma_separate(|e| self.doc_expr(e), exprs), ")")
            }
            Expr::NullIf { l_expr, r_expr } => bracket(
                "NULLIF (",
                comma_separate(|e| self.doc_expr(e), [&**l_expr, &**r_expr]),
                ")",
            ),
            Expr::HomogenizingFunction { function, exprs } => bracket(
                format!("{function}("),
                comma_separate(|e| self.doc_expr(e), exprs),
                ")",
            ),
            Expr::ArraySubquery(s) => bracket("ARRAY(", self.doc_query(s), ")"),
            Expr::ListSubquery(s) => bracket("LIST(", self.doc_query(s), ")"),
            Expr::Array(exprs) => {
                bracket("ARRAY[", comma_separate(|e| self.doc_expr(e), exprs), "]")
            }
            Expr::List(exprs) => bracket("LIST[", comma_separate(|e| self.doc_expr(e), exprs), "]"),
            _ => self.doc_display(v, "expr variant"),
        }
        .group()
    }

    fn doc_function<'a, T: AstInfo>(&'a self, v: &'a Function<T>) -> RcDoc<'a> {
        match &v.args {
            FunctionArgs::Star => self.doc_display_pass(v),
            FunctionArgs::Args { args, order_by } => {
                if args.is_empty() {
                    // Nullary, don't allow newline between parens, so just delegate.
                    return self.doc_display_pass(v);
                }
                if v.filter.is_some() || v.over.is_some() || !order_by.is_empty() {
                    return self.doc_display(v, "function filter or over or order by");
                }
                let name_stable = v.name.to_ast_string_stable();
                let special = match name_stable.as_str() {
                    r#""extract""# if v.args.len() == Some(2) => true,
                    r#""position""# if v.args.len() == Some(2) => true,
                    _ => false,
                };
                if special {
                    return self.doc_display(v, "special function");
                }
                // Mirror the same carve-out as the `AstDisplay for Function`
                // impl: function names that clash with a keyword having its
                // own special-grammar parser form (`(Kw, LParen)` dispatch in
                // parse_prefix) must be quoted on emit, or the reparse goes
                // through the special grammar instead of a regular call. (The
                // `ANY`/`ALL`/`SOME` quantifier keywords are handled more
                // generally by `can_be_printed_bare`, since they're also unsafe
                // as bare identifiers.)
                let needs_quote = matches!(
                    name_stable.as_str(),
                    r#""array""#
                        | r#""coalesce""#
                        | r#""exists""#
                        | r#""extract""#
                        | r#""greatest""#
                        | r#""least""#
                        | r#""list""#
                        | r#""map""#
                        | r#""normalize""#
                        | r#""nullif""#
                        | r#""position""#
                        | r#""row""#
                        | r#""substring""#
                        | r#""trim""#
                );
                let printed_name = if needs_quote {
                    name_stable
                } else {
                    v.name.to_ast_string_simple()
                };
                let name = format!(
                    "{}({}",
                    printed_name,
                    if v.distinct { "DISTINCT " } else { "" }
                );
                bracket(name, comma_separate(|e| self.doc_expr(e), args), ")")
            }
        }
    }
}