uqa-execution 0.4.6

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

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

//! Capture role identities without loading unrelated relation or sequence definitions.

use super::persistence::{self, RoleCatalogSnapshot};
use crate::catalog::snapshot_read::with_read_transaction;
use std::sync::Arc;
use uqa_storage::{CatalogFacade, PersistentStorageSession, StorageBackendResult};

pub fn read_role_snapshot(
    current: RoleCatalogSnapshot,
    bound: Option<&dyn CatalogFacade>,
    independent: Option<&PersistentStorageSession>,
    preserve_private: bool,
) -> StorageBackendResult<RoleCatalogSnapshot> {
    let Some(independent) = independent else {
        return Ok(current);
    };
    with_read_transaction(independent, |catalog| {
        let restored = persistence::restore(catalog)?;
        let snapshot = RoleCatalogSnapshot {
            roles: Arc::new(restored.roles),
            memberships: Arc::new(restored.memberships),
        };
        if preserve_private {
            snapshot.merge_private(bound, &current)
        } else {
            Ok(snapshot)
        }
    })
}