public class org.apache.nifi.processors.standard.UpdateDatabaseTable extends org.apache.nifi.processor.AbstractProcessor { static final org.apache.nifi.components.AllowableValue CREATE_IF_NOT_EXISTS; static final org.apache.nifi.components.AllowableValue FAIL_IF_NOT_EXISTS; static final java.lang.String ATTR_OUTPUT_TABLE; static final org.apache.nifi.components.PropertyDescriptor RECORD_READER; static final org.apache.nifi.components.PropertyDescriptor DBCP_SERVICE; 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 TABLE_NAME; static final org.apache.nifi.components.PropertyDescriptor CREATE_TABLE; static final org.apache.nifi.components.PropertyDescriptor PRIMARY_KEY_FIELDS; static final org.apache.nifi.components.PropertyDescriptor TRANSLATE_FIELD_NAMES; static final org.apache.nifi.components.PropertyDescriptor UPDATE_FIELD_NAMES; static final org.apache.nifi.components.PropertyDescriptor RECORD_WRITER_FACTORY; static final org.apache.nifi.components.PropertyDescriptor QUOTE_COLUMN_IDENTIFIERS; static final org.apache.nifi.components.PropertyDescriptor QUOTE_TABLE_IDENTIFIER; static final org.apache.nifi.components.PropertyDescriptor QUERY_TIMEOUT; static final org.apache.nifi.components.PropertyDescriptor DB_TYPE; public static final org.apache.nifi.processor.Relationship REL_SUCCESS; public static final org.apache.nifi.processor.Relationship REL_FAILURE; protected static final java.util.Map dbAdapters; private static final java.util.List propertyDescriptors; protected static java.util.Set relationships; public void () { org.apache.nifi.processors.standard.UpdateDatabaseTable v; v := @this: org.apache.nifi.processors.standard.UpdateDatabaseTable; specialinvoke v.()>(); return; } protected java.util.List getSupportedPropertyDescriptors() { java.util.List v; org.apache.nifi.processors.standard.UpdateDatabaseTable v; v := @this: org.apache.nifi.processors.standard.UpdateDatabaseTable; v = ; return v; } public java.util.Set getRelationships() { java.util.Set v; org.apache.nifi.processors.standard.UpdateDatabaseTable v; v := @this: org.apache.nifi.processors.standard.UpdateDatabaseTable; v = ; return v; } protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext) { org.apache.nifi.processors.standard.UpdateDatabaseTable v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.components.PropertyValue v, v, v, v; java.util.Map v; boolean v, v, v, v; org.apache.nifi.components.ValidationResult$Builder v, v, v, v, v, v, v, v; java.util.Collection v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.ValidationContext v; java.util.ArrayList v; java.lang.Boolean v; java.lang.String v, v, v, v, v; org.apache.nifi.components.ValidationResult v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.UpdateDatabaseTable; v := @parameter: org.apache.nifi.components.ValidationContext; v = new java.util.ArrayList; v = specialinvoke v.(v); specialinvoke v.(java.util.Collection)>(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; if v == 0 goto label; v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.("Record Writer must be set if \'Update Field Names\' is true"); v = virtualinvoke v.(0); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = ; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.("The specified Database Type does not support Create If Not Exists"); v = virtualinvoke v.(0); v = virtualinvoke v.(); interfaceinvoke v.(v); label: return v; } 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.UpdateDatabaseTable v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.serialization.record.RecordSchema v; java.util.Map v, v; org.apache.nifi.components.AllowableValue v; java.lang.Exception v, v, v; java.util.stream.Stream v, v, v; org.apache.nifi.controller.ControllerService v, v, v; java.lang.Throwable v, v, v, v, v, v, v; java.lang.Object[] v, v, v, v; org.apache.nifi.provenance.ProvenanceReporter 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; org.apache.nifi.processor.ProcessSession v; java.sql.Connection v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.serialization.RecordReader v; org.apache.nifi.processors.standard.UpdateDatabaseTable$OutputMetadataHolder v; boolean v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v, v, v; java.util.function.Predicate v; org.apache.nifi.processor.io.StreamCallback v; java.lang.String[] v; java.util.HashMap v; org.apache.nifi.logging.ComponentLog v, v, v, v; java.util.function.Function v; org.apache.nifi.processor.exception.ProcessException v, v, v, v; java.util.HashSet v, v; java.lang.Boolean v, v, v, v; org.apache.nifi.processor.ProcessContext v; java.util.function.Consumer v; java.lang.Class v, v, v, v, v; java.lang.Object v; java.io.InputStream v; v := @this: org.apache.nifi.processors.standard.UpdateDatabaseTable; 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.(class "Lorg/apache/nifi/serialization/RecordReaderFactory;"); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(class "Lorg/apache/nifi/serialization/RecordSetWriterFactory;"); 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 = virtualinvoke v.(); label: v = interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Unable to create RecordReader", v); throw v; label: if v == null goto label; virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = newarray (java.lang.Object)[2]; v = class "Lorg/apache/nifi/serialization/RecordReader;"; v = virtualinvoke v.(); v[0] = v; v[1] = v; interfaceinvoke v.("Failed to create {} for {} - routing to failure", v, v); v = virtualinvoke v.(); if v == null goto label; v = v; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u Thrown"); label: interfaceinvoke v.(v, "record.error.message", v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u Thrown"); interfaceinvoke v.(v, "record.error.message", v); label: v = ; interfaceinvoke v.(v, v); label: return; label: v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke 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.(); if v != null goto label; if v == 0 goto label; v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.String)>("Record Writer must be set if \'Update Field Names\' is true"); throw v; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(class "Lorg/apache/nifi/dbcp/DBCPService;"); v = ; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = new java.util.HashMap; v = interfaceinvoke v.(); specialinvoke v.(java.util.Map)>(v); if v == 0 goto label; if v == null goto label; v = new java.util.HashSet; specialinvoke v.()>(); v = v; v = virtualinvoke v.(","); v = staticinvoke (v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); goto label; label: v = null; label: v = specialinvoke v.(v, v, v, v, v, v, v, v, v, v, v, v); if v == null goto label; label: 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[1] = v; interfaceinvoke v.("Failed to process {}; will route to failure", v); v = virtualinvoke v.(); if v == null goto label; v = v; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u Thrown"); label: interfaceinvoke v.(v, "record.error.message", v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u Thrown"); interfaceinvoke v.(v, "record.error.message", v); label: v = ; interfaceinvoke v.(v, v); label: if v == null goto label; interfaceinvoke v.(); label: return; label: interfaceinvoke v.("output.table", v); v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = specialinvoke v.(v); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, v); label: if v == null goto label; interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = interfaceinvoke v.(v, "output.table", v); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Exception while processing {} - routing to failure", v, v); v = ; interfaceinvoke v.(v, v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Discontinued processing for {} due to {}", v, v); v = ; interfaceinvoke v.(v, v); goto label; label: v := @caughtexception; v = v instanceof org.apache.nifi.processor.exception.ProcessException; if v != 0 goto label; v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.Throwable)>(v); label: throw v; label: return; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; catch org.apache.nifi.processor.exception.ProcessException from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; catch java.sql.SQLException from label to label with label; catch java.io.IOException from label to label with label; catch java.sql.SQLException from label to label with label; catch java.io.IOException from label to label with label; catch java.sql.SQLException from label to label with label; catch org.apache.nifi.processor.util.pattern.DiscontinuedException from label to label with label; catch org.apache.nifi.processor.util.pattern.DiscontinuedException from label to label with label; catch org.apache.nifi.processor.util.pattern.DiscontinuedException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private synchronized org.apache.nifi.processors.standard.UpdateDatabaseTable$OutputMetadataHolder checkAndUpdateTableSchema(java.sql.Connection, org.apache.nifi.processors.standard.db.DatabaseAdapter, org.apache.nifi.serialization.record.RecordSchema, java.lang.String, java.lang.String, java.lang.String, boolean, boolean, boolean, java.util.Set, boolean, boolean) throws java.io.IOException { org.apache.nifi.serialization.record.DataType v, v, v; org.apache.nifi.processors.standard.UpdateDatabaseTable v; org.apache.nifi.serialization.record.RecordSchema v; org.apache.nifi.processors.standard.db.ColumnDescription v, v; java.util.Set v; org.apache.nifi.serialization.SimpleRecordSchema v; java.lang.Exception v; java.lang.Throwable v; java.util.ArrayList v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.db.DatabaseAdapter v; org.apache.nifi.serialization.record.RecordField v; java.io.IOException v, v; java.sql.Statement v; java.sql.Connection v; org.apache.nifi.processors.standard.UpdateDatabaseTable$OutputMetadataHolder v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.List v, v, v, v, v; org.apache.nifi.processors.standard.db.TableSchema v, v; org.apache.nifi.processors.standard.db.TableNotFoundException v; java.util.HashMap v; org.apache.nifi.logging.ComponentLog v, v, v, v, v; int v, v; java.util.Iterator v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.UpdateDatabaseTable; v := @parameter: java.sql.Connection; v := @parameter: org.apache.nifi.processors.standard.db.DatabaseAdapter; v := @parameter: org.apache.nifi.serialization.record.RecordSchema; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: java.util.Set; v := @parameter: boolean; v := @parameter: boolean; label: v = interfaceinvoke v.(); label: v = null; label: v = virtualinvoke v.(); v = staticinvoke (v, v, v, v, v, null, v); label: goto label; label: v := @caughtexception; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = 0; if v != null goto label; if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = 1; goto label; label: v = 0; label: v = new org.apache.nifi.processors.standard.db.ColumnDescription; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,int,boolean,java.lang.Integer,boolean)>(v, v, v, null, v); interfaceinvoke v.(v); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Adding column \u to table \u0001"); interfaceinvoke v.(v); goto label; label: v = new org.apache.nifi.processors.standard.db.TableSchema; v = interfaceinvoke v.(); specialinvoke v.(java.lang.String,java.util.List,boolean,java.util.Set,java.lang.String)>(v, v, v, v, v); v = v; v = interfaceinvoke v.(v, v, v); v = staticinvoke (v); if v == 0 goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Executing DDL: \u0001"); interfaceinvoke v.(v); interfaceinvoke v.(v); label: v = 1; goto label; label: v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("The table \u could not be found in the database and the processor is configured not to create it."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); interfaceinvoke v.(v); goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); if v != 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke 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 != 0 goto label; v = new org.apache.nifi.processors.standard.db.ColumnDescription; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); if v == null goto label; v = 1; goto label; label: v = 0; label: v = virtualinvoke v.(); specialinvoke v.(java.lang.String,int,boolean,java.lang.Integer,boolean)>(v, v, v, null, v); interfaceinvoke v.(v); interfaceinvoke v.(v); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Adding column \u to table \u0001"); interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(v, v, v, v); if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Executing DDL: \u0001"); interfaceinvoke v.(v); interfaceinvoke v.(v); goto label; label: if v == 0 goto label; v = interfaceinvoke v.(); v = new java.util.ArrayList; specialinvoke v.()>(); v = new java.util.HashMap; specialinvoke v.()>(); v = 0; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = 0; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(v); if v != 0 goto label; v = 1; label: interfaceinvoke v.(v, v); v = new org.apache.nifi.serialization.record.RecordField; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,org.apache.nifi.serialization.record.DataType,java.lang.Object,boolean)>(v, v, v, v); interfaceinvoke v.(v); v = 1; label: if v != 0 goto label; interfaceinvoke v.(v, v); goto label; label: if v == 0 goto label; v = new org.apache.nifi.processors.standard.UpdateDatabaseTable$OutputMetadataHolder; v = v; v = new org.apache.nifi.serialization.SimpleRecordSchema; specialinvoke v.(java.util.List)>(v); specialinvoke v.(org.apache.nifi.serialization.record.RecordSchema,java.util.Map)>(v, v); goto label; label: v = null; label: v = v; goto label; label: v = null; label: v = v; label: if v == null goto label; interfaceinvoke v.(); label: return v; label: v := @caughtexception; throw v; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.Throwable)>(v); throw v; catch org.apache.nifi.processors.standard.db.TableNotFoundException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; } private synchronized org.apache.nifi.serialization.WriteResult updateRecords(org.apache.nifi.serialization.record.RecordSchema, org.apache.nifi.processors.standard.UpdateDatabaseTable$OutputMetadataHolder, org.apache.nifi.serialization.RecordReader, org.apache.nifi.serialization.RecordSetWriter) throws java.io.IOException { java.lang.Throwable v; java.util.HashMap v; org.apache.nifi.processors.standard.UpdateDatabaseTable v; org.apache.nifi.serialization.record.RecordSchema v, v; org.apache.nifi.serialization.RecordReader v; java.util.Map v; int v; java.lang.String v, v; org.apache.nifi.processors.standard.UpdateDatabaseTable$OutputMetadataHolder v; org.apache.nifi.serialization.record.Record v; boolean v; org.apache.nifi.serialization.record.MapRecord v; java.util.Iterator v; org.apache.nifi.serialization.WriteResult v; java.util.Set v; java.io.IOException v; java.util.List v; java.lang.Object v, v, v, v; org.apache.nifi.serialization.RecordSetWriter v; v := @this: org.apache.nifi.processors.standard.UpdateDatabaseTable; v := @parameter: org.apache.nifi.serialization.record.RecordSchema; v := @parameter: org.apache.nifi.processors.standard.UpdateDatabaseTable$OutputMetadataHolder; v := @parameter: org.apache.nifi.serialization.RecordReader; v := @parameter: org.apache.nifi.serialization.RecordSetWriter; label: interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); v = new java.util.HashMap; v = interfaceinvoke v.(); specialinvoke v.(int)>(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(v); interfaceinvoke v.(v, v); goto label; label: v = new org.apache.nifi.serialization.record.MapRecord; v = virtualinvoke v.(); specialinvoke v.(org.apache.nifi.serialization.record.RecordSchema,java.util.Map)>(v, v); interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); label: return v; label: v := @caughtexception; v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Error reading records: \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; catch org.apache.nifi.serialization.MalformedRecordException from label to label with label; } private java.lang.String getJdbcUrl(java.sql.Connection) { java.sql.Connection v; java.sql.DatabaseMetaData v; java.lang.String v; org.apache.nifi.processors.standard.UpdateDatabaseTable v; org.apache.nifi.logging.ComponentLog v; java.lang.Exception v; v := @this: org.apache.nifi.processors.standard.UpdateDatabaseTable; v := @parameter: java.sql.Connection; label: v = interfaceinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); label: return v; label: v := @caughtexception; v = virtualinvoke v.(); interfaceinvoke v.("Could not determine JDBC URL based on the Driver Connection.", v); label: return "DBCPService"; catch java.lang.Exception from label to label with label; } static void () { org.apache.nifi.components.AllowableValue v, v, v, v, v, v; java.lang.Object[] v; org.apache.nifi.processor.Relationship v, v, v, v; java.util.ServiceLoader v; org.apache.nifi.expression.ExpressionLanguageScope v, v, v, v, v; java.util.HashSet v; java.util.function.Consumer v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Set v; java.util.ArrayList v, v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.List v; org.apache.nifi.components.AllowableValue[] v, v, v; java.lang.String[] v, v, v, v, v; java.util.HashMap v; org.apache.nifi.components.Validator v, v, v, v, v, v; org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Create If Not Exists", "Create If Not Exists", "Create a table with the given schema if it does not already exist"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Fail If Not Exists", "Fail If Not Exists", "If the target does not already exist, log an error and route the flowfile to failure"); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("record-reader"); v = virtualinvoke v.("Record Reader"); v = virtualinvoke v.("The service for reading incoming flow files. The reader is only used to determine the schema of the records, the actual records will not be processed."); v = virtualinvoke v.(class "Lorg/apache/nifi/serialization/RecordReaderFactory;"); v = virtualinvoke v.(1); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("updatedatabasetable-dbcp-service"); v = virtualinvoke v.("Database Connection Pooling Service"); v = virtualinvoke v.("The Controller Service that is used to obtain connection(s) to the database"); v = virtualinvoke v.(1); v = virtualinvoke v.(class "Lorg/apache/nifi/dbcp/DBCPService;"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("updatedatabasetable-catalog-name"); v = virtualinvoke v.("Catalog Name"); v = virtualinvoke v.("The name of the catalog that the statement should update. This may not apply for the database that you are updating. In this case, leave the field empty. Note that if the property is set and the database is case-sensitive, the catalog name must match the database\'s catalog name exactly."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("updatedatabasetable-schema-name"); v = virtualinvoke v.("Schema Name"); v = virtualinvoke v.("The name of the database schema that the table belongs to. This may not apply for the database that you are updating. In this case, leave the field empty. Note that if the property is set and the database is case-sensitive, the schema name must match the database\'s schema name exactly."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("updatedatabasetable-table-name"); v = virtualinvoke v.("Table Name"); v = virtualinvoke v.("The name of the database table to update. If the table does not exist, then it will either be created or an error thrown, depending on the value of the Create Table property."); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("updatedatabasetable-create-table"); v = virtualinvoke v.("Create Table Strategy"); v = virtualinvoke v.("Specifies how to process the target table when it does not exist (create it, fail, e.g.)."); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = newarray (org.apache.nifi.components.AllowableValue)[2]; v = ; v[0] = v; v = ; v[1] = v; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("updatedatabasetable-primary-keys"); v = virtualinvoke v.("Primary Key Fields"); v = virtualinvoke v.("A comma-separated list of record field names that uniquely identifies a row in the database. This property is only used if the specified table needs to be created, in which case the Primary Key Fields will be used to specify the primary keys of the newly-created table. IMPORTANT: Primary Key Fields must match the record field names exactly unless \'Quote Column Identifiers\' is false and the database allows for case-insensitive column names. In practice it is best to specify Primary Key Fields that exactly match the record field names, and those will become the column names in the created table."); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[1]; v = ; v[0] = v; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("updatedatabasetable-translate-field-names"); v = virtualinvoke v.("Translate Field Names"); v = virtualinvoke v.("If true, the Processor will attempt to translate field names into the corresponding column names for the table specified, for the purposes of determining whether the field name exists as a column in the target table. NOTE: If the target table does not exist and is to be created, this property is ignored and the field names will be used as-is. If false, the field names must match the column names exactly, or the column may not be found and instead an error my be reported that the column already exists."); v = virtualinvoke v.(1); v = newarray (java.lang.String)[2]; v[0] = "true"; v[1] = "false"; v = virtualinvoke v.(v); v = virtualinvoke v.("true"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("updatedatabasetable-update-field-names"); v = virtualinvoke v.("Update Field Names"); v = virtualinvoke v.("This property indicates whether to update the output schema such that the field names are set to the exact column names from the specified table. This should be used if the incoming record field names may not match the table\'s column names in terms of upper- and lower-case. For example, this property should be set to true if the output FlowFile is destined for Oracle e.g., which expects the field names to match the column names exactly. NOTE: The value of the \'Translate Field Names\' property is ignored when updating field names; instead they are updated to match the column name as returned by the database."); v = newarray (java.lang.String)[2]; v[0] = "true"; v[1] = "false"; v = virtualinvoke v.(v); v = virtualinvoke v.("false"); v = virtualinvoke v.(1); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("updatedatabasetable-record-writer"); v = virtualinvoke v.("Record Writer"); v = virtualinvoke v.("Specifies the Controller Service to use for writing results to a FlowFile. The Record Writer should use Inherit Schema to emulate the inferred schema behavior, i.e. an explicit schema need not be defined in the writer, and will be supplied by the same logic used to infer the schema from the column types. If Create Table Strategy is set \'Create If Not Exists\', the Record Writer\'s output format must match the Record Reader\'s format in order for the data to be placed in the created table location. Note that this property is only used if \'Update Field Names\' is set to true and the field names do not all match the column names exactly. If no update is needed for any field names (or \'Update Field Names\' is false), the Record Writer is not used and instead the input FlowFile is routed to success or failure without modification."); v = virtualinvoke v.(class "Lorg/apache/nifi/serialization/RecordSetWriterFactory;"); v = ; v = newarray (java.lang.String)[0]; v = virtualinvoke v.(v, "true", v); v = virtualinvoke v.(1); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.