public class org.apache.nifi.processors.standard.QueryDatabaseTableTest extends java.lang.Object { org.apache.nifi.processors.standard.QueryDatabaseTableTest$MockQueryDatabaseTable processor; protected org.apache.nifi.util.TestRunner runner; private static final java.lang.String DB_LOCATION; private org.apache.nifi.processors.standard.db.DatabaseAdapter dbAdapter; private java.util.HashMap origDbAdapters; private static final java.lang.String TABLE_NAME_KEY; private static final java.lang.String MAX_ROWS_KEY; public void () { org.apache.nifi.processors.standard.QueryDatabaseTableTest v; v := @this: org.apache.nifi.processors.standard.QueryDatabaseTableTest; specialinvoke v.()>(); return; } public static void setupBeforeClass() { java.io.IOException v; java.io.File v; staticinvoke ("derby.stream.error.file", "target/derby.log"); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/db_qdt"); label: staticinvoke (v, 1); label: goto label; label: v := @caughtexception; label: return; catch java.io.IOException from label to label with label; } public static void cleanUpAfterClass() throws java.lang.Exception { java.io.IOException v; java.sql.SQLNonTransientConnectionException v; java.io.File v; label: staticinvoke ("jdbc:derby:target/db_qdt;shutdown=true"); label: goto label; label: v := @caughtexception; label: v = new java.io.File; specialinvoke v.(java.lang.String)>("target/db_qdt"); label: staticinvoke (v, 1); label: goto label; label: v := @caughtexception; label: staticinvoke ("derby.stream.error.file"); return; catch java.sql.SQLNonTransientConnectionException from label to label with label; catch java.io.IOException from label to label with label; } public org.apache.nifi.processors.standard.db.DatabaseAdapter createDatabaseAdapter() { org.apache.nifi.processors.standard.db.impl.GenericDatabaseAdapter v; org.apache.nifi.processors.standard.QueryDatabaseTableTest v; v := @this: org.apache.nifi.processors.standard.QueryDatabaseTableTest; v = new org.apache.nifi.processors.standard.db.impl.GenericDatabaseAdapter; specialinvoke v.()>(); return v; } public void createDbcpControllerService() throws org.apache.nifi.reporting.InitializationException { org.apache.nifi.processors.standard.QueryDatabaseTableTest$DBCPServiceSimpleImpl v; org.apache.nifi.util.TestRunner v, v; java.util.HashMap v; org.apache.nifi.processors.standard.QueryDatabaseTableTest v; v := @this: org.apache.nifi.processors.standard.QueryDatabaseTableTest; v = new org.apache.nifi.processors.standard.QueryDatabaseTableTest$DBCPServiceSimpleImpl; specialinvoke v.(org.apache.nifi.processors.standard.QueryDatabaseTableTest)>(v); v = new java.util.HashMap; specialinvoke v.()>(); v = v.; interfaceinvoke v.("dbcp", v, v); v = v.; interfaceinvoke v.(v); return; } public void setup() throws org.apache.nifi.reporting.InitializationException, java.io.IOException { java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.components.state.Scope v; org.apache.nifi.util.TestRunner v, v, v, v; java.util.Map v, v; java.lang.String v, v; org.apache.nifi.processors.standard.QueryDatabaseTableTest$MockQueryDatabaseTable v, v; org.apache.nifi.processors.standard.db.DatabaseAdapter v, v, v, v; org.apache.nifi.state.MockStateManager v; org.apache.nifi.processors.standard.QueryDatabaseTableTest v; v := @this: org.apache.nifi.processors.standard.QueryDatabaseTableTest; v = new java.util.HashMap; v = ; specialinvoke v.(java.util.Map)>(v); v. = v; v = virtualinvoke v.(); v. = v; v = ; v = v.; v = interfaceinvoke v.(); v = v.; interfaceinvoke v.(v, v); v = new org.apache.nifi.processors.standard.QueryDatabaseTableTest$MockQueryDatabaseTable; specialinvoke v.()>(); v. = v; v = v.; v = staticinvoke (v); v. = v; virtualinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, "dbcp"); v = v.; v = ; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); v = ; virtualinvoke v.(v); return; } public void teardown() throws java.io.IOException { org.apache.nifi.components.state.Scope v; org.apache.nifi.state.MockStateManager v; org.apache.nifi.util.TestRunner v; java.util.Map v, v; java.util.HashMap v; org.apache.nifi.processors.standard.QueryDatabaseTableTest v; v := @this: org.apache.nifi.processors.standard.QueryDatabaseTableTest; v = v.; v = interfaceinvoke v.(); v = ; virtualinvoke v.(v); v. = null; v = ; interfaceinvoke v.(); v = ; v = v.; interfaceinvoke v.(v); return; } public void testGetQuery() throws java.lang.Exception { java.lang.Integer v, v, v, v, v, v; org.apache.nifi.components.state.Scope v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Map v, v, v, v, v, v, v, v; org.apache.nifi.state.MockStateManager v, v; org.apache.nifi.processors.standard.db.impl.OracleDatabaseAdapter v; org.apache.nifi.processors.standard.db.impl.MSSQLDatabaseAdapter v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.QueryDatabaseTableTest$MockQueryDatabaseTable v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.db.DatabaseAdapter v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.db.impl.MySQLDatabaseAdapter v; org.apache.nifi.util.TestRunner v, v; org.apache.nifi.processors.standard.db.impl.GenericDatabaseAdapter v; org.apache.nifi.components.state.StateMap v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.QueryDatabaseTableTest v; java.util.List v, v, v, v, v, v, v, v, v; java.lang.String[] v, v, v, v, v, v, v; java.util.HashMap v; v := @this: org.apache.nifi.processors.standard.QueryDatabaseTableTest; v = v.; v = v.; v = virtualinvoke v.(v, "myTable", null, null, null, null); staticinvoke ("SELECT * FROM myTable", v); v = v.; v = v.; v = virtualinvoke v.(v, "myTable", "col,col2", null, null, null); staticinvoke ("SELECT col,col FROM myTable", v); v = v.; v = v.; v = staticinvoke ("id"); v = virtualinvoke v.(v, "myTable", null, v, null, null); staticinvoke ("SELECT * FROM myTable", v); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("id", "509"); v = v.; v = interfaceinvoke v.(); v = ; interfaceinvoke v.(v, v); v = v.; v = v.; v = staticinvoke ("mytable", "id", v); v = staticinvoke (4); virtualinvoke v.(v, v); v = v.; v = v.; v = staticinvoke ("id"); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v, "myTable", null, v, null, v); staticinvoke ("SELECT * FROM myTable WHERE id > 509", v); interfaceinvoke v.("date_created", "2016-03-07 12:34:56"); v = ; interfaceinvoke v.(v, v); v = v.; v = v.; v = staticinvoke ("mytable", "date_created", v); v = staticinvoke (93); virtualinvoke v.(v, v); v = v.; v = v.; v = newarray (java.lang.String)[2]; v[0] = "id"; v[1] = "DATE_CREATED"; v = staticinvoke (v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v, "myTable", null, v, null, v); staticinvoke ("SELECT * FROM myTable WHERE id > 509 AND DATE_CREATED >= \'2016-03-07 12:34:56\'", v); interfaceinvoke v.("mytable@!@date-created", "2016-03-07 12:34:56"); v = ; interfaceinvoke v.(v, v); v = v.; v = v.; v = staticinvoke ("\"myTable\"", "\"DATE-CREATED\"", v); v = staticinvoke (93); virtualinvoke v.(v, v); v = v.; v = v.; v = newarray (java.lang.String)[2]; v[0] = "id"; v[1] = "\"DATE-CREATED\""; v = staticinvoke (v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v, "\"myTable\"", null, v, null, v); staticinvoke ("SELECT * FROM \"myTable\" WHERE id > 509 AND \"DATE-CREATED\" >= \'2016-03-07 12:34:56\'", v); v = new org.apache.nifi.processors.standard.db.impl.MySQLDatabaseAdapter; specialinvoke v.()>(); v. = v; v = v.; v = v.; v = staticinvoke ("`myTable`", "`DATE-CREATED`", v); v = staticinvoke (93); virtualinvoke v.(v, v); v = v.; v = v.; v = newarray (java.lang.String)[2]; v[0] = "id"; v[1] = "`DATE-CREATED`"; v = staticinvoke (v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v, "`myTable`", null, v, null, v); staticinvoke ("SELECT * FROM `myTable` WHERE id > 509 AND `DATE-CREATED` >= \'2016-03-07 12:34:56\'", v); v = new org.apache.nifi.processors.standard.db.impl.MSSQLDatabaseAdapter; specialinvoke v.()>(); v. = v; v = v.; v = v.; v = staticinvoke ("[myTable]", "[DATE-CREATED]", v); v = staticinvoke (93); virtualinvoke v.(v, v); v = v.; v = v.; v = newarray (java.lang.String)[2]; v[0] = "id"; v[1] = "[DATE-CREATED]"; v = staticinvoke (v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v, "[myTable]", null, v, null, v); staticinvoke ("SELECT * FROM [myTable] WHERE id > 509 AND [DATE-CREATED] >= \'2016-03-07 12:34:56\'", v); v = new org.apache.nifi.processors.standard.db.impl.OracleDatabaseAdapter; specialinvoke v.()>(); v. = v; v = v.; v = v.; v = newarray (java.lang.String)[2]; v[0] = "id"; v[1] = "DATE_CREATED"; v = staticinvoke (v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v, "myTable", null, v, "type = \"CUSTOMER\"", v); staticinvoke ("SELECT * FROM myTable WHERE id > 509 AND DATE_CREATED >= timestamp \'2016-03-07 12:34:56\' AND (type = \"CUSTOMER\")", v); v = v.; v = staticinvoke (92); virtualinvoke v.("mytable@!@time_created", v); interfaceinvoke v.(); interfaceinvoke v.("id", "509"); interfaceinvoke v.("time_created", "12:34:57"); interfaceinvoke v.("date_created", "2016-03-07 12:34:56"); v = v.; v = interfaceinvoke v.(); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, v); v = v.; v = v.; v = newarray (java.lang.String)[3]; v[0] = "id"; v[1] = "DATE_CREATED"; v[2] = "TIME_CREATED"; v = staticinvoke (v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v, "myTable", null, v, "type = \"CUSTOMER\"", v); staticinvoke ("SELECT * FROM myTable WHERE id > 509 AND DATE_CREATED >= timestamp \'2016-03-07 12:34:56\' AND TIME_CREATED >= timestamp \'12:34:57\' AND (type = \"CUSTOMER\")", v); v = new org.apache.nifi.processors.standard.db.impl.GenericDatabaseAdapter; specialinvoke v.()>(); v. = v; v = v.; v = v.; v = newarray (java.lang.String)[3]; v[0] = "id"; v[1] = "DATE_CREATED"; v[2] = "TIME_CREATED"; v = staticinvoke (v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v, "myTable", null, v, "type = \"CUSTOMER\"", v); staticinvoke ("SELECT * FROM myTable WHERE id > 509 AND DATE_CREATED >= \'2016-03-07 12:34:56\' AND TIME_CREATED >= \'12:34:57\' AND (type = \"CUSTOMER\")", v); return; } public void testGetQueryUsingPhoenixAdapter() throws java.lang.Exception { java.lang.String[] v, v; java.util.HashMap v; java.lang.Integer v, v, v; org.apache.nifi.components.state.Scope v, v, v; org.apache.nifi.util.TestRunner v; java.util.Map v, v; java.lang.String v, v; org.apache.nifi.processors.standard.QueryDatabaseTableTest$MockQueryDatabaseTable v, v, v, v, v; org.apache.nifi.processors.standard.db.DatabaseAdapter v, v; org.apache.nifi.processors.standard.db.impl.GenericDatabaseAdapter v; org.apache.nifi.state.MockStateManager v; org.apache.nifi.processors.standard.db.impl.PhoenixDatabaseAdapter v; org.apache.nifi.components.state.StateMap v, v; org.apache.nifi.processors.standard.QueryDatabaseTableTest v; java.util.List v, v; v := @this: org.apache.nifi.processors.standard.QueryDatabaseTableTest; v = new java.util.HashMap; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); v = v.; v = staticinvoke (4); virtualinvoke v.("mytable@!@id", v); v = v.; v = staticinvoke (92); virtualinvoke v.("mytable@!@time_created", v); v = v.; v = staticinvoke (93); virtualinvoke v.("mytable@!@date_created", v); interfaceinvoke v.("id", "509"); interfaceinvoke v.("time_created", "12:34:57"); interfaceinvoke v.("date_created", "2016-03-07 12:34:56"); v = ; interfaceinvoke v.(v, v); v = new org.apache.nifi.processors.standard.db.impl.PhoenixDatabaseAdapter; specialinvoke v.()>(); v. = v; v = v.; v = v.; v = newarray (java.lang.String)[3]; v[0] = "id"; v[1] = "DATE_CREATED"; v[2] = "TIME_CREATED"; v = staticinvoke (v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v, "myTable", null, v, "type = \"CUSTOMER\"", v); staticinvoke ("SELECT * FROM myTable WHERE id > 509 AND DATE_CREATED >= timestamp \'2016-03-07 12:34:56\' AND TIME_CREATED >= time \'12:34:57\' AND (type = \"CUSTOMER\")", v); v = new org.apache.nifi.processors.standard.db.impl.GenericDatabaseAdapter; specialinvoke v.()>(); v. = v; v = v.; v = v.; v = newarray (java.lang.String)[3]; v[0] = "id"; v[1] = "DATE_CREATED"; v[2] = "TIME_CREATED"; v = staticinvoke (v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v, "myTable", null, v, "type = \"CUSTOMER\"", v); staticinvoke ("SELECT * FROM myTable WHERE id > 509 AND DATE_CREATED >= \'2016-03-07 12:34:56\' AND TIME_CREATED >= \'12:34:57\' AND (type = \"CUSTOMER\")", v); return; } public void testGetQueryNoTable() { org.junit.jupiter.api.function.Executable v; org.apache.nifi.processors.standard.QueryDatabaseTableTest v; v := @this: org.apache.nifi.processors.standard.QueryDatabaseTableTest; v = staticinvoke (v); staticinvoke (class "Ljava/lang/IllegalArgumentException;", v); return; } public void testAddedRows() throws java.lang.ClassNotFoundException, java.sql.SQLException, org.apache.nifi.reporting.InitializationException, java.io.IOException { byte[] v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.state.Scope v, v, v; org.apache.nifi.state.MockStateManager v, v, v; org.apache.nifi.controller.ControllerService v; long v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.sql.Connection v; java.io.ByteArrayInputStream v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v; java.sql.SQLException v; java.lang.String v, v, v, v, v, v; java.sql.Statement v; org.apache.nifi.processors.standard.QueryDatabaseTableTest v; java.util.List v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.QueryDatabaseTableTest; v = v.; v = interfaceinvoke v.("dbcp"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: interfaceinvoke v.("drop table TEST_QUERY_DB_TABLE"); label: goto label; label: v := @caughtexception; label: interfaceinvoke v.("create table TEST_QUERY_DB_TABLE (id integer not null, name varchar(100), scale float, created_on timestamp, bignum bigint default 0)"); interfaceinvoke v.("insert into TEST_QUERY_DB_TABLE (id, name, scale, created_on) VALUES (0, \'Joe Smith\', 1.0, \'1962-09-23 03:23:34.234\')"); interfaceinvoke v.("insert into TEST_QUERY_DB_TABLE (id, name, scale, created_on) VALUES (1, \'Carrie Jones\', 5.0, \'2000-01-01 03:23:34.234\')"); interfaceinvoke v.("insert into TEST_QUERY_DB_TABLE (id, name, scale, created_on) VALUES (2, NULL, 2.0, \'2010-01-01 00:00:00\')"); v = v.; v = ; interfaceinvoke v.(v, "TEST_QUERY_DB_TABLE"); v = v.; interfaceinvoke v.(0); v = v.; v = ; interfaceinvoke v.(v, "ID"); v = v.; v = ; interfaceinvoke v.(v, "2"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("tablename"); staticinvoke ("TEST_QUERY_DB_TABLE", v); v = virtualinvoke v.("maxvalue.id"); staticinvoke (v, "2"); v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = v.; v = ; interfaceinvoke v.(v, "2"); v = specialinvoke v.(v); staticinvoke (2L, v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(1); v = virtualinvoke v.("maxvalue.id"); staticinvoke (v, "2"); v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = specialinvoke v.(v); staticinvoke (1L, v); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, "0"); interfaceinvoke v.("insert into TEST_QUERY_DB_TABLE (id, name, scale, created_on) VALUES (3, \'Mary West\', 15.0, \'2000-01-01 03:23:34.234\')"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("maxvalue.id"); staticinvoke (v, "3"); v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = specialinvoke v.(v); staticinvoke (1L, v); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, "id, created_on"); interfaceinvoke v.("insert into TEST_QUERY_DB_TABLE (id, name, scale, created_on) VALUES (4, \'Marty Johnson\', 15.0, \'2011-01-01 03:23:34.234\')"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("maxvalue.id"); staticinvoke (v, "4"); v = virtualinvoke v.("maxvalue.created_on"); staticinvoke (v, "2011-01-01 03:23:34.234"); v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = specialinvoke v.(v); staticinvoke (1L, v); v = v.; interfaceinvoke v.(); interfaceinvoke v.("insert into TEST_QUERY_DB_TABLE (id, name, scale, created_on) VALUES (5, \'NO NAME\', 15.0, \'2001-01-01 03:23:34.234\')"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); interfaceinvoke v.("insert into TEST_QUERY_DB_TABLE (id, name, scale, created_on) VALUES (6, \'Mr. NiFi\', 1.0, \'2012-01-01 03:23:34.234\')"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = new java.io.ByteArrayInputStream; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = specialinvoke v.(v); staticinvoke (1L, v); v = v.; interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = ; virtualinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v, "name"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = new java.io.ByteArrayInputStream; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = specialinvoke v.(v); staticinvoke (7L, v); v = v.; interfaceinvoke v.(); interfaceinvoke v.("insert into TEST_QUERY_DB_TABLE (id, name, scale, created_on) VALUES (7, \'NULK\', 1.0, \'2012-01-01 03:23:34.234\')"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = new java.io.ByteArrayInputStream; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = specialinvoke v.(v); staticinvoke (1L, v); v = v.; interfaceinvoke v.(); v = v.