public abstract class org.apache.nifi.processors.standard.AbstractExecuteSQL extends org.apache.nifi.processor.AbstractProcessor { public static final java.lang.String RESULT_ROW_COUNT; public static final java.lang.String RESULT_QUERY_DURATION; public static final java.lang.String RESULT_QUERY_EXECUTION_TIME; public static final java.lang.String RESULT_QUERY_FETCH_TIME; public static final java.lang.String RESULTSET_INDEX; public static final java.lang.String RESULT_ERROR_MESSAGE; public static final java.lang.String INPUT_FLOWFILE_UUID; public static final java.lang.String FRAGMENT_ID; public static final java.lang.String FRAGMENT_INDEX; public static final java.lang.String FRAGMENT_COUNT; public static final org.apache.nifi.processor.Relationship REL_SUCCESS; public static final org.apache.nifi.processor.Relationship REL_FAILURE; protected java.util.Set relationships; public static final org.apache.nifi.components.PropertyDescriptor DBCP_SERVICE; public static final org.apache.nifi.components.PropertyDescriptor SQL_PRE_QUERY; public static final org.apache.nifi.components.PropertyDescriptor SQL_SELECT_QUERY; public static final org.apache.nifi.components.PropertyDescriptor SQL_POST_QUERY; public static final org.apache.nifi.components.PropertyDescriptor QUERY_TIMEOUT; public static final org.apache.nifi.components.PropertyDescriptor MAX_ROWS_PER_FLOW_FILE; public static final org.apache.nifi.components.PropertyDescriptor OUTPUT_BATCH_SIZE; public static final org.apache.nifi.components.PropertyDescriptor FETCH_SIZE; public static final org.apache.nifi.components.PropertyDescriptor AUTO_COMMIT; protected java.util.List propDescriptors; protected org.apache.nifi.dbcp.DBCPService dbcpService; public void () { org.apache.nifi.processors.standard.AbstractExecuteSQL v; v := @this: org.apache.nifi.processors.standard.AbstractExecuteSQL; specialinvoke v.()>(); return; } public java.util.Set getRelationships() { java.util.Set v; org.apache.nifi.processors.standard.AbstractExecuteSQL v; v := @this: org.apache.nifi.processors.standard.AbstractExecuteSQL; v = v.; return v; } protected java.util.List getSupportedPropertyDescriptors() { org.apache.nifi.processors.standard.AbstractExecuteSQL v; java.util.List v; v := @this: org.apache.nifi.processors.standard.AbstractExecuteSQL; v = v.; return v; } public void setup(org.apache.nifi.processor.ProcessContext) { org.apache.nifi.processor.ProcessContext v; org.apache.nifi.logging.ComponentLog v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.exception.ProcessException v; org.apache.nifi.components.PropertyValue v, v; org.apache.nifi.processors.standard.AbstractExecuteSQL v; org.apache.nifi.controller.ControllerService v; boolean v, v; v := @this: org.apache.nifi.processors.standard.AbstractExecuteSQL; v := @parameter: org.apache.nifi.processor.ProcessContext; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.("Either the Select Query must be specified or there must be an incoming connection providing flowfile(s) containing a SQL select query"); v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.String)>("Either the Select Query must be specified or there must be an incoming connection providing flowfile(s) containing a SQL select query"); throw v; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(class "Lorg/apache/nifi/dbcp/DBCPService;"); v. = v; return; } public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException { java.sql.SQLFeatureNotSupportedException v; java.lang.Integer v, v, v; byte v, v; org.apache.commons.lang.tuple.Pair v, v; java.lang.Long v, v; java.util.Map v, v, v, v, v, v; java.util.stream.Collector v; java.sql.PreparedStatement v; java.util.stream.Stream v, v; org.apache.nifi.util.StopWatch v, v; java.lang.StringBuilder v; org.apache.nifi.dbcp.DBCPService v; java.lang.Object[] v, v, v, v, v, v, v; long v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v; org.apache.nifi.processor.ProcessSession v; java.util.concurrent.atomic.AtomicLong v; org.apache.nifi.flowfile.attributes.CoreAttributes 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; org.apache.nifi.processors.standard.sql.SqlWriter v; java.util.UUID v; org.apache.nifi.util.db.SensitiveValueWrapper v; java.util.function.Function v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Boolean v, v; java.util.function.Consumer v; java.lang.Object v, v, v, v, v, v, v, v; org.apache.nifi.processor.io.OutputStreamCallback v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v; java.sql.ResultSet v; java.util.Set v, v; java.lang.Exception v; java.lang.Throwable v, v, v; java.util.ArrayList v; java.sql.SQLException v, v, v; org.apache.nifi.provenance.ProvenanceReporter 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; org.apache.nifi.processors.standard.AbstractExecuteSQL v; org.apache.nifi.processor.io.InputStreamCallback v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v, v, v, v, v; java.util.function.Predicate v; java.util.List v, v; java.util.HashMap v; org.apache.nifi.logging.ComponentLog v; org.apache.nifi.processor.exception.ProcessException v, v, v; java.util.Iterator v; org.apache.nifi.processor.ProcessContext v; java.util.concurrent.TimeUnit v, v, v; v := @this: org.apache.nifi.processors.standard.AbstractExecuteSQL; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v = null; v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v != null goto label; v = interfaceinvoke v.(); if v == 0 goto label; return; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke 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.(); if v != null goto label; v = 0; goto label; label: v = virtualinvoke v.(); label: v = 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.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v, v, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); goto label; label: v = new java.lang.StringBuilder; specialinvoke v.()>(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = virtualinvoke v.(); label: v = 0; label: v = v.; if v != null goto label; v = staticinvoke (); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(v); label: v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == v goto label; label: interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = newarray (java.lang.Object)[1]; v = staticinvoke (v); v[0] = v; interfaceinvoke v.("setAutoCommit({}) not supported by this driver", v); label: v = interfaceinvoke v.(v); label: if v == null goto label; v = virtualinvoke v.(); if v <= 0 goto label; label: v = virtualinvoke v.(); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v[2] = v; interfaceinvoke v.("Cannot set fetch size to {} due to {}", v); label: interfaceinvoke v.(v); v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); throw v; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = staticinvoke (); v = staticinvoke (v, v); v = interfaceinvoke v.(v); if v == null goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = new org.apache.nifi.util.db.SensitiveValueWrapper; v = interfaceinvoke v.(); specialinvoke v.(java.lang.String,boolean)>(v, 0); interfaceinvoke v.(v, v); goto label; label: v = interfaceinvoke v.(); if v != 0 goto label; staticinvoke (v, v); label: v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Executing query {}", v); v = 0; v = staticinvoke (); v = virtualinvoke v.(); v = new org.apache.nifi.util.StopWatch; specialinvoke v.(boolean)>(1); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = (int) -1; if v == v goto label; v = 1; goto label; label: v = 0; label: v = v; if v != null goto label; v = null; goto label; label: v = interfaceinvoke v.(); label: v = v; if v != null goto label; v = null; goto label; label: v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v); label: v = v; label: if v != 0 goto label; if v == 0 goto label; label: if v == 0 goto label; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.(long)>(0L); label: v = interfaceinvoke v.(); label: v = new org.apache.nifi.util.StopWatch; specialinvoke v.(boolean)>(1); if v != null goto label; v = interfaceinvoke v.(); goto label; label: v = interfaceinvoke v.(v); label: v = staticinvoke (v, v, v, v); v = interfaceinvoke v.(v, v); v = virtualinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); v = v cmp 0L; if v != 0 goto label; if v <= 0 goto label; interfaceinvoke v.(v); label: goto label; label: v = ; v = virtualinvoke v.(v); v = new java.util.HashMap; specialinvoke v.()>(); if v == null goto label; interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("executesql.row.count", v); v = v + v; v = staticinvoke (v); interfaceinvoke v.("executesql.query.duration", v); v = staticinvoke (v); interfaceinvoke v.("executesql.query.executiontime", v); v = staticinvoke (v); interfaceinvoke v.("executesql.query.fetchtime", v); v = staticinvoke (v); interfaceinvoke v.("executesql.resultset.index", v); if v == null goto label; interfaceinvoke v.("input.flowfile.uuid", v); label: v = virtualinvoke v.(); if v <= 0 goto label; v = ; interfaceinvoke v.(v, v); v = ; v = staticinvoke (v); interfaceinvoke v.(v, v); label: v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(v, v); interfaceinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[1] = v; interfaceinvoke v.("{} contains {} records; transferring to \'success\'", v); v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Retrieved \u rows"); v = v + v; interfaceinvoke v.(v, v, v); goto label; label: v = interfaceinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Retrieved \u rows"); v = v + v; interfaceinvoke v.(v, v, v); label: interfaceinvoke v.(v); if v <= 0 goto label; v = interfaceinvoke v.(); if v < v goto label; v = ; interfaceinvoke v.(v, v); if v == null goto label; interfaceinvoke v.(v); v = null; label: interfaceinvoke v.(); interfaceinvoke v.(); label: v = v + 1; label: goto label; label: v := @caughtexception; interfaceinvoke v.(v); interfaceinvoke v.(v); v = v instanceof org.apache.nifi.processor.exception.ProcessException; if v == 0 goto label; throw v; label: v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = virtualinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; label: if v != 0 goto label; v = virtualinvoke v.(); if v <= 0 goto label; v = 0; label: v = interfaceinvoke v.(); if v >= v goto label; v = interfaceinvoke v.(v); v = ; v = staticinvoke (v); v = interfaceinvoke v.(v, v, v); interfaceinvoke v.(v, v); v = v + 1; goto label; label: v := @caughtexception; v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = v + 1; label: v = interfaceinvoke v.(1); v = interfaceinvoke v.(); v = (int) -1; if v == v goto label; v = 1; goto label; label: v = 0; label: v = v; label: goto label; label: v := @caughtexception; v = 0; v = 0; goto label; label: v = virtualinvoke v.(v, v); if v == null goto label; virtualinvoke v.(); virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = virtualinvoke v.(); throw v; label: v = interfaceinvoke v.(); if v != 0 goto label; interfaceinvoke v.(); label: v = ; interfaceinvoke v.(v, v); interfaceinvoke v.(); if v == null goto label; if v <= 0 goto label; interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(v, v, v); v = ; interfaceinvoke v.(v, v); goto label; label: if v != 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v, v, v); v = ; interfaceinvoke v.(v, v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; if v != null goto label; v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Unable to execute SQL select query [{}]. No FlowFile to route to failure", v); interfaceinvoke v.(); goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Unable to execute SQL select query [{}] for {} routing to failure", v); v = interfaceinvoke v.(v); goto label; label: v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Unable to execute SQL select query [{}] routing to failure", v); interfaceinvoke v.(); label: v = virtualinvoke v.(); interfaceinvoke v.(v, "executesql.error.message", v); v = ; interfaceinvoke v.(v, v); label: return; catch java.sql.SQLFeatureNotSupportedException from label to label with label; catch java.sql.SQLException from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.sql.SQLException from label to label with label; catch java.sql.SQLException 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 org.apache.nifi.processor.exception.ProcessException from label to label with label; catch java.sql.SQLException from label to label with label; } protected org.apache.nifi.flowfile.FlowFile setFlowFileEmptyResults(org.apache.nifi.processor.ProcessSession, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processors.standard.sql.SqlWriter) { org.apache.nifi.processor.io.OutputStreamCallback v; org.apache.nifi.flowfile.FlowFile v, v, v; java.util.HashMap v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.processors.standard.AbstractExecuteSQL v; java.lang.String v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v; org.apache.nifi.processors.standard.sql.SqlWriter v; v := @this: org.apache.nifi.processors.standard.AbstractExecuteSQL; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: org.apache.nifi.processors.standard.sql.SqlWriter; v = staticinvoke (v, v); v = interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("executesql.row.count", "0"); v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(); interfaceinvoke v.(v, v); v = interfaceinvoke v.(v, v); return v; } protected org.apache.commons.lang.tuple.Pair executeConfigStatements(java.sql.Connection, java.util.List) { java.lang.Throwable v; java.sql.Connection v; java.util.Iterator v; org.apache.nifi.processors.standard.AbstractExecuteSQL v; java.sql.SQLException v; java.util.List v; org.apache.commons.lang.tuple.Pair v; java.sql.Statement v; java.lang.Object v; boolean v, v; v := @this: org.apache.nifi.processors.standard.AbstractExecuteSQL; v := @parameter: java.sql.Connection; v := @parameter: java.util.List; if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: return null; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); label: interfaceinvoke v.(v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = staticinvoke (v, v); return v; label: return null; catch java.lang.Throwable from label to label with label; catch java.sql.SQLException from label to label with label; } protected java.util.List getQueries(java.lang.String) { java.lang.String[] v; org.apache.nifi.processors.standard.AbstractExecuteSQL v; int v, v, v, v, v; java.lang.String v, v, v, v, v, v; java.util.LinkedList v; v := @this: org.apache.nifi.processors.standard.AbstractExecuteSQL; v := @parameter: java.lang.String; if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; label: return null; label: v = new java.util.LinkedList; specialinvoke v.()>(); v = virtualinvoke v.("(?= v goto label; v = v[v]; v = virtualinvoke v.("\\\\;", ";"); v = virtualinvoke v.(); v = virtualinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = v + 1; goto label; label: return v; } protected abstract org.apache.nifi.processors.standard.sql.SqlWriter configureSqlWriter(org.apache.nifi.processor.ProcessSession, org.apache.nifi.processor.ProcessContext, org.apache.nifi.flowfile.FlowFile); static void () { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.attributes.FragmentAttributes v, v, v; org.apache.nifi.processor.Relationship v, v; java.lang.String v, v, 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; org.apache.nifi.expression.ExpressionLanguageScope v, v, v, v, v, v, v; java.lang.String[] v; org.apache.nifi.components.Validator v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v; v = ; v = virtualinvoke v.(); = v; v = ; v = virtualinvoke v.(); = v; v = ; v = virtualinvoke v.(); = v; v = new org.apache.nifi.processor.Relationship$Builder; specialinvoke v.()>(); v = virtualinvoke v.("success"); v = virtualinvoke v.("Successfully created FlowFile from SQL query result set."); v = virtualinvoke v.(); = v; v = new org.apache.nifi.processor.Relationship$Builder; specialinvoke v.()>(); v = virtualinvoke v.("failure"); v = virtualinvoke v.("SQL query execution failed. Incoming FlowFile will be penalized and routed to this relationship"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Database Connection Pooling Service"); v = virtualinvoke v.("The Controller Service that is used to obtain connection to 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.("sql-pre-query"); v = virtualinvoke v.("SQL Pre-Query"); v = virtualinvoke v.("A semicolon-delimited list of queries executed before the main SQL query is executed. For example, set session properties before main query. It\'s possible to include semicolons in the statements themselves by escaping them with a backslash (\'\\;\'). Results/outputs from these queries will be suppressed if there are no errors."); 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.("SQL select query"); v = virtualinvoke v.("The SQL select query to execute. The query can be empty, a constant value, or built from attributes using Expression Language. If this property is specified, it will be used regardless of the content of incoming flowfiles. If this property is empty, the content of the incoming flow file is expected to contain a valid SQL select query, to be issued by the processor to the database. Note that Expression Language is not evaluated for flow file contents."); 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.("sql-post-query"); v = virtualinvoke v.("SQL Post-Query"); v = virtualinvoke v.("A semicolon-delimited list of queries executed after the main SQL query is executed. Example like setting session properties after main query. It\'s possible to include semicolons in the statements themselves by escaping them with a backslash (\'\\;\'). Results/outputs from these queries will be suppressed if there are no errors."); 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.("Max Wait Time"); v = virtualinvoke v.("The maximum amount of time allowed for a running SQL select query , zero means there is no limit. Max time less than 1 second will be equal to zero."); v = virtualinvoke v.("0 seconds"); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("esql-max-rows"); v = virtualinvoke v.("Max Rows Per Flow File"); v = virtualinvoke v.("The maximum number of result rows that will be included in a single FlowFile. This will allow you to break up very large result sets into multiple FlowFiles. If the value specified is zero, then all rows are returned in a single FlowFile."); v = virtualinvoke v.("0"); 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.("esql-output-batch-size"); v = virtualinvoke v.("Output Batch Size"); v = virtualinvoke v.("The number of output FlowFiles to queue before committing the process session. When set to zero, the session will be committed when all result set rows have been processed and the output FlowFiles are ready for transfer to the downstream relationship. For large result sets, this can cause a large burst of FlowFiles to be transferred at the end of processor execution. If this property is set, then when the specified number of FlowFiles are ready for transfer, then the session will be committed, thus releasing the FlowFiles to the downstream relationship. NOTE: The fragment.count attribute will not be set on FlowFiles when this property is set."); v = virtualinvoke v.("0"); 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.("esql-fetch-size"); v = virtualinvoke v.("Fetch Size"); v = virtualinvoke v.("The number of result rows to be fetched from the result set at a time. This is a hint to the database driver and may not be honored and/or exact. If the value specified is zero, then the hint is ignored."); v = virtualinvoke v.("0"); 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.("esql-auto-commit"); v = virtualinvoke v.("Set Auto Commit"); v = virtualinvoke v.("Enables or disables the auto commit functionality of the DB connection. Default value is \'true\'. The default value can be used with most of the JDBC drivers and this functionality doesn\'t have any impact in most of the cases since this processor is used to read data. However, for some JDBC drivers such as PostgreSQL driver, it is required to disable the auto committing functionality to limit the number of result rows fetching at a time. When auto commit is enabled, postgreSQL driver loads whole result set to memory at once. This could lead for a large amount of memory usage when executing queries which fetch large data sets. More Details of this behaviour in PostgreSQL driver can be found in https://jdbc.postgresql.org//documentation/head/query.html. "); v = newarray (java.lang.String)[2]; v[0] = "true"; v[1] = "false"; v = virtualinvoke v.(v); v = virtualinvoke v.("true"); v = virtualinvoke v.(1); v = virtualinvoke v.(); = v; return; } }