uqa-execution 0.3.5

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

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

//! Persist view definitions with the original registry guard and publication boundaries.
use super::super::publication::dependencies::CatalogPublicationChanges;
use crate::catalog::view::{catalog_view_row, StoredView, ViewPublication};
use uqa_core::RelationIdentity;
use uqa_sql::{ast::RelationPersistence, SQLError};

pub(super) fn publish_regular_view(
    publication: &dyn ViewPublication,
    changes: &dyn CatalogPublicationChanges,
    relation: RelationIdentity,
    view: StoredView,
    name: &str,
) -> Result<(), SQLError> {
    let mut views = publication.views_write();
    if view.persistence != RelationPersistence::Temporary && publication.has_catalog() {
        publication
            .save_view(
                &catalog_view_row(&relation, &view).map_err(|error| {
                    SQLError::Internal(format!("serialize view `{name}`: {error}"))
                })?,
            )
            .map_err(|error| SQLError::Internal(format!("persist view `{name}`: {error}")))?;
    }
    views.insert(relation, view);
    drop(views);
    changes.catalog_registry_changed();
    Ok(())
}
pub(super) fn publish_materialized_view(
    publication: &dyn ViewPublication,
    changes: &dyn CatalogPublicationChanges,
    relation: RelationIdentity,
    view: StoredView,
    name: &str,
) -> Result<(), SQLError> {
    if publication.has_catalog() {
        publication
            .save_view(&catalog_view_row(&relation, &view).map_err(|error| {
                SQLError::Internal(format!("serialize materialized view `{name}`: {error}"))
            })?)
            .map_err(|error| {
                SQLError::Internal(format!("persist materialized view `{name}`: {error}"))
            })?;
    }
    publication.views_write().insert(relation, view);
    changes.catalog_registry_changed();
    Ok(())
}

#[cfg(test)]
mod tests;