uqa-execution 0.3.0

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

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

//! Supply immutable statement binding inputs for SQL outer-join null rejection.

use super::RowLockContext;
use crate::query::CteScope;
use uqa_sql::{plan::SourcePlan, SQLError, SQLParam, ScalarExpr};

pub(super) fn reduce_null_rejected_outer_joins_to_fixpoint<S: Clone + Send + Sync + 'static>(
    context: RowLockContext<'_, S>,
    source: &mut SourcePlan,
    predicate: Option<&ScalarExpr>,
    params: &[SQLParam],
    ctes: &CteScope<S>,
) -> Result<(), SQLError> {
    uqa_sql::semantics::locking::null_rejection::reduce_null_rejected_outer_joins_to_fixpoint(
        context.catalog,
        source,
        predicate,
        params,
        &crate::query::binding::binding_context(ctes)?,
    )
}