diff --git a/FETCH_HEAD b/FETCH_HEAD new file mode 100644 index 000000000000..e69de29bb2d1 diff --git a/datafusion/sql/src/parser.rs b/datafusion/sql/src/parser.rs index f185d65fa194..e3a137939d18 100644 --- a/datafusion/sql/src/parser.rs +++ b/datafusion/sql/src/parser.rs @@ -354,6 +354,14 @@ impl<'a> DFParser<'a> { self.parse_create() } Keyword::COPY => { + if let Token::Word(w) = self.parser.peek_nth_token(1).token { + // use native parser for COPY INTO + if w.keyword == Keyword::INTO { + return Ok(Statement::Statement(Box::from( + self.parser.parse_statement()?, + ))); + } + } self.parser.next_token(); // COPY self.parse_copy() }