SQLQueryV8

java.lang.Object
- org.kepler.provenance.DefaultQuery
- - org.kepler.provenance.sql.SQLQueryV8

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Queryable
```
public class SQLQueryV8
extends DefaultQuery
```
Implementation of query interface for SQL v8.

Author:

Daniel Crawl, Derik Barseghian, Ben Leinfelder

Field Summary

Fields
Modifier and Type	Field and Description
`protected DatabaseType`	`_dbType` The connection to the database.
`protected static java.sql.Timestamp`	`_maxEndTime` The most futuristic Timestamp possible!
`protected static java.sql.Timestamp`	`_minStartTime` The earliest Timestamp possible.
`protected java.sql.PreparedStatement`	`_psActorExecutionTimes`
`protected java.sql.PreparedStatement`	`_psActorFireId`
`protected java.sql.PreparedStatement`	`_psActorFiringForTokenWrite`
`protected java.sql.PreparedStatement`	`_psActorFirings`
`protected java.sql.PreparedStatement`	`_psActorFiringsForExecution`
`protected java.sql.PreparedStatement`	`_psActorFiringsForTokenRead`
`protected java.sql.PreparedStatement`	`_psActorNameForFiring`
`protected java.sql.PreparedStatement`	`_psActorTypeForFiring`
`protected java.sql.PreparedStatement`	`_psAssociatedKeysValuesForExecution`
`protected java.sql.PreparedStatement`	`_psChangesForTimespan`
`protected java.sql.PreparedStatement`	`_psChangesForTimespanOnHost`
`protected java.sql.PreparedStatement`	`_psChannelForTokenRead`
`protected java.sql.PreparedStatement`	`_psChannelForTokenWrite`
`protected java.sql.PreparedStatement`	`_psDataContents`
`protected java.sql.PreparedStatement`	`_psDataMD5s`
`protected java.sql.PreparedStatement`	`_psDoesExecutionHaveError`
`protected java.sql.PreparedStatement`	`_psEntitiesForChange`
`protected java.sql.PreparedStatement`	`_psEntityId`
`protected java.sql.PreparedStatement`	`_psEntityIdLSID`
`protected java.sql.PreparedStatement`	`_psEntityTokensForExecution`
`protected java.sql.PreparedStatement`	`_psEntityType`
`protected java.sql.PreparedStatement`	`_psEntityWorkflowId`
`protected java.sql.PreparedStatement`	`_psErrorForExecution`
`protected java.sql.PreparedStatement`	`_psExecutionForExecutionLSID`
`protected java.sql.PreparedStatement`	`_psExecutionForExecutionLSIDWithoutRevision`
`protected java.sql.PreparedStatement`	`_psExecutionForOldestReferralExecutionLSIDWithoutRevision`
`protected java.sql.PreparedStatement`	`_psExecutionIdsForTags`
`protected java.sql.PreparedStatement`	`_psExecutionLSIDForExecution`
`protected java.sql.PreparedStatement`	`_psExecutionLSIDs`
`protected java.sql.PreparedStatement`	`_psExecutionLSIDsForWorkflowRuns`
`protected java.sql.PreparedStatement`	`_psExecutions`
`protected java.sql.PreparedStatement`	`_psExecutionsForAnnotation`
`protected java.sql.PreparedStatement`	`_psExecutionsForTimespan`
`protected java.sql.PreparedStatement`	`_psExecutionsForTimespanOnHost`
`protected java.sql.PreparedStatement`	`_psExecutionsForType`
`protected java.sql.PreparedStatement`	`_psExecutionsForWorkflow`
`protected java.sql.PreparedStatement`	`_psExecutionsForWorkflowNameContains`
`protected java.sql.PreparedStatement`	`_psExecutionsForWorkflowRuns`
`protected java.sql.PreparedStatement`	`_psExecutionsForWorkflowRuns2`
`protected java.sql.PreparedStatement`	`_psExecutionsForWorkflowRunsAfter`
`protected java.sql.PreparedStatement`	`_psExecutionsForWorkflowRunsAt`
`protected java.sql.PreparedStatement`	`_psExecutionsForWorkflowRunsBefore`
`protected java.sql.PreparedStatement`	`_psHostIdForExecution`
`protected java.sql.PreparedStatement`	`_psInputRoleToken`
`protected java.sql.PreparedStatement`	`_psIsExecutionImported`
`protected java.sql.PreparedStatement`	`_psLastChangeTime`
`protected java.sql.PreparedStatement`	`_psLastChangeTimeForWorkflowId`
`protected java.sql.PreparedStatement`	`_psLastExecutionForWorkflow`
`protected java.sql.PreparedStatement`	`_psLastExecutionForWorkflowLSID`
`protected java.sql.PreparedStatement`	`_psLastExecutionLSIDForWorkflowLSID`
`protected java.sql.PreparedStatement`	`_psLastExecutionLSIDForWorkflowName`
`protected java.sql.PreparedStatement`	`_psLastExecutionStartTime`
`protected java.sql.PreparedStatement`	`_psLastExecutionStartTimeForWorkflowId`
`protected java.sql.PreparedStatement`	`_psMomlForExecutionId`
`protected java.sql.PreparedStatement`	`_psMomlForExecutionLSID`
`protected java.sql.Statement`	`_psMoMLMD5sForExecutions`
`protected java.sql.PreparedStatement`	`_psOutputRoleToken`
`protected java.sql.PreparedStatement`	`_psParamAndPortParamNameValuesForFiring`
`protected java.sql.PreparedStatement`	`_psParamNameValuesForExecution`
`protected java.sql.PreparedStatement`	`_psParamNameValuesForFiring`
`protected java.sql.PreparedStatement`	`_psParamNameValuesOfSpecificTypeForExecution`
`protected java.sql.PreparedStatement`	`_psParamValueAtTimeForWorkflowLSID`
`protected java.sql.PreparedStatement`	`_psPortEventData`
`protected java.sql.PreparedStatement`	`_psPortIOBytesRead`
`protected java.sql.PreparedStatement`	`_psPortIOBytesWrite`
`protected java.sql.PreparedStatement`	`_psPortsForActor`
`protected java.sql.PreparedStatement`	`_psTagsForExecutionId`
`protected java.sql.PreparedStatement`	`_psTagURNsForExecutionId`
`protected java.sql.PreparedStatement`	`_psTimestampForTokenWrite`
`protected java.sql.PreparedStatement`	`_psTimestampsForActorFiring`
`protected java.sql.PreparedStatement`	`_psTimestampsForExecution`
`protected java.sql.PreparedStatement`	`_psTimestampsForTokenRead`
`protected java.sql.PreparedStatement`	`_psTokensForExecution`
`protected java.sql.PreparedStatement`	`_psTokensForFiring`
`protected java.sql.PreparedStatement`	`_psTokensReadForFiring`
`protected java.sql.PreparedStatement`	`_psTokensWrittenForFiring`
`protected java.sql.PreparedStatement`	`_psTokenType`
`protected java.sql.PreparedStatement`	`_psTypeForTag`
`protected java.sql.PreparedStatement`	`_psUserForExecution`
`protected java.sql.PreparedStatement`	`_psUserForExecutionLSID`
`protected java.sql.PreparedStatement`	`_psWorkflowNameForExecutionLSID`
`protected java.sql.PreparedStatement`	`_psWorkflowNameForLSID`
`protected java.sql.PreparedStatement`	`_psWorkflowRunsForExecutionLSIDs`
`protected java.sql.PreparedStatement`	`_psWorkflowRunsForExecutions`
`protected java.sql.PreparedStatement`	`_psWorkflows`

Constructor Summary

Constructors
Modifier	Constructor and Description
`protected`	`SQLQueryV8(DatabaseType dbType)` Construct a new SQLQueryV8 from a connected DatabaseType.
	`SQLQueryV8(java.util.Map<java.lang.String,java.lang.String> parameters)` Construct a new SQLQueryV8 and connect to a database.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`protected void`	`_createPreparedStatements()` Initialize the prepared statements.
`protected void`	`_debug(java.lang.String str)`
`protected java.util.List<java.lang.Integer>`	`_getChangesForTimespan(java.util.Date start, java.util.Date end, java.lang.String workflow, java.lang.String host)` Get changes performed on a host within a timespan.
`protected java.util.List<java.lang.Integer>`	`_getChangesSince(java.util.Date timeStamp, java.lang.String workflowName, java.lang.String hostName)` Get changes performed since a specific time.
`protected java.util.List<java.lang.String>`	`_getDataMD5s()` Get all the data MD5 checksums.
`protected java.util.List<java.lang.Integer>`	`_getEntitiesForChange(int changeId)` Get the entities for a workflow change.
`protected java.lang.String`	`_getEntityName(java.lang.String name)` Given a fully-qualified entity name, return the name as it would appear in the entity table.
`protected java.util.List<java.lang.Integer>`	`_getExecutionsForTimespan(java.util.Date start, java.util.Date end, java.lang.String workflow, java.lang.String host)` Get executions for a worfkflow run on a host within a timespan.
`protected java.util.List<java.lang.Integer>`	`_getExecutionsStartedSince(java.util.Date timeStamp, boolean including, java.lang.String workflowName, java.lang.String hostName)` Get executions started since a specific time.
`protected java.lang.String`	`_getFullNameFromEntityName(java.lang.String entity, java.lang.String full)` Given a name from the entity table, return the fully-qualified name.
`protected java.util.List<java.lang.Integer>`	`_getIntResults(java.sql.PreparedStatement query, int index)` Convenience routine to get a list of integer SQL results.
`protected java.util.Date`	`_getLastChangeTime(int workflowId, java.lang.String hostName)` Get the last change time for a workflow.
`protected java.util.Date`	`_getLastChangeTime(java.lang.String workflowName, java.lang.String hostName)` Get the last change time for a workflow.
`protected java.util.Date`	`_getLastExecutionStartTime(int workflowId, java.lang.String hostName)` Get the last execution start time.
`protected java.util.Date`	`_getLastExecutionStartTime(java.lang.String workflowName, java.lang.String hostName)` Get the last execution start time.
`protected static java.util.Map<java.lang.String,java.lang.String>`	`_getParameterNameValues(java.sql.PreparedStatement statement)` A convenience method that executes a query returning parameter name value pairs.
`protected java.util.List<java.lang.String>`	`_getStringResults(java.sql.PreparedStatement query, int index)` Convenience routine to get a list of string SQL results.
`protected java.util.List<java.lang.String>`	`_getStringResults(java.sql.Statement statement, java.lang.String queryStr, int index)` Convenience routine to get a list of string SQL results.
`protected int`	`_getWorkflow(java.lang.String workflow)` Get the id for a workflow.
`protected void`	`_init()` Check the schema version and initialize the prepared statements.
`protected void`	`_nullPreparedStatements()` Set our prepared statements to null.
`protected boolean`	`_stringTokenValuesHaveSurroundingQuotes()` Returns true since SQLRecordingV8 saves StringToken values using StringToken.toString(), which adds surrounding double-quotes.
`void`	`disconnect()` Disconnect from provenance store.
`java.util.List<java.lang.Integer>`	`getActorFiringForToken(int tokenId, boolean read)` Get the firing id(s) of the actor(s) that read or wrote a token.
`java.util.List<java.lang.Integer>`	`getActorFiringIds(java.lang.String actorName, java.lang.Integer wfExecId)` Get actor fire ids based on its full name and workflow exec ID.
`java.util.List<java.lang.Integer>`	`getActorFirings(int wfExecId)` Get all actor fire ids for a workflow exec ID.
`java.lang.String`	`getActorName(int fireId)` Get an actor's name for a firing id.
`java.lang.String`	`getActorType(int fireId)` Get an actor's type for a firing id.
`java.util.List<byte[]>`	`getAssociatedDataForExecution(int execId, java.util.Map<java.lang.String,java.lang.String> metadataMap, boolean matchAny)` Get a file associated with an execution.
`java.util.Map<java.lang.String,java.lang.String>`	`getAssociatedKeysValuesForExecution(int execId)` Get any associated keys-values for an execution.
`java.util.List<java.lang.Integer>`	`getChangesForTimespan(java.util.Date start, java.util.Date end)` Get changes within a timespan.
`java.lang.Integer`	`getChannelForToken(int tokenId, boolean read, java.lang.Integer fireId)` Get the channel that a token was read or written on.
`java.lang.Integer`	`getEntityId(java.lang.String entityName, KeplerLSID lsid)` Get the id of entity.
`java.lang.Integer`	`getEntityId(java.lang.String entityName, java.lang.String workflowName)` Get the id of entity.
`java.lang.String`	`getEntityType(java.lang.Integer entityId)` Get the type of entity.
`java.lang.Integer`	`getEntityWorkflowId(java.lang.Integer entityId)` Get the workflow id of entity.
`java.lang.String`	`getErrorForExecution(KeplerLSID lsid)` Get the error for an execution.
`java.lang.Integer`	`getExecutionForExecutionLSID(KeplerLSID execLSID)` Get the execution ids for a specific exec LSID.
`java.lang.Integer`	`getExecutionForExecutionLSIDWithoutRevision(java.lang.String execLSIDWithoutRevision)` Get execution id for an execution LSID without revision.
`java.lang.Integer`	`getExecutionForOldestReferralExecutionLSIDWithoutRevision(java.lang.String execLSIDWithoutRevision)` Get execution id for execution that has the given LSID as its oldest referral.
`java.util.List<java.lang.Integer>`	`getExecutionIdsForTags(java.lang.String tagsSearchString)` Get a list of executions for workflow(s) with tags that contain tagsSearchString (case insensitive)
`KeplerLSID`	`getExecutionLSIDForExecution(java.lang.Integer execId)` Get the execution LSID for a specific execution id.
`java.util.List<KeplerLSID>`	`getExecutionLSIDs()` Get a list of all execution LSIDs.
`java.util.List<KeplerLSID>`	`getExecutionLSIDsForWorkflowRuns(java.lang.String workflowName, java.lang.String userName, java.util.Date after, java.util.Date before, int execIdAfter, int execIdBefore)` Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria.
`java.util.List<java.lang.Integer>`	`getExecutions()` Get a list of all executions.
`java.util.List<java.lang.Integer>`	`getExecutionsForAnnotation(java.lang.String annotation)` Get a list of executions for a specific execution annotation.
`java.util.List<java.lang.Integer>`	`getExecutionsForTimespan(java.util.Date start, java.util.Date end)` Get executions within a timespan.
`java.util.List<KeplerLSID>`	`getExecutionsForType(WorkflowRun.type type)` Get a list of executions corresponding to a specific type.
`java.util.List<java.lang.Integer>`	`getExecutionsForWorkflow(java.lang.String workflow)` Get a list of executions for a specific workflow.
`java.util.List<java.lang.Integer>`	`getExecutionsForWorkflowNameContains(java.lang.String text)` Get a list of executions for workflow(s) with names that contain text (case insensitive).
`java.util.List<java.lang.Integer>`	`getExecutionsForWorkflowRuns(java.lang.String workflowName, java.lang.String userName)` Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria.
`java.util.List<java.lang.Integer>`	`getExecutionsForWorkflowRuns(java.lang.String workflowName, java.lang.String userName, java.util.Date after, java.util.Date before, int execIdAfter, int execIdBefore)` Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria.
`java.util.List<java.lang.Integer>`	`getExecutionsForWorkflowRunsAfter(java.lang.String workflowName, java.lang.String userName, java.util.Date after)` Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria after a date.
`java.util.List<java.lang.Integer>`	`getExecutionsForWorkflowRunsAt(java.lang.String workflowName, java.lang.String userName, java.lang.String date)` Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria "at" a date.
`java.util.List<java.lang.Integer>`	`getExecutionsForWorkflowRunsBefore(java.lang.String workflowName, java.lang.String userName, java.util.Date before)` Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria before a date.
`java.util.Map<java.lang.String,java.lang.Long>`	`getExecutionTimesForActor(KeplerLSID workflow, KeplerLSID execLSID, java.lang.String actor)` Get the execution times for an actor.
`java.lang.String`	`getHostIdForExecution(java.lang.Integer execId)` Get the host id for a specific execution id.
`java.util.List<java.lang.Integer>`	`getImmediateDependencies(int tokenId)` Get the immediate tokens that generated a token.
`java.lang.String`	`getInputRoleForTokenAndFireId(int tokenId, int fireId)` Get the input role (port name) of a token.
`java.util.Map<java.lang.Integer,java.lang.Integer>`	`getIOBytesForPort(KeplerLSID workflow, java.lang.Integer execId, java.lang.String port, boolean read)` Get the number of bytes read or written by a port.
`java.lang.Integer`	`getLastExecutionForWorkflow(KeplerLSID lsid)` Get the last execution for a workflow.
`java.lang.Integer`	`getLastExecutionForWorkflow(java.lang.String workflow)` Get the last execution for a workflow.
`KeplerLSID`	`getLastExecutionLSIDForWorkflow(KeplerLSID lsid)` Get the last execution LSID for a workflow.
`KeplerLSID`	`getLastExecutionLSIDForWorkflow(java.lang.String workflow)` Get the last execution LSID for a workflow.
`java.lang.String`	`getMoMLForExecution(int execId)` Get workflow MoML for an execution, using execution id
`java.lang.String`	`getMoMLForExecution(KeplerLSID lsid)` Get workflow MoML for an execution, using execution lsid.
`java.util.ArrayList<java.lang.String>`	`getMoMLForExecutionLSIDs(java.util.List<KeplerLSID> lsids)` Get workflow MoMLs for a list of execution lsids.
`java.lang.String`	`getOutputRoleToken(int tokenId)` Get the output role (port name) of a token.
`java.util.Map<java.lang.String,java.lang.String>`	`getParameterAndPortParameterNameValuesForFiring(int fireId)` Get an actor's parameter and port parameter name value pairs for a firing id.
`java.util.Map<java.lang.String,java.lang.String>`	`getParameterNameValuesForExecution(int execId)` Get the parameter name value pairs for an execution.
`java.util.Map<java.lang.String,java.lang.String>`	`getParameterNameValuesForFiring(int fireId)` Get an actor's parameter name value pairs for a firing id.
`java.util.Map<java.lang.String,java.lang.String>`	`getParameterNameValuesOfSpecificTypeForExecution(int execId)` Get the parameter name value pairs for an execution, whose parameter type is either '.Parameter' or '.StringParameter'
`java.lang.String`	`getParameterValueAtTime(java.util.Date timestamp, java.lang.String parameter, KeplerLSID lsid)` Get the value of a parameter at a specific time.
`java.lang.String`	`getParameterValueLatest(java.lang.String parameter, KeplerLSID lsid)` Get the latest value of a parameter.
`java.util.List<java.lang.String>`	`getPortsForActor(KeplerLSID workflow, java.lang.String actor)` Get the ports for an actor.
`java.util.List<java.lang.String>`	`getSavedFilenames()` Get a list of files saved in the database.
`java.util.Map<NamedOntClass,java.lang.String>`	`getTagClassesForExecutionId(int execId)` Get a map of tags and their types (context, or tagee, currently "run" or "workflow") for an executionLSID
`java.util.List<java.lang.String>`	`getTagsForExecutionId(int execId)` Get tags for an execution LSID
`java.util.List<java.lang.String>`	`getTagURNsForExecutionLSID(KeplerLSID execLSID)`
`java.util.Date`	`getTimestampForTokenWrite(java.lang.Integer tokenId)` Get the timestamp when a token was written.
`java.util.Date[]`	`getTimestampsForActorFiring(int fireId)` Get the start and end timestamps of an actor firing.
`java.util.Date[]`	`getTimestampsForExecution(int execId)` Get the start and end timestamps of an execution.
`java.util.Date[]`	`getTimestampsForTokenRead(java.lang.Integer tokenId)` Get the timestamp(s) when a token was read.
`java.util.List<java.lang.Integer>`	`getTokensForExecution(int execId, java.lang.Integer portId, boolean last)` Get an sequence of tokens for an execution.
`java.util.List<java.lang.Integer>`	`getTokensForFiring(int fireId, boolean read)` Get tokens for a firing.
`java.lang.String`	`getTokenType(int tokenId)` Get the type of a token.
`java.lang.String`	`getTokenValue(int tokenId)` Get the value of a token.
`java.lang.String`	`getTypeForTag(java.lang.String conceptId)` Get the type of a tag, null if none
`java.lang.String`	`getUserForExecution(java.lang.Integer execId)` Get the user for a specific execution id.
`java.lang.String`	`getUserForExecution(KeplerLSID execLSID)` Get the user for a specific execution LSID.
`java.lang.String`	`getWorkflowName(KeplerLSID lsid)` Get a workflow name.
`java.lang.String`	`getWorkflowNameForExecution(KeplerLSID lsid)` Get a workflow name for an execution LSID.
`java.util.Map<KeplerLSID,WorkflowRun>`	`getWorkflowRunsForExecutionLSIDs(java.util.List<KeplerLSID> executionLSIDs)` Get WorkflowRuns for a list of execution LSIDs
`java.util.List<WorkflowRun>`	`getWorkflowRunsForUser(java.lang.String user)` Get workflow runs for a user.
`java.util.List<java.lang.String>`	`getWorkflows()` Get a list of workflow names.
`boolean`	`isErrorForExecution(KeplerLSID executionLSID)` Returns true if the execution had an error.
`boolean`	`isImportedExecution(KeplerLSID executionLSID)` See if an execution appears to be imported.

Methods inherited from class org.kepler.provenance.DefaultQuery
_getLastExecutionId, close, getToken, getTokensForExecution, getTotalExecutionTimeForActor, getTotalIOBytesForActor, getWorkflowForExecution

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_dbType
```
protected DatabaseType _dbType
```
The connection to the database.

_psActorFiringForTokenWrite

protected java.sql.PreparedStatement _psActorFiringForTokenWrite

_psActorFiringsForExecution

protected java.sql.PreparedStatement _psActorFiringsForExecution

_psActorFiringsForTokenRead

protected java.sql.PreparedStatement _psActorFiringsForTokenRead

_psActorFireId

protected java.sql.PreparedStatement _psActorFireId

_psActorFirings

protected java.sql.PreparedStatement _psActorFirings

_psActorNameForFiring

protected java.sql.PreparedStatement _psActorNameForFiring

_psActorTypeForFiring

protected java.sql.PreparedStatement _psActorTypeForFiring

_psChannelForTokenRead

protected java.sql.PreparedStatement _psChannelForTokenRead

_psChannelForTokenWrite

protected java.sql.PreparedStatement _psChannelForTokenWrite

_psChangesForTimespan

protected java.sql.PreparedStatement _psChangesForTimespan

_psChangesForTimespanOnHost

protected java.sql.PreparedStatement _psChangesForTimespanOnHost

_psDataMD5s

protected java.sql.PreparedStatement _psDataMD5s

_psDoesExecutionHaveError

protected java.sql.PreparedStatement _psDoesExecutionHaveError

_psEntitiesForChange

protected java.sql.PreparedStatement _psEntitiesForChange

_psEntityId

protected java.sql.PreparedStatement _psEntityId

_psEntityWorkflowId

protected java.sql.PreparedStatement _psEntityWorkflowId

_psEntityIdLSID

protected java.sql.PreparedStatement _psEntityIdLSID

_psEntityTokensForExecution

protected java.sql.PreparedStatement _psEntityTokensForExecution

_psEntityType

protected java.sql.PreparedStatement _psEntityType

_psErrorForExecution

protected java.sql.PreparedStatement _psErrorForExecution

_psExecutions

protected java.sql.PreparedStatement _psExecutions

_psExecutionsForAnnotation

protected java.sql.PreparedStatement _psExecutionsForAnnotation

_psExecutionsForTimespan

protected java.sql.PreparedStatement _psExecutionsForTimespan

_psExecutionsForTimespanOnHost

protected java.sql.PreparedStatement _psExecutionsForTimespanOnHost

_psExecutionsForType

protected java.sql.PreparedStatement _psExecutionsForType

_psExecutionsForWorkflow

protected java.sql.PreparedStatement _psExecutionsForWorkflow

_psExecutionForExecutionLSID

protected java.sql.PreparedStatement _psExecutionForExecutionLSID

_psExecutionForExecutionLSIDWithoutRevision

protected java.sql.PreparedStatement _psExecutionForExecutionLSIDWithoutRevision

_psExecutionForOldestReferralExecutionLSIDWithoutRevision

protected java.sql.PreparedStatement _psExecutionForOldestReferralExecutionLSIDWithoutRevision

_psExecutionLSIDForExecution

protected java.sql.PreparedStatement _psExecutionLSIDForExecution

_psExecutionsForWorkflowNameContains

protected java.sql.PreparedStatement _psExecutionsForWorkflowNameContains

_psExecutionsForWorkflowRuns

protected java.sql.PreparedStatement _psExecutionsForWorkflowRuns

_psExecutionsForWorkflowRunsAfter

protected java.sql.PreparedStatement _psExecutionsForWorkflowRunsAfter

_psExecutionsForWorkflowRunsAt

protected java.sql.PreparedStatement _psExecutionsForWorkflowRunsAt

_psExecutionsForWorkflowRunsBefore

protected java.sql.PreparedStatement _psExecutionsForWorkflowRunsBefore

_psExecutionsForWorkflowRuns2

protected java.sql.PreparedStatement _psExecutionsForWorkflowRuns2

_psExecutionLSIDsForWorkflowRuns

protected java.sql.PreparedStatement _psExecutionLSIDsForWorkflowRuns

_psExecutionIdsForTags

protected java.sql.PreparedStatement _psExecutionIdsForTags

_psExecutionLSIDs

protected java.sql.PreparedStatement _psExecutionLSIDs

_psIsExecutionImported

protected java.sql.PreparedStatement _psIsExecutionImported

_psTagsForExecutionId

protected java.sql.PreparedStatement _psTagsForExecutionId

_psTagURNsForExecutionId

protected java.sql.PreparedStatement _psTagURNsForExecutionId

_psTypeForTag

protected java.sql.PreparedStatement _psTypeForTag

_psLastChangeTime

protected java.sql.PreparedStatement _psLastChangeTime

_psLastChangeTimeForWorkflowId

protected java.sql.PreparedStatement _psLastChangeTimeForWorkflowId

_psLastExecutionForWorkflow

protected java.sql.PreparedStatement _psLastExecutionForWorkflow

_psLastExecutionForWorkflowLSID

protected java.sql.PreparedStatement _psLastExecutionForWorkflowLSID

_psLastExecutionLSIDForWorkflowName

protected java.sql.PreparedStatement _psLastExecutionLSIDForWorkflowName

_psLastExecutionLSIDForWorkflowLSID

protected java.sql.PreparedStatement _psLastExecutionLSIDForWorkflowLSID

_psLastExecutionStartTime

protected java.sql.PreparedStatement _psLastExecutionStartTime

_psLastExecutionStartTimeForWorkflowId

protected java.sql.PreparedStatement _psLastExecutionStartTimeForWorkflowId

_psMomlForExecutionId

protected java.sql.PreparedStatement _psMomlForExecutionId

_psMomlForExecutionLSID

protected java.sql.PreparedStatement _psMomlForExecutionLSID

_psParamNameValuesForExecution

protected java.sql.PreparedStatement _psParamNameValuesForExecution

_psParamNameValuesForFiring

protected java.sql.PreparedStatement _psParamNameValuesForFiring

_psParamValueAtTimeForWorkflowLSID

protected java.sql.PreparedStatement _psParamValueAtTimeForWorkflowLSID

_psTimestampsForExecution

protected java.sql.PreparedStatement _psTimestampsForExecution

_psTimestampForTokenWrite

protected java.sql.PreparedStatement _psTimestampForTokenWrite

_psTimestampsForTokenRead

protected java.sql.PreparedStatement _psTimestampsForTokenRead

_psTokenType

protected java.sql.PreparedStatement _psTokenType

_psPortEventData

protected java.sql.PreparedStatement _psPortEventData

_psDataContents

protected java.sql.PreparedStatement _psDataContents

_psTokensForExecution

protected java.sql.PreparedStatement _psTokensForExecution

_psTokensForFiring

protected java.sql.PreparedStatement _psTokensForFiring

_psTokensReadForFiring

protected java.sql.PreparedStatement _psTokensReadForFiring

_psTokensWrittenForFiring

protected java.sql.PreparedStatement _psTokensWrittenForFiring

_psWorkflowRunsForExecutions

protected java.sql.PreparedStatement _psWorkflowRunsForExecutions

_psWorkflowRunsForExecutionLSIDs

protected java.sql.PreparedStatement _psWorkflowRunsForExecutionLSIDs

_psWorkflows

protected java.sql.PreparedStatement _psWorkflows

_psWorkflowNameForLSID

protected java.sql.PreparedStatement _psWorkflowNameForLSID

_psWorkflowNameForExecutionLSID

protected java.sql.PreparedStatement _psWorkflowNameForExecutionLSID

_psMoMLMD5sForExecutions

protected java.sql.Statement _psMoMLMD5sForExecutions

_psPortsForActor

protected java.sql.PreparedStatement _psPortsForActor

_psHostIdForExecution

protected java.sql.PreparedStatement _psHostIdForExecution

_psUserForExecution

protected java.sql.PreparedStatement _psUserForExecution

_psUserForExecutionLSID

protected java.sql.PreparedStatement _psUserForExecutionLSID

_psOutputRoleToken

protected java.sql.PreparedStatement _psOutputRoleToken

_psInputRoleToken

protected java.sql.PreparedStatement _psInputRoleToken

_psParamNameValuesOfSpecificTypeForExecution

protected java.sql.PreparedStatement _psParamNameValuesOfSpecificTypeForExecution

_psTimestampsForActorFiring

protected java.sql.PreparedStatement _psTimestampsForActorFiring

_psParamAndPortParamNameValuesForFiring

protected java.sql.PreparedStatement _psParamAndPortParamNameValuesForFiring

_psActorExecutionTimes

protected java.sql.PreparedStatement _psActorExecutionTimes

_psPortIOBytesRead

protected java.sql.PreparedStatement _psPortIOBytesRead

_psPortIOBytesWrite

protected java.sql.PreparedStatement _psPortIOBytesWrite

_psAssociatedKeysValuesForExecution

protected java.sql.PreparedStatement _psAssociatedKeysValuesForExecution

_maxEndTime

protected static final java.sql.Timestamp _maxEndTime

The most futuristic Timestamp possible!

_minStartTime

protected static final java.sql.Timestamp _minStartTime

The earliest Timestamp possible.

Constructor Detail

SQLQueryV8

public SQLQueryV8(java.util.Map<java.lang.String,java.lang.String> parameters)
           throws QueryException

Construct a new SQLQueryV8 and connect to a database.

Throws:: QueryException

SQLQueryV8
```
protected SQLQueryV8(DatabaseType dbType)
              throws QueryException
```
Construct a new SQLQueryV8 from a connected DatabaseType.

Throws:

QueryException

Method Detail
- disconnect
```
public void disconnect()
                throws QueryException
```
  Disconnect from provenance store.
  
  Specified by:
  
  disconnect in interface Queryable
  
  Overrides:
  
  disconnect in class DefaultQuery
  
  Throws:
  
  QueryException
- getWorkflows
```
public java.util.List<java.lang.String> getWorkflows()
                                              throws QueryException
```
  Get a list of workflow names.
  
  Specified by:
  
  getWorkflows in interface Queryable
  
  Overrides:
  
  getWorkflows in class DefaultQuery
  
  Throws:
  
  QueryException
- getWorkflowName
```
public java.lang.String getWorkflowName(KeplerLSID lsid)
                                 throws QueryException
```
  Get a workflow name.
  
  Specified by:
  
  getWorkflowName in interface Queryable
  
  Overrides:
  
  getWorkflowName in class DefaultQuery
  
  Parameters:
  
  lsid - the workflow's LSID.
  
  Returns:
  
  the workflow name if found, otherwise null.
  
  Throws:
  
  QueryException
- getWorkflowNameForExecution
```
public java.lang.String getWorkflowNameForExecution(KeplerLSID lsid)
                                             throws QueryException
```
  Get a workflow name for an execution LSID.
  
  Specified by:
  
  getWorkflowNameForExecution in interface Queryable
  
  Overrides:
  
  getWorkflowNameForExecution in class DefaultQuery
  
  Parameters:
  
  lsid - the execution LSID.
  
  Returns:
  
  the workflow name if found, otherwise null.
  
  Throws:
  
  QueryException
- getChangesForTimespan
```
public java.util.List<java.lang.Integer> getChangesForTimespan(java.util.Date start,
                                                               java.util.Date end)
                                                        throws QueryException
```
  Get changes within a timespan.
  
  Throws:
  
  QueryException
- getExecutions
```
public java.util.List<java.lang.Integer> getExecutions()
                                                throws QueryException
```
  Get a list of all executions.
  
  Specified by:
  
  getExecutions in interface Queryable
  
  Overrides:
  
  getExecutions in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionLSIDs
```
public java.util.List<KeplerLSID> getExecutionLSIDs()
                                             throws QueryException
```
  Get a list of all execution LSIDs.
  
  Specified by:
  
  getExecutionLSIDs in interface Queryable
  
  Overrides:
  
  getExecutionLSIDs in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionIdsForTags
```
public java.util.List<java.lang.Integer> getExecutionIdsForTags(java.lang.String tagsSearchString)
                                                         throws QueryException
```
  Get a list of executions for workflow(s) with tags that contain tagsSearchString (case insensitive)
  
  Specified by:
  
  getExecutionIdsForTags in interface Queryable
  
  Overrides:
  
  getExecutionIdsForTags in class DefaultQuery
  
  Throws:
  
  QueryException
- getTagClassesForExecutionId
```
public java.util.Map<NamedOntClass,java.lang.String> getTagClassesForExecutionId(int execId)
                                                                          throws QueryException
```
  Description copied from interface: Queryable
  
  Get a map of tags and their types (context, or tagee, currently "run" or "workflow") for an executionLSID
  
  Specified by:
  
  getTagClassesForExecutionId in interface Queryable
  
  Overrides:
  
  getTagClassesForExecutionId in class DefaultQuery
  
  Throws:
  
  QueryException
- getTypeForTag
```
public java.lang.String getTypeForTag(java.lang.String conceptId)
```
  Get the type of a tag, null if none
  
  Specified by:
  
  getTypeForTag in interface Queryable
  
  Overrides:
  
  getTypeForTag in class DefaultQuery
- getTagsForExecutionId
```
public java.util.List<java.lang.String> getTagsForExecutionId(int execId)
                                                       throws QueryException
```
  Description copied from interface: Queryable
  
  Get tags for an execution LSID
  
  Specified by:
  
  getTagsForExecutionId in interface Queryable
  
  Overrides:
  
  getTagsForExecutionId in class DefaultQuery
  
  Throws:
  
  QueryException
- getTagURNsForExecutionLSID
```
public java.util.List<java.lang.String> getTagURNsForExecutionLSID(KeplerLSID execLSID)
                                                            throws QueryException
```
  Throws:
  
  QueryException
- getMoMLForExecution
```
public java.lang.String getMoMLForExecution(int execId)
                                     throws QueryException
```
  Get workflow MoML for an execution, using execution id
  
  Specified by:
  
  getMoMLForExecution in interface Queryable
  
  Overrides:
  
  getMoMLForExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- getMoMLForExecution
```
public java.lang.String getMoMLForExecution(KeplerLSID lsid)
                                     throws QueryException
```
  Get workflow MoML for an execution, using execution lsid.
  
  Specified by:
  
  getMoMLForExecution in interface Queryable
  
  Overrides:
  
  getMoMLForExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- getMoMLForExecutionLSIDs
```
public java.util.ArrayList<java.lang.String> getMoMLForExecutionLSIDs(java.util.List<KeplerLSID> lsids)
```
  Get workflow MoMLs for a list of execution lsids. Only returns one copy of any duplicates.
  
  Specified by:
  
  getMoMLForExecutionLSIDs in interface Queryable
  
  Overrides:
  
  getMoMLForExecutionLSIDs in class DefaultQuery
- getExecutionsForTimespan
```
public java.util.List<java.lang.Integer> getExecutionsForTimespan(java.util.Date start,
                                                                  java.util.Date end)
                                                           throws QueryException
```
  Get executions within a timespan.
  
  Specified by:
  
  getExecutionsForTimespan in interface Queryable
  
  Overrides:
  
  getExecutionsForTimespan in class DefaultQuery
  
  Throws:
  
  QueryException
- getWorkflowRunsForExecutionLSIDs
```
public java.util.Map<KeplerLSID,WorkflowRun> getWorkflowRunsForExecutionLSIDs(java.util.List<KeplerLSID> executionLSIDs)
                                                                       throws QueryException
```
  Get WorkflowRuns for a list of execution LSIDs
  
  Specified by:
  
  getWorkflowRunsForExecutionLSIDs in interface Queryable
  
  Overrides:
  
  getWorkflowRunsForExecutionLSIDs in class DefaultQuery
  
  Throws:
  
  QueryException
- getWorkflowRunsForUser
```
public java.util.List<WorkflowRun> getWorkflowRunsForUser(java.lang.String user)
                                                   throws QueryException
```
  Description copied from class: DefaultQuery
  
  Get workflow runs for a user.
  
  Specified by:
  
  getWorkflowRunsForUser in interface Queryable
  
  Overrides:
  
  getWorkflowRunsForUser in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionsForWorkflow
```
public java.util.List<java.lang.Integer> getExecutionsForWorkflow(java.lang.String workflow)
                                                           throws QueryException
```
  Get a list of executions for a specific workflow.
  
  Specified by:
  
  getExecutionsForWorkflow in interface Queryable
  
  Overrides:
  
  getExecutionsForWorkflow in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionForExecutionLSID
```
public java.lang.Integer getExecutionForExecutionLSID(KeplerLSID execLSID)
                                               throws QueryException
```
  Get the execution ids for a specific exec LSID. If no execution exists, returns null.
  
  Specified by:
  
  getExecutionForExecutionLSID in interface Queryable
  
  Overrides:
  
  getExecutionForExecutionLSID in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionForExecutionLSIDWithoutRevision
```
public java.lang.Integer getExecutionForExecutionLSIDWithoutRevision(java.lang.String execLSIDWithoutRevision)
                                                              throws QueryException
```
  Get execution id for an execution LSID without revision. If no execution exists, returns null.
  
  Specified by:
  
  getExecutionForExecutionLSIDWithoutRevision in interface Queryable
  
  Overrides:
  
  getExecutionForExecutionLSIDWithoutRevision in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionForOldestReferralExecutionLSIDWithoutRevision
```
public java.lang.Integer getExecutionForOldestReferralExecutionLSIDWithoutRevision(java.lang.String execLSIDWithoutRevision)
                                                                            throws QueryException
```
  Get execution id for execution that has the given LSID as its oldest referral.
  
  Specified by:
  
  getExecutionForOldestReferralExecutionLSIDWithoutRevision in interface Queryable
  
  Overrides:
  
  getExecutionForOldestReferralExecutionLSIDWithoutRevision in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionLSIDForExecution
```
public KeplerLSID getExecutionLSIDForExecution(java.lang.Integer execId)
                                        throws QueryException
```
  Get the execution LSID for a specific execution id. If no execution exists, returns null.
  
  Specified by:
  
  getExecutionLSIDForExecution in interface Queryable
  
  Overrides:
  
  getExecutionLSIDForExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionsForWorkflowNameContains
```
public java.util.List<java.lang.Integer> getExecutionsForWorkflowNameContains(java.lang.String text)
                                                                       throws QueryException
```
  Get a list of executions for workflow(s) with names that contain text (case insensitive).
  
  Throws:
  
  QueryException
- getExecutionsForWorkflowRuns
```
public java.util.List<java.lang.Integer> getExecutionsForWorkflowRuns(java.lang.String workflowName,
                                                                      java.lang.String userName)
                                                               throws QueryException
```
  Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria.
  
  Specified by:
  
  getExecutionsForWorkflowRuns in interface Queryable
  
  Overrides:
  
  getExecutionsForWorkflowRuns in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionsForWorkflowRuns
```
public java.util.List<java.lang.Integer> getExecutionsForWorkflowRuns(java.lang.String workflowName,
                                                                      java.lang.String userName,
                                                                      java.util.Date after,
                                                                      java.util.Date before,
                                                                      int execIdAfter,
                                                                      int execIdBefore)
                                                               throws QueryException
```
  Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria.
  
  Specified by:
  
  getExecutionsForWorkflowRuns in interface Queryable
  
  Overrides:
  
  getExecutionsForWorkflowRuns in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionLSIDsForWorkflowRuns
```
public java.util.List<KeplerLSID> getExecutionLSIDsForWorkflowRuns(java.lang.String workflowName,
                                                                   java.lang.String userName,
                                                                   java.util.Date after,
                                                                   java.util.Date before,
                                                                   int execIdAfter,
                                                                   int execIdBefore)
                                                            throws QueryException
```
  Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria.
  
  Specified by:
  
  getExecutionLSIDsForWorkflowRuns in interface Queryable
  
  Overrides:
  
  getExecutionLSIDsForWorkflowRuns in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionsForWorkflowRunsBefore
```
public java.util.List<java.lang.Integer> getExecutionsForWorkflowRunsBefore(java.lang.String workflowName,
                                                                            java.lang.String userName,
                                                                            java.util.Date before)
                                                                     throws QueryException
```
  Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria before a date.
  
  Specified by:
  
  getExecutionsForWorkflowRunsBefore in interface Queryable
  
  Overrides:
  
  getExecutionsForWorkflowRunsBefore in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionsForWorkflowRunsAfter
```
public java.util.List<java.lang.Integer> getExecutionsForWorkflowRunsAfter(java.lang.String workflowName,
                                                                           java.lang.String userName,
                                                                           java.util.Date after)
                                                                    throws QueryException
```
  Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria after a date.
  
  Specified by:
  
  getExecutionsForWorkflowRunsAfter in interface Queryable
  
  Overrides:
  
  getExecutionsForWorkflowRunsAfter in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionsForWorkflowRunsAt
```
public java.util.List<java.lang.Integer> getExecutionsForWorkflowRunsAt(java.lang.String workflowName,
                                                                        java.lang.String userName,
                                                                        java.lang.String date)
                                                                 throws QueryException
```
  Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria "at" a date. We treat this date as a string so we can match using LIKE 'date%'.
  
  Throws:
  
  QueryException
- getExecutionsForAnnotation
```
public java.util.List<java.lang.Integer> getExecutionsForAnnotation(java.lang.String annotation)
                                                             throws QueryException
```
  Get a list of executions for a specific execution annotation.
  
  Specified by:
  
  getExecutionsForAnnotation in interface Queryable
  
  Overrides:
  
  getExecutionsForAnnotation in class DefaultQuery
  
  Throws:
  
  QueryException
- getTimestampsForExecution
```
public java.util.Date[] getTimestampsForExecution(int execId)
                                           throws QueryException
```
  Get the start and end timestamps of an execution.
  
  Specified by:
  
  getTimestampsForExecution in interface Queryable
  
  Overrides:
  
  getTimestampsForExecution in class DefaultQuery
  
  Parameters:
  
  execId - the execution id
  
  Returns:
  
  a two-element array: the first entry is the start timestamp, and the second is the end timestamp. If the execution id is not found, returns null.
  
  Throws:
  
  QueryException
- getLastExecutionForWorkflow
```
public java.lang.Integer getLastExecutionForWorkflow(KeplerLSID lsid)
                                              throws QueryException
```
  Get the last execution for a workflow. NOTE: the LSID revision is ignored.
  
  Specified by:
  
  getLastExecutionForWorkflow in interface Queryable
  
  Overrides:
  
  getLastExecutionForWorkflow in class DefaultQuery
  
  Parameters:
  
  lsid - the workflow lsid.
  
  Returns:
  
  if workflow has been executed, the last execution id. otherwise, returns null.
  
  Throws:
  
  QueryException
- getLastExecutionForWorkflow
```
public java.lang.Integer getLastExecutionForWorkflow(java.lang.String workflow)
                                              throws QueryException
```
  Get the last execution for a workflow.
  
  Specified by:
  
  getLastExecutionForWorkflow in interface Queryable
  
  Overrides:
  
  getLastExecutionForWorkflow in class DefaultQuery
  
  Parameters:
  
  workflow - the workflow name
  
  Returns:
  
  if workflow has been executed, the last execution id. otherwise, returns null.
  
  Throws:
  
  QueryException
- getLastExecutionLSIDForWorkflow
```
public KeplerLSID getLastExecutionLSIDForWorkflow(java.lang.String workflow)
                                           throws QueryException
```
  Get the last execution LSID for a workflow.
  
  Specified by:
  
  getLastExecutionLSIDForWorkflow in interface Queryable
  
  Overrides:
  
  getLastExecutionLSIDForWorkflow in class DefaultQuery
  
  Parameters:
  
  workflow - the workflow name.
  
  Returns:
  
  execution lsid
  
  Throws:
  
  QueryException
- getLastExecutionLSIDForWorkflow
```
public KeplerLSID getLastExecutionLSIDForWorkflow(KeplerLSID lsid)
                                           throws QueryException
```
  Get the last execution LSID for a workflow.
  
  Specified by:
  
  getLastExecutionLSIDForWorkflow in interface Queryable
  
  Overrides:
  
  getLastExecutionLSIDForWorkflow in class DefaultQuery
  
  Parameters:
  
  lsid - the workflow lsid.
  
  Returns:
  
  execution lsid
  
  Throws:
  
  QueryException
- getErrorForExecution
```
public java.lang.String getErrorForExecution(KeplerLSID lsid)
                                      throws QueryException
```
  Get the error for an execution. Returns null if no error message was found. NOTE: returning null is not an indication if the execution had an error.
  
  Specified by:
  
  getErrorForExecution in interface Queryable
  
  Overrides:
  
  getErrorForExecution in class DefaultQuery
  
  Parameters:
  
  lsid - the workflow execution lsid.
  
  Throws:
  
  QueryException
  
  See Also:
  
  isErrorForExecution
- isErrorForExecution
```
public boolean isErrorForExecution(KeplerLSID executionLSID)
                            throws QueryException
```
  Returns true if the execution had an error.
  
  Specified by:
  
  isErrorForExecution in interface Queryable
  
  Overrides:
  
  isErrorForExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- isImportedExecution
```
public boolean isImportedExecution(KeplerLSID executionLSID)
                            throws QueryException
```
  See if an execution appears to be imported.
  
  Specified by:
  
  isImportedExecution in interface Queryable
  
  Overrides:
  
  isImportedExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionsForType
```
public java.util.List<KeplerLSID> getExecutionsForType(WorkflowRun.type type)
                                                throws QueryException
```
  Get a list of executions corresponding to a specific type.
  
  Specified by:
  
  getExecutionsForType in interface Queryable
  
  Overrides:
  
  getExecutionsForType in class DefaultQuery
  
  Throws:
  
  QueryException
- getTokensForExecution
```
public java.util.List<java.lang.Integer> getTokensForExecution(int execId,
                                                               java.lang.Integer portId,
                                                               boolean last)
                                                        throws QueryException
```
  Get an sequence of tokens for an execution.
  
  Specified by:
  
  getTokensForExecution in interface Queryable
  
  Overrides:
  
  getTokensForExecution in class DefaultQuery
  
  Parameters:
  
  execId - the execution id
  
  portId - the port id. If null, returns the ids of tokens read in entire execution.
  
  last - if true, the sequence starts at the last token created and goes backwards to the first; otherwise the sequence starts at the first.
  
  Throws:
  
  QueryException
- getActorFiringForToken
```
public java.util.List<java.lang.Integer> getActorFiringForToken(int tokenId,
                                                                boolean read)
                                                         throws QueryException
```
  Get the firing id(s) of the actor(s) that read or wrote a token.
  
  Specified by:
  
  getActorFiringForToken in interface Queryable
  
  Overrides:
  
  getActorFiringForToken in class DefaultQuery
  
  Parameters:
  
  tokenId - the token id
  
  read - If true, return the actor(s) firing id(s) that read the token. Otherwise, return the actor firing that wrote the token.
  
  Throws:
  
  QueryException
- getTokensForFiring
```
public java.util.List<java.lang.Integer> getTokensForFiring(int fireId,
                                                            boolean read)
                                                     throws QueryException
```
  Get tokens for a firing.
  
  Specified by:
  
  getTokensForFiring in interface Queryable
  
  Overrides:
  
  getTokensForFiring in class DefaultQuery
  
  Parameters:
  
  fireId - the firing id
  
  read - if true, get the tokens read; otherwise get the tokens written.
  
  Throws:
  
  QueryException
- getTokenValue
```
public java.lang.String getTokenValue(int tokenId)
                               throws QueryException
```
  Get the value of a token.
  
  Specified by:
  
  getTokenValue in interface Queryable
  
  Overrides:
  
  getTokenValue in class DefaultQuery
  
  Throws:
  
  QueryException
- getTokenType
```
public java.lang.String getTokenType(int tokenId)
                              throws QueryException
```
  Get the type of a token.
  
  Specified by:
  
  getTokenType in interface Queryable
  
  Overrides:
  
  getTokenType in class DefaultQuery
  
  Throws:
  
  QueryException
- getChannelForToken
```
public java.lang.Integer getChannelForToken(int tokenId,
                                            boolean read,
                                            java.lang.Integer fireId)
                                     throws QueryException
```
  Get the channel that a token was read or written on.
  
  Specified by:
  
  getChannelForToken in interface Queryable
  
  Overrides:
  
  getChannelForToken in class DefaultQuery
  
  Parameters:
  
  tokenId - the token id
  
  read - if true, return the channel the token was read on. otherwise, return the channel the token was written on.
  
  fireId - the actor firing id. can be null for writes, but must be specified for reads.
  
  Returns:
  
  the channel the token was read or written on.
  
  Throws:
  
  QueryException
- getEntityId
```
public java.lang.Integer getEntityId(java.lang.String entityName,
                                     KeplerLSID lsid)
                              throws QueryException
```
  Get the id of entity. If workflow or entity is not found, returns null.
  
  Specified by:
  
  getEntityId in interface Queryable
  
  Overrides:
  
  getEntityId in class DefaultQuery
  
  Parameters:
  
  entityName - name of entity.
  
  lsid - the workflow LSID. NOTE: the revision is ignored.
  
  Throws:
  
  QueryException
- getEntityId
```
public java.lang.Integer getEntityId(java.lang.String entityName,
                                     java.lang.String workflowName)
                              throws QueryException
```
  Get the id of entity. If workflow or entity is not found, returns null.
  
  Specified by:
  
  getEntityId in interface Queryable
  
  Overrides:
  
  getEntityId in class DefaultQuery
  
  Parameters:
  
  entityName - the name of the entity.
  
  workflowName - the name of the workflow.
  
  Throws:
  
  QueryException
- getEntityType
```
public java.lang.String getEntityType(java.lang.Integer entityId)
                               throws QueryException
```
  Description copied from interface: Queryable
  
  Get the type of entity.
  
  Specified by:
  
  getEntityType in interface Queryable
  
  Overrides:
  
  getEntityType in class DefaultQuery
  
  Throws:
  
  QueryException
- getEntityWorkflowId
```
public java.lang.Integer getEntityWorkflowId(java.lang.Integer entityId)
                                      throws QueryException
```
  Description copied from interface: Queryable
  
  Get the workflow id of entity.
  
  Specified by:
  
  getEntityWorkflowId in interface Queryable
  
  Overrides:
  
  getEntityWorkflowId in class DefaultQuery
  
  Throws:
  
  QueryException
- getActorName
```
public java.lang.String getActorName(int fireId)
                              throws QueryException
```
  Get an actor's name for a firing id.
  
  Specified by:
  
  getActorName in interface Queryable
  
  Overrides:
  
  getActorName in class DefaultQuery
  
  Throws:
  
  QueryException
- getActorType
```
public java.lang.String getActorType(int fireId)
                              throws QueryException
```
  Get an actor's type for a firing id.
  
  Specified by:
  
  getActorType in interface Queryable
  
  Overrides:
  
  getActorType in class DefaultQuery
  
  Throws:
  
  QueryException
- getParameterNameValuesForFiring
```
public java.util.Map<java.lang.String,java.lang.String> getParameterNameValuesForFiring(int fireId)
                                                                                 throws QueryException
```
  Get an actor's parameter name value pairs for a firing id. NOTE: Parameter values may change during a firing; this method returns the values at the start of the firing.
  
  Specified by:
  
  getParameterNameValuesForFiring in interface Queryable
  
  Overrides:
  
  getParameterNameValuesForFiring in class DefaultQuery
  
  Throws:
  
  QueryException
- getParameterNameValuesForExecution
```
public java.util.Map<java.lang.String,java.lang.String> getParameterNameValuesForExecution(int execId)
                                                                                    throws QueryException
```
  Get the parameter name value pairs for an execution. NOTE: Parameter values may change during an execution; this method returns the values at the start of the execution.
  
  Specified by:
  
  getParameterNameValuesForExecution in interface Queryable
  
  Overrides:
  
  getParameterNameValuesForExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- getParameterValueLatest
```
public java.lang.String getParameterValueLatest(java.lang.String parameter,
                                                KeplerLSID lsid)
                                         throws QueryException
```
  Get the latest value of a parameter.
  
  Specified by:
  
  getParameterValueLatest in interface Queryable
  
  Overrides:
  
  getParameterValueLatest in class DefaultQuery
  
  Parameters:
  
  parameter - the parameter name.
  
  lsid - the workflow lsid
  
  Returns:
  
  the latest value of the parameter. If the workflow LSID or parameter name cannot be found, returns null.
  
  Throws:
  
  QueryException
- getParameterValueAtTime
```
public java.lang.String getParameterValueAtTime(java.util.Date timestamp,
                                                java.lang.String parameter,
                                                KeplerLSID lsid)
                                         throws QueryException
```
  Get the value of a parameter at a specific time.
  
  Specified by:
  
  getParameterValueAtTime in interface Queryable
  
  Overrides:
  
  getParameterValueAtTime in class DefaultQuery
  
  Parameters:
  
  timestamp - the time
  
  parameter - the parameter name
  
  lsid - the workflow lsid
  
  Returns:
  
  the value of the parameter at the specified time. If the workflow LSID or parameter name cannot be found, returns null.
  
  Throws:
  
  QueryException
- _getEntityName
```
protected java.lang.String _getEntityName(java.lang.String name)
```
  Given a fully-qualified entity name, return the name as it would appear in the entity table.
- _getFullNameFromEntityName
```
protected java.lang.String _getFullNameFromEntityName(java.lang.String entity,
                                                      java.lang.String full)
```
  Given a name from the entity table, return the fully-qualified name.
- getImmediateDependencies
```
public java.util.List<java.lang.Integer> getImmediateDependencies(int tokenId)
                                                           throws QueryException
```
  Get the immediate tokens that generated a token.
  
  Specified by:
  
  getImmediateDependencies in interface Queryable
  
  Overrides:
  
  getImmediateDependencies in class DefaultQuery
  
  Throws:
  
  QueryException
- getAssociatedDataForExecution
```
public java.util.List<byte[]> getAssociatedDataForExecution(int execId,
                                                            java.util.Map<java.lang.String,java.lang.String> metadataMap,
                                                            boolean matchAny)
                                                     throws QueryException
```
  Get a file associated with an execution.
  
  Specified by:
  
  getAssociatedDataForExecution in interface Queryable
  
  Overrides:
  
  getAssociatedDataForExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- getAssociatedKeysValuesForExecution
```
public java.util.Map<java.lang.String,java.lang.String> getAssociatedKeysValuesForExecution(int execId)
                                                                                     throws QueryException
```
  Get any associated keys-values for an execution.
  
  Specified by:
  
  getAssociatedKeysValuesForExecution in interface Queryable
  
  Overrides:
  
  getAssociatedKeysValuesForExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- getSavedFilenames
```
public java.util.List<java.lang.String> getSavedFilenames()
                                                   throws QueryException
```
  Get a list of files saved in the database.
  
  Throws:
  
  QueryException
- getPortsForActor
```
public java.util.List<java.lang.String> getPortsForActor(KeplerLSID workflow,
                                                         java.lang.String actor)
                                                  throws QueryException
```
  Get the ports for an actor.
  
  Specified by:
  
  getPortsForActor in interface Queryable
  
  Overrides:
  
  getPortsForActor in class DefaultQuery
  
  Parameters:
  
  workflow - the LSID of the workflow
  
  actor - the fully-qualified name of the actor
  
  Returns:
  
  a list of fully-qualified names of ports of the actor
  
  Throws:
  
  QueryException
- getHostIdForExecution
```
public java.lang.String getHostIdForExecution(java.lang.Integer execId)
                                       throws QueryException
```
  Get the host id for a specific execution id. If no execution exists, returns null.
  
  Specified by:
  
  getHostIdForExecution in interface Queryable
  
  Overrides:
  
  getHostIdForExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- getUserForExecution
```
public java.lang.String getUserForExecution(KeplerLSID execLSID)
                                     throws QueryException
```
  Get the user for a specific execution LSID.
  
  Specified by:
  
  getUserForExecution in interface Queryable
  
  Overrides:
  
  getUserForExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- getUserForExecution
```
public java.lang.String getUserForExecution(java.lang.Integer execId)
                                     throws QueryException
```
  Get the user for a specific execution id. If no execution exists, returns null.
  
  Specified by:
  
  getUserForExecution in interface Queryable
  
  Overrides:
  
  getUserForExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- getOutputRoleToken
```
public java.lang.String getOutputRoleToken(int tokenId)
                                    throws QueryException
```
  Get the output role (port name) of a token.
  
  Specified by:
  
  getOutputRoleToken in interface Queryable
  
  Overrides:
  
  getOutputRoleToken in class DefaultQuery
  
  Throws:
  
  QueryException
- getInputRoleForTokenAndFireId
```
public java.lang.String getInputRoleForTokenAndFireId(int tokenId,
                                                      int fireId)
                                               throws QueryException
```
  Get the input role (port name) of a token.
  
  Specified by:
  
  getInputRoleForTokenAndFireId in interface Queryable
  
  Overrides:
  
  getInputRoleForTokenAndFireId in class DefaultQuery
  
  Throws:
  
  QueryException
- getParameterNameValuesOfSpecificTypeForExecution
```
public java.util.Map<java.lang.String,java.lang.String> getParameterNameValuesOfSpecificTypeForExecution(int execId)
                                                                                                  throws QueryException
```
  Get the parameter name value pairs for an execution, whose parameter type is either '.Parameter' or '.StringParameter'
  
  Specified by:
  
  getParameterNameValuesOfSpecificTypeForExecution in interface Queryable
  
  Overrides:
  
  getParameterNameValuesOfSpecificTypeForExecution in class DefaultQuery
  
  Throws:
  
  QueryException
- getTimestampsForActorFiring
```
public java.util.Date[] getTimestampsForActorFiring(int fireId)
                                             throws QueryException
```
  Get the start and end timestamps of an actor firing.
  
  Specified by:
  
  getTimestampsForActorFiring in interface Queryable
  
  Overrides:
  
  getTimestampsForActorFiring in class DefaultQuery
  
  Throws:
  
  QueryException
- getActorFiringIds
```
public java.util.List<java.lang.Integer> getActorFiringIds(java.lang.String actorName,
                                                           java.lang.Integer wfExecId)
                                                    throws QueryException
```
  Get actor fire ids based on its full name and workflow exec ID.
  
  Specified by:
  
  getActorFiringIds in interface Queryable
  
  Overrides:
  
  getActorFiringIds in class DefaultQuery
  
  Throws:
  
  QueryException
- getParameterAndPortParameterNameValuesForFiring
```
public java.util.Map<java.lang.String,java.lang.String> getParameterAndPortParameterNameValuesForFiring(int fireId)
                                                                                                 throws QueryException
```
  Get an actor's parameter and port parameter name value pairs for a firing id. NOTE: Parameter values may change during a firing; this method returns the values at the start of the firing.
  
  Specified by:
  
  getParameterAndPortParameterNameValuesForFiring in interface Queryable
  
  Overrides:
  
  getParameterAndPortParameterNameValuesForFiring in class DefaultQuery
  
  Throws:
  
  QueryException
- getActorFirings
```
public java.util.List<java.lang.Integer> getActorFirings(int wfExecId)
                                                  throws QueryException
```
  Get all actor fire ids for a workflow exec ID.
  
  Specified by:
  
  getActorFirings in interface Queryable
  
  Overrides:
  
  getActorFirings in class DefaultQuery
  
  Throws:
  
  QueryException
- getExecutionTimesForActor
```
public java.util.Map<java.lang.String,java.lang.Long> getExecutionTimesForActor(KeplerLSID workflow,
                                                                                KeplerLSID execLSID,
                                                                                java.lang.String actor)
                                                                         throws QueryException
```
  Get the execution times for an actor.
  
  Specified by:
  
  getExecutionTimesForActor in interface Queryable
  
  Overrides:
  
  getExecutionTimesForActor in class DefaultQuery
  
  Parameters:
  
  workflow - the workflow LSID. If null, must specify execution id.
  
  execLSID - the execution LSID. If null, the last execution of the workflow is used.
  
  actor - the full actor name.
  
  Returns:
  
  a map of actor fire id to execution time pairs. if a firing does not have a valid start or stop time, the firing is not included in the result.
  
  Throws:
  
  QueryException
- getIOBytesForPort
```
public java.util.Map<java.lang.Integer,java.lang.Integer> getIOBytesForPort(KeplerLSID workflow,
                                                                            java.lang.Integer execId,
                                                                            java.lang.String port,
                                                                            boolean read)
                                                                     throws QueryException
```
  Get the number of bytes read or written by a port.
  
  Specified by:
  
  getIOBytesForPort in interface Queryable
  
  Overrides:
  
  getIOBytesForPort in class DefaultQuery
  
  Parameters:
  
  workflow - the workflow LSID. If null, must specify execution id.
  
  execId - the execution id. If null, the last execution of the workflow is used.
  
  port - the full port name.
  
  read - If true, get the bytes read. Otherwise, get the bytes written.
  
  Returns:
  
  a map of port event id to bytes read/written.
  
  Throws:
  
  QueryException
- getTimestampsForTokenRead
```
public java.util.Date[] getTimestampsForTokenRead(java.lang.Integer tokenId)
                                           throws QueryException
```
  Get the timestamp(s) when a token was read. If a token was never read, this can return null or an empty array.
  
  Specified by:
  
  getTimestampsForTokenRead in interface Queryable
  
  Overrides:
  
  getTimestampsForTokenRead in class DefaultQuery
  
  Throws:
  
  QueryException
- getTimestampForTokenWrite
```
public java.util.Date getTimestampForTokenWrite(java.lang.Integer tokenId)
                                         throws QueryException
```
  Get the timestamp when a token was written.
  
  Specified by:
  
  getTimestampForTokenWrite in interface Queryable
  
  Overrides:
  
  getTimestampForTokenWrite in class DefaultQuery
  
  Throws:
  
  QueryException
- _init
```
protected void _init()
              throws QueryException
```
  Check the schema version and initialize the prepared statements.
  
  Throws:
  
  QueryException
- _createPreparedStatements
```
protected void _createPreparedStatements()
                                  throws java.sql.SQLException
```
  Initialize the prepared statements.
  
  Throws:
  
  java.sql.SQLException
- _getEntitiesForChange
```
protected java.util.List<java.lang.Integer> _getEntitiesForChange(int changeId)
                                                           throws QueryException
```
  Get the entities for a workflow change.
  
  Throws:
  
  QueryException
- _getLastChangeTime
```
protected java.util.Date _getLastChangeTime(java.lang.String workflowName,
                                            java.lang.String hostName)
                                     throws QueryException
```
  Get the last change time for a workflow.
  
  Throws:
  
  QueryException
- _getLastChangeTime
```
protected java.util.Date _getLastChangeTime(int workflowId,
                                            java.lang.String hostName)
                                     throws QueryException
```
  Get the last change time for a workflow.
  
  Throws:
  
  QueryException
- _getChangesSince
```
protected java.util.List<java.lang.Integer> _getChangesSince(java.util.Date timeStamp,
                                                             java.lang.String workflowName,
                                                             java.lang.String hostName)
                                                      throws QueryException
```
  Get changes performed since a specific time.
  
  Throws:
  
  QueryException
- _getChangesForTimespan
```
protected java.util.List<java.lang.Integer> _getChangesForTimespan(java.util.Date start,
                                                                   java.util.Date end,
                                                                   java.lang.String workflow,
                                                                   java.lang.String host)
                                                            throws QueryException
```
  Get changes performed on a host within a timespan. If host is null, returns changes for all hosts.
  
  Throws:
  
  QueryException
- _getLastExecutionStartTime
```
protected java.util.Date _getLastExecutionStartTime(java.lang.String workflowName,
                                                    java.lang.String hostName)
                                             throws QueryException
```
  Get the last execution start time.
  
  Throws:
  
  QueryException
- _getLastExecutionStartTime
```
protected java.util.Date _getLastExecutionStartTime(int workflowId,
                                                    java.lang.String hostName)
                                             throws QueryException
```
  Get the last execution start time.
  
  Throws:
  
  QueryException
- _getExecutionsStartedSince
```
protected java.util.List<java.lang.Integer> _getExecutionsStartedSince(java.util.Date timeStamp,
                                                                       boolean including,
                                                                       java.lang.String workflowName,
                                                                       java.lang.String hostName)
                                                                throws QueryException
```
  Get executions started since a specific time.
  
  Parameters:
  
  timeStamp - get executions started after this time.
  
  including - if true, include executions starting at timeStamp. if false, do not include executions starting at timeStamp.
  
  workflowName - get executions for a specific workflow.
  
  hostName - get executions for a specific host.
  
  Throws:
  
  QueryException
- _getExecutionsForTimespan
```
protected java.util.List<java.lang.Integer> _getExecutionsForTimespan(java.util.Date start,
                                                                      java.util.Date end,
                                                                      java.lang.String workflow,
                                                                      java.lang.String host)
                                                               throws QueryException
```
  Get executions for a worfkflow run on a host within a timespan.
  
  Throws:
  
  QueryException
- _getWorkflow
```
protected int _getWorkflow(java.lang.String workflow)
                    throws QueryException
```
  Get the id for a workflow. If workflow does not exist, returns an an integer less than 0.
  
  Throws:
  
  QueryException
- _getDataMD5s
```
protected java.util.List<java.lang.String> _getDataMD5s()
                                                 throws QueryException
```
  Get all the data MD5 checksums.
  
  Throws:
  
  QueryException
- _getIntResults
```
protected java.util.List<java.lang.Integer> _getIntResults(java.sql.PreparedStatement query,
                                                           int index)
                                                    throws java.sql.SQLException
```
  Convenience routine to get a list of integer SQL results.
  
  Parameters:
  
  query - the query to execute
  
  index - column number of result
  
  Throws:
  
  java.sql.SQLException
- _getParameterNameValues
```
protected static java.util.Map<java.lang.String,java.lang.String> _getParameterNameValues(java.sql.PreparedStatement statement)
                                                                                   throws QueryException,
                                                                                          java.sql.SQLException
```
  A convenience method that executes a query returning parameter name value pairs.
  
  Throws:
  
  QueryException
  
  java.sql.SQLException
- _getStringResults
```
protected java.util.List<java.lang.String> _getStringResults(java.sql.PreparedStatement query,
                                                             int index)
                                                      throws java.sql.SQLException
```
  Convenience routine to get a list of string SQL results.
  
  Parameters:
  
  query - the query to execute
  
  index - column number of result
  
  Throws:
  
  java.sql.SQLException
- _getStringResults
```
protected java.util.List<java.lang.String> _getStringResults(java.sql.Statement statement,
                                                             java.lang.String queryStr,
                                                             int index)
                                                      throws java.sql.SQLException
```
  Convenience routine to get a list of string SQL results.
  
  Parameters:
  
  statement - statement to execute
  
  queryStr - the query string to execute
  
  index - column number of result
  
  Throws:
  
  java.sql.SQLException
- _nullPreparedStatements
```
protected void _nullPreparedStatements()
```
  Set our prepared statements to null.
- _debug
```
protected void _debug(java.lang.String str)
```
- _stringTokenValuesHaveSurroundingQuotes
```
protected boolean _stringTokenValuesHaveSurroundingQuotes()
```
  Returns true since SQLRecordingV8 saves StringToken values using StringToken.toString(), which adds surrounding double-quotes.
  
  Specified by:
  
  _stringTokenValuesHaveSurroundingQuotes in class DefaultQuery

Class SQLQueryV8

Field Summary

Constructor Summary

Method Summary

Methods inherited from class org.kepler.provenance.DefaultQuery

Methods inherited from class java.lang.Object

Field Detail

_dbType

_psActorFiringForTokenWrite

_psActorFiringsForExecution

_psActorFiringsForTokenRead

_psActorFireId

_psActorFirings

_psActorNameForFiring

_psActorTypeForFiring

_psChannelForTokenRead

_psChannelForTokenWrite

_psChangesForTimespan

_psChangesForTimespanOnHost

_psDataMD5s

_psDoesExecutionHaveError

_psEntitiesForChange

_psEntityId

_psEntityWorkflowId

_psEntityIdLSID

_psEntityTokensForExecution

_psEntityType

_psErrorForExecution

_psExecutions

_psExecutionsForAnnotation

_psExecutionsForTimespan

_psExecutionsForTimespanOnHost

_psExecutionsForType

_psExecutionsForWorkflow

_psExecutionForExecutionLSID

_psExecutionForExecutionLSIDWithoutRevision

_psExecutionForOldestReferralExecutionLSIDWithoutRevision

_psExecutionLSIDForExecution

_psExecutionsForWorkflowNameContains

_psExecutionsForWorkflowRuns

_psExecutionsForWorkflowRunsAfter

_psExecutionsForWorkflowRunsAt

_psExecutionsForWorkflowRunsBefore

_psExecutionsForWorkflowRuns2

_psExecutionLSIDsForWorkflowRuns

_psExecutionIdsForTags

_psExecutionLSIDs

_psIsExecutionImported

_psTagsForExecutionId

_psTagURNsForExecutionId

_psTypeForTag

_psLastChangeTime

_psLastChangeTimeForWorkflowId

_psLastExecutionForWorkflow

_psLastExecutionForWorkflowLSID

_psLastExecutionLSIDForWorkflowName

_psLastExecutionLSIDForWorkflowLSID

_psLastExecutionStartTime

_psLastExecutionStartTimeForWorkflowId

_psMomlForExecutionId

_psMomlForExecutionLSID

_psParamNameValuesForExecution

_psParamNameValuesForFiring

_psParamValueAtTimeForWorkflowLSID

_psTimestampsForExecution

_psTimestampForTokenWrite

_psTimestampsForTokenRead

_psTokenType

_psPortEventData

_psDataContents

_psTokensForExecution

_psTokensForFiring

_psTokensReadForFiring

_psTokensWrittenForFiring

_psWorkflowRunsForExecutions

_psWorkflowRunsForExecutionLSIDs

_psWorkflows

_psWorkflowNameForLSID

_psWorkflowNameForExecutionLSID

_psMoMLMD5sForExecutions