3965135367

Build Type

github

Committed by GitHub

Commit Message

Merge 1add77327 into 56c0cf2b3

Pull Request Pull Request #680: feat: Implement nested queries and CTE.

Run Details

506 of 506 new or added lines in 18 files covered. (100.0%)

21999 of 33062 relevant lines covered (66.54%)

50489.13 hits per line

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

82.35

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

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

use crate::pipeline::errors::PipelineError;
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> {
    return match *query.body.clone() {
        SetExpr::Select(select) => {
            return select;
        }
        SetExpr::Query(query) => get_query_select(&query),
        _ => panic!("Only select queries are supported"),
    };
}

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

getdozer / dozer / 3965135367

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