public class org.apache.nifi.processors.standard.TestConvertJSONToSQL extends java.lang.Object
{
private static final java.lang.String DERBY_LOG_PROPERTY;
protected static org.apache.nifi.dbcp.DBCPService service;
public void <init>()
{
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static void setupDerbyLog() throws org.apache.nifi.processor.exception.ProcessException
{
java.lang.String v, v;
java.io.File v;
v = new java.io.File;
v = staticinvoke <org.apache.nifi.processors.standard.TestConvertJSONToSQL: java.lang.String getSystemTemporaryDirectory()>();
specialinvoke v.<java.io.File: void <init>(java.lang.String,java.lang.String)>(v, "derby.log");
virtualinvoke v.<java.io.File: void deleteOnExit()>();
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("derby.stream.error.file", v);
return;
}
public void setup() throws java.sql.SQLException
{
java.lang.Throwable v, v;
java.sql.Connection v;
java.io.File v, v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL$MockDBCPService v;
java.sql.Statement v;
java.lang.String v;
org.apache.nifi.dbcp.DBCPService v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = new java.io.File;
v = specialinvoke v.<org.apache.nifi.processors.standard.TestConvertJSONToSQL: java.io.File getEmptyDirectory()>();
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "db");
virtualinvoke v.<java.io.File: void deleteOnExit()>();
v = new org.apache.nifi.processors.standard.TestConvertJSONToSQL$MockDBCPService;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
specialinvoke v.<org.apache.nifi.processors.standard.TestConvertJSONToSQL$MockDBCPService: void <init>(java.lang.String)>(v);
<org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service> = v;
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
v = interfaceinvoke v.<org.apache.nifi.dbcp.DBCPService: java.sql.Connection getConnection()>();
label:
v = interfaceinvoke v.<java.sql.Connection: java.sql.Statement createStatement()>();
label:
interfaceinvoke v.<java.sql.Statement: int executeUpdate(java.lang.String)>("CREATE TABLE PERSONS (id integer primary key, name varchar(100), code integer)");
label:
interfaceinvoke v.<java.sql.Statement: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
interfaceinvoke v.<java.sql.Connection: void close()>();
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 <java.lang.System: java.lang.String clearProperty(java.lang.String)>("derby.stream.error.file");
return;
}
public void testInsert() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?)");
return;
}
public void testInsertStatementType() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "Use statement.type Attribute");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("statement.type", "INSERT");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path,java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?)");
return;
}
public void testInsertQuotedIdentifiers() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor QUOTED_IDENTIFIERS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO PERSONS (\"ID\", \"NAME\", \"CODE\") VALUES (?, ?, ?)");
return;
}
public void testInsertQuotedTableIdentifier() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor QUOTED_TABLE_IDENTIFIER>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO \"PERSONS\" (ID, NAME, CODE) VALUES (?, ?, ?)");
return;
}
public void testInsertWithNullValue() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-with-null-code.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeNotExists(java.lang.String)>("sql.args.3.value");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?)");
return;
}
public void testInsertBoolToInteger() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-with-bool.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Bool");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?)");
return;
}
public void testUpdateWithNullValue() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-with-null-code.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeNotExists(java.lang.String)>("sql.args.2.value");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("UPDATE PERSONS SET NAME = ?, CODE = ? WHERE ID = ?");
return;
}
public void testUpdateQuotedTableIdentifier() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor QUOTED_TABLE_IDENTIFIER>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-with-null-code.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeNotExists(java.lang.String)>("sql.args.2.value");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("UPDATE \"PERSONS\" SET NAME = ?, CODE = ? WHERE ID = ?");
return;
}
public void testMultipleInserts() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v, v, v;
java.nio.file.Path v;
boolean v;
java.util.Iterator v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/persons.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "5");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 5);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?)");
v = 1;
label:
if v > 3 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("sql.args.\u.type");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("sql.args.\u.value");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>(v);
v = v + 1;
goto label;
label:
return;
}
public void testMultipleInsertsQuotedIdentifiers() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v, v, v;
java.nio.file.Path v;
boolean v;
java.util.Iterator v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor QUOTED_IDENTIFIERS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/persons.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "5");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 5);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO PERSONS (\"ID\", \"NAME\", \"CODE\") VALUES (?, ?, ?)");
v = 1;
label:
if v > 3 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("sql.args.\u.type");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("sql.args.\u.value");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>(v);
v = v + 1;
goto label;
label:
return;
}
public void testUpdateBasedOnPrimaryKey() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "48");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("UPDATE PERSONS SET NAME = ?, CODE = ? WHERE ID = ?");
return;
}
public void testUpdateBasedOnPrimaryKeyQuotedIdentifier() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor QUOTED_IDENTIFIERS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "48");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("UPDATE PERSONS SET \"NAME\" = ?, \"CODE\" = ? WHERE \"ID\" = ?");
return;
}
public void testUnmappedFieldBehavior() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v;
java.nio.file.Path v, v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.components.AllowableValue v, v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UNMATCHED_FIELD_BEHAVIOR>;
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.AllowableValue IGNORE_UNMATCHED_FIELD>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-with-extra-field.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?)");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UNMATCHED_FIELD_BEHAVIOR>;
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.AllowableValue FAIL_UNMATCHED_FIELD>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-with-extra-field.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testUpdateBasedOnUpdateKey() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UPDATE_KEY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "code");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("UPDATE PERSONS SET ID = ?, NAME = ? WHERE CODE = ?");
return;
}
public void testUpdateBasedOnUpdateKeyQuotedIdentifier() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UPDATE_KEY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "code");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor QUOTED_IDENTIFIERS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("UPDATE PERSONS SET \"ID\" = ?, \"NAME\" = ? WHERE \"CODE\" = ?");
return;
}
public void testUpdateBasedOnCompoundUpdateKey() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v, v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UPDATE_KEY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "name,  code");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_ID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>(v);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("UPDATE PERSONS SET ID = ? WHERE NAME = ? AND CODE = ?");
return;
}
public void testUpdateWithMissingFieldBasedOnCompoundUpdateKey() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.dbcp.DBCPService v, v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UPDATE_KEY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "name,  code");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-without-code.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testUpdateWithMalformedJson() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.dbcp.DBCPService v, v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UPDATE_KEY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "name,  code");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/malformed-person-extra-comma.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testInsertWithMissingField() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.dbcp.DBCPService v, v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UPDATE_KEY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "name,  code");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-without-id.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testInsertWithMissingColumnFail() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException, java.io.IOException
{
java.lang.Throwable v, v;
java.sql.Connection v;
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
java.nio.file.Path v;
org.apache.nifi.components.AllowableValue v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.sql.Statement v;
org.apache.nifi.dbcp.DBCPService v, v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
v = interfaceinvoke v.<org.apache.nifi.dbcp.DBCPService: java.sql.Connection getConnection()>();
label:
v = interfaceinvoke v.<java.sql.Connection: java.sql.Statement createStatement()>();
label:
interfaceinvoke v.<java.sql.Statement: int executeUpdate(java.lang.String)>("CREATE TABLE PERSONS3 (id integer, name varchar(100), code integer, generated_key integer primary key)");
label:
interfaceinvoke v.<java.sql.Statement: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
interfaceinvoke v.<java.sql.Connection: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS3");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UNMATCHED_COLUMN_BEHAVIOR>;
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.AllowableValue FAIL_UNMATCHED_COLUMN>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue)>(v, v);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void testInsertWithMissingColumnWarning() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException, java.io.IOException
{
java.lang.Throwable v, v;
java.sql.Connection v;
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.components.AllowableValue v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.sql.Statement v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
v = interfaceinvoke v.<org.apache.nifi.dbcp.DBCPService: java.sql.Connection getConnection()>();
label:
v = interfaceinvoke v.<java.sql.Connection: java.sql.Statement createStatement()>();
label:
interfaceinvoke v.<java.sql.Statement: int executeUpdate(java.lang.String)>("CREATE TABLE PERSONS2 (id integer, name varchar(100), code integer, generated_key integer primary key)");
label:
interfaceinvoke v.<java.sql.Statement: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
interfaceinvoke v.<java.sql.Connection: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS2");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UNMATCHED_COLUMN_BEHAVIOR>;
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.AllowableValue WARNING_UNMATCHED_COLUMN>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue)>(v, v);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO PERSONS2 (ID, NAME, CODE) VALUES (?, ?, ?)");
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void testInsertWithMissingColumnIgnore() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UNMATCHED_COLUMN_BEHAVIOR>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "Ignore Unmatched Columns");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO PERSONS (ID, NAME, CODE) VALUES (?, ?, ?)");
return;
}
public void testUpdateWithMissingColumnFail() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.AllowableValue v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.dbcp.DBCPService v, v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UPDATE_KEY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "name,  code, extra");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UNMATCHED_COLUMN_BEHAVIOR>;
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.AllowableValue FAIL_UNMATCHED_COLUMN>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue)>(v, v);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testUpdateWithMissingColumnWarning() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.components.AllowableValue v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UPDATE_KEY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "name,  code, extra");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UNMATCHED_COLUMN_BEHAVIOR>;
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.AllowableValue WARNING_UNMATCHED_COLUMN>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue)>(v, v);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("UPDATE PERSONS SET ID = ? WHERE NAME = ? AND CODE = ?");
return;
}
public void testUpdateWithMissingColumnIgnore() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UPDATE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UPDATE_KEY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "name,  code, extra");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor UNMATCHED_COLUMN_BEHAVIOR>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "Ignore Unmatched Columns");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("UPDATE PERSONS SET ID = ? WHERE NAME = ? AND CODE = ?");
return;
}
public void testCreateSqlStringValue() throws org.apache.nifi.processor.exception.ProcessException, java.sql.SQLException, java.io.IOException, org.apache.nifi.reporting.InitializationException
{
byte[] v, v;
java.sql.Connection v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.nifi.util.TestRunner v;
java.sql.ResultSet v;
com.fasterxml.jackson.databind.JsonNode v, v;
boolean v;
org.apache.nifi.dbcp.DBCPService v, v, v;
java.lang.Throwable v, v;
java.sql.DatabaseMetaData v;
java.util.HashMap v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.sql.Statement v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/PutSQL;");
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(20);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.PutSQL: org.apache.nifi.components.PropertyDescriptor OBTAIN_GENERATED_KEYS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = <org.apache.nifi.processors.standard.PutSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
v = interfaceinvoke v.<org.apache.nifi.dbcp.DBCPService: java.sql.Connection getConnection()>();
label:
v = interfaceinvoke v.<java.sql.Connection: java.sql.Statement createStatement()>();
label:
interfaceinvoke v.<java.sql.Statement: int executeUpdate(java.lang.String)>("CREATE TABLE DIFTYPES (id integer primary key, b boolean, f float, dbl double, dcml decimal, d date)");
label:
interfaceinvoke v.<java.sql.Statement: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = interfaceinvoke v.<java.sql.Connection: java.sql.DatabaseMetaData getMetaData()>();
v = interfaceinvoke v.<java.sql.DatabaseMetaData: java.sql.ResultSet getColumns(java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(null, null, "DIFTYPES", "%");
label:
v = interfaceinvoke v.<java.sql.ResultSet: boolean next()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.sql.ResultSet: int getInt(java.lang.String)>("DATA_TYPE");
v = interfaceinvoke v.<java.sql.ResultSet: int getInt(java.lang.String)>("COLUMN_SIZE");
lookupswitch(v)
{
case 6: goto label;
case 8: goto label;
case 16: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.String writeValueAsString(java.lang.Object)>("true");
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(java.lang.String)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.ConvertJSONToSQL: java.lang.String createSqlStringValue(com.fasterxml.jackson.databind.JsonNode,java.lang.Integer,int)>(v, v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("true", v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("sql.args.1.type", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("sql.args.1.value", v);
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int incrementAndGet()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("INSERT INTO DIFTYPES (ID, B) VALUES (\u, ?)");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.PutSQL: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = <org.apache.nifi.processors.standard.PutSQL: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.PutSQL: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
goto label;
label:
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.String writeValueAsString(java.lang.Object)>("78895654.6575");
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(java.lang.String)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.ConvertJSONToSQL: java.lang.String createSqlStringValue(com.fasterxml.jackson.databind.JsonNode,java.lang.Integer,int)>(v, v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("78895654.6575", v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("sql.args.1.type", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("sql.args.1.value", v);
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int incrementAndGet()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("INSERT INTO DIFTYPES (ID, dbl) VALUES (\u, ?)");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.PutSQL: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = <org.apache.nifi.processors.standard.PutSQL: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.PutSQL: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
goto label;
label:
interfaceinvoke v.<java.sql.Connection: void close()>();
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 testDelete() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "DELETE");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("DELETE FROM PERSONS WHERE ID = ? AND NAME = ? AND CODE = ?");
return;
}
public void testDeleteQuotedIdentifiers() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "DELETE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor QUOTED_IDENTIFIERS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("DELETE FROM PERSONS WHERE \"ID\" = ? AND \"NAME\" = ? AND \"CODE\" = ?");
return;
}
public void testDeleteQuotedTableIdentifier() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "DELETE");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor QUOTED_TABLE_IDENTIFIER>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("DELETE FROM \"PERSONS\" WHERE ID = ? AND NAME = ? AND CODE = ?");
return;
}
public void testDeleteWithNullValue() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "DELETE");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-with-null-code.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeNotExists(java.lang.String)>("sql.args.3.value");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("DELETE FROM PERSONS WHERE ID = ? AND NAME = ? AND CODE = ?");
return;
}
public void testAttributePrefix() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "INSERT");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor QUOTED_IDENTIFIERS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor SQL_PARAM_ATTR_PREFIX>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "hiveql");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("hiveql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("hiveql.args.1.value", "1");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("hiveql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("hiveql.args.2.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("hiveql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("hiveql.args.3.value", "48");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("INSERT INTO PERSONS (\"ID\", \"NAME\", \"CODE\") VALUES (?, ?, ?)");
return;
}
public void testUpdateStatementTypeWithStatementTypeAttribute() throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.processor.exception.ProcessException, java.io.IOException
{
java.lang.String[] v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
java.nio.file.Path v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.util.List v, v;
java.lang.Object v, v;
org.apache.nifi.dbcp.DBCPService v, v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertJSONToSQL;");
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("dbcp", v);
v = <org.apache.nifi.processors.standard.TestConvertJSONToSQL: org.apache.nifi.dbcp.DBCPService service>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "dbcp");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "PERSONS");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "Use statement.type Attribute");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("statement.type", "UPDATE");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestConvertJSONToSQL/person-1.json", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path,java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ConvertJSONToSQL: org.apache.nifi.processor.Relationship REL_SQL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.1.value", "Mark");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.2.value", "48");
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.type", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("sql.args.3.value", "1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("UPDATE PERSONS SET NAME = ?, CODE = ? WHERE ID = ?");
return;
}
private java.io.File getEmptyDirectory()
{
java.lang.Object[] v;
java.lang.String[] v;
java.util.UUID v;
java.io.File v;
org.apache.nifi.processors.standard.TestConvertJSONToSQL v;
java.lang.Class v;
java.lang.String v, v, v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestConvertJSONToSQL;
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v[0] = v;
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("%s-%s", v);
v = staticinvoke <org.apache.nifi.processors.standard.TestConvertJSONToSQL: java.lang.String getSystemTemporaryDirectory()>();
v = newarray (java.lang.String)[1];
v[0] = v;
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = interfaceinvoke v.<java.nio.file.Path: java.io.File toFile()>();
return v;
}
private static java.lang.String getSystemTemporaryDirectory()
{
java.lang.String v;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("java.io.tmpdir");
return v;
}
}