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
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

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

//! Prepare referential actions and partition rewrites before publishing row changes.
use super::{
    assignment::refresh_stored_generated_columns,
    candidate::{MutationLockTarget, PhysicalDocumentIdentity, PhysicalMutationLockTarget},
    constraints::{
        lock_document_key_dependencies, lock_existing_document_foreign_key_dependencies,
        lock_existing_document_rewrite_foreign_key_dependencies,
        period::period_foreign_key_coverage,
    },
    errors::{dml_storage_error, missing_document_error},
    events::{ReferentialActionContext, ReferentialRewritePreparation},
    identity::integer_primary_key_doc_id,
    locking::{lock_mutation_row, lock_mutation_target, lock_physical_mutation_target},
    prepared::{PreparedDeleteAction, PreparedDocumentDelete, PreparedDocumentRewrite},
};
use crate::query::locking::context::update_lock_strength;
use std::collections::BTreeSet;
use uqa_core::{DocId, Value};
use uqa_sql::{
    ast::{ForeignKey, ForeignKeyAction},
    semantics::{
        foreign_keys::{
            foreign_key_comparison_types, foreign_key_lookup_values, foreign_key_relation_name,
            ForeignKeyComparison,
        },
        partition::partition_insert_target,
        referential::referrers_to_for_actions,
    },
    SQLError, SQLParam,
};
use uqa_storage::document_store::Document;
mod context;
pub use context::{
    ReferentialContext, ReferentialDeferrals, ReferentialReadSnapshot, ReferentialSnapshots,
};
mod actions;
mod delete;
mod references;
mod rewrite;
mod snapshots;
pub use actions::{prepare_referenced_key_delete_actions, prepare_referenced_key_update_actions};
pub use delete::prepare_document_delete;
pub use references::{
    apply_set_action_to_child, lock_referencing_child, referencing_rows, ReferencingChildLock,
};
pub use rewrite::{
    prepare_document_rewrite, prepare_partition_update_route, prepare_referential_document_rewrite,
    prepare_routed_document_rewrite, reject_partition_rewrite,
};
pub enum PartitionUpdateRoute {
    Rewrite {
        document: Document,
        destination: Option<String>,
    },
    Delete {
        attempted_document: Document,
    },
}