Skip to content

Commit df21533

Browse files
committed
Fix partition clauses with values
1 parent 0181680 commit df21533

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

src/ast/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -460,7 +460,7 @@ pub enum Statement {
460460
/// A SQL query that specifies what to insert
461461
source: Box<Query>,
462462
/// partitioned insert (Hive)
463-
partitioned: Option<Vec<Ident>>
463+
partitioned: Option<Vec<Expr>>
464464
},
465465
Copy {
466466
/// TABLE

src/parser.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2358,7 +2358,7 @@ impl Parser {
23582358

23592359
let partitioned = if self.parse_keyword(Keyword::PARTITION) {
23602360
self.expect_token(&Token::LParen)?;
2361-
let r = Some(self.parse_comma_separated(Parser::parse_identifier)?);
2361+
let r = Some(self.parse_comma_separated(Parser::parse_expr)?);
23622362
self.expect_token(&Token::RParen)?;
23632363
r
23642364
} else {

tests/sqlparser_hive.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ fn parse_table_create() {
3131

3232
#[test]
3333
fn parse_insert_overwrite() {
34-
let insert_partitions = r#"INSERT OVERWRITE TABLE db.new_table PARTITION (a, b) SELECT a, b, c FROM db.table"#;
34+
let insert_partitions = r#"INSERT OVERWRITE TABLE db.new_table PARTITION (a = '1', b) SELECT a, b, c FROM db.table"#;
3535
hive().verified_stmt(insert_partitions);
3636
}
3737

0 commit comments

Comments
 (0)