Package org.apache.nifi.processors.standard.db

Class TableSchema

java.lang.Object

org.apache.nifi.processors.standard.db.TableSchema

public class TableSchema
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final String	catalogName
private final Map<String,ColumnDescription>	columns
private final Set<String>	primaryKeyColumnNames
private final String	quotedIdentifierString
private final List<String>	requiredColumnNames
private final String	schemaName
private final String	tableName

Constructor Summary

Constructors

Constructor	Description
TableSchema(String catalogName, String schemaName, String tableName, List<ColumnDescription> columnDescriptions, boolean translateColumnNames, NameNormalizer normalizer, Set<String> primaryKeyColumnNames, String quotedIdentifierString)

Method Summary

Modifier and Type	Method	Description
static TableSchema	from(Connection conn, String catalog, String schema, String tableName, boolean translateColumnNames, NameNormalizer normalizer, String updateKeys, org.apache.nifi.logging.ComponentLog log)
String	getCatalogName()
Map<String,ColumnDescription>	getColumns()
List<ColumnDescription>	getColumnsAsList()
Set<String>	getPrimaryKeyColumnNames()
String	getQuotedIdentifierString()
List<String>	getRequiredColumnNames()
String	getSchemaName()
String	getTableName()
static String	normalizedName(String name, boolean translateNames, NameNormalizer normalizer)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

requiredColumnNames

private final List<String> requiredColumnNames

primaryKeyColumnNames

private final Set<String> primaryKeyColumnNames

columns

private final Map<String,ColumnDescription> columns

quotedIdentifierString

private final String quotedIdentifierString

catalogName

private final String catalogName

schemaName

private final String schemaName

tableName

private final String tableName

Constructor Details

TableSchema

public TableSchema(String catalogName,
 String schemaName,
 String tableName,
 List<ColumnDescription> columnDescriptions,
 boolean translateColumnNames,
 NameNormalizer normalizer,
 Set<String> primaryKeyColumnNames,
 String quotedIdentifierString)

Method Details

getCatalogName

public String getCatalogName()

getSchemaName

public String getSchemaName()

getTableName

public String getTableName()

getColumns

public Map<String,ColumnDescription> getColumns()

getColumnsAsList

public List<ColumnDescription> getColumnsAsList()

getRequiredColumnNames

public List<String> getRequiredColumnNames()

getPrimaryKeyColumnNames

public Set<String> getPrimaryKeyColumnNames()

getQuotedIdentifierString

public String getQuotedIdentifierString()

from

public static TableSchema from(Connection conn,
 String catalog,
 String schema,
 String tableName,
 boolean translateColumnNames,
 NameNormalizer normalizer,
 String updateKeys,
 org.apache.nifi.logging.ComponentLog log)
                        throws SQLException

Throws:

SQLException

normalizedName

public static String normalizedName(String name,
 boolean translateNames,
 NameNormalizer normalizer)

toString

public String toString()

Overrides:

toString in class Object