public class org.apache.nifi.processors.standard.ConvertJSONToSQL extends org.apache.nifi.processor.AbstractProcessor { private static final java.lang.String UPDATE_TYPE; private static final java.lang.String INSERT_TYPE; private static final java.lang.String DELETE_TYPE; static final java.lang.String USE_ATTR_TYPE; static final java.lang.String STATEMENT_TYPE_ATTRIBUTE; static final org.apache.nifi.components.AllowableValue IGNORE_UNMATCHED_FIELD; static final org.apache.nifi.components.AllowableValue FAIL_UNMATCHED_FIELD; static final org.apache.nifi.components.AllowableValue IGNORE_UNMATCHED_COLUMN; static final org.apache.nifi.components.AllowableValue WARNING_UNMATCHED_COLUMN; static final org.apache.nifi.components.AllowableValue FAIL_UNMATCHED_COLUMN; static final org.apache.nifi.components.PropertyDescriptor CONNECTION_POOL; static final org.apache.nifi.components.PropertyDescriptor STATEMENT_TYPE; static final org.apache.nifi.components.PropertyDescriptor TABLE_NAME; static final org.apache.nifi.components.PropertyDescriptor CATALOG_NAME; static final org.apache.nifi.components.PropertyDescriptor SCHEMA_NAME; static final org.apache.nifi.components.PropertyDescriptor TRANSLATE_FIELD_NAMES; static final org.apache.nifi.components.PropertyDescriptor UNMATCHED_FIELD_BEHAVIOR; static final org.apache.nifi.components.PropertyDescriptor UNMATCHED_COLUMN_BEHAVIOR; static final org.apache.nifi.components.PropertyDescriptor UPDATE_KEY; static final org.apache.nifi.components.PropertyDescriptor QUOTED_IDENTIFIERS; static final org.apache.nifi.components.PropertyDescriptor QUOTED_TABLE_IDENTIFIER; static final org.apache.nifi.components.PropertyDescriptor SQL_PARAM_ATTR_PREFIX; static final org.apache.nifi.components.PropertyDescriptor TABLE_SCHEMA_CACHE_SIZE; static final org.apache.nifi.processor.Relationship REL_ORIGINAL; static final org.apache.nifi.processor.Relationship REL_SQL; static final org.apache.nifi.processor.Relationship REL_FAILURE; private com.github.benmanes.caffeine.cache.Cache schemaCache; public void () { org.apache.nifi.processors.standard.ConvertJSONToSQL v; v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL; specialinvoke v.()>(); return; } protected java.util.List getSupportedPropertyDescriptors() { org.apache.nifi.processors.standard.ConvertJSONToSQL v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.ArrayList v; v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL; v = new java.util.ArrayList; specialinvoke v.()>(); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); return v; } public java.util.Set getRelationships() { java.util.HashSet v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.processors.standard.ConvertJSONToSQL v; v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL; v = new java.util.HashSet; specialinvoke v.()>(); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); return v; } public void onScheduled(org.apache.nifi.processor.ProcessContext) { com.github.benmanes.caffeine.cache.Caffeine v, v; org.apache.nifi.processors.standard.ConvertJSONToSQL v; org.apache.nifi.processor.ProcessContext v; com.github.benmanes.caffeine.cache.Cache v; java.lang.Integer v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyValue v; int v; v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL; v := @parameter: org.apache.nifi.processor.ProcessContext; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; return; } public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException { org.apache.nifi.processors.standard.ConvertJSONToSQL v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v; com.fasterxml.jackson.databind.JsonNode v; org.apache.nifi.processors.standard.ConvertJSONToSQL$SchemaKey v; org.apache.nifi.flowfile.attributes.FragmentAttributes v, v, v; org.apache.nifi.components.AllowableValue v, v, v; com.fasterxml.jackson.databind.node.JsonNodeFactory v; java.lang.StringBuilder v, v, v; java.lang.Throwable v, v, v; java.lang.Object[] v, v, v; com.github.benmanes.caffeine.cache.Cache v; org.apache.nifi.processor.Relationship v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.flowfile.attributes.CoreAttributes v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v, v, v, v; java.util.UUID v; com.fasterxml.jackson.databind.node.ArrayNode v; org.apache.nifi.processors.standard.ConvertJSONToSQL$2 v; org.apache.nifi.processors.standard.ConvertJSONToSQL$1 v; java.util.HashMap v; org.apache.nifi.logging.ComponentLog v, v, v; java.util.concurrent.atomic.AtomicReference v; java.util.function.Function v; java.util.HashSet v; int v, v, v, v; java.lang.Boolean v, v, v; com.fasterxml.jackson.databind.ObjectMapper v; org.apache.nifi.processor.ProcessContext v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v = interfaceinvoke v.(); if v != null goto label; return; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = "Use statement.type Attribute"; v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.("statement.type"); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = new org.apache.nifi.processors.standard.ConvertJSONToSQL$SchemaKey; specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = "UPDATE"; v = virtualinvoke v.(v); if v == 0 goto label; if v != null goto label; v = 1; goto label; label: v = 0; label: v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = v.; v = staticinvoke (v, v, v, v, v, v, v); v = interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v = virtualinvoke v.(); v[1] = v; interfaceinvoke v.("Failed to convert {} into a SQL statement due to {}; routing to failure", v, v); v = ; interfaceinvoke v.(v, v); return; label: v = new com.fasterxml.jackson.databind.ObjectMapper; specialinvoke v.()>(); v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.(java.lang.Object)>(null); label: v = new org.apache.nifi.processors.standard.ConvertJSONToSQL$1; specialinvoke v.(org.apache.nifi.processors.standard.ConvertJSONToSQL,java.util.concurrent.atomic.AtomicReference,com.fasterxml.jackson.databind.ObjectMapper)>(v, v, v); interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v = virtualinvoke v.(); v[1] = v; interfaceinvoke v.("Failed to parse {} as JSON due to {}; routing to failure", v, v); v = ; interfaceinvoke v.(v, v); return; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = ; v = new com.fasterxml.jackson.databind.node.ArrayNode; specialinvoke v.(com.fasterxml.jackson.databind.node.JsonNodeFactory)>(v); virtualinvoke v.(v); label: v = staticinvoke (); v = virtualinvoke v.(); v = new java.util.HashSet; specialinvoke v.()>(); v = 0; label: v = virtualinvoke v.(); if v >= v goto label; v = virtualinvoke v.(v); v = new java.util.HashMap; specialinvoke v.()>(); label: v = new java.lang.StringBuilder; specialinvoke v.()>(); if v == null goto label; v = virtualinvoke v.(v); virtualinvoke v.("."); label: if v == null goto label; v = virtualinvoke v.(v); virtualinvoke v.("."); label: virtualinvoke v.(v); v = virtualinvoke v.(); v = "INSERT"; v = virtualinvoke v.(v); if v == 0 goto label; v = specialinvoke v.(v, v, v, v, v, v, v, v, v, v, v); goto label; label: v = "UPDATE"; v = virtualinvoke v.(v); if v == 0 goto label; v = specialinvoke v.(v, v, v, v, v, v, v, v, v, v, v, v); goto label; label: v = specialinvoke v.(v, v, v, v, v, v, v, v, v, v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Failed to convert {} to a SQL {} statement due to {}; routing to failure", v, v); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, v); return; label: v = interfaceinvoke v.(v); interfaceinvoke v.(v); v = new org.apache.nifi.processors.standard.ConvertJSONToSQL$2; specialinvoke v.(org.apache.nifi.processors.standard.ConvertJSONToSQL,java.lang.String)>(v, v); v = interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "text/plain"); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.table"); interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); if v == null goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.catalog"); interfaceinvoke v.(v, v); label: v = interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, v); v = v + 1; goto label; label: v = virtualinvoke v.(); v = staticinvoke (v, v, v, v); v = ; interfaceinvoke v.(v, v); return; catch org.apache.nifi.processor.exception.ProcessException from label to label with label; catch org.apache.nifi.processor.exception.ProcessException from label to label with label; catch org.apache.nifi.processor.exception.ProcessException from label to label with label; } private java.util.Set getNormalizedColumnNames(com.fasterxml.jackson.databind.JsonNode, boolean) { java.util.Iterator v; org.apache.nifi.processors.standard.ConvertJSONToSQL v; java.util.HashSet v; com.fasterxml.jackson.databind.JsonNode v; java.lang.Object v; java.lang.String v; boolean v, v; v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL; v := @parameter: com.fasterxml.jackson.databind.JsonNode; v := @parameter: boolean; v = new java.util.HashSet; specialinvoke v.()>(); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, v); interfaceinvoke v.(v); goto label; label: return v; } private java.lang.String generateInsert(com.fasterxml.jackson.databind.JsonNode, java.util.Map, java.lang.String, org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema, boolean, boolean, boolean, boolean, boolean, boolean, java.lang.String) { org.apache.nifi.processors.standard.ConvertJSONToSQL v; org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema v; java.lang.Integer v; java.util.Map v, v; com.fasterxml.jackson.databind.JsonNode v, v; boolean v, v, v, v, v, v, v, v, v, v; java.util.Set v; java.util.List v; java.lang.StringBuilder v, v, v, v, v; org.apache.nifi.logging.ComponentLog v, v; org.apache.nifi.processor.exception.ProcessException v, v, v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Iterator v, v; java.lang.Object v, v, v; v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL; v := @parameter: com.fasterxml.jackson.databind.JsonNode; v := @parameter: java.util.Map; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: java.lang.String; v = specialinvoke v.(v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, v); v = interfaceinvoke v.(v); if v != 0 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("JSON does not have a value for the Required column \'\u0001\'"); if v == 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.String)>(v); throw v; label: if v == 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = new java.lang.StringBuilder; specialinvoke v.()>(); v = 0; virtualinvoke v.("INSERT INTO "); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); label: virtualinvoke v.(" ("); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); v = interfaceinvoke v.(v); if v != null goto label; if v != 0 goto label; v = new org.apache.nifi.processor.exception.ProcessException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot map JSON field \'\u0001\' to any column in the database"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v == null goto label; v = v; v = v + 1; if v <= 0 goto label; virtualinvoke v.(", "); label: if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u.args.\u.type"); v = staticinvoke (v); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = staticinvoke (v, v, v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u.args.\u.value"); interfaceinvoke v.(v, v); goto label; label: virtualinvoke v.(") VALUES ("); v = 0; label: if v >= v goto label; if v <= 0 goto label; virtualinvoke v.(", "); label: virtualinvoke v.("?"); v = v + 1; goto label; label: virtualinvoke v.(")"); if v != 0 goto label; v = new org.apache.nifi.processor.exception.ProcessException; v = dynamicinvoke "makeConcatWithConstants" (v) ("None of the fields in the JSON map to the columns defined by the \u table"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); return v; } protected static java.lang.String createSqlStringValue(com.fasterxml.jackson.databind.JsonNode, java.lang.Integer, int) { java.lang.Integer v; int v, v, v, v; java.lang.Boolean v; com.fasterxml.jackson.databind.JsonNode v; java.lang.String v, v; boolean v, v; v := @parameter: com.fasterxml.jackson.databind.JsonNode; v := @parameter: java.lang.Integer; v := @parameter: int; v = virtualinvoke v.(); lookupswitch(v) { case -16: goto label; case -15: goto label; case -9: goto label; case -7: goto label; case -6: goto label; case -5: goto label; case -1: goto label; case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; case 8: goto label; case 12: goto label; case 16: goto label; case 91: goto label; case 92: goto label; case 93: goto label; default: goto label; }; label: v = staticinvoke (v); v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = "1"; goto label; label: v = "0"; label: v = v; goto label; label: if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v <= v goto label; v = virtualinvoke v.(); v = virtualinvoke v.(0, v); label: return v; } private java.lang.String generateUpdate(com.fasterxml.jackson.databind.JsonNode, java.util.Map, java.lang.String, java.lang.String, org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema, boolean, boolean, boolean, boolean, boolean, boolean, java.lang.String) { org.apache.nifi.processors.standard.ConvertJSONToSQL v; org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema v; java.lang.Integer v, v; java.util.Map v, v, v; com.fasterxml.jackson.databind.JsonNode v, v, v; java.util.Set v, v; java.lang.StringBuilder v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String[] v; org.apache.nifi.logging.ComponentLog v, v; org.apache.nifi.processor.exception.ProcessException v, v, v; java.util.HashSet v, v; int v, v, v, v, v, v, v, v, v, v, v; java.util.Iterator v, v, v; java.lang.Object v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL; v := @parameter: com.fasterxml.jackson.databind.JsonNode; v := @parameter: java.util.Map; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: java.lang.String; if v != null goto label; v = virtualinvoke v.(); goto label; label: v = new java.util.HashSet; specialinvoke v.()>(); v = v; v = virtualinvoke v.(","); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v + 1; goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = new org.apache.nifi.processor.exception.ProcessException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Table \'\u0001\' does not have a Primary Key and no Update Keys were specified"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new java.lang.StringBuilder; specialinvoke v.()>(); v = 0; virtualinvoke v.("UPDATE "); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); label: virtualinvoke v.(" SET "); v = specialinvoke v.(v, v); v = new java.util.HashSet; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, v); interfaceinvoke v.(v); v = interfaceinvoke v.(v); if v != 0 goto label; if v != null goto label; v = "Primary"; goto label; label: v = "Update"; label: v = dynamicinvoke "makeConcatWithConstants" (v, v) ("JSON does not have a value for the \u0001Key column \'\u0001\'"); if v == 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.String)>(v); throw v; label: if v == 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; if v != 0 goto label; v = new org.apache.nifi.processor.exception.ProcessException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot map JSON field \'\u0001\' to any column in the database"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); if v != 0 goto label; v = v; v = v + 1; if v <= 0 goto label; virtualinvoke v.(", "); label: if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); virtualinvoke v.(v); label: virtualinvoke v.(" = ?"); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u.args.\u.type"); v = staticinvoke (v); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = staticinvoke (v, v, v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u.args.\u.value"); interfaceinvoke v.(v, v); goto label; label: virtualinvoke v.(" WHERE "); v = virtualinvoke v.(); v = 0; label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = interfaceinvoke v.(v); if v == 0 goto label; v = v; v = v + 1; if v <= 0 goto label; virtualinvoke v.(" AND "); label: v = v + 1; if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); label: virtualinvoke v.(" = ?"); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u.args.\u.type"); v = staticinvoke (v); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v <= v goto label; v = virtualinvoke v.(); v = virtualinvoke v.(0, v); label: v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u.args.\u.value"); interfaceinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); return v; } private java.lang.String generateDelete(com.fasterxml.jackson.databind.JsonNode, java.util.Map, java.lang.String, org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema, boolean, boolean, boolean, boolean, boolean, boolean, java.lang.String) { org.apache.nifi.processors.standard.ConvertJSONToSQL v; org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema v; java.lang.Integer v; java.util.Map v, v; com.fasterxml.jackson.databind.JsonNode v, v; boolean v, v, v, v, v, v, v, v, v, v; java.util.Set v; java.util.List v; java.lang.StringBuilder v, v, v, v, v; org.apache.nifi.logging.ComponentLog v, v; org.apache.nifi.processor.exception.ProcessException v, v, v; int v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Iterator v, v; java.lang.Object v, v, v; v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL; v := @parameter: com.fasterxml.jackson.databind.JsonNode; v := @parameter: java.util.Map; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: java.lang.String; v = specialinvoke v.(v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, v); v = interfaceinvoke v.(v); if v != 0 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("JSON does not have a value for the Required column \'\u0001\'"); if v == 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.String)>(v); throw v; label: if v == 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = new java.lang.StringBuilder; specialinvoke v.()>(); v = 0; virtualinvoke v.("DELETE FROM "); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); label: virtualinvoke v.(" WHERE "); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); v = interfaceinvoke v.(v); if v != null goto label; if v != 0 goto label; v = new org.apache.nifi.processor.exception.ProcessException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot map JSON field \'\u0001\' to any column in the database"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v == null goto label; v = v; v = v + 1; if v <= 0 goto label; virtualinvoke v.(" AND "); label: if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); virtualinvoke v.(v); label: virtualinvoke v.(" = ?"); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u.args.\u.type"); v = staticinvoke (v); interfaceinvoke v.(v, v); v = virtualinvoke v.