Package org.odpi.openmetadata.adapters.connectors.postgres.tabulardatasource

Class PostgresTabularDataSetCollectionConnector

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

org.odpi.openmetadata.adapters.connectors.postgres.tabulardatasource.PostgresTabularDataSetConnector

org.odpi.openmetadata.adapters.connectors.postgres.tabulardatasource.PostgresTabularDataSetCollectionConnector

All Implemented Interfaces:

SecureConnectorExtension, ReadableTabularDataCollection, ReadableTabularDataSource, TabularDataCollection, WritableTabularDataSource, VirtualConnectorExtension

public class PostgresTabularDataSetCollectionConnector
extends PostgresTabularDataSetConnector
implements ReadableTabularDataCollection

PostgresTabularDataSetCollectionConnector presents the tables of one PostgreSQL schema as a collection of simple tables of data. One table is in focus at a time - it is chosen with setTableName(java.lang.String, java.lang.String) - and is read and written exactly as PostgresTabularDataSetConnector reads and writes its single table. As a source, the collection lists its tables with getTableNames() so that each can be brought into focus and read in turn; as a destination, a table is created in the schema the first time data is written to it.

Nested Class Summary

Nested classes/interfaces inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

ConnectorBase.ProtectedConnection

Field Summary

Fields inherited from class org.odpi.openmetadata.adapters.connectors.postgres.tabulardatasource.PostgresTabularDataSetConnector

propertyHelper, tableDescription, tableName

Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

auditLog, connectionBean, connectorInstanceId, embeddedConnectors, messageFormatter, secretsStoreConnectorMap

Constructor Summary

Constructors

Constructor	Description
PostgresTabularDataSetCollectionConnector()

Method Summary

Modifier and Type	Method	Description
List<String>	getTableNames()	Return the names of the tables in the schema, in canonical form so that they can be passed back to setTableName(java.lang.String, java.lang.String) and translated by a destination into its own naming convention.
void	setTableName(String tableName, String tableDescription)	Set up the table name for the tabular data set to focus on.

Methods inherited from class org.odpi.openmetadata.adapters.connectors.postgres.tabulardatasource.PostgresTabularDataSetConnector

appendRecord, deleteRecord, disconnect, focusOnTable, getColumnDescriptions, getColumnNumber, getRecordCount, getSchemaTableNames, getTableDescription, getTableName, readRecord, setColumnDescriptions, start, writeRecord

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

combineConfigurationProperties, disconnectConnectors, equals, fromCamelToCanonicalCase, fromCanonicalToCamelCase, fromCanonicalToKebabCase, fromCanonicalToSnakeCase, fromKebabToCanonicalCase, fromSnakeToCanonicalCase, getArrayConfigurationProperty, getArrayConfigurationProperty, getArrayConfigurationProperty, getArrayValue, getBooleanConfigurationProperty, getConnection, getConnectorInstanceId, getDateConfigurationProperty, getIntConfigurationProperty, getLongConfigurationProperty, getSecretsCollectionName, getSecretsLocation, getSecretsProvider, getStringConfigurationProperty, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initialize, initializeEmbeddedConnectors, initializeSecretsStoreConnector, isActive, logExceptionRecord, logExceptionRecord, logRecord, logRecord, throwMissingConfigurationProperty, throwMissingElement, throwMissingEndpointAddress, throwMissingResource, throwNoAsset, throwWrongTypeOfAsset, throwWrongTypeOfResource, throwWrongTypeOfRootSchema, toString

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.Connector

clearStatisticProperty, clearStatisticTimestamp, getConnectorStatistics, getStatisticCounter, getStatisticProperty, getStatisticTimestamp, incrementStatisticCounter, initializeStatisticCounter, refreshStatistics, setStatisticProperty, setStatisticTimestamp

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.odpi.openmetadata.frameworks.connectors.tabulardatasets.ReadableTabularDataSource

getColumnDescriptions, getColumnNumber, getRecordCount, getTableDescription, getTableName, readRecord

Constructor Details

PostgresTabularDataSetCollectionConnector

public PostgresTabularDataSetCollectionConnector()

Method Details

setTableName

public void setTableName(String tableName,
 String tableDescription)

Set up the table name for the tabular data set to focus on. This is in canonical word format where each word in the name should be capitalized, with spaces between the words. This format allows easy translation between different naming conventions.

Specified by:

setTableName in interface TabularDataCollection

Parameters:

tableName - name of the table

tableDescription - optional description for the table - useful if the connector needs to set up a definition of the table.

getTableNames

public List<String> getTableNames()
                           throws ConnectorCheckedException

Return the names of the tables in the schema, in canonical form so that they can be passed back to setTableName(java.lang.String, java.lang.String) and translated by a destination into its own naming convention.

Specified by:

getTableNames in interface ReadableTabularDataCollection

Returns:

list of table names (may be empty)

Throws:

ConnectorCheckedException - problem accessing the database