Package org.odpi.openmetadata.frameworkservices.ocf.metadatamanagement.client

Class ConnectedAssetClientBase

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.client.ConnectedAssetClient

org.odpi.openmetadata.frameworkservices.ocf.metadatamanagement.client.ConnectedAssetClientBase

All Implemented Interfaces:

ConnectorFactoryInterface

Direct Known Subclasses:

EgeriaConnectedAssetClient

public class ConnectedAssetClientBase
extends ConnectedAssetClient

ConnectedAssetClient provides a base calls for clients that support an OCF interface. In particular, it manages the retrieval of connections for assets, and the creation of connectors.

Field Summary

Fields

Modifier and Type	Field	Description
protected InvalidParameterHandler	invalidParameterHandler

Fields inherited from class org.odpi.openmetadata.frameworks.connectors.client.ConnectedAssetClient

auditLog, maxPageSize, propertyHelper, serverName, serverPlatformURLRoot, serviceURLMarker

Constructor Summary

Constructors

Constructor	Description
ConnectedAssetClientBase(String serverName, String serverPlatformURLRoot, String serviceURLMarker, int maxPageSize, AuditLog auditLog)	Create a new client with no authentication embedded in the HTTP request.
ConnectedAssetClientBase(String serverName, String serverPlatformURLRoot, String serviceURLMarker, String userId, String password, int maxPageSize, AuditLog auditLog)	Create a new client with no authentication embedded in the HTTP request.

Method Summary

Modifier and Type	Method	Description
protected Connection	getConnectionByGUID(OCFRESTClient restClient, String serviceName, String userId, String guid)	Returns the connection corresponding to the supplied connection GUID.
protected Connection	getConnectionByName(OCFRESTClient restClient, String serviceName, String userId, String name)	Returns the connection object corresponding to the supplied connection name.
Connection	getConnectionForAsset(OCFRESTClient restClient, String serviceName, String userId, String assetGUID)	Returns the connection corresponding to the supplied asset GUID.
Connector	getConnectorByConnection(String userId, Connection connection)	Returns the connector corresponding to the supplied connection.
Connector	getConnectorByGUID(String userId, String connectionGUID)	Returns the connector corresponding to the supplied connection GUID.
Connector	getConnectorByName(String userId, String connectionName)	Returns the connector corresponding to the supplied connection name.
Connector	getConnectorForAsset(String userId, String assetGUID)	Returns the connector corresponding to the supplied asset GUID.
Connector	getConnectorForAsset(String userId, String assetGUID, AuditLog auditLog)	Returns the connector corresponding to the supplied asset GUID.
protected Connector	getConnectorForConnection(String serviceName, Connection requestedConnection, String methodName)	Use the Open Connector Framework (OCF) to create a connector using the supplied connection.
String	saveConnection(String userId, String assetGUID, Connection connection)	Returns the unique identifier corresponding to the supplied connection.
String	saveConnection(String userId, Connection connection)	Returns the unique identifier corresponding to the supplied connection.

Methods inherited from class java.lang.Object

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

Field Details

invalidParameterHandler

protected InvalidParameterHandler invalidParameterHandler

Constructor Details

ConnectedAssetClientBase

public ConnectedAssetClientBase(String serverName,
 String serverPlatformURLRoot,
 String serviceURLMarker,
 int maxPageSize,
 AuditLog auditLog)
                         throws InvalidParameterException

Create a new client with no authentication embedded in the HTTP request.

Parameters:

serverName - name of the server to connect to

serverPlatformURLRoot - the network address of the server running the OCF REST services

maxPageSize - maximum page size for this process

serviceURLMarker - indicator of the OMAS that this client is supporting

auditLog - destination for log messages

Throws:

InvalidParameterException - there is a problem creating the client-side components to issue any REST API calls.

ConnectedAssetClientBase

public ConnectedAssetClientBase(String serverName,
 String serverPlatformURLRoot,
 String serviceURLMarker,
 String userId,
 String password,
 int maxPageSize,
 AuditLog auditLog)
                         throws InvalidParameterException

Create a new client with no authentication embedded in the HTTP request.

Parameters:

serverName - name of the server to connect to

serverPlatformURLRoot - the network address of the server running the OCF REST services

userId - caller's userId embedded in all HTTP requests

password - caller's userId embedded in all HTTP requests

maxPageSize - maximum page size for this process

serviceURLMarker - indicator of the OMAS that this client is supporting

auditLog - destination for log messages

Throws:

InvalidParameterException - there is a problem creating the client-side components to issue any REST API calls.

Method Details

getConnectorForConnection

protected Connector getConnectorForConnection(String serviceName,
 Connection requestedConnection,
 String methodName)
                                       throws ConnectionCheckedException,
ConnectorCheckedException,
UserNotAuthorizedException

Use the Open Connector Framework (OCF) to create a connector using the supplied connection. The connector is initialized by not started.

Parameters:

serviceName - calling service

requestedConnection - connection describing the required connector

methodName - name of the calling method.

Returns:

a new connector.

Throws:

ConnectionCheckedException - there are issues with the values in the connection

ConnectorCheckedException - the connector had an operational issue accessing the asset.

UserNotAuthorizedException - connector disconnected

getConnectionByGUID

protected Connection getConnectionByGUID(OCFRESTClient restClient,
 String serviceName,
 String userId,
 String guid)
                                  throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException

Returns the connection corresponding to the supplied connection GUID.

Parameters:

restClient - client that calls REST APIs

serviceName - name of the calling service

userId - userId of user making request.

guid - the unique id for the connection within the metadata repository.

Returns:

connection instance.

Throws:

InvalidParameterException - one of the parameters is null or invalid.

PropertyServerException - there is a problem retrieving information from the property server(s).

UserNotAuthorizedException - the requesting user is not authorized to issue this request.

getConnectionByName

protected Connection getConnectionByName(OCFRESTClient restClient,
 String serviceName,
 String userId,
 String name)
                                  throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException

Returns the connection object corresponding to the supplied connection name.

Parameters:

restClient - client that calls REST APIs

serviceName - name of the calling service

userId - String - userId of user making request.

name - this is the qualifiedName of the connection.

Returns:

Connection retrieved from property server.

Throws:

InvalidParameterException - one of the parameters is null or invalid.

PropertyServerException - there is a problem retrieving information from the property (metadata) server.

UserNotAuthorizedException - the requesting user is not authorized to issue this request.

getConnectionForAsset

public Connection getConnectionForAsset(OCFRESTClient restClient,
 String serviceName,
 String userId,
 String assetGUID)
                                 throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException

Returns the connection corresponding to the supplied asset GUID.

Parameters:

restClient - client that calls REST APIs

serviceName - name of the calling service

userId - userId of user making request.

assetGUID - the unique id for the asset within the metadata repository.

Returns:

connector instance.

Throws:

InvalidParameterException - one of the parameters is null or invalid.

PropertyServerException - there is a problem retrieving information from the property server(s).

UserNotAuthorizedException - the requesting user is not authorized to issue this request.

saveConnection

public String saveConnection(String userId,
 Connection connection)
                      throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException,
ConnectionCheckedException,
ConnectorCheckedException

Returns the unique identifier corresponding to the supplied connection.

Specified by:

saveConnection in class ConnectedAssetClient

Parameters:

userId - calling user

connection - the connection object that contains the properties needed to create the connection.

Returns:

guid

Throws:

InvalidParameterException - one of the parameters is null or invalid.

ConnectionCheckedException - there are errors in the configuration of the connection which is preventing the creation of a connector.

ConnectorCheckedException - there are errors in the initialization of the connector.

PropertyServerException

UserNotAuthorizedException

saveConnection

public String saveConnection(String userId,
 String assetGUID,
 Connection connection)
                      throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException,
ConnectionCheckedException,
ConnectorCheckedException

Returns the unique identifier corresponding to the supplied connection.

Specified by:

saveConnection in class ConnectedAssetClient

Parameters:

userId - calling user

assetGUID - the unique identifier of an asset to attach the connection to

connection - the connection object that contains the properties needed to create the connection.

Returns:

guid

Throws:

InvalidParameterException - one of the parameters is null or invalid.

ConnectionCheckedException - there are errors in the configuration of the connection which is preventing the creation of a connector.

ConnectorCheckedException - there are errors in the initialization of the connector.

PropertyServerException

UserNotAuthorizedException

getConnectorByName

public Connector getConnectorByName(String userId,
 String connectionName)
                             throws InvalidParameterException,
ConnectionCheckedException,
ConnectorCheckedException,
PropertyServerException,
UserNotAuthorizedException

Returns the connector corresponding to the supplied connection name.

Specified by:

getConnectorByName in interface ConnectorFactoryInterface

Specified by:

getConnectorByName in class ConnectedAssetClient

Parameters:

userId - userId of user making request.

connectionName - this may be the qualifiedName or displayName of the connection.

Returns:

connector instance - or null if there is no connection

Throws:

InvalidParameterException - one of the parameters is null or invalid.

ConnectionCheckedException - there are errors in the configuration of the connection which is preventing the creation of a connector.

ConnectorCheckedException - there are errors in the initialization of the connector.

PropertyServerException - there is a problem retrieving information from the property server(s).

UserNotAuthorizedException - the requesting user is not authorized to issue this request.

getConnectorForAsset

public Connector getConnectorForAsset(String userId,
 String assetGUID)
                               throws InvalidParameterException,
ConnectionCheckedException,
ConnectorCheckedException,
PropertyServerException,
UserNotAuthorizedException

Returns the connector corresponding to the supplied asset GUID.

Specified by:

getConnectorForAsset in interface ConnectorFactoryInterface

Specified by:

getConnectorForAsset in class ConnectedAssetClient

Parameters:

userId - userId of user making request.

assetGUID - the unique id for the asset within the metadata repository.

Returns:

connector instance - or null if there is no connection

Throws:

InvalidParameterException - one of the parameters is null or invalid.

ConnectionCheckedException - there are errors in the configuration of the connection which is preventing the creation of a connector.

ConnectorCheckedException - there are errors in the initialization of the connector.

PropertyServerException - there is a problem retrieving information from the property server(s).

UserNotAuthorizedException - the requesting user is not authorized to issue this request.

getConnectorForAsset

public Connector getConnectorForAsset(String userId,
 String assetGUID,
 AuditLog auditLog)
                               throws InvalidParameterException,
ConnectionCheckedException,
ConnectorCheckedException,
PropertyServerException,
UserNotAuthorizedException

Returns the connector corresponding to the supplied asset GUID.

Specified by:

getConnectorForAsset in interface ConnectorFactoryInterface

Specified by:

getConnectorForAsset in class ConnectedAssetClient

Parameters:

userId - userId of user making request.

assetGUID - the unique id for the asset within the metadata repository.

auditLog - optional logging destination

Returns:

connector instance - or null if there is no connection

Throws:

InvalidParameterException - one of the parameters is null or invalid.

ConnectionCheckedException - there are errors in the configuration of the connection which is preventing the creation of a connector.

ConnectorCheckedException - there are errors in the initialization of the connector.

PropertyServerException - there is a problem retrieving information from the property server(s).

UserNotAuthorizedException - the requesting user is not authorized to issue this request.

getConnectorByGUID

public Connector getConnectorByGUID(String userId,
 String connectionGUID)
                             throws InvalidParameterException,
ConnectionCheckedException,
ConnectorCheckedException,
PropertyServerException,
UserNotAuthorizedException

Returns the connector corresponding to the supplied connection GUID.

Specified by:

getConnectorByGUID in interface ConnectorFactoryInterface

Specified by:

getConnectorByGUID in class ConnectedAssetClient

Parameters:

userId - userId of user making request.

connectionGUID - the unique id for the connection within the metadata repository.

Returns:

connector instance - or null if there is no connection

Throws:

InvalidParameterException - one of the parameters is null or invalid.

ConnectionCheckedException - there are errors in the configuration of the connection which is preventing the creation of a connector.

ConnectorCheckedException - there are errors in the initialization of the connector.

PropertyServerException - there is a problem retrieving information from the property server(s).

UserNotAuthorizedException - the requesting user is not authorized to issue this request.

getConnectorByConnection

public Connector getConnectorByConnection(String userId,
 Connection connection)
                                   throws InvalidParameterException,
ConnectionCheckedException,
ConnectorCheckedException,
UserNotAuthorizedException

Returns the connector corresponding to the supplied connection.

Specified by:

getConnectorByConnection in interface ConnectorFactoryInterface

Specified by:

getConnectorByConnection in class ConnectedAssetClient

Parameters:

userId - userId of user making request.

connection - the connection object that contains the properties needed to create the connection.

Returns:

connector instance

Throws:

InvalidParameterException - one of the parameters is null or invalid.

ConnectionCheckedException - there are errors in the configuration of the connection which is preventing the creation of a connector.

ConnectorCheckedException - there are errors in the initialization of the connector.

UserNotAuthorizedException - connector disconnected