diff --git a/src/ast/query.rs b/src/ast/query.rs index ffe1e4023..4398531cb 100644 --- a/src/ast/query.rs +++ b/src/ast/query.rs @@ -341,7 +341,7 @@ pub struct Select { /// DISTRIBUTE BY (Hive) pub distribute_by: Vec, /// SORT BY (Hive) - pub sort_by: Vec, + pub sort_by: Vec, /// HAVING pub having: Option, /// WINDOW AS diff --git a/src/parser/mod.rs b/src/parser/mod.rs index a28540d14..8e3b5c768 100644 --- a/src/parser/mod.rs +++ b/src/parser/mod.rs @@ -11580,7 +11580,7 @@ impl<'a> Parser<'a> { }; let sort_by = if self.parse_keywords(&[Keyword::SORT, Keyword::BY]) { - self.parse_comma_separated(Parser::parse_expr)? + self.parse_comma_separated(Parser::parse_order_by_expr)? } else { vec![] }; diff --git a/tests/sqlparser_hive.rs b/tests/sqlparser_hive.rs index 14dcbffd1..fd52b7730 100644 --- a/tests/sqlparser_hive.rs +++ b/tests/sqlparser_hive.rs @@ -341,6 +341,9 @@ fn lateral_view() { fn sort_by() { let sort_by = "SELECT * FROM db.table SORT BY a"; hive().verified_stmt(sort_by); + + let sort_by_with_direction = "SELECT * FROM db.table SORT BY a, b DESC"; + hive().verified_stmt(sort_by_with_direction); } #[test]