uqa-execution 0.5.3

Volcano physical operators with row-batch pipelines
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

//
// Unified Query Algebra
//
// Copyright (c) 2023-2026 Cognica, Inc.
//

//! Borrow selected view inputs for the information-schema column projection.

use super::{information_schema_column_row, view_columns_for};
use crate::catalog::{
    context::CatalogContext, projection::CatalogRequest, CatalogReadView, RelationNameResolution,
};
use uqa_sql::{ResultRow, SQLError};

pub(super) fn append_view_columns(
    context: &CatalogContext<'_>,
    catalog: &CatalogReadView,
    resolution: &RelationNameResolution,
    request: &CatalogRequest,
    out: &mut Vec<ResultRow>,
) -> Result<(), SQLError> {
    for (identity, stored) in catalog.snapshot().definitions.views.iter() {
        if stored.kind != crate::catalog::view::StoredViewKind::View
            || !request.matches_relation(&identity.schema, &identity.name)
            || !catalog.view_is_visible_to(stored, resolution.current_user())
        {
            continue;
        }
        let view_name = identity.qualified_name();
        let updatability = request
            .includes("is_updatable")
            .then(|| {
                context
                    .views
                    .view_updatability_with_catalog(&view_name, catalog, resolution)
            })
            .transpose()?;
        let columns = view_columns_for(context, catalog, resolution, stored)?;
        for (idx, column) in columns.iter().enumerate() {
            if !request.matches_name("column_name", &column.name)
                || !catalog.view_column_is_visible_to(
                    stored,
                    &column.name,
                    resolution.current_user(),
                )
            {
                continue;
            }
            out.push(information_schema_column_row(
                Some(&crate::catalog::projection::CatalogOutput(*context)),
                (catalog, resolution, request),
                (identity.schema.clone(), identity.name.clone()),
                idx,
                column,
                updatability
                    .as_ref()
                    .and_then(|value| value.catalog_columns.get(idx))
                    .copied()
                    .unwrap_or(false),
                None,
            )?);
        }
    }
    Ok(())
}