mirrors/datafusion-sqlparse
1
0
Fork 0
mirror of https://github.com/apache/datafusion-sqlparser-rs.git synced 2025-08-23 07:24:10 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

added create and drop schema

Browse source
This commit is contained in:
Alex Dukhno 2020-05-28 19:50:16 +03:00
parent b28dd82838
commit 91f769e460
4 changed files with 42 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

16
src/parser.rs
View file

@ -864,11 +864,21 @@ impl Parser {
self.parse_create_view()
} else if self.parse_keyword("EXTERNAL") {
self.parse_create_external_table()
} else if self.parse_keyword("SCHEMA") {
self.parse_create_schema()
} else {
self.expected("TABLE, VIEW or INDEX after CREATE", self.peek_token())
self.expected(
"TABLE, VIEW, INDEX or SCHEMA after CREATE",
self.peek_token(),
)
}
}
pub fn parse_create_schema(&mut self) -> Result<Statement, ParserError> {
let schema_name = self.parse_object_name()?;
Ok(Statement::CreateSchema { schema_name })
}
pub fn parse_create_external_table(&mut self) -> Result<Statement, ParserError> {
self.expect_keyword("TABLE")?;
let table_name = self.parse_object_name()?;
@ -918,8 +928,10 @@ impl Parser {
ObjectType::View
} else if self.parse_keyword("INDEX") {
ObjectType::Index
} else if self.parse_keyword("SCHEMA") {
ObjectType::Schema
} else {
return self.expected("TABLE, VIEW or INDEX after DROP", self.peek_token());
return self.expected("TABLE, VIEW, INDEX or SCHEMA after DROP", self.peek_token());
};
// Many dialects support the non standard `IF EXISTS` clause and allow
// specifying multiple objects to delete in a single statement