radixdb-executor 1.1.0

SQL binding, planning, and execution engine for RadixDB
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

use radixdb_core::{ParamVec, Row, Value};
use radixdb_procedural::{Diagnostic, DiagnosticKind, ProceduralResult, RuntimeValue};

pub(super) fn scalar_parameters(values: &[RuntimeValue]) -> ProceduralResult<ParamVec> {
    values.iter().map(scalar_value).collect()
}

pub(super) fn scalar_value(value: &RuntimeValue) -> ProceduralResult<Value> {
    match value {
        RuntimeValue::Scalar(value) => Ok(value.clone()),
        RuntimeValue::Record(_)
        | RuntimeValue::NullRecord
        | RuntimeValue::Collection(_)
        | RuntimeValue::SqlIdentifier(_) => Err(Diagnostic::new(
            DiagnosticKind::RuntimeInvalidArgument,
            "SQL parameters must be scalar values",
        )),
    }
}

pub(super) fn runtime_row(row: Row) -> Vec<RuntimeValue> {
    row.into_values()
        .into_iter()
        .map(RuntimeValue::scalar)
        .collect()
}