magnumdb 0.4.1

High-performance embeddable database engine in Rust with B+ Tree storage, WAL durability, Volcano query engine, and Postgres wire protocol support.
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

use crate::sql::parser::Statement;
use crate::storage::Database;
use anyhow::Result;

/// Cost-Based Query Optimizer (CBO) module.
pub struct Optimizer;

#[derive(Debug, Clone)]
pub enum ExecutionStrategy {
    SeqScan,
    IndexScan(String), // Index Name
}

impl Optimizer {
    /// Estimates cost and selects the best execution strategy for a query.
    pub fn plan_select(
        db: &mut Database,
        table_name: &str,
        filter_col: Option<&str>,
    ) -> Result<ExecutionStrategy> {
        if let Some(col) = filter_col {
            let idx_key = format!("__index__:{}:{}", table_name, col);
            if db.get(idx_key.as_bytes())?.is_some() {
                // Secondary index exists for column!
                return Ok(ExecutionStrategy::IndexScan(col.to_string()));
            }
        }

        Ok(ExecutionStrategy::SeqScan)
    }

    /// Optimizes a SQL statement.
    pub fn optimize(_db: &mut Database, stmt: Statement) -> Statement {
        stmt
    }
}