Method resolve_active_schema

src/sql/src/plan/statement.rs:729–734

(&self)

    }

    pub fn resolve_active_schema(&self) -> Result<&SchemaSpecifier, PlanError> {
        match self.current_schema() {
            Some((_db, schema)) => Ok(schema),
            None => Err(PlanError::InvalidSchemaName),
        }
    }

    pub fn get_cluster(&self, id: &ClusterId) -> &dyn CatalogCluster<'_> {
        self.catalog.get_cluster(*id)