aedb 0.2.3

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

use crate::query::error::QueryError;
use crate::query::plan::Aggregate;

pub(super) fn aggregate_col_idx(
    agg: &Aggregate,
    columns: &[String],
) -> Result<Option<usize>, QueryError> {
    let column_index = match agg {
        Aggregate::Count => return Ok(None),
        Aggregate::Sum(col) | Aggregate::Min(col) | Aggregate::Max(col) | Aggregate::Avg(col) => {
            columns
                .iter()
                .position(|c| c == col)
                .ok_or_else(|| QueryError::ColumnNotFound {
                    table: "".to_string(),
                    column: col.clone(),
                })?
        }
    };
    Ok(Some(column_index))
}

pub(super) fn aggregate_output_name(agg: &Aggregate) -> String {
    match agg {
        Aggregate::Count => "count_star".to_string(),
        Aggregate::Sum(col) => format!("sum_{col}"),
        Aggregate::Min(col) => format!("min_{col}"),
        Aggregate::Max(col) => format!("max_{col}"),
        Aggregate::Avg(col) => format!("avg_{col}"),
    }
}