mod alter_table;
mod assignment;
mod build;
mod column_def;
mod column_list;
mod create_table;
mod data_type;
mod delete;
mod drop_table;
mod error;
mod execute;
mod expr;
mod expr_list;
mod expr_with_alias;
mod index;
mod insert;
mod order_by_expr;
mod order_by_expr_list;
mod query;
mod select;
mod select_item;
mod select_item_list;
mod show_columns;
mod source;
mod table_access;
mod table_name;
mod transaction;
mod update;
pub use expr::{
ExprNode, bitwise_not, bytea, case, col, date, exists, expr, factorial, minus, nested, not,
not_exists, null, num, numeric::NumericNode, plus, subquery, text, time, timestamp, uuid,
value,
};
pub use expr::{
aggregate::{
AggregateNode, avg, avg_distinct, count, count_distinct, max, max_distinct, min,
min_distinct, stdev, stdev_distinct, sum, sum_distinct, variance, variance_distinct,
},
function,
};
pub use transaction::{begin, commit, rollback};
pub use {
alter_table::{
AddColumnNode, AlterTableNode, DropColumnNode, RenameColumnNode, RenameTableNode,
},
assignment::AssignmentNode,
build::Build,
column_def::ColumnDefNode,
column_list::ColumnList,
create_table::CreateTableNode,
data_type::DataTypeNode,
delete::DeleteNode,
drop_table::DropTableNode,
error::QueryBuilderError,
execute::Execute,
expr_list::ExprList,
expr_with_alias::ExprWithAliasNode,
index::{CreateIndexNode, DropIndexNode},
insert::InsertNode,
order_by_expr::OrderByExprNode,
order_by_expr_list::OrderByExprList,
query::QueryNode,
select::{
DistinctNode, FilterNode, GroupByNode, HavingNode, InnerHashJoinNode,
InnerJoinConditionNode, InnerNestedLoopJoinNode, LeftOuterHashJoinNode,
LeftOuterJoinConditionNode, LeftOuterNestedLoopJoinNode, LimitNode, OffsetLimitNode,
OffsetNode, ProjectNode, SelectNode, SelectOrderByNode, ValuesOrderByNode, select, values,
},
select_item::SelectItemNode,
select_item_list::SelectItemList,
show_columns::ShowColumnsNode,
source::{SourceNode, glue_indexes, glue_objects, glue_table_columns, glue_tables, series},
table_access::{
IndexPredicateNode, NonClusteredNode, PrimaryKeyNode, TableAccessNode, non_clustered,
primary_key,
},
table_name::table,
update::UpdateNode,
};
#[cfg(test)]
fn test(actual: &crate::result::Result<crate::plan::StatementPlan>, expected: &str) {
use crate::{parse_sql::parse, plan::StatementPlan, translate::translate};
let parsed = &parse(expected).expect(expected)[0];
let expected = translate(parsed).map(StatementPlan::from);
pretty_assertions::assert_eq!(*actual, expected);
}
#[cfg(test)]
fn test_expr(actual: crate::query_builder::ExprNode, expected: &str) {
use crate::{
parse_sql::parse_expr,
plan::ExprPlan,
translate::{NO_PARAMS, translate_expr},
};
let parsed = &parse_expr(expected).expect(expected);
let expected = translate_expr(parsed, NO_PARAMS);
pretty_assertions::assert_eq!(actual.clone().build_expr(), expected);
pretty_assertions::assert_eq!(actual.build_expr_plan(), expected.map(ExprPlan::from));
}
#[cfg(test)]
fn test_query(actual: crate::query_builder::QueryNode, expected: &str) {
use crate::{
parse_sql::parse_query,
plan::QueryPlan,
translate::{NO_PARAMS, translate_query},
};
let parsed = &parse_query(expected).expect(expected);
let expected = translate_query(parsed, NO_PARAMS);
pretty_assertions::assert_eq!(actual.clone().build_query(), expected);
pretty_assertions::assert_eq!(actual.build_query_plan(), expected.map(QueryPlan::from));
}
#[cfg(test)]
fn test_query_builder<T>(actual: T, expected: &str)
where
T: crate::query_builder::select::BuildQuery
+ crate::query_builder::select::BuildQueryPlan
+ Clone,
{
use crate::{
parse_sql::parse_query,
plan::QueryPlan,
translate::{NO_PARAMS, translate_query},
};
let parsed = &parse_query(expected).expect(expected);
let expected = translate_query(parsed, NO_PARAMS);
pretty_assertions::assert_eq!(actual.clone().build_query(), expected);
pretty_assertions::assert_eq!(actual.build_query_plan(), expected.map(QueryPlan::from));
}