aedb 0.3.1

Embedded Rust storage engine with transactional commits, WAL durability, and snapshot-consistent reads
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

use crate::catalog::schema::{ColumnDef, TableSchema};
use crate::catalog::types::{ColumnType, Value};
use crate::query::plan::{Query, col};
use crate::query::planner::{ExecutionStage, build_physical_plan};

fn schema() -> TableSchema {
    TableSchema {
        project_id: "p".into(),
        scope_id: "app".into(),
        table_name: "users".into(),
        owner_id: None,
        columns: vec![ColumnDef {
            name: "id".into(),
            col_type: ColumnType::Integer,
            nullable: false,
        }],
        primary_key: vec!["id".into()],
        constraints: Vec::new(),
        foreign_keys: Vec::new(),
    }
}

#[test]
fn exact_index_predicate_skips_filter_stage() {
    let query = Query::select(&["id"])
        .from("users")
        .where_(col("id").eq(Value::Integer(1)));

    let plan =
        build_physical_plan(&schema(), &query, Some("by_id".into()), 1, false).expect("plan");

    assert!(!plan.stages.contains(&ExecutionStage::Filter));
    assert!(!plan.plan.has_residual_filter);
}

#[test]
fn residual_predicate_keeps_filter_stage() {
    let query = Query::select(&["id"])
        .from("users")
        .where_(col("id").eq(Value::Integer(1)));

    let plan = build_physical_plan(&schema(), &query, Some("by_id".into()), 1, true).expect("plan");

    assert!(plan.stages.contains(&ExecutionStage::Filter));
    assert!(plan.plan.has_residual_filter);
}