risinglight 0.2.0

An OLAP database system for educational purpose
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

// Copyright 2022 RisingLight Project Authors. Licensed under Apache-2.0.

use std::sync::Arc;

use crate::types::ConvertError;
use crate::v1::binder::BoundStatement;
use crate::v1::optimizer::plan_nodes::PlanRef;

mod copy;
mod create;
mod delete;
mod drop;
mod explain;
mod insert;
mod select;

pub use copy::*;
pub use create::*;
pub use delete::*;
pub use drop::*;
pub use explain::*;
pub use insert::*;

/// The error type of logical planner.
#[derive(thiserror::Error, Debug, PartialEq)]
pub enum LogicalPlanError {
    #[error("invalid SQL")]
    InvalidSQL,
    #[error("conversion error: {0}")]
    Convert(#[from] ConvertError),
    #[error("{0} must appear in the GROUP BY clause or be used in an aggregate function")]
    IllegalGroupBySQL(String),
    #[error("ORDER BY items must appear in the select list if SELECT DISTINCT is specified")]
    IllegalDistinctSQL,
}

#[derive(Default)]
pub struct LogicalPlaner;

impl LogicalPlaner {
    /// Generate the logical plan from a bound statement.
    pub fn plan(&self, stmt: BoundStatement) -> Result<PlanRef, LogicalPlanError> {
        use BoundStatement::*;
        match stmt {
            CreateTable(stmt) => self.plan_create_table(stmt),
            Drop(stmt) => self.plan_drop(stmt),
            Insert(stmt) => self.plan_insert(stmt),
            Copy(stmt) => self.plan_copy(stmt),
            Select(stmt) => self.plan_select(stmt),
            Explain(stmt) => self.plan_explain(*stmt),
            Delete(stmt) => self.plan_delete(*stmt),
        }
    }
}