uqa-execution 0.5.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

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

//! The OIDs graphs record when they and their labels are created, one catalog metadata entry per graph name. Graphs and labels created before OIDs were recorded derive theirs from their names.

use std::collections::BTreeMap;

use uqa_sql::catalog::graph_oids::GraphCatalogOids;
use uqa_storage::{CatalogFacade, StorageBackendResult};

/// The catalog metadata key prefix of the entries, which the graph's name completes.
pub const GRAPH_CATALOG_OIDS_METADATA_PREFIX: &str = "graph_catalog_oids:";

/// The recorded OIDs of the catalog's graphs by graph name.
pub fn load(
    catalog: &dyn CatalogFacade,
) -> StorageBackendResult<BTreeMap<String, GraphCatalogOids>> {
    catalog
        .metadata_with_prefix(GRAPH_CATALOG_OIDS_METADATA_PREFIX)?
        .into_iter()
        .map(|(key, value)| {
            let graph = key
                .strip_prefix(GRAPH_CATALOG_OIDS_METADATA_PREFIX)
                .unwrap_or(&key)
                .to_string();
            Ok((graph, serde_json::from_str(&value)?))
        })
        .collect()
}

/// Record a graph's OIDs, replacing any it recorded before.
pub fn record(
    catalog: &dyn CatalogFacade,
    graph: &str,
    oids: &GraphCatalogOids,
) -> StorageBackendResult<()> {
    catalog.set_metadata(&metadata_key(graph), &serde_json::to_string(oids)?)
}

/// Forget the OIDs of a graph being removed or renamed.
pub fn forget(catalog: &dyn CatalogFacade, graph: &str) -> StorageBackendResult<()> {
    catalog.delete_metadata(&metadata_key(graph))
}

fn metadata_key(graph: &str) -> String {
    format!("{GRAPH_CATALOG_OIDS_METADATA_PREFIX}{graph}")
}