public class org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 extends org.apache.drill.test.ClusterTest { public static final java.lang.String TEST_TABLE; public static final java.lang.String DROP_TEST_TABLE; public void () { org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2; specialinvoke v.()>(); return; } public static void init() throws java.lang.Exception { org.apache.drill.test.BaseDirTestWatcher v, v, v; java.sql.Connection v; java.net.URL v; java.lang.Integer v; java.nio.file.Path v; org.apache.drill.exec.store.jdbc.JdbcStorageConfig v, v; org.apache.drill.common.logical.security.PlainCredentialsProvider v; java.util.TimeZone v; org.apache.drill.common.logical.StoragePluginConfig$AuthMode v, v; java.lang.ClassLoader v; org.apache.drill.test.ClusterFixtureBuilder v; java.lang.Throwable v, v; java.lang.String[] v; java.util.HashMap v, v; java.lang.Boolean v, v, v, v; java.lang.String v, v, v, v, v; org.apache.drill.test.ClusterFixture v, v, v; java.io.File v; org.apache.drill.exec.store.enumerable.plan.EnumMockPlugin$EnumMockStoragePluginConfig v; java.lang.Class v; java.io.FileReader v; v = ; v = staticinvoke (v); staticinvoke (v); v = staticinvoke ("UTC"); staticinvoke (v); v = ; v = newarray (java.lang.String)[0]; v = staticinvoke ("", v); virtualinvoke v.(v); staticinvoke ("org.h.Driver"); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("jdbc:h2:\u0001"); v = class "Lorg/apache/drill/exec/store/jdbc/TestJdbcPluginWithH2IT;"; v = virtualinvoke v.(); v = virtualinvoke v.("h2-test-data.sql"); staticinvoke ("Script for test tables generation \'h2-test-data.sql\' cannot be found in test resources", v); v = staticinvoke (v, "root", "root"); label: v = new java.io.FileReader; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); label: staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: if v == null goto label; interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("username", "root"); interfaceinvoke v.("password", "root"); v = new org.apache.drill.common.logical.security.PlainCredentialsProvider; specialinvoke v.(java.util.Map)>(v); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (1); interfaceinvoke v.("minimumIdle", v); v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig; v = ; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,boolean,java.util.Map,org.apache.drill.common.logical.security.CredentialsProvider,java.lang.String,int)>("org.h.Driver", v, "root", "root", 1, 1, v, v, v, 10000); v = staticinvoke (1); virtualinvoke v.(v); v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig; v = ; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,boolean,java.util.Map,org.apache.drill.common.logical.security.CredentialsProvider,java.lang.String,int)>("org.h.Driver", v, "root", "root", 1, 0, v, v, v, 10000); v = staticinvoke (1); virtualinvoke v.(v); v = staticinvoke (1); virtualinvoke v.(v); v = ; virtualinvoke v.("h2", v); v = ; virtualinvoke v.("h2_unwritable", v); v = new org.apache.drill.exec.store.enumerable.plan.EnumMockPlugin$EnumMockStoragePluginConfig; specialinvoke v.()>(); v = staticinvoke (1); virtualinvoke v.(v); v = ; virtualinvoke v.("mocked_enum", v); return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testBasicCTAS() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; java.lang.Integer v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; boolean v, v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; org.apache.drill.test.QueryBuilder$QuerySummary v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v; java.lang.String v, v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2; v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("CREATE TABLE %s (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); label: v = virtualinvoke v.(); staticinvoke (v); v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("SELECT * FROM %s", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("ID", v, v); v = ; v = ; v = virtualinvoke v.("NAME", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = staticinvoke (1); v[0] = v; v = staticinvoke (2); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke (3); v[0] = v; v = staticinvoke (4); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testBasicCTASWithDataTypes() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v, v, v, v, v, v; java.lang.Integer v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v; java.lang.Long v, v; java.time.LocalTime v; boolean v, v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; org.apache.drill.test.QueryBuilder$QuerySummary v, v, v; java.time.LocalDate v; java.lang.Throwable v; java.lang.Object[] v, v, v; java.lang.Double v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.Boolean v; java.lang.String v, v, v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2; v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("CREATE TABLE %s AS ", v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001SELECT CAST(1 AS INTEGER) AS int_field,CAST(2 AS BIGINT) AS bigint_field,CAST(3.0 AS FLOAT) AS float4_field,CAST(4.0 AS DOUBLE) AS float8_field,\'5.0\' AS varchar_field,CAST(\'2021-01-01\' AS DATE) as date_field,CAST(\'12:00:00\' AS TIME) as time_field, CAST(\'2015-12-30 22:55:55.23\' AS TIMESTAMP) as timestamp_field, true AS boolean_field FROM (VALUES(1))"); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("SELECT * FROM %s", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("int_field", v, 32); v = ; v = virtualinvoke v.("bigint_field", v, 38); v = ; v = virtualinvoke v.("float4_field", v, 38); v = ; v = virtualinvoke v.("float8_field", v, 38); v = ; v = virtualinvoke v.("varchar_field", v, 3); v = ; v = virtualinvoke v.("date_field", v, 10); v = ; v = virtualinvoke v.("time_field", v, 12, 3); v = ; v = virtualinvoke v.("timestamp_field", v, 23, 3); v = ; v = virtualinvoke v.("boolean_field", v, 1); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[9]; v = staticinvoke (1); v[0] = v; v = staticinvoke (2L); v[1] = v; v = staticinvoke (3.0); v[2] = v; v = staticinvoke (4.0); v[3] = v; v[4] = "5.0"; v = staticinvoke ("2021-01-01"); v[5] = v; v = staticinvoke ("12:00"); v[6] = v; v = staticinvoke (1451516155230L); v[7] = v; v = staticinvoke (1); v[8] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testBasicCTASWithSpacesInFieldNames() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; java.lang.Integer v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; boolean v, v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; org.apache.drill.test.QueryBuilder$QuerySummary v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v; java.lang.String v, v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2; v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("CREATE TABLE %s (`My id`, `My name`) AS SELECT * FROM (VALUES(1,2), (3,4))", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("SELECT * FROM %s", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("My id", v, v); v = ; v = ; v = virtualinvoke v.("My name", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = staticinvoke (1); v[0] = v; v = staticinvoke (2); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke (3); v[0] = v; v = staticinvoke (4); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testCTASFromFileWithNulls() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v; java.lang.Long v, v; boolean v, v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; org.apache.drill.test.QueryBuilder$QuerySummary v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v; java.lang.Double v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.Boolean v, v; java.lang.String v, v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2; v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("CREATE TABLE %s AS SELECT int_field, float_field, varchar_field, boolean_field FROM cp.`json/dataTypes.json`", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("SELECT * FROM %s", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("int_field", v, 38); v = ; v = virtualinvoke v.("float_field", v, 38); v = ; v = virtualinvoke v.("varchar_field", v, 38); v = ; v = virtualinvoke v.("boolean_field", v, 1); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[4]; v = staticinvoke (1L); v[0] = v; v = staticinvoke (1.0); v[1] = v; v[2] = "foo1"; v = staticinvoke (1); v[3] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[4]; v[0] = null; v[1] = null; v[2] = null; v[3] = null; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[4]; v = staticinvoke (2L); v[0] = v; v = staticinvoke (2.0); v[1] = v; v[2] = "foo2"; v = staticinvoke (0); v[3] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testDropNonExistentTable() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; java.lang.String v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 v; boolean v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2; label: v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE h.tmp.`drill_h2_test`.`none_shall_pass`"); virtualinvoke v.(); staticinvoke (); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.("VALIDATION ERROR: Table [none_shall_pass] not found"); staticinvoke (v); label: return; catch org.apache.drill.common.exceptions.UserRemoteException from label to label with label; } public void testBasicCTASWithSpacesInTableName() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; java.lang.Integer v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; boolean v, v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; org.apache.drill.test.QueryBuilder$QuerySummary v, v, v; java.lang.Throwable v; java.lang.Object[] v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE h.tmp.`drill_h2_test`.`test table` (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); label: v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM h.tmp.`drill_h2_test`.`test table`"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("ID", v, v); v = ; v = ; v = virtualinvoke v.("NAME", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = staticinvoke (1); v[0] = v; v = staticinvoke (2); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke (3); v[0] = v; v = staticinvoke (4); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE h.tmp.`drill_h2_test`.`test table`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE h.tmp.`drill_h2_test`.`test table`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testBasicCTASIfNotExists() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; java.lang.Integer v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; boolean v, v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; org.apache.drill.test.QueryBuilder$QuerySummary v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v; java.lang.String v, v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2; v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("CREATE TABLE IF NOT EXISTS %s (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("SELECT * FROM %s", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("ID", v, v); v = ; v = ; v = virtualinvoke v.("NAME", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = staticinvoke (1); v[0] = v; v = staticinvoke (2); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke (3); v[0] = v; v = staticinvoke (4); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testCTASWithDuplicateTable() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; boolean v, v, v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; org.apache.drill.test.QueryBuilder$QuerySummary v, v, v; java.lang.Throwable v, v; java.lang.Object[] v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v; java.lang.Boolean v; java.lang.String v, v, v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2; v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("CREATE TABLE %s (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); label: v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(); staticinvoke (); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.("VALIDATION ERROR"); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("CREATE TABLE IF NOT EXISTS %s (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("ok", v); v = ; v = ; v = virtualinvoke v.("summary", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = staticinvoke (0); v[0] = v; v[1] = "A table or view with given name [test_table] already exists in schema [h.tmp.drill_h2_test]"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); throw v; label: return; catch org.apache.drill.common.exceptions.UserRemoteException from label to label with label; catch java.lang.Throwable from label to label with label; } public void testWithComplexData() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; java.lang.Object[] v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 v; java.lang.String v, v; boolean v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2; label: v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("CREATE TABLE %s AS SELECT * FROM cp.`json/complexData.json`", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(); staticinvoke (); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.("DATA_WRITE ERROR: Drill does not support writing complex fields to JDBC data sources."); staticinvoke (v); label: return; catch org.apache.drill.common.exceptions.UserRemoteException from label to label with label; } public void testCTASFromFileWithUglyData() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; boolean v, v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2 v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; org.apache.drill.test.QueryBuilder$QuerySummary v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.String v, v, v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithH2; v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("CREATE TABLE %s AS SELECT ugly, ugly FROM cp.`json/uglyData.json`", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); label: v = newarray (java.lang.Object)[1]; v[0] = "h.tmp.drill_h2_test.test_table"; v = staticinvoke ("SELECT * FROM %s", v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("ugly1", v, 38); v = ; v = virtualinvoke v.("ugly2", v, 38); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v[0] = "O\'Malley"; v[1] = "Abraham Lincoln\'s best speech started with: \"Four score and seven years ago..."; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.