selene-db-gql 1.3.0

ISO/IEC 39075:2024 GQL parser, planner, optimizer, and executor for selene-db.
Documentation 
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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85

//! Per-operation EXPLAIN payload summaries.
//!
//! Pulled out of `summary.rs` so the snapshot renderer stays under the file-size
//! cap. Each helper renders one pipeline-op payload string used by
//! `pipeline_summary`.

use crate::{
    LabelExpr,
    plan::{MutationOp, SessionOp, TxOp},
};

pub(super) fn mutation_summary(mutation: &MutationOp) -> String {
    match mutation {
        MutationOp::InsertNode {
            label_expr,
            property_inits,
            ..
        } => format!(
            "op=InsertNode(label={}, props={})",
            label_expr_summary(label_expr.as_ref()),
            property_inits.len()
        ),
        MutationOp::InsertEdge {
            label_expr,
            property_inits,
            ..
        } => format!(
            "op=InsertEdge(label={}, props={})",
            label_expr_summary(label_expr.as_ref()),
            property_inits.len()
        ),
        MutationOp::SetProperty { key, .. } => format!("op=SetProperty(key={})", key.as_str()),
        MutationOp::SetLabel { label, .. } => format!("op=SetLabel(label={})", label.as_str()),
        MutationOp::RemoveProperty { key, .. } => {
            format!("op=RemoveProperty(key={})", key.as_str())
        }
        MutationOp::RemoveLabel { label, .. } => {
            format!("op=RemoveLabel(label={})", label.as_str())
        }
        MutationOp::DeleteTargets { mode, targets, .. } => {
            format!("op=DeleteTargets(mode={mode:?}, targets={})", targets.len())
        }
    }
}

pub(super) fn tx_summary(tx: &TxOp) -> String {
    match tx {
        TxOp::Start { .. } => "op=Start".to_owned(),
        TxOp::Commit { .. } => "op=Commit".to_owned(),
        TxOp::Rollback { .. } => "op=Rollback".to_owned(),
    }
}

pub(super) fn session_summary(session: &SessionOp) -> String {
    match session {
        SessionOp::SetValue {
            param,
            if_not_exists,
            ..
        } => format!(
            "op=SetValue(param={}, if_not_exists={if_not_exists})",
            param.as_str()
        ),
        SessionOp::SetTimeZone { zone, .. } => format!("op=SetTimeZone(zone={zone})"),
        SessionOp::SetGraph { target, .. } => format!("op=SetGraph(target={target:?})"),
        SessionOp::ResetAllCharacteristics { .. } => "op=ResetAllCharacteristics".to_owned(),
        SessionOp::ResetParameters { .. } => "op=ResetParameters".to_owned(),
        SessionOp::ResetTimeZone { .. } => "op=ResetTimeZone".to_owned(),
        SessionOp::ResetParameter { param, .. } => {
            format!("op=ResetParameter(param={})", param.as_str())
        }
        SessionOp::Close { .. } => "op=Close".to_owned(),
    }
}

pub(super) fn label_expr_summary(label: Option<&LabelExpr>) -> String {
    match label {
        Some(LabelExpr::Single(label)) => label.as_str().to_owned(),
        Some(LabelExpr::Conjunction(_)) => "conjunction".to_owned(),
        Some(LabelExpr::Disjunction(_)) => "disjunction".to_owned(),
        Some(LabelExpr::Negation(_)) => "negation".to_owned(),
        Some(LabelExpr::Wildcard) => "*".to_owned(),
        None => "none".to_owned(),
    }
}