sql解析AST
1、样例sql
select distinct a, count(*) from t where a = 1 and b - 1 < a group by a having a = 1;
2、首先要构建Parser: 用于将上面的sql解析为<Statement>
- 指定当前sql解析使用的方言
- 待解析的sql
- 解析sql：sqlparser::parser::Parser::parse_sql
# 解析sql的详细步骤
## 1、创建Tokenizer(dialect, sql): 执行当前采用的方言dialect\被解析的sql\定位token位置(行line和列col)
## 2、将sql生成token：Tokenizer.tokenize()
### - 将sql转为字符迭代器
### - 循环迭代sql转换后的字符迭代器
#### - 判断每个token的类型；
1、当前token=Whitespace::Newline 是需要换行，变更line+1， col重置=1
2、当前token=Whitespace::Tab 是将col+4
3、当前token=Word，需要严重当前token是否是关键字或其他sql引用(需要根据quote_style区分)
4、当前token=Token::Number 无符号数字类型
5、当前token=SingleQuotedString 单引号`X`
#### - 将token记录下来
#### - 如此循环就把当前sql转为tokens集
## 3、在拿到<tokens>流后,使用Parser进行tokens解析，持续迭代
### - 调用parser.consume_token检查当前tokens是否是需要的Statement
### - 迭代tokens是否是EOF
### - 此时真正解析token->statement: parser.parse_statement()
#### 1、开始迭代<tokens>: next_token
#### 2、判断当前token：Word、LParen、unexpected三者之一
##### 当是Word时，还需要进一步确认是什么sql关键字，根据不同的关键字调用不同的逻辑
##### 当是LParen时，需要确认左括号上一个token是什么，是否需要和左括号关联
##### 当是unexpected时，说明当前的token不满足需求
#### 3、构建<Statement>
## 4、使用Transformer来将前面构建的<statement>集构建成AST
### 这里需要注意的为了后续能够支持不同的sql parser生成AST，这地方进行了抽象
### 定义了trait: AstTransformer,通过工厂模式输出不同的实现，默认使用sql-parser-rs: AstTransformer(TransformerSqlparser)
## 5、至此sql的AST生成：sql解析部分完成
样例
对应的代码实现(只包含关键代码)：
### 1、构建parser： let parser = Parser{}
### 2、使用sql-parser进行sql解析：parser.parse_with_sqlparser(sql)
#### - 其实真正进行sql解析：sqlparser::parser::Parser::parse_sql(&sqlparser::dialect::PostgreSqlDialect {}, sql)?
#### - 使用transformer进行statement转换：AstTransformer.transform()
### 3、得到sql解析集：<Statement>
源码解读(仅限databend自身代码)
1、Parser：databend/common/ast/src/parser/mod.rs
只是为了将一个sql字符串转为statement，不过真正完成parse操作是通过sql-parser-rs包来完成的
pub struct Parser;
impl Parser {
// Parse a SQL string into `Statement`s.
#[allow(unused)]
pub fn parse_sql(&self, _: &str) -> Result<Vec<Statement>> {
todo!()
}
/// 使用sqlparser来进行解析
#[allow(unused)]
pub fn parse_with_sqlparser(&self, sql: &str) -> Result<Vec<Statement>> {
// 指定sql方言+对应的sql
// 在这个过程会将sql转为符合方言语义的<token>集;
// 接着使用parse(此处是sqlparser)将<token>集处理成<statement>集，并输出符合当前sql方言的AST
let stmts =
sqlparser::parser::Parser::parse_sql(&sqlparser::dialect::PostgreSqlDialect {}, sql)?;
// 接下来，将对拿到的AST，进行transform，将上面的<Statement>集转为databend的statement集
stmts
.into_iter()
.map(|stmt| {
let transformer = AstTransformerFactory::new_sqlparser_transformer(stmt);
transformer.transform()
})
.collect::<Result<_>>()
}
}
2、将根据sql-parser得到的AST转为databend支持的Statement: databend/common/ast/src/parser/transformer/mod.rs
/// 为了支持更多的parser生成的AST， 这里抽象了一个工具trait主要用于采用不同的parser生成的AST转换为databend statement
pub trait AstTransformer {
fn transform(&self) -> Result<Statement>;
}
/// 使用工厂模式构建不同的transformer
pub struct AstTransformerFactory;
impl AstTransformerFactory {
#[allow(unused)]
pub fn new_sqlparser_transformer(stmt: sqlparser::ast::Statement) -> impl AstTransformer {
TransformerSqlparser::new(stmt)
}
}
3、TransformerSqlparser： 完成AST到databend的statementd转换; atabend/common/ast/src/parser/transformer/transform_sqlparser.rs
// Implementation of `AstTransformer` for sqlparser-rs
// 其实内部还是使用了sqlparser-rs
pub struct TransformerSqlparser {
pub orig_stmt: SqlparserStatement, // 待转换的statement
}
impl TransformerSqlparser {
// 构建Transformer
#[allow(unused)]
pub fn new(stmt: SqlparserStatement) -> Self {
TransformerSqlparser { orig_stmt: stmt }
}
// 对外提供进行statement转换
pub fn transform_impl(&self) -> Result<Statement> {
self.transform_statement(&self.orig_stmt)
}
// 真正完成statement转换
fn transform_statement(&self, orig_ast: &SqlparserStatement) -> Result<Statement> {
// 根据当前statement类型的不同 采用不同的转换
// 是将sqlparser.Statement转为databend.Statement
match orig_ast {
SqlparserStatement::Query(q) => {
Ok(Statement::Select(Box::new(self.transform_query(q)?)))
}
SqlparserStatement::Explain {
analyze, statement, ..
} => Ok(Explain {
analyze: analyze.to_owned(),
query: Box::new(self.transform_statement(statement)?),
}),
// Transform DDL
SqlparserStatement::Truncate { .. }
| SqlparserStatement::CreateTable { .. }
| SqlparserStatement::AlterTable { .. }
| SqlparserStatement::Drop { .. }
| SqlparserStatement::CreateDatabase { .. } => self.transform_ddl(orig_ast),
_ => Err(ErrorCode::SyntaxException(format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
}
}
// 从statement中获取对应的database和table
fn get_database_and_table_from_idents(
&self,
idents: &[Ident],
) -> (Option<Identifier>, Option<Identifier>) {
if idents.len() == 1 {
(None, Some(Identifier::from(&idents[0])))
} else if idents.len() == 2 {
(
Some(Identifier::from(&idents[0])),
Some(Identifier::from(&idents[1])),
)
} else {
(None, None)
}
}
// 当碰到DDL相关的转换
fn transform_ddl(&self, orig_ast: &SqlparserStatement) -> Result<Statement> {
match orig_ast {
// truncate table操作
SqlparserStatement::Truncate { table_name, .. } => {
let (db, tbl) = self.get_database_and_table_from_idents(&table_name.0);
if let Some(table) = tbl {
Ok(Statement::TruncateTable {
database: db,
table,
})
} else {
Err(ErrorCode::SyntaxException(format!(
"Unsupported SQL statement: {}",
self.orig_stmt
)))
}
}
// create table操作
SqlparserStatement::CreateTable {
if_not_exists,
name,
columns,
like,
..
} => {
// 获取database和table
let (db, tbl) = self.get_database_and_table_from_idents(&name.0);
// 省略部分代码
// like语法
// statement of 'CREATE TABLE db1.table1 LIKE db2.table2'
let (like_db, like_table) = match like {
Some(like_table_name) => {
self.get_database_and_table_from_idents(&like_table_name.0)
}
None => (None, None),
};
//省略部分代码
let mut cols: Vec<ColumnDefinition> = vec![];
// 处理不同的列
for column in columns {
let ident = Identifier {
name: column.name.value.clone(),
quote: column.name.quote_style,
};
let typ = self.transform_data_type(&column.data_type)?;
let mut is_null: bool = true;
let mut has_default: bool = false;
let mut default_literal: Literal = Literal::Null;
for column_option_def in &column.options {
use sqlparser::ast::ColumnOption::*;
match &column_option_def.option {
Null => {
is_null = true;
}
NotNull => {
is_null = false;
}
Default(expr) => {
has_default = true;
let res = self.transform_expr(expr)?;
if let Expr::Literal(lit) = res {
default_literal = lit;
} else {
return Err(ErrorCode::SyntaxException(format!(
"Unsupported SQL statement: {}",
self.orig_stmt
)));
}
}
_ => {}
}
}
let mut default_val: Option<Literal> = None;
if has_default {
default_val = Some(default_literal);
}
let col = ColumnDefinition { // 每个列的定义：标识/数据类型/是否为null/默认值
name: ident,
data_type: typ,
nullable: is_null,
default_value: default_val,
};
cols.push(col);
}
// 构建databend的create table
Ok(Statement::CreateTable {
if_not_exists: *if_not_exists,
database: db,
table: tbl,
columns: cols,
engine: "".to_string(),
options: vec![],
like_db,
like_table,
})
}
// 修改table： 待实现
SqlparserStatement::AlterTable { .. } => {
// TODO: support transform DDL AlterTable
Err(ErrorCode::SyntaxException(format!(
"Unsupported SQL statement: {}",
self.orig_stmt
)))
}
// 删除表：
SqlparserStatement::Drop {
object_type,
if_exists,
names,
..
} => {
use sqlparser::ast::ObjectType::*;
match object_type { // 面对表table和视图view
Table => {
// 省略部分代码
let (db, tpl) = self.get_database_and_table_from_idents(&names[0].0);
if let Some(table) = tpl {
Ok(Statement::DropTable {
if_exists: *if_exists,
database: db,
table,
})
} else {
Err(ErrorCode::SyntaxException(format!(
"Unsupported SQL statement: {}",
self.orig_stmt
)))
}
}
View | Index | Schema => Err(ErrorCode::SyntaxException(format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
}
}
// 创建database
SqlparserStatement::CreateDatabase {
db_name,
if_not_exists,
..
} => {
let idents = &db_name.0;
if idents.len() != 1 {
return Err(ErrorCode::SyntaxException(format!(
"Unsupported SQL statement: {}",
self.orig_stmt
)));
}
Ok(Statement::CreateDatabase {
if_not_exists: *if_not_exists,
name: Identifier::from(&idents[0]),
engine: "".to_string(),
options: vec![],
})
}
// 不支持的操作
_ => Err(ErrorCode::SyntaxException(format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
}
}
// 省略部分代码
}
impl From<Ident> for Identifier {
fn from(ident: Ident) -> Self {
Identifier {
name: ident.value,
quote: ident.quote_style,
}
}
}
impl From<&Ident> for Identifier {
fn from(ident: &Ident) -> Self {
Identifier {
name: ident.value.to_owned(),
quote: ident.quote_style.to_owned(),
}
}
}
impl From<SqlparserSetOperator> for SetOperator {
fn from(src: SqlparserSetOperator) -> Self {
match src {
SqlparserSetOperator::Union => SetOperator::Union,
SqlparserSetOperator::Except => SetOperator::Except,
SqlparserSetOperator::Intersect => SetOperator::Intersect,
}
}
}
impl AstTransformer for TransformerSqlparser {
fn transform(&self) -> Result<Statement> {
self.transform_impl()
}
}
4、不同的statement的具体操作
// 处理query语句的转换
fn transform_query(&self, orig_ast: &SqlparserQuery) -> Result<Query> {
let body = self.transform_set_expr(&orig_ast.body)?;
let order_by = orig_ast
.order_by
.iter()
.map(|expr| {
Ok(OrderByExpr {
expr: self.transform_expr(&expr.expr)?,
asc: expr.asc,
nulls_first: expr.nulls_first,
})
})
.collect::<Result<_>>()?;
let limit = orig_ast
.limit
.as_ref()
.map(|expr| self.transform_expr(expr))
.transpose()?;
Ok(Query {
body,
order_by,
limit,
})
}
// 处理set语句
fn transform_set_expr(&self, orig_ast: &SqlparserSetExpr) -> Result<SetExpr> {
match orig_ast {
SqlparserSetExpr::SetOperation {
op,
all,
left,
right,
} => {
let left = self.transform_set_expr(left.as_ref())?;
let right = self.transform_set_expr(right.as_ref())?;
let op = SetOperator::from(op.to_owned());
Ok(SetExpr::SetOperation {
op,
all: all.to_owned(),
left: Box::new(left),
right: Box::new(right),
})
}
SqlparserSetExpr::Query(query) => {
Ok(SetExpr::Query(Box::new(self.transform_query(query)?)))
}
SqlparserSetExpr::Select(select) => {
Ok(SetExpr::Select(Box::new(self.transform_select(select)?)))
}
_ => Err(ErrorCode::SyntaxException(std::format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
}
}
// 处理select的转换
fn transform_select(&self, orig_ast: &SqlparserSelect) -> Result<SelectStmt> {
let distinct = orig_ast.distinct;
let select_list: Vec<SelectTarget> = orig_ast
.projection
.iter()
.map(|x| {
match x {
SelectItem::UnnamedExpr(expr) => Ok(SelectTarget::Projection {
expr: self.transform_expr(expr)?,
alias: None,
}),
SelectItem::ExprWithAlias { expr, alias } => Ok(SelectTarget::Projection {
expr: self.transform_expr(expr)?,
alias: Some(Identifier::from(alias)),
}),
SelectItem::QualifiedWildcard(object_name) => {
// Transform fields to `Indirection`s first
let mut v: Vec<Indirection> = Self::transform_object_name(object_name)
.into_iter()
.map(Indirection::Identifier)
.collect();
// Push a wildcard star to the end
v.push(Indirection::Star);
Ok(SelectTarget::Indirections(v))
}
SelectItem::Wildcard => Ok(SelectTarget::Indirections(vec![Indirection::Star])),
}
})
.collect::<Result<Vec<SelectTarget>>>()?;
let from = self.transform_from(&orig_ast.from)?;
let selection = orig_ast
.selection
.as_ref()
.map(|expr| self.transform_expr(expr))
.transpose()?;
let group_by = orig_ast
.group_by
.iter()
.map(|expr| self.transform_expr(expr))
.collect::<Result<_>>()?;
let having = orig_ast
.having
.as_ref()
.map(|expr| self.transform_expr(expr))
.transpose()?;
Ok(SelectStmt {
distinct,
select_list,
from,
selection,
group_by,
having,
})
}
// 处理from
fn transform_from(&self, orig_ast: &[TableWithJoins]) -> Result<TableReference> {
let mut table_refs: Vec<TableReference> = orig_ast
.iter()
.map(|v| self.transform_table_with_joins(v))
.collect::<Result<_>>()?;
if !table_refs.is_empty() {
let head = table_refs.drain(0..1).next().unwrap();
table_refs.into_iter().fold(Ok(head), |acc, r| {
Ok(TableReference::Join(Join {
op: JoinOperator::CrossJoin,
condition: JoinCondition::None,
left: Box::new(acc?),
right: Box::new(r),
}))
})
} else {
Err(ErrorCode::SyntaxException(format!(
"Invalid SQL statement: {}",
self.orig_stmt
)))
}
}
// 处理join
fn transform_table_with_joins(
&self,
table_with_joins: &TableWithJoins,
) -> Result<TableReference> {
// Take `table_with_joins.relation` as initial left table, then we can build a left-deep tree.
let mut left_table = self.transform_table_factor(&table_with_joins.relation)?;
// Join the tables and finally produce a left-deep tree
for join in table_with_joins.joins.iter() {
let right_table = self.transform_table_factor(&join.relation)?;
left_table = match &join.join_operator {
SqlparserJoinOperator::Inner(constraint) => match constraint {
JoinConstraint::On(cond) => Ok(TableReference::Join(Join {
op: JoinOperator::Inner,
condition: JoinCondition::On(self.transform_expr(cond)?),
left: Box::from(left_table),
right: Box::from(right_table),
})),
JoinConstraint::Using(idents) => Ok(TableReference::Join(Join {
op: JoinOperator::Inner,
condition: JoinCondition::Using(
idents.iter().map(Identifier::from).collect(),
),
left: Box::from(left_table),
right: Box::from(right_table),
})),
JoinConstraint::Natural => Ok(TableReference::Join(Join {
op: JoinOperator::Inner,
condition: JoinCondition::Natural,
left: Box::from(left_table),
right: Box::from(right_table),
})),
JoinConstraint::None => Ok(TableReference::Join(Join {
op: JoinOperator::Inner,
condition: JoinCondition::None,
left: Box::from(left_table),
right: Box::from(right_table),
})),
},
SqlparserJoinOperator::LeftOuter(constraint) => match constraint {
JoinConstraint::On(cond) => Ok(TableReference::Join(Join {
op: JoinOperator::LeftOuter,
condition: JoinCondition::On(self.transform_expr(cond)?),
left: Box::from(left_table),
right: Box::from(right_table),
})),
JoinConstraint::Using(idents) => Ok(TableReference::Join(Join {
op: JoinOperator::LeftOuter,
condition: JoinCondition::Using(
idents.iter().map(Identifier::from).collect(),
),
left: Box::from(left_table),
right: Box::from(right_table),
})),
JoinConstraint::Natural => Ok(TableReference::Join(Join {
op: JoinOperator::LeftOuter,
condition: JoinCondition::Natural,
left: Box::from(left_table),
right: Box::from(right_table),
})),
// Cannot run OUTER JOIN without condition
JoinConstraint::None => Err(ErrorCode::SyntaxException(format!(
"Invalid SQL statement: {}",
self.orig_stmt
))),
},
SqlparserJoinOperator::RightOuter(constraint) => match constraint {
JoinConstraint::On(cond) => Ok(TableReference::Join(Join {
op: JoinOperator::RightOuter,
condition: JoinCondition::On(self.transform_expr(cond)?),
left: Box::from(left_table),
right: Box::from(right_table),
})),
JoinConstraint::Using(idents) => Ok(TableReference::Join(Join {
op: JoinOperator::RightOuter,
condition: JoinCondition::Using(
idents.iter().map(Identifier::from).collect(),
),
left: Box::from(left_table),
right: Box::from(right_table),
})),
JoinConstraint::Natural => Ok(TableReference::Join(Join {
op: JoinOperator::RightOuter,
condition: JoinCondition::Natural,
left: Box::from(left_table),
right: Box::from(right_table),
})),
// Cannot run OUTER JOIN without condition
JoinConstraint::None => Err(ErrorCode::SyntaxException(format!(
"Invalid SQL statement: {}",
self.orig_stmt
))),
},
SqlparserJoinOperator::FullOuter(constraint) => match constraint {
JoinConstraint::On(cond) => Ok(TableReference::Join(Join {
op: JoinOperator::FullOuter,
condition: JoinCondition::On(self.transform_expr(cond)?),
left: Box::from(left_table),
right: Box::from(right_table),
})),
JoinConstraint::Using(idents) => Ok(TableReference::Join(Join {
op: JoinOperator::FullOuter,
condition: JoinCondition::Using(
idents.iter().map(Identifier::from).collect(),
),
left: Box::from(left_table),
right: Box::from(right_table),
})),
JoinConstraint::Natural => Ok(TableReference::Join(Join {
op: JoinOperator::FullOuter,
condition: JoinCondition::Natural,
left: Box::from(left_table),
right: Box::from(right_table),
})),
// Cannot run OUTER JOIN without condition
JoinConstraint::None => Err(ErrorCode::SyntaxException(format!(
"Invalid SQL statement: {}",
self.orig_stmt
))),
},
SqlparserJoinOperator::CrossJoin => Ok(TableReference::Join(Join {
op: JoinOperator::CrossJoin,
condition: JoinCondition::None,
left: Box::from(left_table),
right: Box::from(right_table),
})),
_ => Err(ErrorCode::SyntaxException(format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
}?;
}
Ok(left_table)
}
//
fn transform_table_factor(&self, table_factor: &TableFactor) -> Result<TableReference> {
let result = match table_factor {
TableFactor::Table { name, alias, .. } => {
let idents = &name.0;
if idents.len() == 1 {
Ok(TableReference::Table {
database: None,
table: Identifier::from(&idents[0]),
alias: alias.as_ref().map(Self::transform_table_alias),
})
} else if idents.len() == 2 {
Ok(TableReference::Table {
database: Some(Identifier::from(&idents[0])),
table: Identifier::from(&idents[1]),
alias: alias.as_ref().map(Self::transform_table_alias),
})
} else {
Err(ErrorCode::SyntaxException(format!(
"Unsupported SQL statement: {}",
self.orig_stmt
)))
}
}
TableFactor::Derived {
subquery, alias, ..
} => Ok(TableReference::Subquery {
subquery: Box::from(self.transform_query(subquery.as_ref())?),
alias: alias.as_ref().map(Self::transform_table_alias),
}),
TableFactor::TableFunction { expr, alias } => Ok(TableReference::TableFunction {
expr: self.transform_expr(expr)?,
alias: alias.as_ref().map(Self::transform_table_alias),
}),
TableFactor::NestedJoin(nested_join) => self.transform_table_with_joins(nested_join),
};
result
}
// 如下是辅助方法 ObjectName-->Identifier
#[inline]
fn transform_object_name(object_name: &ObjectName) -> Vec<Identifier> {
object_name.0.iter().map(Identifier::from).collect()
}
// alias处理
#[inline]
fn transform_table_alias(table_alias: &SqlparserTableAlias) -> TableAlias {
TableAlias {
name: Identifier::from(&table_alias.name),
columns: table_alias.columns.iter().map(Identifier::from).collect(),
}
}
// sql中的表达式转换
fn transform_expr(&self, orig_ast: &SqlparserExpr) -> Result<Expr> {
match orig_ast {
SqlparserExpr::Identifier(ident) => Ok(Expr::ColumnRef {
database: None,
table: None,
column: Identifier::from(ident),
}),
SqlparserExpr::CompoundIdentifier(idents) => {
if idents.len() == 3 {
Ok(Expr::ColumnRef {
database: Some(Identifier::from(&idents[0])),
table: Some(Identifier::from(&idents[1])),
column: Identifier::from(&idents[2]),
})
} else if idents.len() == 2 {
Ok(Expr::ColumnRef {
database: None,
table: Some(Identifier::from(&idents[0])),
column: Identifier::from(&idents[1]),
})
} else if idents.len() == 1 {
Ok(Expr::ColumnRef {
database: None,
table: None,
column: Identifier::from(&idents[0]),
})
} else {
Err(ErrorCode::SyntaxException(std::format!(
"Unsupported SQL statement: {}",
self.orig_stmt
)))
}
}
SqlparserExpr::IsNull(expr) => Ok(Expr::IsNull {
expr: Box::new(self.transform_expr(expr)?),
not: false,
}),
SqlparserExpr::IsNotNull(expr) => Ok(Expr::IsNull {
expr: Box::new(self.transform_expr(expr)?),
not: true,
}),
SqlparserExpr::InList {
expr,
list,
negated,
} => Ok(Expr::InList {
expr: Box::new(self.transform_expr(expr)?),
list: list
.iter()
.map(|expr| self.transform_expr(expr))
.collect::<Result<_>>()?,
not: negated.to_owned(),
}),
SqlparserExpr::InSubquery {
expr,
subquery,
negated,
} => Ok(Expr::InSubquery {
expr: Box::new(self.transform_expr(expr)?),
subquery: Box::new(self.transform_query(subquery)?),
not: *negated,
}),
SqlparserExpr::Between {
expr,
negated,
low,
high,
} => Ok(Expr::Between {
expr: Box::new(self.transform_expr(expr)?),
low: Box::new(self.transform_expr(low)?),
high: Box::new(self.transform_expr(high)?),
not: *negated,
}),
SqlparserExpr::BinaryOp { left, op, right } => Ok(Expr::BinaryOp {
op: self.transform_binary_operator(op)?,
left: Box::new(self.transform_expr(left)?),
right: Box::new(self.transform_expr(right)?),
}),
SqlparserExpr::UnaryOp { op, expr } => Ok(Expr::UnaryOp {
op: self.transform_unary_operator(op)?,
expr: Box::new(self.transform_expr(expr)?),
}),
SqlparserExpr::Cast { expr, data_type } => Ok(Expr::Cast {
expr: Box::new(self.transform_expr(expr)?),
target_type: self.transform_data_type(data_type)?,
}),
SqlparserExpr::Value(literal) => {
let lit = match literal {
Value::Number(str, _) => Ok(Literal::Number(str.to_owned())),
Value::SingleQuotedString(str) => Ok(Literal::String(str.to_owned())),
Value::NationalStringLiteral(str) => Ok(Literal::String(str.to_owned())),
Value::HexStringLiteral(str) => Ok(Literal::String(str.to_owned())),
Value::DoubleQuotedString(str) => Ok(Literal::String(str.to_owned())),
Value::Boolean(v) => Ok(Literal::Boolean(v.to_owned())),
Value::Null => Ok(Literal::Null),
_ => Err(ErrorCode::SyntaxException(std::format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
}?;
Ok(Expr::Literal(lit))
}
SqlparserExpr::Function(func)
if func.name.0.get(0).map(|ident| ident.value.to_uppercase())
== Some("COUNT".to_string())
&& func.args.get(0)
== Some(&FunctionArg::Unnamed(FunctionArgExpr::Wildcard)) =>
{
Ok(Expr::CountAll)
}
SqlparserExpr::Function(func) => Ok(Expr::FunctionCall {
distinct: func.distinct,
name: func
.name
.0
.get(0)
.ok_or_else(|| {
ErrorCode::SyntaxException(std::format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))
})?
.value
.to_owned(),
args: func
.args
.iter()
.map(|arg| match arg {
FunctionArg::Unnamed(expr) => self.transform_function_arg(expr),
FunctionArg::Named { .. } => Err(ErrorCode::SyntaxException(std::format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
})
.collect::<Result<_>>()?,
// TODO(leiysky): wait for bumping to https://github.com/datafuse-extras/sqlparser-rs/pull/5
params: vec![],
}),
SqlparserExpr::Case {
operand,
conditions,
results,
else_result,
} => Ok(Expr::Case {
operand: operand
.as_ref()
.map(|expr| self.transform_expr(expr))
.transpose()?
.map(Box::new),
conditions: conditions
.iter()
.map(|expr| self.transform_expr(expr))
.collect::<Result<_>>()?,
results: results
.iter()
.map(|expr| self.transform_expr(expr))
.collect::<Result<_>>()?,
else_result: else_result
.as_ref()
.map(|expr| self.transform_expr(expr))
.transpose()?
.map(Box::new),
}),
SqlparserExpr::Exists(subquery) => {
Ok(Expr::Exists(Box::new(self.transform_query(subquery)?)))
}
SqlparserExpr::Subquery(subquery) => {
Ok(Expr::Subquery(Box::new(self.transform_query(subquery)?)))
}
_ => Err(ErrorCode::SyntaxException(std::format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
}
}
// 二元运算的操作
fn transform_binary_operator(&self, op: &SqlparserBinaryOperator) -> Result<BinaryOperator> {
match op {
SqlparserBinaryOperator::Plus => Ok(BinaryOperator::Plus),
SqlparserBinaryOperator::Minus => Ok(BinaryOperator::Minus),
SqlparserBinaryOperator::Multiply => Ok(BinaryOperator::Multiply),
SqlparserBinaryOperator::Divide => Ok(BinaryOperator::Divide),
SqlparserBinaryOperator::Div => Ok(BinaryOperator::Div),
SqlparserBinaryOperator::Modulo => Ok(BinaryOperator::Modulo),
SqlparserBinaryOperator::StringConcat => Ok(BinaryOperator::StringConcat),
SqlparserBinaryOperator::Gt => Ok(BinaryOperator::Gt),
SqlparserBinaryOperator::Lt => Ok(BinaryOperator::Lt),
SqlparserBinaryOperator::GtEq => Ok(BinaryOperator::Gte),
SqlparserBinaryOperator::LtEq => Ok(BinaryOperator::Lte),
SqlparserBinaryOperator::Eq => Ok(BinaryOperator::Eq),
SqlparserBinaryOperator::NotEq => Ok(BinaryOperator::NotEq),
SqlparserBinaryOperator::And => Ok(BinaryOperator::And),
SqlparserBinaryOperator::Or => Ok(BinaryOperator::Or),
SqlparserBinaryOperator::Like => Ok(BinaryOperator::Like),
SqlparserBinaryOperator::NotLike => Ok(BinaryOperator::NotLike),
SqlparserBinaryOperator::BitwiseOr => Ok(BinaryOperator::BitwiseOr),
SqlparserBinaryOperator::BitwiseAnd => Ok(BinaryOperator::BitwiseAnd),
SqlparserBinaryOperator::BitwiseXor => Ok(BinaryOperator::BitwiseXor),
_ => Err(ErrorCode::SyntaxException(std::format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
}
}
// 一元运算的操作
fn transform_unary_operator(&self, op: &SqlparserUnaryOperator) -> Result<UnaryOperator> {
match op {
SqlparserUnaryOperator::Plus => Ok(UnaryOperator::Plus),
SqlparserUnaryOperator::Minus => Ok(UnaryOperator::Minus),
SqlparserUnaryOperator::Not => Ok(UnaryOperator::Not),
_ => Err(ErrorCode::SyntaxException(std::format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
}
}
// 数据类型的转换
fn transform_data_type(&self, data_type: &SqlparserDataType) -> Result<TypeName> {
match data_type {
SqlparserDataType::Char(length) => Ok(TypeName::Char(length.to_owned())),
SqlparserDataType::Varchar(length) => Ok(TypeName::Varchar(length.to_owned())),
SqlparserDataType::Decimal(prec, scale) => {
Ok(TypeName::Decimal(prec.to_owned(), scale.to_owned()))
}
SqlparserDataType::Float(length) => Ok(TypeName::Float(length.to_owned())),
SqlparserDataType::Int(zerofill) => Ok(TypeName::Int(zerofill.to_owned())),
SqlparserDataType::TinyInt(zerofill) => Ok(TypeName::TinyInt(zerofill.to_owned())),
SqlparserDataType::SmallInt(zerofill) => Ok(TypeName::SmallInt(zerofill.to_owned())),
SqlparserDataType::BigInt(zerofill) => Ok(TypeName::BigInt(zerofill.to_owned())),
SqlparserDataType::Real => Ok(TypeName::Real),
SqlparserDataType::Double => Ok(TypeName::Double),
SqlparserDataType::Boolean => Ok(TypeName::Boolean),
SqlparserDataType::Date => Ok(TypeName::Date),
SqlparserDataType::Time => Ok(TypeName::Time),
SqlparserDataType::Timestamp => Ok(TypeName::Timestamp),
SqlparserDataType::Interval => Ok(TypeName::Interval),
SqlparserDataType::Text => Ok(TypeName::Text),
_ => Err(ErrorCode::SyntaxException(std::format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
}
}
// 处理函数中的参数：表达式/通用符等
fn transform_function_arg(&self, arg_expr: &FunctionArgExpr) -> Result<Expr> {
match arg_expr {
FunctionArgExpr::Expr(expr) => self.transform_expr(expr),
FunctionArgExpr::Wildcard => unreachable!(),
FunctionArgExpr::QualifiedWildcard(_) => Err(ErrorCode::SyntaxException(std::format!(
"Unsupported SQL statement: {}",
self.orig_stmt
))),
}
}
5、demo用例
let parser = Parser {};
let sqls = vec![
"select distinct a, count(*) from t where a = 1 and b - 1 < a group by a having a = 1;"
];
let stmts: Vec<Statement> = sqls
.into_iter()
.flat_map(|sql| {
parser
.parse_with_sqlparser(sql)
.map_err(|e| e.add_message(format!("SQL: {}", sql.to_owned())))
.unwrap()
})
.collect();
let expected = vec![
r#"SELECT DISTINCT a, COUNT(*) FROM t WHERE a = 1 AND b - 1 < a GROUP BY a HAVING a = 1"#
];
for (stmt, expect) in stmts.iter().zip(expected) {
assert_eq!(format!("{}", stmt), expect);
}
网友评论