eu.transformproject.provenance.ws

Class ProvenanceWS_DataConnectorTool

java.lang.Object

eu.transformproject.provenance.representation.commonItInstantiation.CommonInstantiation

eu.transformproject.provenance.ws.ProvenanceWS_DataConnectorTool

All Implemented Interfaces:

CommomInstantiationInterface, ProvenanceWS_DataConnector_Interface

public class ProvenanceWS_DataConnectorTool
extends CommonInstantiation
implements ProvenanceWS_DataConnector_Interface

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DATA_CONNECTOR_GRAPH_PROJECT
static java.lang.String	MIDDLEWARE_GRAPH_PROJECT_NAME_IN_DCT

Fields inherited from class eu.transformproject.provenance.representation.commonItInstantiation.CommonInstantiation

MIDDLEWARE_GRAPH_PROJECT_NAME, server

Constructor Summary

Constructors

Constructor and Description
ProvenanceWS_DataConnectorTool()
ProvenanceWS_DataConnectorTool(java.lang.String localZoneName, java.lang.String fxmlConfig, boolean isResource)

Method Summary

Methods

Modifier and Type	Method and Description
void	endsPackageData(java.lang.Object signedDetails, java.lang.Object encryptedPackage) Ends of the packaging process.
java.lang.String	excecuteSQLQuery(java.lang.Object sqlResultsQuery, java.util.Date start)
java.lang.String	receiveData(java.lang.String receptorQueueName, java.lang.Object encryptedReceivedData) Reception of an encrypted data.
void	sendData(java.lang.String receptorQueueName, java.lang.String encryptedDataA) Send an encrypted data.
java.lang.String	startPackageData(java.lang.String uriDataToPackage, java.util.Date start) Starts of the packaging processing.
java.lang.String	translateCDIMQuery(java.lang.String dataSourceName, java.lang.String receivedQueryA, java.lang.String sqlQuery, java.util.Date start) translateCDIMQuery, annotates the translation from CDIM query to SQL query process at the moment it ends.
java.lang.String	unpackageData(java.lang.String encryptedReceivedDataA, java.lang.String provenanceA, java.lang.Object decryptedDataA, java.util.Date start) Decryptation of an encrypted data.

Methods inherited from class eu.transformproject.provenance.representation.commonItInstantiation.CommonInstantiation

closeSession, createSession, finalize, getSyncDateTime, login, logout

Methods inherited from class java.lang.Object

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

Methods inherited from interface eu.transformproject.provenance.representation.commonItInstantiation.CommomInstantiationInterface

closeSession, createSession, getSyncDateTime, login, logout

Field Detail

MIDDLEWARE_GRAPH_PROJECT_NAME_IN_DCT

public static java.lang.String MIDDLEWARE_GRAPH_PROJECT_NAME_IN_DCT

DATA_CONNECTOR_GRAPH_PROJECT

public static java.lang.String DATA_CONNECTOR_GRAPH_PROJECT

Constructor Detail

ProvenanceWS_DataConnectorTool

public ProvenanceWS_DataConnectorTool(java.lang.String localZoneName,
                              java.lang.String fxmlConfig,
                              boolean isResource)
                               throws java.lang.Exception

Throws:

java.lang.Exception

ProvenanceWS_DataConnectorTool

public ProvenanceWS_DataConnectorTool()
                               throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

startPackageData

public java.lang.String startPackageData(java.lang.String uriDataToPackage,
                                java.util.Date start)
                                  throws java.lang.Exception

Description copied from interface: CommomInstantiationInterface

Starts of the packaging processing. Annotates the start of the packaging, and returns an artifact identifier that needs to be added in the package to encrypt and/or transmit.

Specified by:

startPackageData in interface CommomInstantiationInterface

Overrides:

startPackageData in class CommonInstantiation

Parameters:

uriDataToPackage - the uri of the artifact associated to the object to be transmitted. This value needs to be obtained through any of the provenance server method.

start - the time in which the packaging process started.

Returns:

encryptedDataA artifact identifier to which the encrypted data will be associated.

Throws:

java.lang.Exception

endsPackageData

public void endsPackageData(java.lang.Object signedDetails,
                   java.lang.Object encryptedPackage)
                     throws java.lang.Exception

Description copied from interface: CommomInstantiationInterface

Ends of the packaging process. Annotates the packaging of a data at the time the packaging has finished.

Specified by:

endsPackageData in interface CommomInstantiationInterface

Overrides:

endsPackageData in class CommonInstantiation

Parameters:

signedDetails - sign object created during encryptation.

encryptedPackage - the encrypted object.

Throws:

java.lang.Exception

sendData

public void sendData(java.lang.String receptorQueueName,
            java.lang.String encryptedDataA)
              throws java.lang.Exception

Description copied from interface: CommomInstantiationInterface

Send an encrypted data. Annotates the sending encrypted process data at the time it was sent.

Specified by:

sendData in interface CommomInstantiationInterface

Overrides:

sendData in class CommonInstantiation

Parameters:

receptorQueueName - an string that identifies the queue that controls the sent data messages (e.g. "QW2MW", "MW2DC", etc.).

encryptedDataA - identifier of the encryptedData artifact, as returned by the packageData method.

Throws:

java.lang.Exception

receiveData

public java.lang.String receiveData(java.lang.String receptorQueueName,
                           java.lang.Object encryptedReceivedData)
                             throws java.lang.Exception

Description copied from interface: CommomInstantiationInterface

Reception of an encrypted data. Annotates an encrypted data reception process at the time it was received.

Specified by:

receiveData in interface CommomInstantiationInterface

Overrides:

receiveData in class CommonInstantiation

Parameters:

receptorQueueName - an string that identifies the queue that controls the reception of data messages (e.g. "QW2MW", "MW2DC", etc.).

encryptedReceivedData - an object describing the data recovered from the queue.

Returns:

encryptedReceivedDataA identifier of the generated encrypted received data artifact.

Throws:

java.lang.Exception

unpackageData

public java.lang.String unpackageData(java.lang.String encryptedReceivedDataA,
                             java.lang.String provenanceA,
                             java.lang.Object decryptedDataA,
                             java.util.Date start)
                               throws java.lang.Exception

Description copied from interface: CommomInstantiationInterface

Decryptation of an encrypted data. Annotates a decryptation data process at the time it finished.

Specified by:

unpackageData in interface CommomInstantiationInterface

Overrides:

unpackageData in class CommonInstantiation

Parameters:

encryptedReceivedDataA - identifier of the generated encrypted received data artifact, as returned by receiveData or packageData methods

provenanceA - identifier of the provenance artifact from which the encrypted received data comes from. This data needs to be extracted from the transmitted package, and should contain the artifact identifier of the transmitted data.

decryptedDataA - an object describing the data decrypted data.

start - the time when the unpackage process starts.

Returns:

decryptedDataA identifier of the generated decrypted data artifact.

Throws:

java.lang.Exception

translateCDIMQuery

public java.lang.String translateCDIMQuery(java.lang.String dataSourceName,
                                  java.lang.String receivedQueryA,
                                  java.lang.String sqlQuery,
                                  java.util.Date start)
                                    throws java.lang.Exception

Description copied from interface: ProvenanceWS_DataConnector_Interface

translateCDIMQuery, annotates the translation from CDIM query to SQL query process at the moment it ends.

Specified by:

translateCDIMQuery in interface ProvenanceWS_DataConnector_Interface

Returns:

the uri of the artifact representing the translated sqlQuery

Throws:

java.lang.Exception

excecuteSQLQuery

public java.lang.String excecuteSQLQuery(java.lang.Object sqlResultsQuery,
                                java.util.Date start)
                                  throws java.lang.Exception

Specified by:

excecuteSQLQuery in interface ProvenanceWS_DataConnector_Interface

Throws:

java.lang.Exception