public class org.apache.nifi.processors.standard.TestPutSQL extends java.lang.Object { private static final java.lang.String createPersons; private static final java.lang.String createPersonsAutoId; private static final java.lang.String DERBY_LOG_PROPERTY; protected static org.apache.nifi.dbcp.DBCPService service; public void () { org.apache.nifi.processors.standard.TestPutSQL v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; specialinvoke v.()>(); return; } public static void setupDerbyLog() throws org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL$MockDBCPService v; java.io.File v, v; java.sql.Statement v; java.lang.String v; org.apache.nifi.dbcp.DBCPService v; staticinvoke ("derby.stream.error.file", "target/derby.log"); v = new java.io.File; v = staticinvoke (); specialinvoke v.(java.io.File,java.lang.String)>(v, "db"); virtualinvoke v.(); v = new org.apache.nifi.processors.standard.TestPutSQL$MockDBCPService; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); = v; v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: interfaceinvoke v.("CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); interfaceinvoke v.("CREATE TABLE PERSONS_AI (id INTEGER NOT NULL GENERATED ALWAYS AS IDENTITY (START WITH 1), name VARCHAR(100), code INTEGER check(code <= 100))"); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public static void cleanupDerbyLog() { staticinvoke ("derby.stream.error.file"); return; } public void testDirectStatements() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v, v, v; byte[] v, v; java.sql.Connection v, v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v, v; int v, v, v, v; java.lang.String v, v, v, v; boolean v, v, v, v; java.sql.Statement v, v; org.apache.nifi.dbcp.DBCPService v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (1, \'Mark\', 84)"; v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("Mark", v); v = interfaceinvoke v.(3); staticinvoke (84, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = "UPDATE PERSONS SET NAME=\'George\' WHERE ID=1"; v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("George", v); v = interfaceinvoke v.(3); staticinvoke (84, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testCommitOnCleanup() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v; byte[] v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; int v, v; java.lang.String v, v; boolean v, v; java.sql.Statement v; org.apache.nifi.dbcp.DBCPService v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "false"); specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (1, \'Mark\', 84)"; v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("Mark", v); v = interfaceinvoke v.(3); staticinvoke (84, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testInsertWithGeneratedKeys() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v; byte[] v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; int v, v; java.lang.String v, v; boolean v, v; java.util.List v; java.sql.Statement v; java.lang.Object v; org.apache.nifi.dbcp.DBCPService v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "true"); specialinvoke v.("PERSONS_AI", "CREATE TABLE PERSONS_AI (id INTEGER NOT NULL GENERATED ALWAYS AS IDENTITY (START WITH 1), name VARCHAR(100), code INTEGER check(code <= 100))"); v = "INSERT INTO PERSONS_AI (NAME, CODE) VALUES (\'Mark\', 84)"; v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("sql.generated.key", "1"); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS_AI"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("Mark", v); v = interfaceinvoke v.(3); staticinvoke (84, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testProvenanceEventsWithBatchMode() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "10"); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "false"); specialinvoke v.(v); return; } public void testProvenanceEventsWithFragmentedTransaction() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "10"); v = ; interfaceinvoke v.(v, "true"); v = ; interfaceinvoke v.(v, "false"); specialinvoke v.(v); return; } public void testProvenanceEventsWithObtainGeneratedKeys() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "10"); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "true"); specialinvoke v.(v); return; } private void testProvenanceEvents(org.apache.nifi.util.TestRunner) throws org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.util.Iterator v; org.apache.nifi.provenance.ProvenanceEventType v, v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.List v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; int v; java.lang.Object v; boolean v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v := @parameter: org.apache.nifi.util.TestRunner; specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); interfaceinvoke v.("DELETE FROM PERSONS WHERE ID = 1"); interfaceinvoke v.("INSERT INTO PERSONS (ID, NAME, CODE) VALUES (1, \'Mark\', 84)"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 2); v = interfaceinvoke v.(); v = interfaceinvoke v.(); staticinvoke (2, v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); staticinvoke (v, v); goto label; label: return; } public void testKeepFlowFileOrderingWithBatchMode() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "10"); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "false"); specialinvoke v.(v); return; } public void testKeepFlowFileOrderingWithFragmentedTransaction() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "10"); v = ; interfaceinvoke v.(v, "true"); v = ; interfaceinvoke v.(v, "false"); specialinvoke v.(v); return; } public void testKeepFlowFileOrderingWithObtainGeneratedKeys() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "10"); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "true"); specialinvoke v.(v); return; } private void testKeepFlowFileOrdering(org.apache.nifi.util.TestRunner) throws org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { org.apache.nifi.processors.standard.TestPutSQL v; java.lang.String[] v; java.lang.Integer v; java.util.function.Function v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; int v, v, v, v, v; java.lang.String v, v, v, v, v, v, v; java.util.List v, v; java.lang.Object v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v := @parameter: org.apache.nifi.util.TestRunner; specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); v = newarray (java.lang.String)[6]; v[0] = "DELETE FROM PERSONS WHERE ID = ?"; v[1] = "INSERT INTO PERSONS (ID) VALUES (?)"; v[2] = "INSERT INTO PERSONS (ID) VALUES (?)"; v[3] = "DELETE FROM PERSONS WHERE ID = ?"; v[4] = "DELETE FROM PERSONS WHERE ID = ?"; v[5] = "INSERT INTO PERSONS (ID) VALUES (?)"; v = staticinvoke (); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = staticinvoke (v); v = interfaceinvoke v.(v); interfaceinvoke v.(v, v); v = v + 1; goto label; label: interfaceinvoke v.(); v = ; interfaceinvoke v.(v, v); v = ; v = interfaceinvoke v.(v); v = 0; label: if v >= v goto label; v = interfaceinvoke v.(v); v = v[v]; v = virtualinvoke v.(); staticinvoke (v, v); v = staticinvoke (v); v = virtualinvoke v.("sql.args.1.value"); staticinvoke (v, v); v = v + 1; goto label; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); staticinvoke (v, v); v = 0; label: if v >= v goto label; v = interfaceinvoke v.(v); v = staticinvoke (v); v = interfaceinvoke v.("sql.args.1.value"); staticinvoke (v, v); v = v + 1; goto label; label: return; } public void testFailInMiddleWithBadStatementAndSupportTransaction() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException { org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); specialinvoke v.(v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 4); v = ; interfaceinvoke v.(v, 0); v = ; staticinvoke (v, v); return; } public void testFailInMiddleWithBadStatementAndNotSupportTransaction() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException { org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "false"); specialinvoke v.(v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 3); v = ; staticinvoke (v, v); return; } public void testFailInMiddleWithBadStatementRollbackOnFailure() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException { java.lang.Throwable v, v; byte[] v, v, v, v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v, v; org.junit.jupiter.api.function.Executable v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "true"); v = "INSERT INTO PERSONS_AI (NAME, CODE) VALUES (\'Mark\', 84)"; v = virtualinvoke v.(); interfaceinvoke v.(v); v = "INSERT INTO PERSONS_AI"; v = virtualinvoke v.(); interfaceinvoke v.(v); v = "INSERT INTO PERSONS_AI (NAME, CODE) VALUES (\'Tom\', 3)"; v = virtualinvoke v.(); interfaceinvoke v.(v); v = "INSERT INTO PERSONS_AI (NAME, CODE) VALUES (\'Harry\', 44)"; v = virtualinvoke v.(); interfaceinvoke v.(v); virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (class "Ljava/lang/AssertionError;", v); v = virtualinvoke v.(); staticinvoke (class "Lorg/apache/nifi/processor/exception/ProcessException;", v); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); return; } public void testFailInMiddleWithBadParameterTypeAndNotSupportTransaction() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException { org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "false"); specialinvoke v.(v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 3); v = ; staticinvoke (v, v); v = ; staticinvoke (v, v); return; } public void testFailInMiddleWithBadParameterTypeAndSupportTransaction() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException { org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); specialinvoke v.(v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 4); v = ; interfaceinvoke v.(v, 0); v = ; staticinvoke (v, v); return; } public void testFailInMiddleWithBadParameterTypeRollbackOnFailure() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException { java.lang.Throwable v, v; byte[] v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v, v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.junit.jupiter.api.function.Executable v; java.lang.String v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "true"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "84"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (12); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "hello"); v = "INSERT INTO PERSONS_AI (NAME, CODE) VALUES (\'Mark\', ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (class "Ljava/lang/AssertionError;", v); v = virtualinvoke v.(); staticinvoke (class "Lorg/apache/nifi/processor/exception/ProcessException;", v); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); return; } public void testFailInMiddleWithBadParameterValueAndSupportTransaction() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; java.sql.Statement v; org.apache.nifi.dbcp.DBCPService v; boolean v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); specialinvoke v.(v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 4); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS_AI"); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = ; staticinvoke (v, v); staticinvoke (v); return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testFailInMiddleWithBadParameterValueAndNotSupportTransaction() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; int v, v; java.lang.String v; boolean v, v; java.sql.Statement v; org.apache.nifi.dbcp.DBCPService v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "false"); specialinvoke v.(v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 2); v = ; staticinvoke (v, v); staticinvoke (v); v = ; staticinvoke (v, v); v = ; staticinvoke (v, v); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS_AI"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("Mark", v); v = interfaceinvoke v.(3); staticinvoke (84, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testFailInMiddleWithBadParameterValueRollbackOnFailure() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v, v, v; byte[] v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v, v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; java.lang.String v, v, v; boolean v; org.junit.jupiter.api.function.Executable v; java.sql.Statement v; org.apache.nifi.dbcp.DBCPService v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "true"); specialinvoke v.("PERSONS_AI", "CREATE TABLE PERSONS_AI (id INTEGER NOT NULL GENERATED ALWAYS AS IDENTITY (START WITH 1), name VARCHAR(100), code INTEGER check(code <= 100))"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "84"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "9999"); v = "INSERT INTO PERSONS_AI (NAME, CODE) VALUES (\'Mark\', ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (class "Ljava/lang/AssertionError;", v); v = virtualinvoke v.(); staticinvoke (class "Lorg/apache/nifi/processor/exception/ProcessException;", v); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS_AI"); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testUsingSqlDataTypesWithNegativeValues() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v, v, v; byte[] v; java.sql.Connection v, v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; int v, v; java.lang.String v, v; boolean v, v; java.sql.Statement v, v; org.apache.nifi.dbcp.DBCPService v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: interfaceinvoke v.("CREATE TABLE PERSONS2 (id integer primary key, name varchar(100), code bigint)"); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("sql.args.1.type", "-5"); interfaceinvoke v.("sql.args.1.value", "84"); v = "INSERT INTO PERSONS2 (ID, NAME, CODE) VALUES (1, \'Mark\', ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS2"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("Mark", v); v = interfaceinvoke v.(3); staticinvoke (84, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testUsingTimestampValuesEpochAndString() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException, java.text.ParseException { java.lang.Throwable v, v, v, v; byte[] v; java.sql.Connection v, v; java.util.Date v; org.apache.nifi.processors.standard.TestPutSQL v; java.text.SimpleDateFormat v; java.util.HashMap v; long v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; int v; java.lang.String v, v, v, v, v, v; boolean v, v; java.sql.Statement v, v; org.apache.nifi.dbcp.DBCPService v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: interfaceinvoke v.("CREATE TABLE TIMESTAMPTEST1 (id integer primary key, ts timestamp, ts timestamp)"); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = new java.text.SimpleDateFormat; specialinvoke v.(java.lang.String)>("yyyy-MM-dd HH:mm:ss.SSS"); v = virtualinvoke v.("2001-01-01 00:01:01.001"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (93); interfaceinvoke v.("sql.args.1.type", v); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("sql.args.1.value", v); v = staticinvoke (93); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "2002-02-02 12:02:02.002"); v = "INSERT INTO TIMESTAMPTEST1 (ID, ts, ts) VALUES (1, ?, ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM TIMESTAMPTEST1"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("2001-01-01 00:01:01.001", v); v = interfaceinvoke v.(3); staticinvoke ("2002-02-02 12:02:02.002", v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testUsingTimestampValuesWithFormatAttribute() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { byte[] v; java.sql.Connection v, v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; boolean v, v; java.sql.Timestamp v, v, v, v, v; org.apache.nifi.dbcp.DBCPService v, v; java.lang.Throwable v, v, v, v; java.util.HashMap v; long v, v, v, v; org.apache.nifi.processor.Relationship v; int v, v; java.lang.String v, v, v; java.sql.Statement v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: interfaceinvoke v.("CREATE TABLE TIMESTAMPTEST2 (id integer primary key, ts timestamp, ts timestamp)"); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = staticinvoke ("2002-02-02 12:02:02"); v = virtualinvoke v.(); v = staticinvoke ("2002-02-02 12:02:02.123456789"); v = virtualinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (93); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "2002-02-02T12:02:02"); interfaceinvoke v.("sql.args.1.format", "ISO_LOCAL_DATE_TIME"); v = staticinvoke (93); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "2002-02-02T12:02:02.123456789"); interfaceinvoke v.("sql.args.2.format", "yyyy-MM-dd\'T\'HH:mm:ss.SSSSSSSSS"); v = "INSERT INTO TIMESTAMPTEST2 (ID, ts, ts) VALUES (1, ?, ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM TIMESTAMPTEST2"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); v = virtualinvoke v.(); staticinvoke (v, v); v = interfaceinvoke v.(3); v = virtualinvoke v.(); staticinvoke (v, v); v = interfaceinvoke v.(3); v = virtualinvoke v.(); staticinvoke (123456789L, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testUsingDateTimeValuesWithFormatAttribute() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException, java.text.ParseException { byte[] v, v, v; java.time.ZonedDateTime v; java.sql.ResultSet v; java.time.ZoneId v; org.apache.nifi.dbcp.DBCPService v, v; java.lang.Throwable v, v, v, v; java.time.LocalDateTime v; java.text.SimpleDateFormat v, v; long v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; java.sql.Statement v, v; java.sql.Connection v, v; java.sql.Time v, v, v, v; java.util.Date v, v, v, v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.util.TestRunner v; java.time.LocalTime v; boolean v, v, v, v; java.time.Instant v; java.time.LocalDate v; java.util.HashMap v, v, v; int v, v, v; java.sql.Date v, v, v; java.time.format.DateTimeFormatter v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: interfaceinvoke v.("CREATE TABLE TIMESTAMPTEST3 (id integer primary key, ts TIME, ts DATE)"); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = ; v = staticinvoke ("02:03:04", v); v = staticinvoke (v); v = ; v = staticinvoke ("2002-03-04", v); v = new java.util.Date; v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); specialinvoke v.(long)>(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (92); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "02:03:04"); interfaceinvoke v.("sql.args.1.format", "ISO_LOCAL_TIME"); v = staticinvoke (91); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "2002-03-04"); interfaceinvoke v.("sql.args.2.format", "ISO_LOCAL_DATE"); v = "INSERT INTO TIMESTAMPTEST3 (ID, ts, ts) VALUES (1, ?, ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new java.text.SimpleDateFormat; specialinvoke v.(java.lang.String)>("HH:mm:ss"); v = virtualinvoke v.("02:03:04"); v = new java.text.SimpleDateFormat; specialinvoke v.(java.lang.String)>("yyyy-MM-dd"); v = virtualinvoke v.("2002-03-04"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (92); interfaceinvoke v.("sql.args.1.type", v); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("sql.args.1.value", v); v = staticinvoke (91); interfaceinvoke v.("sql.args.2.type", v); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("sql.args.2.value", v); v = "INSERT INTO TIMESTAMPTEST3 (ID, ts, ts) VALUES (2, ?, ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (92); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "020304000"); interfaceinvoke v.("sql.args.1.format", "HHmmssSSS"); v = staticinvoke (91); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "20020304"); interfaceinvoke v.("sql.args.2.format", "yyyyMMdd"); v = "INSERT INTO TIMESTAMPTEST3 (ID, ts, ts) VALUES (3, ?, ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM TIMESTAMPTEST3 ORDER BY ID"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); v = virtualinvoke v.(); staticinvoke (v, v); v = interfaceinvoke v.(3); v = virtualinvoke v.(); staticinvoke (v, v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (2, v); v = virtualinvoke v.(); v = interfaceinvoke v.(2); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(3); v = virtualinvoke v.(); staticinvoke (v, v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (3, v); v = interfaceinvoke v.(2); v = virtualinvoke v.(); staticinvoke (v, v); v = interfaceinvoke v.(3); v = virtualinvoke v.(); staticinvoke (v, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testBitType() throws java.sql.SQLException, org.apache.nifi.reporting.InitializationException { byte[] v; java.sql.ResultSet v; org.apache.nifi.dbcp.DBCPService v, v; java.lang.Throwable v, v, v, v; org.apache.nifi.processor.Relationship v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.sql.Statement v, v; java.sql.Connection v, v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.util.TestRunner v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.HashMap v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: interfaceinvoke v.("CREATE TABLE BITTESTS (id integer primary key, bt BOOLEAN)"); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = "INSERT INTO BITTESTS (ID, bt) VALUES (?, ?)"; v = virtualinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = (int) -7; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "1"); interfaceinvoke v.(v, v); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "2"); v = (int) -7; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "0"); interfaceinvoke v.(v, v); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "3"); v = (int) -7; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "-5"); interfaceinvoke v.(v, v); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "4"); v = (int) -7; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "t"); interfaceinvoke v.(v, v); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "5"); v = (int) -7; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "f"); interfaceinvoke v.(v, v); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "6"); v = (int) -7; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "T"); interfaceinvoke v.(v, v); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "7"); v = (int) -7; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "true"); interfaceinvoke v.(v, v); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "8"); v = (int) -7; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "false"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 8); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM BITTESTS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke (v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (2, v); v = interfaceinvoke v.(2); staticinvoke (v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (3, v); v = interfaceinvoke v.(2); staticinvoke (v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (4, v); v = interfaceinvoke v.(2); staticinvoke (v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (5, v); v = interfaceinvoke v.(2); staticinvoke (v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (6, v); v = interfaceinvoke v.(2); staticinvoke (v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (7, v); v = interfaceinvoke v.(2); staticinvoke (v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (8, v); v = interfaceinvoke v.(2); staticinvoke (v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testUsingTimeValuesEpochAndString() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException, java.text.ParseException { java.lang.Throwable v, v, v, v; byte[] v; java.sql.Connection v, v; java.sql.Time v; java.util.Date v; org.apache.nifi.processors.standard.TestPutSQL v; java.text.SimpleDateFormat v; java.util.HashMap v; long v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; int v; java.lang.String v, v, v, v, v, v; boolean v, v; java.sql.Statement v, v; org.apache.nifi.dbcp.DBCPService v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: interfaceinvoke v.("CREATE TABLE TIMETESTS (id integer primary key, ts time, ts time)"); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = new java.text.SimpleDateFormat; specialinvoke v.(java.lang.String)>("HH:mm:ss"); v = virtualinvoke v.("00:01:02"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (92); interfaceinvoke v.("sql.args.1.type", v); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("sql.args.1.value", v); v = staticinvoke (92); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "02:03:04"); interfaceinvoke v.("sql.args.2.format", "HH:mm:ss"); v = "INSERT INTO TIMETESTS (ID, ts, ts) VALUES (1, ?, ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM TIMETESTS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); v = virtualinvoke v.(v); staticinvoke ("00:01:02", v); v = interfaceinvoke v.(3); staticinvoke ("02:03:04", v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testUsingDateValuesEpochAndString() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException, java.text.ParseException { java.lang.Throwable v, v, v, v; byte[] v; java.sql.Connection v, v; java.util.Date v; org.apache.nifi.processors.standard.TestPutSQL v; java.text.SimpleDateFormat v; java.util.HashMap v; long v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; int v; java.lang.String v, v, v, v, v, v; boolean v, v; java.sql.Statement v, v; org.apache.nifi.dbcp.DBCPService v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: interfaceinvoke v.("CREATE TABLE DATETESTS (id integer primary key, ts date, ts date)"); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = new java.text.SimpleDateFormat; specialinvoke v.(java.lang.String)>("yyyy-MM-dd"); v = virtualinvoke v.("2001-01-01"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (91); interfaceinvoke v.("sql.args.1.type", v); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("sql.args.1.value", v); v = staticinvoke (91); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "2002-02-02"); v = "INSERT INTO DATETESTS (ID, ts, ts) VALUES (1, ?, ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM DATETESTS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("2001-01-01", v); v = interfaceinvoke v.(3); staticinvoke ("2002-02-02", v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testBinaryColumnTypes() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { byte[] 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.sql.ResultSet v; org.apache.nifi.dbcp.DBCPService v, v; java.lang.Throwable v, v, v, v; org.apache.nifi.processor.Relationship v; java.lang.String 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.sql.Statement v, v; java.sql.Connection v, v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.util.TestRunner v; boolean v, v, v, v, v; java.util.HashMap v, v, v, v; java.nio.charset.Charset v, v, v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: interfaceinvoke v.("CREATE TABLE BINARYTESTS (id integer primary key, bn CHAR(8) FOR BIT DATA, bn VARCHAR(100) FOR BIT DATA, bn LONG VARCHAR FOR BIT DATA)"); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = "INSERT INTO BINARYTESTS (ID, bn, bn, bn) VALUES (?, ?, ?, ?)"; v = virtualinvoke v.(); v = specialinvoke v.(8); v = specialinvoke v.(50); v = specialinvoke v.(32700); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = (int) -2; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", v); v = (int) -3; v = staticinvoke (v); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", v); v = (int) -4; v = staticinvoke (v); interfaceinvoke v.("sql.args.4.type", v); interfaceinvoke v.("sql.args.4.value", v); interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "2"); v = (int) -2; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", v); interfaceinvoke v.("sql.args.2.format", "ascii"); v = (int) -3; v = staticinvoke (v); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", v); interfaceinvoke v.("sql.args.3.format", "ascii"); v = (int) -4; v = staticinvoke (v); interfaceinvoke v.("sql.args.4.type", v); interfaceinvoke v.("sql.args.4.value", v); interfaceinvoke v.("sql.args.4.format", "ascii"); interfaceinvoke v.(v, v); v = specialinvoke v.(8); v = specialinvoke v.(50); v = specialinvoke v.(32700); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "3"); v = (int) -2; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", v); interfaceinvoke v.("sql.args.2.format", "hex"); v = (int) -3; v = staticinvoke (v); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", v); interfaceinvoke v.("sql.args.3.format", "hex"); v = (int) -4; v = staticinvoke (v); interfaceinvoke v.("sql.args.4.type", v); interfaceinvoke v.("sql.args.4.value", v); interfaceinvoke v.("sql.args.4.format", "hex"); interfaceinvoke v.(v, v); v = specialinvoke v.(8); v = specialinvoke v.(50); v = specialinvoke v.(32700); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "4"); v = (int) -2; v = staticinvoke (v); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", v); interfaceinvoke v.("sql.args.2.format", "base64"); v = (int) -3; v = staticinvoke (v); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", v); interfaceinvoke v.("sql.args.3.format", "base64"); v = (int) -4; v = staticinvoke (v); interfaceinvoke v.("sql.args.4.type", v); interfaceinvoke v.("sql.args.4.value", v); interfaceinvoke v.("sql.args.4.format", "base64"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 4); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM BINARYTESTS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = ; v = virtualinvoke v.(v); v = interfaceinvoke v.(2); staticinvoke (v, v); v = ; v = virtualinvoke v.(v); v = interfaceinvoke v.(3); staticinvoke (v, v); v = ; v = virtualinvoke v.(v); v = interfaceinvoke v.(4); staticinvoke (v, v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (2, v); v = ; v = virtualinvoke v.(v); v = interfaceinvoke v.(2); staticinvoke (v, v); v = ; v = virtualinvoke v.(v); v = interfaceinvoke v.(3); staticinvoke (v, v); v = ; v = virtualinvoke v.(v); v = interfaceinvoke v.(4); staticinvoke (v, v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (3, v); v = staticinvoke (v); v = interfaceinvoke v.(2); staticinvoke (v, v); v = staticinvoke (v); v = interfaceinvoke v.(3); staticinvoke (v, v); v = staticinvoke (v); v = interfaceinvoke v.(4); staticinvoke (v, v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (4, v); v = staticinvoke (v); v = interfaceinvoke v.(2); staticinvoke (v, v); v = staticinvoke (v); v = interfaceinvoke v.(3); staticinvoke (v, v); v = staticinvoke (v); v = interfaceinvoke v.(4); staticinvoke (v, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testStatementsWithPreparedParameters() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { byte[] v, v; java.sql.Connection v, v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v, v; boolean v, v, v, v; org.apache.nifi.dbcp.DBCPService v, v; java.lang.Throwable v, v, v, v; java.util.HashMap v; org.apache.nifi.processor.Relationship v, v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v; java.sql.Statement v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = staticinvoke (12); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "Mark"); v = staticinvoke (4); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", "84"); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("Mark", v); v = interfaceinvoke v.(3); staticinvoke (84, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); interfaceinvoke v.(); v = staticinvoke (12); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "George"); v = staticinvoke (4); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "1"); v = "UPDATE PERSONS SET NAME=? WHERE ID=?"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("George", v); v = interfaceinvoke v.(3); staticinvoke (84, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testMultipleStatementsWithinFlowFile() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v; byte[] v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; java.lang.String v, v, v, v, v; boolean v; java.sql.Statement v; org.apache.nifi.dbcp.DBCPService v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = staticinvoke (12); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "Mark"); v = staticinvoke (4); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", "84"); v = staticinvoke (4); interfaceinvoke v.("sql.args.4.type", v); interfaceinvoke v.("sql.args.4.value", "1"); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?); UPDATE PERSONS SET NAME=\'George\' WHERE ID=?; "; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; staticinvoke (v, v); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testMultipleStatementsWithinFlowFileRollbackOnFailure() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v, v, v; byte[] v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; java.lang.String v, v, v, v, v; boolean v; org.junit.jupiter.api.function.Executable v; java.sql.Statement v; org.apache.nifi.dbcp.DBCPService v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "true"); specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = staticinvoke (12); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "Mark"); v = staticinvoke (4); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", "84"); v = staticinvoke (4); interfaceinvoke v.("sql.args.4.type", v); interfaceinvoke v.("sql.args.4.value", "1"); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?); UPDATE PERSONS SET NAME=\'George\' WHERE ID=?; "; v = virtualinvoke v.(); interfaceinvoke v.(v, v); virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (class "Ljava/lang/AssertionError;", v); v = virtualinvoke v.(); staticinvoke (class "Lorg/apache/nifi/processor/exception/ProcessException;", v); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testWithNullParameter() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v; byte[] v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; int v, v; java.lang.String v, v, v, v, v; boolean v, v; java.sql.Statement v; org.apache.nifi.dbcp.DBCPService v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = staticinvoke (12); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "Mark"); v = staticinvoke (4); interfaceinvoke v.("sql.args.3.type", v); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("Mark", v); v = interfaceinvoke v.(3); staticinvoke (0, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testInvalidStatement() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v; byte[] v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; java.lang.String v, v, v, v, v; boolean v; java.sql.Statement v; org.apache.nifi.dbcp.DBCPService v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = staticinvoke (12); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "Mark"); v = staticinvoke (4); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", "84"); v = staticinvoke (4); interfaceinvoke v.("sql.args.4.type", v); interfaceinvoke v.("sql.args.4.value", "1"); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?); UPDATE SOME_RANDOM_TABLE NAME=\'George\' WHERE ID=?; "; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; staticinvoke (v, v); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testInvalidStatementRollbackOnFailure() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v, v, v; byte[] v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; java.lang.String v, v, v, v, v; boolean v; org.junit.jupiter.api.function.Executable v; java.sql.Statement v; org.apache.nifi.dbcp.DBCPService v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "true"); specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = staticinvoke (12); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "Mark"); v = staticinvoke (4); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", "84"); v = staticinvoke (4); interfaceinvoke v.("sql.args.4.type", v); interfaceinvoke v.("sql.args.4.value", "1"); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?); UPDATE SOME_RANDOM_TABLE NAME=\'George\' WHERE ID=?; "; v = virtualinvoke v.(); interfaceinvoke v.(v, v); virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (class "Ljava/lang/AssertionError;", v); v = virtualinvoke v.(); staticinvoke (class "Lorg/apache/nifi/processor/exception/ProcessException;", v); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testRetryableFailure() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException { byte[] v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.processors.standard.TestPutSQL$SQLExceptionService v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = staticinvoke (class "Lorg/apache/nifi/processors/standard/PutSQL;"); v = new org.apache.nifi.processors.standard.TestPutSQL$SQLExceptionService; specialinvoke v.(org.apache.nifi.dbcp.DBCPService)>(null); interfaceinvoke v.("dbcp", v); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "dbcp"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = staticinvoke (12); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "Mark"); v = staticinvoke (4); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", "84"); v = staticinvoke (4); interfaceinvoke v.("sql.args.4.type", v); interfaceinvoke v.("sql.args.4.value", "1"); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?); UPDATE PERSONS SET NAME=\'George\' WHERE ID=?; "; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; staticinvoke (v, v); return; } public void testRetryableFailureRollbackOnFailure() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException { java.lang.Throwable v, v; byte[] v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.processors.standard.TestPutSQL$SQLExceptionService v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v, v, v; org.junit.jupiter.api.function.Executable v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = staticinvoke (class "Lorg/apache/nifi/processors/standard/PutSQL;"); v = new org.apache.nifi.processors.standard.TestPutSQL$SQLExceptionService; specialinvoke v.(org.apache.nifi.dbcp.DBCPService)>(null); interfaceinvoke v.("dbcp", v); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "dbcp"); v = ; interfaceinvoke v.(v, "true"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = staticinvoke (12); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "Mark"); v = staticinvoke (4); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", "84"); v = staticinvoke (4); interfaceinvoke v.("sql.args.4.type", v); interfaceinvoke v.("sql.args.4.value", "1"); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?); UPDATE PERSONS SET NAME=\'George\' WHERE ID=?; "; v = virtualinvoke v.(); interfaceinvoke v.(v, v); virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (class "Ljava/lang/AssertionError;", v); v = virtualinvoke v.(); staticinvoke (class "Lorg/apache/nifi/processor/exception/ProcessException;", v); v = ; interfaceinvoke v.(v, 0); return; } public void testMultipleFlowFilesSuccessfulInTransaction() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v; byte[] v, v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v, v, v, v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v; int v, v; java.lang.String v, v, v, v, v, v; boolean v, v, v; java.util.Iterator v; java.util.List v; java.sql.Statement v; java.lang.Object v; org.apache.nifi.dbcp.DBCPService v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "1"); specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = staticinvoke (12); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "Mark"); v = staticinvoke (4); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", "84"); interfaceinvoke v.("fragment.identifier", "1"); interfaceinvoke v.("fragment.count", "2"); interfaceinvoke v.("fragment.index", "0"); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 0); interfaceinvoke v.(); interfaceinvoke v.("fragment.identifier", "1"); interfaceinvoke v.("fragment.count", "2"); interfaceinvoke v.("fragment.index", "1"); interfaceinvoke v.(); v = "UPDATE PERSONS SET NAME=\'Leonard\' WHERE ID=1"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 2); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.("fragment.identifier", "1"); goto label; label: v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("Leonard", v); v = interfaceinvoke v.(3); staticinvoke (84, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testMultipleFlowFilesSuccessfulInTransactionRollBackOnFailure() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { byte[] v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "1"); v = ; interfaceinvoke v.(v, "true"); specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "1"); v = staticinvoke (12); interfaceinvoke v.("sql.args.2.type", v); interfaceinvoke v.("sql.args.2.value", "Mark"); v = staticinvoke (4); interfaceinvoke v.("sql.args.3.type", v); interfaceinvoke v.("sql.args.3.value", "84"); interfaceinvoke v.("fragment.identifier", "1"); interfaceinvoke v.("fragment.count", "2"); interfaceinvoke v.("fragment.index", "0"); v = "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 0); return; } public void testTransactionTimeout() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException { java.lang.Object[] v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processors.standard.TestPutSQL$1 v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "5 secs"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("fragment.identifier", "1"); interfaceinvoke v.("fragment.count", "2"); interfaceinvoke v.("fragment.index", "0"); v = new org.apache.nifi.processors.standard.TestPutSQL$1; specialinvoke v.(org.apache.nifi.processors.standard.TestPutSQL,long,java.util.Map)>(v, 0L, v); v = newarray (org.apache.nifi.flowfile.FlowFile)[1]; v[0] = v; interfaceinvoke v.(v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); staticinvoke (v); return; } public void testTransactionTimeoutRollbackOnFailure() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException { java.lang.Throwable v, v; java.lang.Object[] v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; org.junit.jupiter.api.function.Executable v; org.apache.nifi.processors.standard.TestPutSQL$2 v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "5 secs"); v = ; interfaceinvoke v.(v, "true"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("fragment.identifier", "1"); interfaceinvoke v.("fragment.count", "2"); interfaceinvoke v.("fragment.index", "0"); v = new org.apache.nifi.processors.standard.TestPutSQL$2; specialinvoke v.(org.apache.nifi.processors.standard.TestPutSQL,long,java.util.Map)>(v, 0L, v); v = newarray (org.apache.nifi.flowfile.FlowFile)[1]; v[0] = v; interfaceinvoke v.(v); virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (class "Ljava/lang/AssertionError;", v); v = virtualinvoke v.(); staticinvoke (class "Lorg/apache/nifi/processor/exception/ProcessException;", v); v = ; interfaceinvoke v.(v, 0); return; } public void testNullFragmentCountRollbackOnFailure() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException { java.lang.Throwable v, v; byte[] v, v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v, v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; org.junit.jupiter.api.function.Executable v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "5 secs"); v = ; interfaceinvoke v.(v, "true"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("fragment.identifier", "1"); interfaceinvoke v.("fragment.count", "2"); interfaceinvoke v.("fragment.index", "0"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("fragment.identifier", "1"); interfaceinvoke v.("fragment.index", "1"); v = newarray (byte)[0]; interfaceinvoke v.(v, v); v = newarray (byte)[0]; interfaceinvoke v.(v, v); virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (class "Ljava/lang/AssertionError;", v); v = virtualinvoke v.(); staticinvoke (class "Lorg/apache/nifi/processor/exception/ProcessException;", v); v = ; interfaceinvoke v.(v, 0); return; } public void testStatementsFromProperty() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { byte[] v, v; java.sql.Connection v, v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v; java.sql.ResultSet v, v; java.util.Map v, v; boolean v, v, v, v; org.apache.nifi.dbcp.DBCPService v, v; java.lang.Throwable v, v, v, v; org.apache.nifi.processor.Relationship v; int v, v, v, v; java.lang.String v, v, v, v; java.sql.Statement v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = specialinvoke v.(); v = ; interfaceinvoke v.(v, "INSERT INTO PERSONS (ID, NAME, CODE) VALUES (${row.id}, \'Mark\', 84)"); specialinvoke v.("PERSONS", "CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)"); v = "This statement should be ignored"; v = virtualinvoke v.(); v = staticinvoke ("row.id", "1"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("Mark", v); v = interfaceinvoke v.(3); staticinvoke (84, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = ; interfaceinvoke v.(v, "UPDATE PERSONS SET NAME=\'George\' WHERE ID=${row.id}"); v = "This statement should be ignored"; v = virtualinvoke v.(); v = staticinvoke ("row.id", "1"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.("SELECT * FROM PERSONS"); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(1); staticinvoke (1, v); v = interfaceinvoke v.(2); staticinvoke ("George", v); v = interfaceinvoke v.(3); staticinvoke (84, v); v = interfaceinvoke v.(); staticinvoke (v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testTransactionalFlowFileFilter() { org.apache.nifi.processor.FlowFileFilter$FlowFileFilterResult 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; org.apache.nifi.processor.FlowFileFilter v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.processors.standard.PutSQL$TransactionalFlowFileFilter v, v, v, v; java.util.Map v, v, v, v, v; org.apache.nifi.util.MockFlowFile v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = new org.apache.nifi.util.MockFlowFile; specialinvoke v.(long)>(0L); v = new org.apache.nifi.util.MockFlowFile; specialinvoke v.(long)>(1L); v = new org.apache.nifi.util.MockFlowFile; specialinvoke v.(long)>(2L); v = new org.apache.nifi.util.MockFlowFile; specialinvoke v.(long)>(3L); v = new org.apache.nifi.util.MockFlowFile; specialinvoke v.(long)>(4L); v = specialinvoke v.("tx-1", 3, 0); virtualinvoke v.(v); v = staticinvoke ("accept", "false"); virtualinvoke v.(v); v = specialinvoke v.("tx-1", 3, 1); virtualinvoke v.(v); v = staticinvoke ("accept", "true"); virtualinvoke v.(v); v = specialinvoke v.("tx-1", 3, 2); virtualinvoke v.(v); v = new org.apache.nifi.processors.standard.PutSQL$TransactionalFlowFileFilter; specialinvoke v.(org.apache.nifi.processor.FlowFileFilter)>(null); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = new org.apache.nifi.processors.standard.PutSQL$TransactionalFlowFileFilter; specialinvoke v.(org.apache.nifi.processor.FlowFileFilter)>(null); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = staticinvoke (); v = new org.apache.nifi.processors.standard.PutSQL$TransactionalFlowFileFilter; specialinvoke v.(org.apache.nifi.processor.FlowFileFilter)>(v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = new org.apache.nifi.processors.standard.PutSQL$TransactionalFlowFileFilter; specialinvoke v.(org.apache.nifi.processor.FlowFileFilter)>(v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); return; } private void testFailInMiddleWithBadParameterType(org.apache.nifi.util.TestRunner) throws org.apache.nifi.processor.exception.ProcessException { byte[] v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v := @parameter: org.apache.nifi.util.TestRunner; v = ; interfaceinvoke v.(v, "false"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "84"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (12); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "hello"); v = "INSERT INTO PERSONS_AI (NAME, CODE) VALUES (\'Mark\', ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); return; } private void testFailInMiddleWithBadParameterValue(org.apache.nifi.util.TestRunner) throws org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { byte[] v; org.apache.nifi.processors.standard.TestPutSQL v; java.util.HashMap v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v := @parameter: org.apache.nifi.util.TestRunner; v = ; interfaceinvoke v.(v, "false"); specialinvoke v.("PERSONS_AI", "CREATE TABLE PERSONS_AI (id INTEGER NOT NULL GENERATED ALWAYS AS IDENTITY (START WITH 1), name VARCHAR(100), code INTEGER check(code <= 100))"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "84"); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (4); interfaceinvoke v.("sql.args.1.type", v); interfaceinvoke v.("sql.args.1.value", "9999"); v = "INSERT INTO PERSONS_AI (NAME, CODE) VALUES (\'Mark\', ?)"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); return; } private void testFailInMiddleWithBadStatement(org.apache.nifi.util.TestRunner) { byte[] v, v, v, v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v := @parameter: org.apache.nifi.util.TestRunner; v = ; interfaceinvoke v.(v, "false"); v = "INSERT INTO PERSONS_AI (NAME, CODE) VALUES (\'Mark\', 84)"; v = virtualinvoke v.(); interfaceinvoke v.(v); v = "INSERT INTO PERSONS_AI"; v = virtualinvoke v.(); interfaceinvoke v.(v); v = "INSERT INTO PERSONS_AI (NAME, CODE) VALUES (\'Tom\', 3)"; v = virtualinvoke v.(); interfaceinvoke v.(v); v = "INSERT INTO PERSONS_AI (NAME, CODE) VALUES (\'Harry\', 44)"; v = virtualinvoke v.(); interfaceinvoke v.(v); return; } private java.util.Map createFragmentedTransactionAttributes(java.lang.String, int, int) { org.apache.nifi.processors.standard.TestPutSQL v; int v, v; java.util.HashMap v; java.lang.String v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v := @parameter: java.lang.String; v := @parameter: int; v := @parameter: int; v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("fragment.identifier", v); v = staticinvoke (v); interfaceinvoke v.("fragment.count", v); v = staticinvoke (v); interfaceinvoke v.("fragment.index", v); return v; } private void recreateTable(java.lang.String, java.lang.String) throws org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException { java.lang.Throwable v, v; java.sql.Connection v; org.apache.nifi.processors.standard.TestPutSQL v; java.sql.Statement v; java.lang.String v, v, v; org.apache.nifi.dbcp.DBCPService v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: v = dynamicinvoke "makeConcatWithConstants" (v) ("drop table \u0001"); interfaceinvoke v.(v); interfaceinvoke v.(v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private java.lang.String fixedSizeByteArrayAsASCIIString(int) { byte[] v; org.apache.nifi.processors.standard.TestPutSQL v; java.nio.ByteBuffer v; byte v; int v, v, v; java.lang.StringBuilder v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v := @parameter: int; v = staticinvoke (v); v = staticinvoke (v); v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.(); label: v = virtualinvoke v.(); if v >= v goto label; v = virtualinvoke v.(v); virtualinvoke v.(v); v = v + 1; goto label; label: v = virtualinvoke v.(); return v; } private java.lang.String fixedSizeByteArrayAsHexString(int) { byte[] v; org.apache.nifi.processors.standard.TestPutSQL v; int v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v := @parameter: int; v = staticinvoke (v); v = staticinvoke (v); return v; } private java.lang.String fixedSizeByteArrayAsBase64String(int) { byte[] v; org.apache.nifi.processors.standard.TestPutSQL v; int v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v := @parameter: int; v = staticinvoke (v); v = staticinvoke (v); return v; } private org.apache.nifi.util.TestRunner initTestRunner() throws org.apache.nifi.reporting.InitializationException { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutSQL v; org.apache.nifi.dbcp.DBCPService v, v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.TestPutSQL; v = staticinvoke (class "Lorg/apache/nifi/processors/standard/PutSQL;"); v = ; interfaceinvoke v.("dbcp", v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "dbcp"); return v; } private static java.io.File getEmptyDirectory() { java.lang.Object[] v; java.lang.String[] v; java.util.UUID v; java.io.File v; java.lang.Class v; java.lang.String v, v, v; java.nio.file.Path v; v = newarray (java.lang.Object)[2]; v = class "Lorg/apache/nifi/processors/standard/TestPutSQL;"; v = virtualinvoke v.(); v[0] = v; v = staticinvoke (); v[1] = v; v = staticinvoke ("%s-%s", v); v = staticinvoke (); v = newarray (java.lang.String)[1]; v[0] = v; v = staticinvoke (v, v); v = interfaceinvoke v.(); return v; } private static void assertSQLExceptionRelatedAttributes(org.apache.nifi.util.TestRunner, org.apache.nifi.processor.Relationship) { java.util.function.Consumer v; java.util.List v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; v := @parameter: org.apache.nifi.util.TestRunner; v := @parameter: org.apache.nifi.processor.Relationship; v = interfaceinvoke v.(v); v = staticinvoke (); interfaceinvoke v.(v); return; } private static void assertNonSQLExceptionRelatedAttribute(org.apache.nifi.util.TestRunner) { java.util.function.Consumer v; java.util.List v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; v := @parameter: org.apache.nifi.util.TestRunner; v = ; v = interfaceinvoke v.(v); v = staticinvoke (); interfaceinvoke v.(v); return; } private static void assertOriginalAttributesAreKept(org.apache.nifi.util.TestRunner) { org.apache.nifi.util.TestRunner v; v := @parameter: org.apache.nifi.util.TestRunner; interfaceinvoke v.("sql.args.1.type"); interfaceinvoke v.("sql.args.1.value"); return; } private static void assertErrorAttributesInTransaction(org.apache.nifi.util.TestRunner, org.apache.nifi.processor.Relationship) { java.util.List v; java.util.stream.Stream v, v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.util.function.Predicate v; long v; v := @parameter: org.apache.nifi.util.TestRunner; v := @parameter: org.apache.nifi.processor.Relationship; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1L, v, "Only one FlowFile should have the error attributes when transaction is used."); return; } private static void assertErrorAttributesNotSet(org.apache.nifi.util.TestRunner, org.apache.nifi.processor.Relationship) { java.util.function.Consumer v; java.util.List v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; v := @parameter: org.apache.nifi.util.TestRunner; v := @parameter: org.apache.nifi.processor.Relationship; v = interfaceinvoke v.(v); v = staticinvoke (); interfaceinvoke v.(v); return; } public static boolean errorAttributesAreSet(org.apache.nifi.util.MockFlowFile) { java.lang.String v, v, v; boolean v; org.apache.nifi.util.MockFlowFile v; v := @parameter: org.apache.nifi.util.MockFlowFile; v = virtualinvoke v.("error.message"); if v == null goto label; v = virtualinvoke v.("error.code"); if v == null goto label; v = virtualinvoke v.("error.sql.state"); if v == null goto label; v = 1; goto label; label: v = 0; label: return v; } private static java.lang.String getSystemTemporaryDirectory() { java.lang.String v; v = staticinvoke ("java.io.tmpdir"); return v; } }