public class org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres extends org.apache.drill.test.ClusterTest { private static final java.lang.String DOCKER_IMAGE_POSTGRES_X86; private static org.testcontainers.containers.JdbcDatabaseContainer jdbcContainer; public void () { org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; specialinvoke v.()>(); return; } public static void initPostgres() throws java.lang.Exception { org.apache.drill.test.BaseDirTestWatcher v, v; org.testcontainers.utility.DockerImageName v; java.nio.file.Path v; org.apache.drill.exec.store.jdbc.JdbcStorageConfig v, v; java.util.TimeZone v; org.apache.drill.common.logical.StoragePluginConfig$AuthMode v, v; org.apache.drill.test.ClusterFixtureBuilder v; java.lang.String[] v; java.util.HashMap v; long v, v, v; org.testcontainers.containers.PostgreSQLContainer v, v, v, v; org.testcontainers.containers.JdbcDatabaseContainer v, v, v, v, v, v, v, v; java.lang.Boolean v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.test.ClusterFixture v, v; java.util.concurrent.TimeUnit v, v, v; v = ; v = staticinvoke (v); staticinvoke (v); v = ; v = newarray (java.lang.String)[0]; v = staticinvoke ("", v); virtualinvoke v.(v); v = staticinvoke ("UTC"); staticinvoke (v); v = staticinvoke ("postgres:12.8-alpine.14"); v = new org.testcontainers.containers.PostgreSQLContainer; specialinvoke v.(org.testcontainers.utility.DockerImageName)>(v); v = virtualinvoke v.("postgres"); v = virtualinvoke v.("password"); v = virtualinvoke v.("drill_postgres_test"); v = virtualinvoke v.("postgres-test-data.sql"); = v; v = ; virtualinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("maximumPoolSize", "16"); v = ; v = virtualinvoke v.(5L); v = staticinvoke (v); interfaceinvoke v.("idleTimeout", v); v = ; v = virtualinvoke v.(5L); v = staticinvoke (v); interfaceinvoke v.("keepaliveTime", v); v = ; v = virtualinvoke v.(20L); v = staticinvoke (v); interfaceinvoke v.("maxLifetime", v); interfaceinvoke v.("minimumIdle", "0"); v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig; v = ; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); 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.postgresql.Driver", v, v, v, 1, 1, v, null, v, 10000); v = staticinvoke (1); virtualinvoke v.(v); v = ; virtualinvoke v.("pg", v); v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig; v = ; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); 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.postgresql.Driver", v, v, v, 1, 0, v, null, v, 10000); v = staticinvoke (1); virtualinvoke v.(v); v = ; virtualinvoke v.("pg_unwritable", v); return; } public static void stopPostgres() { org.testcontainers.containers.JdbcDatabaseContainer v, v; v = ; if v == null goto label; v = ; virtualinvoke v.(); label: return; } public void testUnwritableConnectionWithIfNotExists() throws java.lang.Exception { java.io.PrintStream v; java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres v; java.lang.String v, v; boolean v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; label: v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE IF NOT EXISTS pg_unwritable.public.`test_table` (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))"); virtualinvoke v.(); staticinvoke (); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.("VALIDATION ERROR: Unable to create or drop objects. Schema [pg_unwritable.public] is immutable."); staticinvoke (v); label: return; catch org.apache.drill.common.exceptions.UserRemoteException from label to label with label; } public void testUnwritableConnection() throws java.lang.Exception { java.io.PrintStream v; java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres v; java.lang.String v, v; boolean v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; label: v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE pg_unwritable.`public`.`test_table` (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))"); virtualinvoke v.(); staticinvoke (); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.("VALIDATION ERROR: Unable to create or drop objects. Schema [pg_unwritable.public] is immutable."); staticinvoke (v); label: return; catch org.apache.drill.common.exceptions.UserRemoteException 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; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres 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; 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; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE pg.`public`.`test_table` (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM pg.`public`.`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); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE pg.`public`.`test_table`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); return; } 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; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres 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; java.time.LocalDate v; java.lang.Object[] v; java.lang.Double v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.Boolean v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE pg.public.`data_types` AS SELECT 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.(); staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM pg.`public`.`data_types`"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("int_field", v, 10); v = ; v = virtualinvoke v.("bigint_field", v, 19); v = ; v = virtualinvoke v.("float4_field", v, 17, 17); v = ; v = virtualinvoke v.("float8_field", v, 17, 17); v = ; v = virtualinvoke v.("varchar_field", v, 3); v = ; v = virtualinvoke v.("date_field", v, 13); v = ; v = virtualinvoke v.("time_field", v, 12, 3); v = ; v = virtualinvoke v.("timestamp_field", v, 26, 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); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE pg.`public`.`data_types`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); return; } 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; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres 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; 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; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE pg.public.`test table` (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM pg.public.`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); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE pg.public.`test table`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); return; } public void testWithLargeFile() throws java.lang.Exception { org.apache.drill.test.QueryBuilder v, v, v, v, v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres v; long v; org.apache.drill.test.QueryBuilder$QuerySummary v, v; boolean v, v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE pg.public.test (id,first_name,last_name,email,gender,ip_address) AS SELECT id,first_name,last_name,email,gender,ip_address FROM cp.`csv/large_csv.csvh`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT COUNT(*) FROM pg.public.test"); v = virtualinvoke v.(); staticinvoke (6000L, v); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE pg.public.`test`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); return; } public void testWithReallyLongFile() throws java.lang.Exception { long v, v; org.apache.hadoop.fs.Path v; java.lang.String v; boolean v, v, v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v, v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres v; java.io.IOException v; org.apache.drill.test.QueryBuilder$QuerySummary v, v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; v = null; label: v = staticinvoke ("csv/very_large_file.csvh", 10, 100000); label: goto label; label: v := @caughtexception; staticinvoke (); label: v = virtualinvoke v.(); v = virtualinvoke v.("SELECT COUNT(*) FROM dfs.`csv/very_large_file.csvh`"); v = virtualinvoke v.(); staticinvoke (100000L, v); v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE pg.public.`test_big_table` AS SELECT * FROM dfs.`csv/very_large_file.csvh`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT COUNT(*) FROM pg.public.`test_big_table`"); v = virtualinvoke v.(); staticinvoke (100000L, v); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE pg.public.`test_big_table`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = staticinvoke (v); v = staticinvoke (v); if v != 0 goto label; staticinvoke (); label: return; catch java.io.IOException 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; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres 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; 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; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE pg.public.`test table` (`My id`, `My name`) AS SELECT * FROM (VALUES(1,2), (3,4))"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM pg.public.`test table`"); 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); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE pg.public.`test table`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); return; } 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; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres 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; java.lang.Object[] v, v, v; java.lang.Double v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.Boolean v, v; org.apache.drill.test.ClientFixture v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE pg.public.`t1` AS SELECT int_field, float_field, varchar_field, boolean_field FROM cp.`json/dataTypes.json`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM pg.public.`t1`"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("int_field", v, 19); v = ; v = virtualinvoke v.("float_field", v, 22); 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); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE pg.`public`.`t1`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); return; } public void testDropNonExistentTable() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres v; java.lang.String v; boolean v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; label: v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE pg.`public`.`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 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; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres 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; 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; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE IF NOT EXISTS pg.`public`.`test_table` (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM pg.`public`.`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); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE pg.`public`.`test_table`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); return; } public void testCTASWithDuplicateTable() throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v; 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; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v; java.lang.Boolean v; java.lang.String v; org.apache.drill.test.ClientFixture v; boolean v, v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres 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 := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE pg.`public`.`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.("CREATE TABLE pg.`public`.`test_table` (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))"); virtualinvoke v.(); staticinvoke (); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.("VALIDATION ERROR"); staticinvoke (v); label: v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE IF NOT EXISTS pg.`public`.`test_table` (ID, NAME) AS SELECT * FROM (VALUES(1,2), (3,4))"); 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 [pg.public]"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); return; catch org.apache.drill.common.exceptions.UserRemoteException from label to label with label; } public void testWithComplexData() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres v; java.lang.String v; boolean v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; label: v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE pg.`public`.`complex` AS SELECT * FROM cp.`json/complexData.json`"); 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 { java.lang.Object[] v; 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; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.test.ClientFixture v; boolean v, v; org.apache.drill.test.QueryBuilder v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres 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 := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE pg.public.`t2` AS SELECT ugly, ugly FROM cp.`json/uglyData.json`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM pg.public.`t2`"); 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); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE pg.public.`t2`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); return; } public void testWithArrayField() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres v; org.hamcrest.Matcher v; java.lang.String v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithPostgres; label: v = virtualinvoke v.