All Implemented Interfaces:
RegisteredIntegrationModule

public class RDBMSIntegrationModule extends DatabaseIntegrationModuleBase
RDBMSIntegrationModule manages the cataloguing of RDBMS entities stored in Apache Atlas into the open metadata ecosystem.
  • Constructor Details

    • RDBMSIntegrationModule

      public RDBMSIntegrationModule(String connectorName, Connection connectionDetails, AuditLog auditLog, IntegrationContext myContext, String targetRootURL, ApacheAtlasRESTConnector atlasClient) throws UserNotAuthorizedException
      Constructor for the module is supplied with the runtime context in order to operate.
      Parameters:
      connectorName - name of the connector (for messages)
      connectionDetails - connection properties used to start the connector
      auditLog - logging destination
      myContext - integration context
      targetRootURL - URL to connect to Apache Atlas
      atlasClient - client to connect to Apache Atlas
      Throws:
      UserNotAuthorizedException - security problem
  • Method Details

    • getEgeriaDatabaseProperties

      protected DataAssetProperties getEgeriaDatabaseProperties(AtlasEntity atlasEntity, String egeriaTypeName)
      Map the properties from the entity retrieved from Apache Atlas to the Egeria properties for the open metadata entity.
      Specified by:
      getEgeriaDatabaseProperties in class DatabaseIntegrationModuleBase
      Parameters:
      atlasEntity - retrieve entity from Apache Atlas
      egeriaTypeName - name of the type used in the open metadata ecosystem
      Returns:
      properties to pass to Egeria
    • getEgeriaDatabaseTableProperties

      protected RelationalTableProperties getEgeriaDatabaseTableProperties(AtlasEntity atlasEntity, String egeriaSchemaAttributeTypeName)
      Map the properties from the entity retrieved from Apache Atlas to the Egeria properties for the open metadata entity.
      Specified by:
      getEgeriaDatabaseTableProperties in class DatabaseIntegrationModuleBase
      Parameters:
      atlasEntity - retrieve entity from Apache Atlas
      egeriaSchemaAttributeTypeName - name of the type used in the open metadata ecosystem
      Returns:
      properties to pass to Egeria
    • getEgeriaDatabaseColumnProperties

      protected RelationalColumnProperties getEgeriaDatabaseColumnProperties(AtlasEntity atlasEntity, String egeriaSchemaAttributeTypeName)
      Map the properties from the entity retrieved from Apache Atlas to the Egeria properties for the open metadata entity.
      Specified by:
      getEgeriaDatabaseColumnProperties in class DatabaseIntegrationModuleBase
      Parameters:
      atlasEntity - retrieve entity from Apache Atlas
      egeriaSchemaAttributeTypeName - name of the type used in the open metadata ecosystem
      Returns:
      properties to pass to Egeria
    • getEgeriaDatabaseColumnTypeProperties

      protected TypeEmbeddedAttributeProperties getEgeriaDatabaseColumnTypeProperties(AtlasEntity atlasEntity, String egeriaSchemaTypeTypeName)
      Map the properties from the entity retrieved from Apache Atlas to the Egeria properties for the open metadata entity.
      Specified by:
      getEgeriaDatabaseColumnTypeProperties in class DatabaseIntegrationModuleBase
      Parameters:
      atlasEntity - retrieve entity from Apache Atlas
      egeriaSchemaTypeTypeName - name of the type used in the open metadata ecosystem
      Returns:
      properties to pass to Egeria