fix(isthmus): support DDL statements in SqlToSubstrait conversion (#736)

Author: ZorinAnton

isthmus/src/main/java/io/substrait/isthmus/SqlToSubstrait.java

@@ -5,6 +5,7 @@
 import io.substrait.plan.Plan;
 import io.substrait.plan.Plan.Version;
 import org.apache.calcite.prepare.Prepare;
+import org.apache.calcite.server.ServerDdlExecutor;
 import org.apache.calcite.sql.SqlDialect;
 import org.apache.calcite.sql.SqlOperatorTable;
 import org.apache.calcite.sql.parser.SqlParseException;
@@ -67,7 +68,9 @@ public Plan convert(
     Builder builder = io.substrait.plan.Plan.builder();
     builder.version(Version.builder().from(Version.DEFAULT_VERSION).producer("isthmus").build());
 
-    final SqlParser.Config sqlParserConfig = sqlDialect.configureParser(SqlParser.config());
+    final SqlParser.Config sqlParserConfig =
+        sqlDialect.configureParser(
+            SqlParser.config().withParserFactory(ServerDdlExecutor.PARSER_FACTORY));
 
     // TODO: consider case in which one sql passes conversion while others don't
     SubstraitSqlToCalcite.convertQueries(sqlStatements, catalogReader, sqlParserConfig).stream()

isthmus/src/test/java/io/substrait/isthmus/DdlToSubstraitConversionTest.java

@@ -0,0 +1,22 @@
+package io.substrait.isthmus;
+
+import io.substrait.isthmus.sql.SubstraitCreateStatementParser;
+import org.apache.calcite.prepare.Prepare;
+import org.apache.calcite.sql.SqlDialect;
+import org.apache.calcite.sql.parser.SqlParseException;
+import org.junit.jupiter.api.Test;
+
+class DdlToSubstraitConversionTest {
+  @Test
+  void testConversion() throws SqlParseException {
+    final Prepare.CatalogReader catalogReader =
+        SubstraitCreateStatementParser.processCreateStatementsToCatalog(
+            "create table src1 (intcol int, charcol varchar(10))");
+
+    final SqlToSubstrait converter = new SqlToSubstrait();
+    converter.convert(
+        "create table dst1 as select * from src1",
+        catalogReader,
+        SqlDialect.DatabaseProduct.CALCITE.getDialect());
+  }
+}