public class org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy extends java.lang.Object implements org.apache.nifi.processors.standard.enrichment.RecordJoinStrategy
{
private final org.apache.nifi.processors.standard.enrichment.SqlJoinCache cache;
private final org.apache.nifi.logging.ComponentLog logger;
private final java.lang.String sql;
private final int defaultPrecision;
private final int defaultScale;
public void <init>(org.apache.nifi.processors.standard.enrichment.SqlJoinCache, java.lang.String, org.apache.nifi.logging.ComponentLog, int, int)
{
org.apache.nifi.processors.standard.enrichment.SqlJoinCache v;
int v, v;
org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy v;
java.lang.String v;
org.apache.nifi.logging.ComponentLog v;
v := @this: org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy;
v := @parameter: org.apache.nifi.processors.standard.enrichment.SqlJoinCache;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.logging.ComponentLog;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy: org.apache.nifi.processors.standard.enrichment.SqlJoinCache cache> = v;
v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy: java.lang.String sql> = v;
v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy: org.apache.nifi.logging.ComponentLog logger> = v;
v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy: int defaultPrecision> = v;
v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy: int defaultScale> = v;
return;
}
public org.apache.nifi.processors.standard.enrichment.RecordJoinResult join(org.apache.nifi.processors.standard.enrichment.RecordJoinInput, org.apache.nifi.processors.standard.enrichment.RecordJoinInput, org.apache.nifi.processor.ProcessSession, org.apache.nifi.serialization.record.RecordSchema) throws java.sql.SQLException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.enrichment.SqlJoinCache v;
org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy$1 v;
org.apache.nifi.serialization.record.RecordSchema v;
java.sql.ResultSet v;
int v, v;
org.apache.nifi.processors.standard.enrichment.RecordJoinInput v, v;
java.lang.String v;
org.apache.nifi.serialization.record.ResultSetRecordSet v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy v;
org.apache.nifi.processor.ProcessSession v;
java.sql.PreparedStatement v;
org.apache.nifi.queryrecord.FlowFileTable v, v;
org.apache.nifi.processors.standard.enrichment.SqlJoinCalciteParameters v;
v := @this: org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy;
v := @parameter: org.apache.nifi.processors.standard.enrichment.RecordJoinInput;
v := @parameter: org.apache.nifi.processors.standard.enrichment.RecordJoinInput;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v := @parameter: org.apache.nifi.serialization.record.RecordSchema;
v = v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy: org.apache.nifi.processors.standard.enrichment.SqlJoinCache cache>;
v = v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy: java.lang.String sql>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.SqlJoinCache: org.apache.nifi.processors.standard.enrichment.SqlJoinCalciteParameters getCalciteParameters(java.lang.String,org.apache.nifi.processor.ProcessSession,org.apache.nifi.serialization.record.RecordSchema,org.apache.nifi.processors.standard.enrichment.RecordJoinInput,org.apache.nifi.processors.standard.enrichment.RecordJoinInput)>(v, v, v, v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.SqlJoinCalciteParameters: org.apache.nifi.queryrecord.FlowFileTable getOriginalTable()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.SqlJoinCalciteParameters: org.apache.nifi.queryrecord.FlowFileTable getEnrichmentTable()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.RecordJoinInput: org.apache.nifi.flowfile.FlowFile getFlowFile()>();
virtualinvoke v.<org.apache.nifi.queryrecord.FlowFileTable: void setFlowFile(org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.RecordJoinInput: org.apache.nifi.flowfile.FlowFile getFlowFile()>();
virtualinvoke v.<org.apache.nifi.queryrecord.FlowFileTable: void setFlowFile(org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.SqlJoinCalciteParameters: java.sql.PreparedStatement getPreparedStatement()>();
label:
v = interfaceinvoke v.<java.sql.PreparedStatement: java.sql.ResultSet executeQuery()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.nifi.queryrecord.FlowFileTable: void close()>();
virtualinvoke v.<org.apache.nifi.queryrecord.FlowFileTable: void close()>();
throw v;
label:
v = new org.apache.nifi.serialization.record.ResultSetRecordSet;
v = v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy: int defaultPrecision>;
v = v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy: int defaultScale>;
specialinvoke v.<org.apache.nifi.serialization.record.ResultSetRecordSet: void <init>(java.sql.ResultSet,org.apache.nifi.serialization.record.RecordSchema,int,int,boolean)>(v, v, v, v, 1);
v = new org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy$1;
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy$1: void <init>(org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy,org.apache.nifi.queryrecord.FlowFileTable,org.apache.nifi.queryrecord.FlowFileTable,org.apache.nifi.serialization.record.RecordSchema,org.apache.nifi.processors.standard.enrichment.SqlJoinCalciteParameters,org.apache.nifi.serialization.record.RecordSet)>(v, v, v, v, v, v);
return v;
catch java.lang.Throwable from label to label with label;
}
private transient void closeQuietly(java.lang.AutoCloseable[])
{
java.lang.AutoCloseable[] v;
int v, v;
org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy v;
java.lang.AutoCloseable v;
v := @this: org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy;
v := @parameter: java.lang.AutoCloseable[];
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy: void closeQuietly(java.lang.AutoCloseable)>(v);
v = v + 1;
goto label;
label:
return;
}
private void closeQuietly(java.lang.AutoCloseable)
{
org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy v;
java.lang.AutoCloseable v;
v := @this: org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy;
v := @parameter: java.lang.AutoCloseable;
return;
}
}