vibesql-executor 0.2.0

Query execution engine for vibesql SQL database
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

//! Test helpers and utilities for iterator tests

use vibesql_storage::Row;
use vibesql_types::SqlValue;

use super::*;
use crate::{
    evaluator::CombinedExpressionEvaluator,
    select::iterator::{join::LazyNestedLoopJoin, projection::ProjectionIterator},
};

/// Helper to create a simple schema for testing
pub(crate) fn test_schema() -> CombinedSchema {
    let table_schema = vibesql_catalog::TableSchema::new(
        "test".to_string(),
        vec![vibesql_catalog::ColumnSchema::new(
            "id".to_string(),
            vibesql_types::DataType::Integer,
            false,
        )],
    );
    CombinedSchema::from_table("test".to_string(), table_schema)
}

/// Helper to create two-table schema for join tests
pub(crate) fn test_join_schemas() -> (CombinedSchema, CombinedSchema) {
    let left_schema = vibesql_catalog::TableSchema::new(
        "t1".to_string(),
        vec![
            vibesql_catalog::ColumnSchema::new(
                "id".to_string(),
                vibesql_types::DataType::Integer,
                false,
            ),
            vibesql_catalog::ColumnSchema::new(
                "value".to_string(),
                vibesql_types::DataType::Integer,
                false,
            ),
        ],
    );
    let right_schema = vibesql_catalog::TableSchema::new(
        "t2".to_string(),
        vec![
            vibesql_catalog::ColumnSchema::new(
                "id".to_string(),
                vibesql_types::DataType::Integer,
                false,
            ),
            vibesql_catalog::ColumnSchema::new(
                "data".to_string(),
                vibesql_types::DataType::Integer,
                false,
            ),
        ],
    );
    (
        CombinedSchema::from_table("t1".to_string(), left_schema),
        CombinedSchema::from_table("t2".to_string(), right_schema),
    )
}

mod basic;
mod join;
mod phase_c;