4360628700

Build Type

push

github

Committed by GitHub

Commit Message

refactor: pipeline memory storage (#1135)

Run Details

1152 of 1152 new or added lines in 40 files covered. (100.0%)

27472 of 39301 relevant lines covered (69.9%)

28369.11 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

72.22

/dozer-sql/src/pipeline/tests/utils.rs

use crate::pipeline::errors::PipelineError;
use sqlparser::{
    ast::{Query, Select, SetExpr, Statement},
    dialect::AnsiDialect,
    parser::Parser,
};

pub fn get_select(sql: &str) -> Result<Box<Select>, PipelineError> {
    let dialect = AnsiDialect {};

    let ast = Parser::parse_sql(&dialect, sql).unwrap();

    let statement = ast.get(0).expect("First statement is missing").to_owned();
    if let Statement::Query(query) = statement {
        Ok(get_query_select(&query))
    } else {
        panic!("this is not supposed to be called");
    }
}

pub fn get_query_select(query: &Query) -> Box<Select> {
    match *query.body.clone() {
        SetExpr::Select(select) => select,
        SetExpr::Query(query) => get_query_select(&query),
        _ => panic!("Only select queries are supported"),
    }
}

1	use crate::pipeline::errors::PipelineError;
2	use sqlparser::{
3	ast::{Query, Select, SetExpr, Statement},
4	dialect::AnsiDialect,
5	parser::Parser,
6	};
7
8	pub fn get_select(sql: &str) -> Result<Box<Select>, PipelineError> {	117✔
9	let dialect = AnsiDialect {};	117✔
10		117✔
11	let ast = Parser::parse_sql(&dialect, sql).unwrap();	117✔
12		117✔
13	let statement = ast.get(0).expect("First statement is missing").to_owned();	117✔
14	if let Statement::Query(query) = statement {	117✔
15	Ok(get_query_select(&query))	117✔
16	} else {
17	panic!("this is not supposed to be called");	×
18	}
19	}	117✔
20
21	pub fn get_query_select(query: &Query) -> Box<Select> {	117✔
22	match *query.body.clone() {	117✔
23	SetExpr::Select(select) => select,	117✔
24	SetExpr::Query(query) => get_query_select(&query),	×
25	_ => panic!("Only select queries are supported"),	×
26	}	×
27	}	117✔

getdozer / dozer / 4360628700

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous