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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

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

//! `pg_depend` and `pg_shdepend` rows.

use crate::catalog::projection::helpers::rows::{int_value, row, str_value};
use uqa_sql::catalog::dependencies::{Dependency, SharedDependency};
use uqa_sql::ResultRow;

pub(super) fn depend_row(dependency: &Dependency) -> ResultRow {
    row([
        (
            "classid",
            int_value(i64::from(dependency.dependent.class_id)),
        ),
        (
            "objid",
            int_value(i64::from(dependency.dependent.object_id)),
        ),
        (
            "objsubid",
            int_value(i64::from(dependency.dependent.sub_id)),
        ),
        (
            "refclassid",
            int_value(i64::from(dependency.referenced.class_id)),
        ),
        (
            "refobjid",
            int_value(i64::from(dependency.referenced.object_id)),
        ),
        (
            "refobjsubid",
            int_value(i64::from(dependency.referenced.sub_id)),
        ),
        ("deptype", str_value(dependency.kind.code())),
    ])
}

pub(super) fn shared_depend_row(dependency: &SharedDependency) -> ResultRow {
    row([
        ("dbid", int_value(i64::from(dependency.database))),
        (
            "classid",
            int_value(i64::from(dependency.dependent.class_id)),
        ),
        (
            "objid",
            int_value(i64::from(dependency.dependent.object_id)),
        ),
        (
            "objsubid",
            int_value(i64::from(dependency.dependent.sub_id)),
        ),
        (
            "refclassid",
            int_value(i64::from(dependency.referenced.class_id)),
        ),
        (
            "refobjid",
            int_value(i64::from(dependency.referenced.object_id)),
        ),
        ("deptype", str_value(dependency.kind.code())),
    ])
}