iridium_core 0.1.12

SQL Server-compatible Rust engine core for Iridium SQL
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

use crate::catalog::TableDef;
use crate::storage::StoredRow;
use crate::types::Value;

#[derive(Debug, Clone)]
pub struct Group {
    pub key: Vec<Value>,
    pub rows: Vec<JoinedRow>,
}

#[derive(Debug, Clone)]
pub(crate) struct BoundTable {
    pub(crate) table: TableDef,
    pub(crate) alias: String,
    pub(crate) virtual_rows: Option<Vec<StoredRow>>,
}

#[derive(Debug, Clone)]
pub struct ContextTable {
    pub table: TableDef,
    pub alias: String,
    pub row: Option<StoredRow>,
    pub storage_index: Option<usize>,
    pub source_aliases: Vec<String>,
}

impl ContextTable {
    pub fn null_row(&self) -> Self {
        Self {
            table: self.table.clone(),
            alias: self.alias.clone(),
            row: None,
            storage_index: None,
            source_aliases: self.source_aliases.clone(),
        }
    }
}

pub type JoinedRow = Vec<ContextTable>;

pub(crate) fn single_row_context(table: &TableDef, row: StoredRow) -> JoinedRow {
    vec![ContextTable {
        table: table.clone(),
        alias: table.name.clone(),
        row: Some(row),
        storage_index: None,
        source_aliases: Vec::new(),
    }]
}

#[derive(Debug, Clone)]
pub struct Cursor {
    pub query: Option<crate::ast::SelectStmt>,
    pub query_result: super::result::QueryResult,
    pub current_row: i64,
}