uqa_sql/catalog/stored_view/
dependencies.rs

1//
2// Unified Query Algebra
3//
4// Copyright (c) 2023-2026 Cognica, Inc.
5//
6
7//! Select stored view dependencies and rewrite exact routine identities in their bound plans.
8
9use super::StoredView;
10use crate::{
11    ast::FunctionBinding,
12    binding::view_dependencies::{
13        query_plan_references_function, query_plan_references_relation,
14        query_plan_references_sequence, rewrite_query_plan_routine_identity,
15    },
16};
17use std::collections::{BTreeMap, BTreeSet};
18use uqa_core::RelationIdentity;
19
20/// Canonical bound sources make dependency checks exact; malformed in-memory plans remain conservative to prevent dangling DDL.
21pub fn views_depending_on_relation(
22    views: &BTreeMap<RelationIdentity, StoredView>,
23    target: &RelationIdentity,
24) -> Vec<String> {
25    let empty_ctes = BTreeSet::new();
26    let mut dependents = views
27        .iter()
28        .filter(|(relation, view)| {
29            *relation != target && query_plan_references_relation(&view.query, target, &empty_ctes)
30        })
31        .map(|(relation, _)| relation.qualified_name())
32        .collect::<Vec<_>>();
33    dependents.sort_unstable();
34    dependents
35}
36
37pub fn views_depending_on_sequence(
38    views: &BTreeMap<RelationIdentity, StoredView>,
39    target: &RelationIdentity,
40) -> Vec<String> {
41    let mut dependents = views
42        .iter()
43        .filter(|(_, view)| query_plan_references_sequence(&view.query, target))
44        .map(|(relation, _)| relation.qualified_name())
45        .collect::<Vec<_>>();
46    dependents.sort_unstable();
47    dependents
48}
49
50/// Return type is excluded from the exact non-builtin routine identity.
51pub fn views_depending_on_function(
52    views: &BTreeMap<RelationIdentity, StoredView>,
53    target: &FunctionBinding,
54) -> Vec<String> {
55    let mut dependents = views
56        .iter()
57        .filter(|(_, view)| query_plan_references_function(&view.query, target))
58        .map(|(relation, _)| relation.qualified_name())
59        .collect::<Vec<_>>();
60    dependents.sort_unstable();
61    dependents
62}
63
64/// Give the bound types that views embed, in typed constants and materialized column types, the current name of the user-defined type `oid`. Returns the views that changed.
65pub fn rewrite_view_type_references(
66    views: &mut BTreeMap<RelationIdentity, StoredView>,
67    oid: u32,
68    identity: &RelationIdentity,
69) -> Vec<RelationIdentity> {
70    let mut changed = Vec::new();
71    for (relation, view) in views {
72        let mut view_changed = false;
73        view.query.rewrite_scalar_expressions(&mut |expression| {
74            if let crate::ir::ScalarExpr::TypedLiteral {
75                bound_type: Some(ty),
76                ..
77            } = expression
78            {
79                view_changed |= ty.rename_user_type(oid, identity);
80            }
81        });
82        for ty in view.materialized_column_types.iter_mut().flatten() {
83            view_changed |= ty.rename_user_type(oid, identity);
84        }
85        if view_changed {
86            changed.push(relation.clone());
87        }
88    }
89    changed
90}
91
92pub fn rewrite_view_routine_identity(
93    views: &mut BTreeMap<RelationIdentity, StoredView>,
94    target: &FunctionBinding,
95    new_name: &str,
96) -> Vec<RelationIdentity> {
97    let mut changed = Vec::new();
98    for (relation, view) in views {
99        if rewrite_query_plan_routine_identity(&mut view.query, target, new_name) {
100            changed.push(relation.clone());
101        }
102    }
103    changed
104}
uqa_sql/catalog/stored_view/dependencies.rs

uqa_sql/catalog/stored_view/
dependencies.rs
