net.sf.taverna.t2.provenance.lineageservice
Class Provenance

java.lang.Object
  extended by net.sf.taverna.t2.provenance.lineageservice.Provenance

public class Provenance
extends java.lang.Object

Implemented by the database class that a ProvenanceConnector implementation uses for storage purposes

Author:
Paolo Missier, Ian Dunlop

Field Summary
protected  EventProcessor ep
           
protected  ProvenanceQuery pq
           
protected  ProvenanceWriter pw
           
 
Constructor Summary
Provenance()
           
Provenance(EventProcessor eventProcessor)
           
 
Method Summary
 void acceptRawProvenanceEvent(net.sf.taverna.t2.provenance.vocabulary.SharedVocabulary eventType, net.sf.taverna.t2.provenance.item.ProvenanceItem provenanceItem)
          maps each incoming event to an insert query into the provenance store
 void clearDB()
           
 EventProcessor getEp()
           
 ProvenanceQuery getPq()
           
 ProvenanceWriter getPw()
           
 java.lang.String getSaveEvents()
           
 boolean isFirstWorkflowStructure()
           
protected  void processEvent(net.sf.taverna.t2.provenance.item.ProvenanceItem provenanceItem, net.sf.taverna.t2.provenance.vocabulary.SharedVocabulary eventType)
          parse d and generate SQL insert calls into the provenance DB
 void setEp(EventProcessor ep)
           
 void setFirstWorkflowStructure(boolean firstWorkflowStructure)
           
 void setPq(ProvenanceQuery pq)
           
 void setPw(ProvenanceWriter pw)
           
 void setSaveEvents(java.lang.String saveEvents)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

pq

protected ProvenanceQuery pq

pw

protected ProvenanceWriter pw

ep

protected EventProcessor ep
Constructor Detail

Provenance

public Provenance()

Provenance

public Provenance(EventProcessor eventProcessor)
Method Detail

isFirstWorkflowStructure

public boolean isFirstWorkflowStructure()

setFirstWorkflowStructure

public void setFirstWorkflowStructure(boolean firstWorkflowStructure)

clearDB

public void clearDB()
             throws java.sql.SQLException
Throws:
java.sql.SQLException

getSaveEvents

public java.lang.String getSaveEvents()
Returns:
the saveEvents

setSaveEvents

public void setSaveEvents(java.lang.String saveEvents)
Parameters:
saveEvents - the saveEvents to set

setPq

public void setPq(ProvenanceQuery pq)

getPq

public ProvenanceQuery getPq()

setPw

public void setPw(ProvenanceWriter pw)

getPw

public ProvenanceWriter getPw()

setEp

public void setEp(EventProcessor ep)

getEp

public EventProcessor getEp()

acceptRawProvenanceEvent

public void acceptRawProvenanceEvent(net.sf.taverna.t2.provenance.vocabulary.SharedVocabulary eventType,
                                     net.sf.taverna.t2.provenance.item.ProvenanceItem provenanceItem)
                              throws java.sql.SQLException,
                                     java.io.IOException
maps each incoming event to an insert query into the provenance store

Parameters:
eventType -
content -
Throws:
java.sql.SQLException
java.io.IOException

processEvent

protected void processEvent(net.sf.taverna.t2.provenance.item.ProvenanceItem provenanceItem,
                            net.sf.taverna.t2.provenance.vocabulary.SharedVocabulary eventType)
                     throws java.sql.SQLException,
                            java.io.IOException
parse d and generate SQL insert calls into the provenance DB

Parameters:
d - DOM for the event
eventType - see SharedVocabulary
Throws:
java.sql.SQLException
java.io.IOException