public class org.apache.nifi.processors.standard.db.TableSchema extends java.lang.Object
{
private final java.util.List requiredColumnNames;
private final java.util.Set primaryKeyColumnNames;
private final java.util.Map columns;
private final java.lang.String quotedIdentifierString;
private final java.lang.String catalogName;
private final java.lang.String schemaName;
private final java.lang.String tableName;
public void <init>(java.lang.String, java.lang.String, java.lang.String, java.util.List, boolean, java.util.Set, java.lang.String)
{
java.util.ArrayList v;
java.util.LinkedHashMap v;
java.util.Map v;
java.lang.String v, v, v, v, v, v, v;
boolean v, v, v;
java.util.Iterator v;
java.util.Set v;
java.util.List v, v;
org.apache.nifi.processors.standard.db.TableSchema v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.db.TableSchema;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v := @parameter: boolean;
v := @parameter: java.util.Set;
v := @parameter: java.lang.String;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.nifi.processors.standard.db.TableSchema: java.lang.String catalogName> = v;
v.<org.apache.nifi.processors.standard.db.TableSchema: java.lang.String schemaName> = v;
v.<org.apache.nifi.processors.standard.db.TableSchema: java.lang.String tableName> = v;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v.<org.apache.nifi.processors.standard.db.TableSchema: java.util.Map columns> = v;
v.<org.apache.nifi.processors.standard.db.TableSchema: java.util.Set primaryKeyColumnNames> = v;
v.<org.apache.nifi.processors.standard.db.TableSchema: java.lang.String quotedIdentifierString> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.nifi.processors.standard.db.TableSchema: java.util.List requiredColumnNames> = 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()>();
v = v.<org.apache.nifi.processors.standard.db.TableSchema: java.util.Map columns>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.db.ColumnDescription: java.lang.String getColumnName()>();
v = staticinvoke <org.apache.nifi.processors.standard.db.ColumnDescription: java.lang.String normalizeColumnName(java.lang.String,boolean)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.db.ColumnDescription: boolean isRequired()>();
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.db.TableSchema: java.util.List requiredColumnNames>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.db.ColumnDescription: java.lang.String getColumnName()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return;
}
public java.lang.String getCatalogName()
{
java.lang.String v;
org.apache.nifi.processors.standard.db.TableSchema v;
v := @this: org.apache.nifi.processors.standard.db.TableSchema;
v = v.<org.apache.nifi.processors.standard.db.TableSchema: java.lang.String catalogName>;
return v;
}
public java.lang.String getSchemaName()
{
java.lang.String v;
org.apache.nifi.processors.standard.db.TableSchema v;
v := @this: org.apache.nifi.processors.standard.db.TableSchema;
v = v.<org.apache.nifi.processors.standard.db.TableSchema: java.lang.String schemaName>;
return v;
}
public java.lang.String getTableName()
{
java.lang.String v;
org.apache.nifi.processors.standard.db.TableSchema v;
v := @this: org.apache.nifi.processors.standard.db.TableSchema;
v = v.<org.apache.nifi.processors.standard.db.TableSchema: java.lang.String tableName>;
return v;
}
public java.util.Map getColumns()
{
org.apache.nifi.processors.standard.db.TableSchema v;
java.util.Map v;
v := @this: org.apache.nifi.processors.standard.db.TableSchema;
v = v.<org.apache.nifi.processors.standard.db.TableSchema: java.util.Map columns>;
return v;
}
public java.util.List getColumnsAsList()
{
org.apache.nifi.processors.standard.db.TableSchema v;
java.util.Collection v;
java.util.Map v;
java.util.ArrayList v;
v := @this: org.apache.nifi.processors.standard.db.TableSchema;
v = new java.util.ArrayList;
v = v.<org.apache.nifi.processors.standard.db.TableSchema: java.util.Map columns>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
return v;
}
public java.util.List getRequiredColumnNames()
{
java.util.List v;
org.apache.nifi.processors.standard.db.TableSchema v;
v := @this: org.apache.nifi.processors.standard.db.TableSchema;
v = v.<org.apache.nifi.processors.standard.db.TableSchema: java.util.List requiredColumnNames>;
return v;
}
public java.util.Set getPrimaryKeyColumnNames()
{
java.util.Set v;
org.apache.nifi.processors.standard.db.TableSchema v;
v := @this: org.apache.nifi.processors.standard.db.TableSchema;
v = v.<org.apache.nifi.processors.standard.db.TableSchema: java.util.Set primaryKeyColumnNames>;
return v;
}
public java.lang.String getQuotedIdentifierString()
{
java.lang.String v;
org.apache.nifi.processors.standard.db.TableSchema v;
v := @this: org.apache.nifi.processors.standard.db.TableSchema;
v = v.<org.apache.nifi.processors.standard.db.TableSchema: java.lang.String quotedIdentifierString>;
return v;
}
public static org.apache.nifi.processors.standard.db.TableSchema 'from'(java.sql.Connection, java.lang.String, java.lang.String, java.lang.String, boolean, java.lang.String, org.apache.nifi.logging.ComponentLog) throws java.sql.SQLException
{
java.sql.Connection v;
org.apache.nifi.processors.standard.db.ColumnDescription v;
java.sql.ResultSet v, v, v;
boolean v, v, v, v, v;
org.apache.nifi.processors.standard.db.TableSchema v;
java.lang.Throwable v, v, v;
org.apache.nifi.processors.standard.db.TableNotFoundException v;
java.lang.String[] v;
java.sql.DatabaseMetaData v;
org.apache.nifi.logging.ComponentLog v;
java.util.ArrayList v, v;
java.util.HashSet v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @parameter: java.sql.Connection;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.logging.ComponentLog;
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)>(v, v, v, "%");
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
label:
v = interfaceinvoke v.<java.sql.ResultSet: boolean next()>();
if v == 0 goto label;
v = staticinvoke <org.apache.nifi.processors.standard.db.ColumnDescription: org.apache.nifi.processors.standard.db.ColumnDescription 'from'(java.sql.ResultSet)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.sql.DatabaseMetaData: java.sql.ResultSet getTables(java.lang.String,java.lang.String,java.lang.String,java.lang.String[])>(v, v, v, null);
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
if v == null goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
if v == null goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
if v == null goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = interfaceinvoke v.<java.sql.ResultSet: boolean next()>();
if v != 0 goto label;
v = new org.apache.nifi.processors.standard.db.TableNotFoundException;
v = staticinvoke <java.lang.String: java.lang.String join(java.lang.CharSequence,java.lang.Iterable)>(".", v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Table \u not found, ensure the Catalog, Schema, and/or Table Names match those in the database exactly");
specialinvoke v.<org.apache.nifi.processors.standard.db.TableNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <java.lang.String: java.lang.String join(java.lang.CharSequence,java.lang.Iterable)>(".", v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Table \u found but no columns were found, if this is not expected then check the user permissions for getting table metadata from the database");
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String)>(v);
label:
interfaceinvoke v.<java.sql.ResultSet: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
if v != null goto label;
v = interfaceinvoke v.<java.sql.DatabaseMetaData: java.sql.ResultSet getPrimaryKeys(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
label:
v = interfaceinvoke v.<java.sql.ResultSet: boolean next()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.sql.ResultSet: java.lang.String getString(java.lang.String)>("COLUMN_NAME");
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
interfaceinvoke v.<java.sql.ResultSet: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = staticinvoke <org.apache.nifi.processors.standard.db.ColumnDescription: java.lang.String normalizeColumnName(java.lang.String,boolean)>(v, v);
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = new org.apache.nifi.processors.standard.db.TableSchema;
v = interfaceinvoke v.<java.sql.DatabaseMetaData: java.lang.String getIdentifierQuoteString()>();
specialinvoke v.<org.apache.nifi.processors.standard.db.TableSchema: void <init>(java.lang.String,java.lang.String,java.lang.String,java.util.List,boolean,java.util.Set,java.lang.String)>(v, v, v, v, v, v, v);
label:
interfaceinvoke v.<java.sql.ResultSet: void close()>();
return v;
label:
v := @caughtexception;
throw v;
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;
}
public java.lang.String toString()
{
org.apache.nifi.processors.standard.db.TableSchema v;
java.util.Collection v;
java.util.Map v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.db.TableSchema;
v = v.<org.apache.nifi.processors.standard.db.TableSchema: java.util.Map columns>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.Collection)>(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[])>("TableSchema[columns=\u]");
return v;
}
}