From 4536e6e9b6622343e6cdac86540b09a4e29acc18 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=AB=98=E9=93=81?= Date: Tue, 12 Jan 2016 10:16:42 +0800 Subject: [PATCH] mysql sql parser support 'create database if not exists' --- .../statement/SQLCreateDatabaseStatement.java | 10 +++++ .../mysql/parser/MySqlStatementParser.java | 8 ++++ .../sql/visitor/SQLASTOutputVisitor.java | 3 ++ .../sql/mysql/MySqlCreateDatabaseTest.java | 42 +++++++++++++++++++ 4 files changed, 63 insertions(+) create mode 100644 src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateDatabaseTest.java diff --git a/src/main/java/com/alibaba/druid/sql/ast/statement/SQLCreateDatabaseStatement.java b/src/main/java/com/alibaba/druid/sql/ast/statement/SQLCreateDatabaseStatement.java index 6216fed085..14df97b1d6 100644 --- a/src/main/java/com/alibaba/druid/sql/ast/statement/SQLCreateDatabaseStatement.java +++ b/src/main/java/com/alibaba/druid/sql/ast/statement/SQLCreateDatabaseStatement.java @@ -30,6 +30,8 @@ public class SQLCreateDatabaseStatement extends SQLStatementImpl { private String collate; private List hints; + + protected boolean ifNotExists = false; public SQLCreateDatabaseStatement(){ } @@ -77,5 +79,13 @@ public class SQLCreateDatabaseStatement extends SQLStatementImpl { public void setHints(List hints) { this.hints = hints; } + + public boolean isIfNotExists() { + return ifNotExists; + } + + public void setIfNotExists(boolean ifNotExists) { + this.ifNotExists = ifNotExists; + } } diff --git a/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java b/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java index 936c85e592..3e7ae247d9 100644 --- a/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java +++ b/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java @@ -2688,6 +2688,14 @@ public class MySqlStatementParser extends SQLStatementParser { accept(Token.DATABASE); SQLCreateDatabaseStatement stmt = new SQLCreateDatabaseStatement(JdbcConstants.MYSQL); + + if (lexer.token() == Token.IF) { + lexer.nextToken(); + accept(Token.NOT); + accept(Token.EXISTS); + stmt.setIfNotExists(true); + } + stmt.setName(this.exprParser.name()); if (lexer.token() == Token.DEFAULT) { diff --git a/src/main/java/com/alibaba/druid/sql/visitor/SQLASTOutputVisitor.java b/src/main/java/com/alibaba/druid/sql/visitor/SQLASTOutputVisitor.java index 8c43f57ccd..f4224ef1e2 100644 --- a/src/main/java/com/alibaba/druid/sql/visitor/SQLASTOutputVisitor.java +++ b/src/main/java/com/alibaba/druid/sql/visitor/SQLASTOutputVisitor.java @@ -1601,6 +1601,9 @@ public class SQLASTOutputVisitor extends SQLASTVisitorAdapter implements Printab @Override public boolean visit(SQLCreateDatabaseStatement x) { print0(ucase ? "CREATE DATABASE " : "create database "); + if (x.isIfNotExists()) { + print0(ucase ? "IF NOT EXISTS " : "if not exists "); + } x.getName().accept(this); return false; } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateDatabaseTest.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateDatabaseTest.java new file mode 100644 index 0000000000..58a737b27c --- /dev/null +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateDatabaseTest.java @@ -0,0 +1,42 @@ +/* + * Copyright 1999-2101 Alibaba Group Holding Ltd. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.alibaba.druid.bvt.sql.mysql; + +import org.junit.Assert; +import org.junit.Test; + +import com.alibaba.druid.sql.MysqlTest; +import com.alibaba.druid.sql.SQLUtils; +import com.alibaba.druid.sql.ast.SQLStatement; +import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser; +import com.alibaba.druid.sql.dialect.mysql.visitor.MySqlSchemaStatVisitor; + +public class MySqlCreateDatabaseTest extends MysqlTest { + + @Test + public void test_one() throws Exception { + String sql = "create database if not exists a"; + + MySqlStatementParser parser = new MySqlStatementParser(sql); + SQLStatement stmt = parser.parseStatement(); + + MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); + stmt.accept(visitor); + + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE DATABASE IF NOT EXISTS a", output); + } +}