Function plan_explain_analyze_object

src/sql/src/plan/statement/dml.rs:879–1115

(
    scx: &StatementContext,
    statement: ExplainAnalyzeObjectStatement<Aug>,
    params: &Params,
)

}

pub fn plan_explain_analyze_object(
    scx: &StatementContext,
    statement: ExplainAnalyzeObjectStatement<Aug>,
    params: &Params,
) -> Result<Plan, PlanError> {
    let explainee_name = statement
        .explainee
        .name()
        .ok_or_else(|| sql_err!("EXPLAIN ANALYZE on anonymous dataflows",))?
        .full_name_str();
    let explainee = plan_explainee(scx, statement.explainee, params)?;

    let check_ownership = |item_id: &CatalogItemId, item_type: &str| -> Result<(), PlanError> {
        if scx.catalog.restrict_to_user_objects() {
            let item = scx.catalog.get_item(item_id);
            if item.owner_id() != *scx.catalog.active_role_id() {
                let full_name = scx.catalog.resolve_full_name(item.name());
                return Err(sql_err!("must be owner of {item_type} {full_name}"));
            }
        }
        Ok(())
    };
    match &explainee {
        plan::Explainee::Index(item_id) => check_ownership(item_id, "INDEX")?,
        plan::Explainee::MaterializedView(item_id) => {
            check_ownership(item_id, "MATERIALIZED VIEW")?
        }
        _ => return Err(sql_err!("EXPLAIN ANALYZE queries for this explainee type",)),
    };

    // generate SQL query

    /* WITH {CTEs}
       SELECT REPEAT(' ', nesting * 2) || operator AS operator
             {columns}
        FROM      mz_introspection.mz_lir_mapping mlm
             JOIN {from} USING (lir_id)
             JOIN mz_introspection.mz_mappable_objects mo
               ON (mlm.global_id = mo.global_id)
       WHERE     mo.name = {escaped explainee_name}
             AND {predicates}
       ORDER BY lir_id DESC
    */
    let mut ctes = Vec::with_capacity(4); // max 2 per ExplainAnalyzeComputationProperty
    let mut columns = vec!["REPEAT(' ', nesting * 2) || operator AS operator"];
    let mut from = vec!["mz_introspection.mz_lir_mapping mlm"];
    let mut predicates = vec![format!(
        "mo.name = {}",
        escaped_string_literal(&explainee_name)
    )];
    let mut order_by = vec!["mlm.lir_id DESC"];

    match statement.properties {
        ExplainAnalyzeProperty::Computation(ExplainAnalyzeComputationProperties {
            properties,
            skew,
        }) => {
            let mut worker_id = None;