Skip to content

Commit 1e46ff8

Browse files
committed
Update SqlExpr::Trim struct to match latest sqlparser changes
1 parent 4e6cd03 commit 1e46ff8

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

datafusion/sql/src/planner.rs

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2026,21 +2026,21 @@ impl<'a, S: ContextProvider> SqlToRel<'a, S> {
20262026
))
20272027
}
20282028

2029-
SQLExpr::Trim { expr, trim_where } => {
2030-
let (fun, where_expr) = match trim_where {
2031-
Some((TrimWhereField::Leading, expr)) => {
2032-
(BuiltinScalarFunction::Ltrim, Some(expr))
2029+
SQLExpr::Trim { expr, trim_where, trim_what } => {
2030+
let fun = match trim_where {
2031+
Some(TrimWhereField::Leading) => {
2032+
BuiltinScalarFunction::Ltrim
20332033
}
2034-
Some((TrimWhereField::Trailing, expr)) => {
2035-
(BuiltinScalarFunction::Rtrim, Some(expr))
2034+
Some(TrimWhereField::Trailing) => {
2035+
BuiltinScalarFunction::Rtrim
20362036
}
2037-
Some((TrimWhereField::Both, expr)) => {
2038-
(BuiltinScalarFunction::Btrim, Some(expr))
2037+
Some(TrimWhereField::Both) => {
2038+
BuiltinScalarFunction::Btrim
20392039
}
2040-
None => (BuiltinScalarFunction::Trim, None),
2040+
None => BuiltinScalarFunction::Trim
20412041
};
20422042
let arg = self.sql_expr_to_logical_expr(*expr, schema, ctes)?;
2043-
let args = match where_expr {
2043+
let args = match trim_what {
20442044
Some(to_trim) => {
20452045
let to_trim = self.sql_expr_to_logical_expr(*to_trim, schema, ctes)?;
20462046
vec![arg, to_trim]

0 commit comments

Comments
 (0)