Support CREATE TABLE WITH (#194)

Author: jogrogan

hoptimator-jdbc/src/main/codegen/config.fmpp

@@ -34,6 +34,7 @@ data: {
       "org.apache.calcite.sql.ddl.SqlDdlNodes"
       "com.linkedin.hoptimator.jdbc.ddl.SqlCreateFunction"
       "com.linkedin.hoptimator.jdbc.ddl.SqlCreateMaterializedView"
+      "com.linkedin.hoptimator.jdbc.ddl.SqlCreateTable"
       "com.linkedin.hoptimator.jdbc.ddl.SqlCreateTrigger"
       "com.linkedin.hoptimator.jdbc.ddl.SqlFire"
       "com.linkedin.hoptimator.jdbc.ddl.SqlFireMaterializedView"

hoptimator-jdbc/src/main/codegen/includes/parserImpls.ftl

@@ -192,6 +192,7 @@ SqlCreate SqlCreateTable(Span s, boolean replace) :
     final boolean ifNotExists;
     final SqlIdentifier id;
     SqlNodeList tableElementList = null;
+    SqlNodeList optionList = null;
     SqlNode query = null;
 
     SqlCreate createTableLike = null;
@@ -204,9 +205,10 @@ SqlCreate SqlCreateTable(Span s, boolean replace) :
         }
     |
         [ tableElementList = TableElementList() ]
+        [ optionList = Options() ]
         [ <AS> query = OrderedQueryOrExpr(ExprContext.ACCEPT_QUERY) ]
         {
-            return SqlDdlNodes.createTable(s.end(this), replace, ifNotExists, id, tableElementList, query);
+            return new SqlCreateTable(s.end(this), replace, ifNotExists, id, tableElementList, optionList, query);
         }
     )
 }

hoptimator-jdbc/src/main/java/com/linkedin/hoptimator/jdbc/HoptimatorDdlExecutor.java

@@ -30,6 +30,7 @@
 import com.linkedin.hoptimator.View;
 import com.linkedin.hoptimator.jdbc.ddl.HoptimatorDdlParserImpl;
 import com.linkedin.hoptimator.jdbc.ddl.SqlCreateMaterializedView;
+import com.linkedin.hoptimator.jdbc.ddl.SqlCreateTable;
 import com.linkedin.hoptimator.jdbc.ddl.SqlCreateTrigger;
 import com.linkedin.hoptimator.util.ArrayTable;
 import com.linkedin.hoptimator.jdbc.ddl.SqlDropTrigger;
@@ -70,7 +71,6 @@
 import org.apache.calcite.sql.SqlLiteral;
 import org.apache.calcite.sql.SqlNode;
 import org.apache.calcite.sql.ddl.SqlColumnDeclaration;
-import org.apache.calcite.sql.ddl.SqlCreateTable;
 import org.apache.calcite.sql.ddl.SqlCreateView;
 import org.apache.calcite.sql.ddl.SqlDropMaterializedView;
 import org.apache.calcite.sql.ddl.SqlDropObject;
@@ -461,7 +461,9 @@ public void execute(SqlCreateTable create, CalcitePrepare.Context context) {
       List<String> tablePath = new ArrayList<>(schemaPath);
       tablePath.add(tableName);
 
-      Source source = new Source(database, tablePath, Collections.emptyMap());
+      Map<String, String> tableOptions = HoptimatorDdlUtils.options(create.options);
+
+      Source source = new Source(database, tablePath, tableOptions);
       logger.info("Validating new table {}", source);
       ValidationService.validateOrThrow(source);
       deployers = DeploymentService.deployers(source, connection);