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
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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

//! Cached execution descriptors shared by statement dispatch and fast paths.

use std::sync::Arc;

use radixdb_core::{CompactArc, DataType, Schema, SmartString, Value};

/// How a compiled statement obtains its primary-key value.
#[derive(Debug, Clone)]
pub enum PkValueSource {
    Parameter(usize),
    Literal(i64),
    NamedParameter(SmartString),
}

/// Pre-bound state for `SELECT * ... WHERE pk = value`.
#[derive(Debug, Clone)]
pub struct CompiledPkLookup {
    pub table_name: SmartString,
    pub schema: CompactArc<Schema>,
    pub column_names: CompactArc<Vec<String>>,
    pub pk_value_source: PkValueSource,
    pub cached_epoch: u64,
}

/// One pre-bound UPDATE assignment.
#[derive(Debug, Clone)]
pub struct CompiledUpdateColumn {
    pub column_idx: usize,
    pub column_type: DataType,
    pub value_source: UpdateValueSource,
}

/// How a compiled UPDATE obtains an assignment value.
#[derive(Debug, Clone)]
pub enum UpdateValueSource {
    Literal(Value),
    Parameter(usize),
    NamedParameter(SmartString),
}

/// Pre-bound state for a primary-key UPDATE.
#[derive(Debug, Clone)]
pub struct CompiledPkUpdate {
    pub table_name: SmartString,
    pub schema: CompactArc<Schema>,
    pub pk_column_name: SmartString,
    pub pk_value_source: PkValueSource,
    pub updates: Vec<CompiledUpdateColumn>,
    pub cached_epoch: u64,
}

/// Pre-bound state for a primary-key DELETE.
#[derive(Debug, Clone)]
pub struct CompiledPkDelete {
    pub table_name: SmartString,
    pub schema: CompactArc<Schema>,
    pub pk_column_name: SmartString,
    pub pk_value_source: PkValueSource,
    pub cached_epoch: u64,
}

/// Schema-derived INSERT state reused by cached statements.
#[derive(Debug, Clone)]
pub struct CompiledInsert {
    pub table_name: SmartString,
    pub column_indices: Arc<Vec<usize>>,
    pub column_types: Arc<Vec<DataType>>,
    pub column_vector_dims: Arc<Vec<u16>>,
    pub column_names: Arc<Vec<SmartString>>,
    pub all_column_types: Arc<Vec<DataType>>,
    pub default_row_template: Arc<Vec<Value>>,
    pub cached_epoch: u64,
}

/// Pre-bound state for `COUNT(DISTINCT column)`.
#[derive(Debug, Clone)]
pub struct CompiledCountDistinct {
    pub table_name: SmartString,
    pub column_name: SmartString,
    pub result_column_name: String,
    pub cached_epoch: u64,
}

/// Pre-bound state for `COUNT(*)`.
#[derive(Debug, Clone)]
pub struct CompiledCountStar {
    pub table_name: SmartString,
    pub result_column_name: String,
    pub cached_epoch: u64,
}

/// Cached execution state selected by statement dispatch.
#[derive(Debug, Clone, Default)]
pub enum CompiledExecution {
    #[default]
    Unknown,
    NotOptimizable(u64),
    PkLookup(CompiledPkLookup),
    PkUpdate(CompiledPkUpdate),
    PkDelete(CompiledPkDelete),
    Insert(CompiledInsert),
    CountDistinct(CompiledCountDistinct),
    CountStar(CompiledCountStar),
}