public class org.apache.drill.exec.store.jdbc.TestJdbcWriterWithMySQL extends org.apache.drill.test.ClusterTest { private static final java.lang.String DOCKER_IMAGE_MYSQL; private static final java.lang.String DOCKER_IMAGE_MARIADB; private static final org.slf4j.Logger logger; private static org.testcontainers.containers.JdbcDatabaseContainer jdbcContainer; public void () { org.apache.drill.exec.store.jdbc.TestJdbcWriterWithMySQL v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithMySQL; specialinvoke v.()>(); return; } public static void initMysql() throws java.lang.Exception { java.lang.Integer v; java.nio.file.Path v; org.apache.drill.exec.store.jdbc.JdbcStorageConfig v, v, v; java.lang.Integer[] v; long v, v, v; org.testcontainers.containers.GenericContainer v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.testcontainers.containers.MySQLContainer v, v, v, v, v; org.apache.drill.test.BaseDirTestWatcher v, v; org.testcontainers.utility.DockerImageName v, v; boolean v, v, v, v; java.util.TimeZone v; org.apache.drill.common.logical.StoragePluginConfig$AuthMode v, v, v; org.apache.drill.test.ClusterFixtureBuilder v; java.lang.String[] v; java.util.HashMap v; org.testcontainers.jdbc.JdbcDatabaseDelegate v; org.testcontainers.containers.JdbcDatabaseContainer v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Boolean v, v, v; org.slf4j.Logger v; org.apache.drill.test.ClusterFixture v, 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 ("os.name"); v = virtualinvoke v.(); v = virtualinvoke v.("linux"); if v == 0 goto label; v = "aarch64"; v = staticinvoke ("os.arch"); v = virtualinvoke v.(v); if v == 0 goto label; v = staticinvoke ("mariadb:10.6.0"); v = virtualinvoke v.("mysql"); goto label; label: v = staticinvoke ("mysql:5.7.27"); label: v = new org.testcontainers.containers.MySQLContainer; specialinvoke v.(org.testcontainers.utility.DockerImageName)>(v); v = newarray (java.lang.Integer)[1]; v = staticinvoke (3306); v[0] = v; v = virtualinvoke v.(v); v = virtualinvoke v.("mysql_config_override"); v = virtualinvoke v.("mysqlUser"); v = virtualinvoke v.("mysqlPass"); v = virtualinvoke v.("drill_mysql_test"); v = virtualinvoke v.("serverTimezone", "UTC"); v = virtualinvoke v.("useJDBCCompliantTimezoneShift", "true"); v = virtualinvoke v.("mysql-test-data.sql"); = v; v = ; virtualinvoke v.(); v = virtualinvoke v.("linux"); if v == 0 goto label; v = new org.testcontainers.jdbc.JdbcDatabaseDelegate; v = ; specialinvoke v.(org.testcontainers.containers.JdbcDatabaseContainer,java.lang.String)>(v, ""); staticinvoke (v, "mysql-test-data-linux.sql"); label: v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("maximumPoolSize", "1"); 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 = ; v = virtualinvoke v.(); v = ; interfaceinvoke v.("JDBC URL: {}", v); v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig; 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)>("com.mysql.cj.jdbc.Driver", v, v, v, 0, 1, v, null, v, 10000); v = staticinvoke (1); virtualinvoke v.(v); v = ; virtualinvoke v.("mysql", v); v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig; 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)>("com.mysql.cj.jdbc.Driver", v, v, v, 0, 0, v, null, v, 10000); v = staticinvoke (1); virtualinvoke v.(v); v = ; virtualinvoke v.("mysql_no_write", v); v = virtualinvoke v.("linux"); if v == 0 goto label; v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig; 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)>("com.mysql.cj.jdbc.Driver", v, v, v, 1, 1, v, null, v, 10000); v = staticinvoke (1); virtualinvoke v.(v); v = ; virtualinvoke v.("mysqlCaseInsensitive", v); label: return; } 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.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.exec.store.jdbc.TestJdbcWriterWithMySQL 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.TestJdbcWriterWithMySQL; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE mysql.`drill_mysql_test`.`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 mysql.`drill_mysql_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); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE mysql.`drill_mysql_test`.`test_table`"); 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.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.exec.store.jdbc.TestJdbcWriterWithMySQL 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.TestJdbcWriterWithMySQL; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE mysql.`drill_mysql_test`.`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 mysql.`drill_mysql_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); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE mysql.`drill_mysql_test`.`test table`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); return; } 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.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.exec.store.jdbc.TestJdbcWriterWithMySQL 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.TestJdbcWriterWithMySQL; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE mysql.`drill_mysql_test`.`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 mysql.`drill_mysql_test`.`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 mysql.`drill_mysql_test`.`test table`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); return; } public void testBasicCTASWithLocalDatabase() 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; java.lang.Long v, v, v, v; org.apache.drill.exec.store.jdbc.JdbcStorageConfig v; boolean v, v; org.apache.drill.common.logical.StoragePluginConfig$AuthMode 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.exec.store.jdbc.TestJdbcWriterWithMySQL v; java.lang.Boolean v; java.lang.String 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; org.apache.drill.test.ClusterFixture v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithMySQL; 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)>("com.mysql.cj.jdbc.Driver", "jdbc:mysql://localhost:3306/?useJDBCCompliantTimezoneShift=true&serverTimezone=EST5EDT", "root", "password", 0, 1, null, null, v, 10000); v = staticinvoke (1); virtualinvoke v.(v); v = ; virtualinvoke v.("localMysql", v); v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE localMysql.`drill_mysql_test`.`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 localMysql.`drill_mysql_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 (1L); v[0] = v; v = staticinvoke (2L); v[1] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke (3L); v[0] = v; v = staticinvoke (4L); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE localMysql.`drill_mysql_test`.`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.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; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithMySQL 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.TestJdbcWriterWithMySQL; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE mysql.drill_mysql_test.`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 mysql.`drill_mysql_test`.`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, 12); v = ; v = virtualinvoke v.("float8_field", v, 22); v = ; v = virtualinvoke v.("varchar_field", v, 3); v = ; v = virtualinvoke v.("date_field", v, 10); v = ; v = virtualinvoke v.("time_field", v, 14); v = ; v = virtualinvoke v.("timestamp_field", v, 23); 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 mysql.`drill_mysql_test`.`data_types`"); 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.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; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithMySQL 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.TestJdbcWriterWithMySQL; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE mysql.drill_mysql_test.`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 mysql.drill_mysql_test.`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, 0); 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 mysql.`drill_mysql_test`.`t1`"); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); return; } 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.exec.store.jdbc.TestJdbcWriterWithMySQL 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.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.TestJdbcWriterWithMySQL; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE mysql.drill_mysql_test.`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 mysql.drill_mysql_test.`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 mysql.`drill_mysql_test`.`t2`"); 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.TestJdbcWriterWithMySQL v; java.lang.String v; boolean v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithMySQL; label: v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE mysql.`drill_mysql_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 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.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.exec.store.jdbc.TestJdbcWriterWithMySQL 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.TestJdbcWriterWithMySQL; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE IF NOT EXISTS mysql.`drill_mysql_test`.`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 mysql.`drill_mysql_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); v = virtualinvoke v.(); v = virtualinvoke v.("DROP TABLE mysql.`drill_mysql_test`.`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; org.apache.drill.exec.store.jdbc.TestJdbcWriterWithMySQL 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.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.TestJdbcWriterWithMySQL; v = virtualinvoke v.(); v = virtualinvoke v.("CREATE TABLE mysql.`drill_mysql_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.("CREATE TABLE mysql.`drill_mysql_test`.`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 mysql.`drill_mysql_test`.`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 [mysql.drill_mysql_test]"; 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.TestJdbcWriterWithMySQL v; org.hamcrest.Matcher v; java.lang.String v; v := @this: org.apache.drill.exec.store.jdbc.TestJdbcWriterWithMySQL; label: v = virtualinvoke v.