net.sf.taverna.t2.provenance.lineageservice.rdf
Class RDFProvenanceWriter

java.lang.Object
  net.sf.taverna.t2.provenance.lineageservice.ProvenanceWriter
      net.sf.taverna.t2.provenance.lineageservice.rdf.RDFProvenanceWriter

public class RDFProvenanceWriter
extends ProvenanceWriter

Author:

paolo

Field Summary

Fields inherited from class net.sf.taverna.t2.provenance.lineageservice.ProvenanceWriter

cnt, pq

Constructor Summary

RDFProvenanceWriter()

Method Summary

void	addArc(java.lang.String sourceVarName, java.lang.String sourceProcName, java.lang.String sinkVarName, java.lang.String sinkProcName, java.lang.String wfId)
void	addArc(Var sourceVar, Var sinkVar, java.lang.String wfId) inserts one row into the ARC DB table -- OBSOLETE, see instead
java.lang.String	addCollection(java.lang.String processorId, java.lang.String collId, java.lang.String parentCollectionId, java.lang.String iteration, java.lang.String portName, java.lang.String dataflowId)
void	addProcessor(java.lang.String pName, java.lang.String type, java.lang.String wfNameRef, boolean isTopLevel) add a processor to the static portion of the DB with given name, type and wfnameRef scope
void	addProcessorBinding(ProcBinding pb)
void	addVarBinding(VarBinding vb) also fetches data values from the Data table of the relational provenance DB and adds it as a rdfs:comment to the RDF graph
void	addVariables(java.util.List<Var> vars, java.lang.String wfId) add each Var as a row into the VAR DB table note: no static var type available as part of the dataflow...
void	addWFId(java.lang.String wfId, java.lang.String parentWFname, java.lang.String externalName, java.sql.Blob dataflow)
void	addWFInstanceId(java.lang.String wfId, java.lang.String wfInstanceId)
void	closeCurrentModel()
void	dumpCurrentModel(java.lang.String fileName)
com.hp.hpl.jena.rdf.model.Model	getModel()
void	setModel(com.hp.hpl.jena.rdf.model.Model m)

Methods inherited from class net.sf.taverna.t2.provenance.lineageservice.ProvenanceWriter

addData, addData, addProcessor, addWFId, clearDBDynamic, clearDBDynamic, clearDBStatic, clearDBStatic, clearDD, getConnection, getQuery, replaceCollectionRecord, setQuery, updateVar, updateVarBinding, writeDDRecord

Methods inherited from class java.lang.Object

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

Constructor Detail

RDFProvenanceWriter

public RDFProvenanceWriter()

Method Detail

closeCurrentModel

public void closeCurrentModel()

Specified by:

closeCurrentModel in class ProvenanceWriter

dumpCurrentModel

public void dumpCurrentModel(java.lang.String fileName)

addWFId

public void addWFId(java.lang.String wfId,
                    java.lang.String parentWFname,
                    java.lang.String externalName,
                    java.sql.Blob dataflow)
             throws java.sql.SQLException

Overrides:

addWFId in class ProvenanceWriter

Throws:

java.sql.SQLException

addProcessor

public void addProcessor(java.lang.String pName,
                         java.lang.String type,
                         java.lang.String wfNameRef,
                         boolean isTopLevel)
                  throws java.sql.SQLException

Description copied from class: ProvenanceWriter

add a processor to the static portion of the DB with given name, type and wfnameRef scope

Overrides:

addProcessor in class ProvenanceWriter

Throws:

java.sql.SQLException

addVariables

public void addVariables(java.util.List<Var> vars,
                         java.lang.String wfId)
                  throws java.sql.SQLException

Description copied from class: ProvenanceWriter

add each Var as a row into the VAR DB table
note: no static var type available as part of the dataflow...

Overrides:

addVariables in class ProvenanceWriter

Throws:

java.sql.SQLException

addArc

public void addArc(Var sourceVar,
                   Var sinkVar,
                   java.lang.String wfId)
            throws java.sql.SQLException

Description copied from class: ProvenanceWriter

inserts one row into the ARC DB table -- OBSOLETE, see instead

Overrides:

addArc in class ProvenanceWriter

Throws:

java.sql.SQLException

addArc

public void addArc(java.lang.String sourceVarName,
                   java.lang.String sourceProcName,
                   java.lang.String sinkVarName,
                   java.lang.String sinkProcName,
                   java.lang.String wfId)

Overrides:

addArc in class ProvenanceWriter

addWFInstanceId

public void addWFInstanceId(java.lang.String wfId,
                            java.lang.String wfInstanceId)
                     throws java.sql.SQLException

Overrides:

addWFInstanceId in class ProvenanceWriter

Throws:

java.sql.SQLException

addProcessorBinding

public void addProcessorBinding(ProcBinding pb)
                         throws java.sql.SQLException

Overrides:

addProcessorBinding in class ProvenanceWriter

Throws:

java.sql.SQLException

addCollection

public java.lang.String addCollection(java.lang.String processorId,
                                      java.lang.String collId,
                                      java.lang.String parentCollectionId,
                                      java.lang.String iteration,
                                      java.lang.String portName,
                                      java.lang.String dataflowId)
                               throws java.sql.SQLException

Overrides:

addCollection in class ProvenanceWriter

Throws:

java.sql.SQLException

addVarBinding

public void addVarBinding(VarBinding vb)
                   throws java.sql.SQLException

also fetches data values from the Data table of the relational provenance DB and adds it as a rdfs:comment to the RDF graph

Overrides:

addVarBinding in class ProvenanceWriter

Throws:

java.sql.SQLException

getModel

public com.hp.hpl.jena.rdf.model.Model getModel()

Returns:

the m

setModel

public void setModel(com.hp.hpl.jena.rdf.model.Model m)

Parameters:

m - the m to set