feat: CREATE SCHEMA IF NOT EXISTS ...

- fixes #2061

Signed-off-by: Andreas Reichel <[email protected]>
Signed-off-by: manticore-projects <[email protected]>

Author: manticore-projects

src/main/java/net/sf/jsqlparser/statement/create/schema/CreateSchema.java

@@ -24,6 +24,7 @@ public class CreateSchema implements Statement {
     private String schemaName;
     private List<String> schemaPath;
     private List<Statement> statements = new ArrayList<>();
+    private boolean hasIfNotExists = false;
 
     @Override
     public <T, S> T accept(StatementVisitor<T> statementVisitor, S context) {
@@ -103,8 +104,20 @@ public List<Statement> getStatements() {
         return statements;
     }
 
+    public boolean hasIfNotExists() {
+        return hasIfNotExists;
+    }
+
+    public CreateSchema setIfNotExists(boolean hasIfNotExists) {
+        this.hasIfNotExists = hasIfNotExists;
+        return this;
+    }
+
     public String toString() {
         String sql = "CREATE SCHEMA";
+        if (hasIfNotExists) {
+            sql += " IF NOT EXISTS";
+        }
         if (schemaName != null) {
             sql += " " + schemaName;
         }

src/main/jjtree/net/sf/jsqlparser/parser/JSqlParserCC.jjt

@@ -5946,7 +5946,7 @@ CreateSchema CreateSchema():
     List<Statement> statements = new ArrayList<Statement>();
 }
 {
-    <K_SCHEMA>
+    <K_SCHEMA> [ <K_IF> <K_NOT> <K_EXISTS> { schema.setIfNotExists(true); } ]
     [ ( tk=<S_IDENTIFIER> | tk=<S_QUOTED_IDENTIFIER>) { schema.setSchemaName(tk.image); } ]
     [ <K_AUTHORIZATION>
         (tk=<S_IDENTIFIER> | tk=<S_QUOTED_IDENTIFIER>) { schema.setAuthorization(tk.image); }

src/test/java/net/sf/jsqlparser/statement/create/schema/CreateSchemaTest.java

@@ -34,4 +34,10 @@ public void testSimpleCreateWithAuth() throws JSQLParserException {
         assertDeparse(new CreateSchema().withSchemaName("myschema").withAuthorization("myauth"),
                 statement);
     }
+
+    @Test
+    void testIfNotExistsIssue2061() throws JSQLParserException {
+        String sqlStr = "CREATE SCHEMA IF NOT EXISTS sales_kpi";
+        assertSqlCanBeParsedAndDeparsed(sqlStr);
+    }
 }