class org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema extends java.lang.Object
{
private java.util.List requiredColumnNames;
private java.util.Set primaryKeyColumnNames;
private java.util.Map columns;
private java.lang.String quotedIdentifierString;
private void <init>(java.util.List, boolean, java.util.Set, java.lang.String)
{
java.util.HashMap v;
org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema v;
java.util.ArrayList v;
java.util.Map v;
java.lang.String v, v, v, v;
boolean v, v, v;
java.util.Iterator v;
java.util.Set v;
java.util.List v, v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema;
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 = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema: java.util.Map columns> = v;
v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema: java.util.Set primaryKeyColumnNames> = v;
v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema: java.lang.String quotedIdentifierString> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$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.ConvertJSONToSQL$TableSchema: java.util.Map columns>;
v = v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$ColumnDescription: java.lang.String columnName>;
v = staticinvoke <org.apache.nifi.processors.standard.ConvertJSONToSQL: 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.ConvertJSONToSQL$ColumnDescription: boolean isRequired()>();
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema: java.util.List requiredColumnNames>;
v = v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$ColumnDescription: java.lang.String columnName>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return;
}
public java.util.Map getColumns()
{
org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema v;
java.util.Map v;
v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema;
v = v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema: java.util.Map columns>;
return v;
}
public java.util.List getRequiredColumnNames()
{
java.util.List v;
org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema v;
v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema;
v = v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema: java.util.List requiredColumnNames>;
return v;
}
public java.util.Set getPrimaryKeyColumnNames()
{
java.util.Set v;
org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema v;
v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema;
v = v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema: java.util.Set primaryKeyColumnNames>;
return v;
}
public java.lang.String getQuotedIdentifierString()
{
java.lang.String v;
org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema v;
v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema;
v = v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema: java.lang.String quotedIdentifierString>;
return v;
}
public static org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema 'from'(java.sql.Connection, java.lang.String, java.lang.String, java.lang.String, boolean, boolean) throws java.sql.SQLException
{
java.lang.Throwable v, v;
java.sql.Connection v;
java.sql.DatabaseMetaData v, v;
org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema v;
java.util.ArrayList v;
java.util.HashSet v;
org.apache.nifi.processors.standard.ConvertJSONToSQL$ColumnDescription v;
java.sql.ResultSet v, v;
java.lang.String v, v, v, v, v, v;
boolean 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: boolean;
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.ConvertJSONToSQL$ColumnDescription: org.apache.nifi.processors.standard.ConvertJSONToSQL$ColumnDescription 'from'(java.sql.ResultSet)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.sql.Connection: java.sql.DatabaseMetaData getMetaData()>();
v = interfaceinvoke v.<java.sql.DatabaseMetaData: java.sql.ResultSet getPrimaryKeys(java.lang.String,java.lang.String,java.lang.String)>(v, null, 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");
v = staticinvoke <org.apache.nifi.processors.standard.ConvertJSONToSQL: java.lang.String normalizeColumnName(java.lang.String,boolean)>(v, v);
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 = new org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema;
v = interfaceinvoke v.<java.sql.DatabaseMetaData: java.lang.String getIdentifierQuoteString()>();
specialinvoke v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$TableSchema: void <init>(java.util.List,boolean,java.util.Set,java.lang.String)>(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;
}
}