public class org.apache.nifi.processors.standard.TestExecuteSQL extends java.lang.Object { private final org.slf4j.Logger LOGGER; static final java.lang.String DB_LOCATION; static final java.lang.String QUERY_WITH_EL; static final java.lang.String QUERY_WITHOUT_EL; static final java.lang.String QUERY_WITHOUT_EL_WITH_PARAMS; private org.apache.nifi.util.TestRunner runner; public void () { org.slf4j.Logger v; org.apache.nifi.processors.standard.TestExecuteSQL v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; specialinvoke v.()>(); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/TestExecuteSQL;"); v. = v; return; } public static void setupClass() { staticinvoke ("derby.stream.error.file", "target/derby.log"); return; } public static void cleanupClass() { staticinvoke ("derby.stream.error.file"); return; } public void setup() throws org.apache.nifi.reporting.InitializationException { org.apache.nifi.processors.standard.TestExecuteSQL$DBCPServiceSimpleImpl v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processors.standard.TestExecuteSQL v; org.apache.nifi.util.TestRunner v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = new org.apache.nifi.processors.standard.TestExecuteSQL$DBCPServiceSimpleImpl; specialinvoke v.(org.apache.nifi.processors.standard.TestExecuteSQL)>(v); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteSQL;"); v. = v; v = v.; interfaceinvoke v.("dbcp", v, v); v = v.; interfaceinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v, "dbcp"); return; } public void testIncomingConnectionWithNoFlowFile() throws org.apache.nifi.reporting.InitializationException { org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processors.standard.TestExecuteSQL v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, "SELECT * FROM persons"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); return; } public void testIncomingConnectionWithNoFlowFileAndNoQuery() throws org.apache.nifi.reporting.InitializationException { org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v; org.apache.nifi.processors.standard.TestExecuteSQL v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = v.; interfaceinvoke v.(1); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); return; } public void testNoIncomingConnectionAndNoQuery() throws org.apache.nifi.reporting.InitializationException { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestExecuteSQL v; org.junit.jupiter.api.function.Executable v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = v.; interfaceinvoke v.(0); v = staticinvoke (v); staticinvoke (class "Ljava/lang/AssertionError;", v); return; } public void testNoIncomingConnection() throws java.lang.ClassNotFoundException, java.sql.SQLException, org.apache.nifi.reporting.InitializationException, java.io.IOException { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestExecuteSQL v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = v.; interfaceinvoke v.(0); virtualinvoke v.(null, "select PER.ID as PersonId, PER.NAME as PersonName, PER.CODE as PersonCode, PRD.ID as ProductId,PRD.NAME as ProductName,PRD.CODE as ProductCode, REL.ID as RelId, REL.NAME as RelName, REL.CODE as RelCode, ROW_NUMBER() OVER () as rownr from persons PER, products PRD, relationships REL where PER.ID = 10", 0, null, 1); return; } public void testNoTimeLimit() throws org.apache.nifi.reporting.InitializationException, java.lang.ClassNotFoundException, java.sql.SQLException, java.io.IOException { org.apache.nifi.processors.standard.TestExecuteSQL v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; virtualinvoke v.(null, "select PER.ID as PersonId, PER.NAME as PersonName, PER.CODE as PersonCode, PRD.ID as ProductId,PRD.NAME as ProductName,PRD.CODE as ProductCode, REL.ID as RelId, REL.NAME as RelName, REL.CODE as RelCode, ROW_NUMBER() OVER () as rownr from persons PER, products PRD, relationships REL where PER.ID = ${person.id}", 1, null, 1); return; } public void testSelectQueryInFlowFile() throws org.apache.nifi.reporting.InitializationException, java.lang.ClassNotFoundException, java.sql.SQLException, java.io.IOException { org.apache.nifi.processors.standard.TestExecuteSQL v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; virtualinvoke v.(null, "select PER.ID as PersonId, PER.NAME as PersonName, PER.CODE as PersonCode, PRD.ID as ProductId,PRD.NAME as ProductName,PRD.CODE as ProductCode, REL.ID as RelId, REL.NAME as RelName, REL.CODE as RelCode, ROW_NUMBER() OVER () as rownr from persons PER, products PRD, relationships REL where PER.ID = 10", 1, null, 0); return; } public void testSelectQueryInFlowFileWithParameters() throws org.apache.nifi.reporting.InitializationException, java.lang.ClassNotFoundException, java.sql.SQLException, java.io.IOException { org.apache.nifi.processors.standard.TestExecuteSQL v; org.apache.nifi.processors.standard.TestExecuteSQL$1 v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = new org.apache.nifi.processors.standard.TestExecuteSQL$1; specialinvoke v.(org.apache.nifi.processors.standard.TestExecuteSQL)>(v); virtualinvoke v.(null, "select PER.ID as PersonId, PER.NAME as PersonName, PER.CODE as PersonCode, PRD.ID as ProductId,PRD.NAME as ProductName,PRD.CODE as ProductCode, REL.ID as RelId, REL.NAME as RelName, REL.CODE as RelCode, ROW_NUMBER() OVER () as rownr from persons PER, products PRD, relationships REL where PER.ID < ? AND REL.ID < ?", 1, v, 0); return; } public void testQueryTimeout() throws org.apache.nifi.reporting.InitializationException, java.lang.ClassNotFoundException, java.sql.SQLException, java.io.IOException { java.lang.Integer v; org.apache.nifi.processors.standard.TestExecuteSQL v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = staticinvoke (1); virtualinvoke v.(v, "select PER.ID as PersonId, PER.NAME as PersonName, PER.CODE as PersonCode, PRD.ID as ProductId,PRD.NAME as ProductName,PRD.CODE as ProductCode, REL.ID as RelId, REL.NAME as RelName, REL.CODE as RelCode, ROW_NUMBER() OVER () as rownr from persons PER, products PRD, relationships REL where PER.ID = ${person.id}", 1, null, 1); return; } public void testAutoCommitFalse() throws org.apache.nifi.reporting.InitializationException, java.lang.ClassNotFoundException, java.sql.SQLException, java.io.IOException { org.apache.nifi.util.TestRunner v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processors.standard.TestExecuteSQL v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = v.; v = ; interfaceinvoke v.(v, "false"); virtualinvoke v.(null, "select PER.ID as PersonId, PER.NAME as PersonName, PER.CODE as PersonCode, PRD.ID as ProductId,PRD.NAME as ProductName,PRD.CODE as ProductCode, REL.ID as RelId, REL.NAME as RelName, REL.CODE as RelCode, ROW_NUMBER() OVER () as rownr from persons PER, products PRD, relationships REL where PER.ID = 10", 1, null, 0); return; } public void testAutoCommitTrue() throws org.apache.nifi.reporting.InitializationException, java.lang.ClassNotFoundException, java.sql.SQLException, java.io.IOException { org.apache.nifi.util.TestRunner v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processors.standard.TestExecuteSQL v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = v.; v = ; interfaceinvoke v.(v, "true"); virtualinvoke v.(null, "select PER.ID as PersonId, PER.NAME as PersonName, PER.CODE as PersonCode, PRD.ID as ProductId,PRD.NAME as ProductName,PRD.CODE as ProductCode, REL.ID as RelId, REL.NAME as RelName, REL.CODE as RelCode, ROW_NUMBER() OVER () as rownr from persons PER, products PRD, relationships REL where PER.ID = 10", 1, null, 0); return; } public void testWithNullIntColumn() throws java.sql.SQLException { java.sql.Connection v; org.apache.nifi.components.PropertyDescriptor v; java.sql.SQLException v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v; java.io.File v; org.apache.nifi.processors.standard.TestExecuteSQL v; java.util.List v, v; java.sql.Statement v; org.apache.nifi.controller.ControllerService v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/db"); virtualinvoke v.(); v = v.; v = interfaceinvoke v.("dbcp"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: interfaceinvoke v.("drop table TEST_NULL_INT"); label: goto label; label: v := @caughtexception; label: interfaceinvoke v.("create table TEST_NULL_INT (id integer not null, val integer, val integer, constraint my_pk primary key (id))"); interfaceinvoke v.("insert into TEST_NULL_INT (id, val, val) VALUES (0, NULL, 1)"); interfaceinvoke v.("insert into TEST_NULL_INT (id, val, val) VALUES (1, 1, 1)"); v = v.; interfaceinvoke v.(0); v = v.; v = ; interfaceinvoke v.(v, "SELECT * FROM TEST_NULL_INT"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("executesql.row.count", "2"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("executesql.resultset.index", "0"); return; catch java.sql.SQLException from label to label with label; } public void testCompression() throws java.sql.SQLException, org.apache.commons.compress.compressors.CompressorException, java.io.IOException { java.lang.Throwable v; byte[] v; java.sql.Connection v; org.apache.nifi.components.PropertyDescriptor v, v; java.sql.SQLException v; java.io.ByteArrayInputStream v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v; java.lang.String v, v, v, v, v; org.apache.avro.file.DataFileStream v; java.io.File v; org.apache.nifi.processors.standard.TestExecuteSQL v; java.util.List v; java.sql.Statement v; org.apache.nifi.controller.ControllerService v; java.lang.Object v; org.apache.nifi.util.db.AvroUtil$CodecType v, v; org.apache.avro.generic.GenericDatumReader v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/db"); virtualinvoke v.(); v = v.; v = interfaceinvoke v.("dbcp"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: interfaceinvoke v.("drop table TEST_NULL_INT"); label: goto label; label: v := @caughtexception; label: interfaceinvoke v.("create table TEST_NULL_INT (id integer not null, val integer, val integer, constraint my_pk primary key (id))"); interfaceinvoke v.("insert into TEST_NULL_INT (id, val, val) VALUES (0, NULL, 1)"); interfaceinvoke v.("insert into TEST_NULL_INT (id, val, val) VALUES (1, 1, 1)"); v = v.; interfaceinvoke v.(0); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "SELECT * FROM TEST_NULL_INT"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = new org.apache.avro.file.DataFileStream; v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = new org.apache.avro.generic.GenericDatumReader; specialinvoke v.()>(); specialinvoke v.(java.io.InputStream,org.apache.avro.io.DatumReader)>(v, v); label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.("avro.codec"); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.sql.SQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public void testWithOutputBatching() throws java.sql.SQLException { java.sql.Connection v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.attributes.FragmentAttributes v, v, v, v, v; org.apache.nifi.processors.standard.TestExecuteSQL v; java.util.List v, v; org.apache.nifi.controller.ControllerService v; java.sql.SQLException v; org.apache.nifi.processor.Relationship v, v, v, v, v; int v; java.lang.String v, v, v, v, v, v; java.io.File v; java.sql.Statement v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/db"); virtualinvoke v.(); v = v.; v = interfaceinvoke v.("dbcp"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: interfaceinvoke v.("drop table TEST_NULL_INT"); label: goto label; label: v := @caughtexception; label: interfaceinvoke v.("create table TEST_NULL_INT (id integer not null, val integer, val integer, constraint my_pk primary key (id))"); v = 0; label: if v >= 1000 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("insert into TEST_NULL_INT (id, val, val) VALUES (\u, 1, 1)"); interfaceinvoke v.(v); v = v + 1; goto label; label: v = v.; interfaceinvoke v.(0); v = v.; v = ; interfaceinvoke v.(v, "5"); v = v.; v = ; interfaceinvoke v.(v, "5"); v = v.; v = ; interfaceinvoke v.(v, "SELECT * FROM TEST_NULL_INT"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 200); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("executesql.row.count", "5"); v = ; v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "0"); virtualinvoke v.("executesql.resultset.index", "0"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(199); virtualinvoke v.("executesql.row.count", "5"); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "199"); virtualinvoke v.("executesql.resultset.index", "0"); return; catch java.sql.SQLException from label to label with label; } public void testWithOutputBatchingAndIncomingFlowFile() throws java.sql.SQLException { java.sql.Connection v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.attributes.FragmentAttributes v, v, v, v, v; org.apache.nifi.processors.standard.TestExecuteSQL v; java.util.List v, v; org.apache.nifi.controller.ControllerService v; org.apache.nifi.util.MockFlowFile v; java.util.HashMap v; java.sql.SQLException v; org.apache.nifi.processor.Relationship v, v, v, v, v; int v; java.lang.String v, v, v, v, v, v, v, v; java.io.File v; java.sql.Statement v; java.lang.Object v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/db"); virtualinvoke v.(); v = v.; v = interfaceinvoke v.("dbcp"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: interfaceinvoke v.("drop table TEST_NULL_INT"); label: goto label; label: v := @caughtexception; label: interfaceinvoke v.("create table TEST_NULL_INT (id integer not null, val integer, val integer, constraint my_pk primary key (id))"); v = 0; label: if v >= 1000 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("insert into TEST_NULL_INT (id, val, val) VALUES (\u, 1, 1)"); interfaceinvoke v.(v); v = v + 1; goto label; label: v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("attr1", "value1"); interfaceinvoke v.("max.rows", "5"); interfaceinvoke v.("batch.size", "1"); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, "${max.rows}"); v = v.; v = ; interfaceinvoke v.(v, "${batch.size}"); v = v.; v = interfaceinvoke v.("SELECT * FROM TEST_NULL_INT", v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 200); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("executesql.row.count", "5"); v = ; v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "0"); virtualinvoke v.("executesql.resultset.index", "0"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(199); virtualinvoke v.("executesql.row.count", "5"); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "199"); virtualinvoke v.("attr1", "value1"); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.("input.flowfile.uuid", v); return; catch java.sql.SQLException from label to label with label; } public void testMaxRowsPerFlowFile() throws java.sql.SQLException { java.sql.Connection v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.attributes.FragmentAttributes v, v, v, v, v; org.apache.nifi.processors.standard.TestExecuteSQL v; java.util.List v, v; org.apache.nifi.controller.ControllerService v; java.sql.SQLException v; org.apache.nifi.processor.Relationship v, v, v, v, v, v; int v; java.lang.String v, v, v, v, v, v; java.io.File v; java.sql.Statement v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/db"); virtualinvoke v.(); v = v.; v = interfaceinvoke v.("dbcp"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: interfaceinvoke v.("drop table TEST_NULL_INT"); label: goto label; label: v := @caughtexception; label: interfaceinvoke v.("create table TEST_NULL_INT (id integer not null, val integer, val integer, constraint my_pk primary key (id))"); v = 0; label: if v >= 1000 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("insert into TEST_NULL_INT (id, val, val) VALUES (\u, 1, 1)"); interfaceinvoke v.(v); v = v + 1; goto label; label: v = v.; interfaceinvoke v.(0); v = v.; v = ; interfaceinvoke v.(v, "5"); v = v.; v = ; interfaceinvoke v.(v, "5"); v = v.; v = ; interfaceinvoke v.(v, "0"); v = v.; v = ; interfaceinvoke v.(v, "SELECT * FROM TEST_NULL_INT"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 200); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("executesql.row.count", "5"); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "0"); virtualinvoke v.("executesql.resultset.index", "0"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(199); virtualinvoke v.("executesql.row.count", "5"); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "199"); virtualinvoke v.("executesql.resultset.index", "0"); return; catch java.sql.SQLException from label to label with label; } public void testInsertStatementCreatesFlowFile() throws java.sql.SQLException { java.sql.Connection v; org.apache.nifi.components.PropertyDescriptor v; java.sql.SQLException v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v; java.io.File v; org.apache.nifi.processors.standard.TestExecuteSQL v; java.util.List v; java.sql.Statement v; org.apache.nifi.controller.ControllerService v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/db"); virtualinvoke v.(); v = v.; v = interfaceinvoke v.("dbcp"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: interfaceinvoke v.("drop table TEST_NULL_INT"); label: goto label; label: v := @caughtexception; label: interfaceinvoke v.("create table TEST_NULL_INT (id integer not null, val integer, val integer, constraint my_pk primary key (id))"); v = v.; interfaceinvoke v.(0); v = v.; v = ; interfaceinvoke v.(v, "insert into TEST_NULL_INT (id, val, val) VALUES (0, NULL, 1)"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("executesql.row.count", "0"); return; catch java.sql.SQLException from label to label with label; } public void testNoRowsStatementCreatesEmptyFlowFile() throws java.lang.Exception { java.lang.Throwable v; byte[] v, v; java.sql.Connection v; long v; org.apache.nifi.components.PropertyDescriptor v; java.sql.SQLException v; java.io.ByteArrayInputStream v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v; java.lang.String v; boolean v; org.apache.avro.file.DataFileStream v; java.io.File v; org.apache.nifi.processors.standard.TestExecuteSQL v; java.util.List v; java.sql.Statement v; org.apache.nifi.controller.ControllerService v; java.lang.Object v; org.apache.avro.generic.GenericDatumReader v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/db"); virtualinvoke v.(); v = v.; v = interfaceinvoke v.("dbcp"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: interfaceinvoke v.("drop table TEST_NULL_INT"); label: goto label; label: v := @caughtexception; label: interfaceinvoke v.("create table TEST_NULL_INT (id integer not null, val integer, val integer, constraint my_pk primary key (id))"); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, "select * from TEST_NULL_INT"); v = v.; v = "Hello"; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("executesql.row.count", "0"); v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = new org.apache.avro.generic.GenericDatumReader; specialinvoke v.()>(); v = new org.apache.avro.file.DataFileStream; specialinvoke v.(java.io.InputStream,org.apache.avro.io.DatumReader)>(v, v); label: v = 0L; label: v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(null); v = v + 1L; goto label; label: staticinvoke (0L, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.sql.SQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public void testWithDuplicateColumns() throws java.sql.SQLException { java.sql.Connection v; org.apache.nifi.components.PropertyDescriptor v; java.sql.SQLException v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v; java.io.File v; org.apache.nifi.processors.standard.TestExecuteSQL v; java.util.List v; java.sql.Statement v; org.apache.nifi.controller.ControllerService v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteSQL; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/db"); virtualinvoke v.(); v = v.; v = interfaceinvoke v.("dbcp"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: interfaceinvoke v.("drop table host1"); interfaceinvoke v.("drop table host2"); label: goto label; label: v := @caughtexception; label: interfaceinvoke v.("create table host (id integer not null, host varchar(45))"); interfaceinvoke v.("create table host (id integer not null, host varchar(45))"); interfaceinvoke v.("insert into host values(1,\'host1\')"); interfaceinvoke v.("insert into host values(1,\'host2\')"); interfaceinvoke v.("select a.host as hostA,b.host as hostB from host a join host b on b.id=a.id"); v = v.; interfaceinvoke v.(0); v = v.; v = ; interfaceinvoke v.(v, "select a.host as hostA,b.host as hostB from host a join host b on b.id=a.id"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.