Class JDBCIntegrationCatalogTargetProcessor


public class JDBCIntegrationCatalogTargetProcessor extends CatalogTargetProcessorBase
JDBCIntegrationCatalogTargetProcessor supports the cataloguing of database schema via the JDBC interface for a single database that is linked as a catalog target.
  • Constructor Details

    • JDBCIntegrationCatalogTargetProcessor

      public JDBCIntegrationCatalogTargetProcessor(CatalogTarget template, CatalogTargetContext catalogTargetContext, Connector connectorToTarget, String connectorName, AuditLog auditLog)
      Primary constructor
      Parameters:
      template - object to copy
      catalogTargetContext - specialized context for this catalog target
      connectorToTarget - connector to access the target resource
      connectorName - name of this integration connector
      auditLog - logging destination
  • Method Details

    • refresh

      public void refresh() throws ConnectorCheckedException
      Requests that the connector does a comparison of the metadata in the third party technology and open metadata repositories. Refresh is called when the integration connector first starts and then at intervals defined in the connector's configuration as well as any external REST API calls to explicitly refresh the connector.
      Overrides:
      refresh in class CatalogTargetProcessorBase
      Throws:
      ConnectorCheckedException - there is a problem within the connector.
    • refreshDatabase

      public void refreshDatabase(JDBCResourceConnector jdbcResourceConnector, String databaseName, OpenMetadataRootElement databaseElement, Map<String,Object> configurationProperties) throws ConnectorCheckedException
      Refresh a single database.
      Parameters:
      jdbcResourceConnector - connector to the database
      databaseName - qualified name of the database
      configurationProperties - configuration properties for the database
      Throws:
      ConnectorCheckedException
    • close

      public void close(Connection connection)
      Work has completed, close the database connection.
      Parameters:
      connection - database connection