org.apache.manifoldcf.crawler.jobs

Class PrereqEventManager

java.lang.Object

org.apache.manifoldcf.core.database.BaseTable

org.apache.manifoldcf.crawler.jobs.PrereqEventManager

public class PrereqEventManager
extends BaseTable

This class manages the prerequisite event table. This table lists the prerequisite event rows that must NOT exist in order for a jobqueue entry to be queued for processing. If a prerequisite event row does, in fact, exist, then queuing and processing do not take place until that row is cleared.

prereqevents

Field	Type	Description
owner	BIGINT	Reference:jobqueue.id
eventname	VARCHAR(255)

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	_rcsid
static java.lang.String	eventNameField
static java.lang.String	ownerField

Fields inherited from class org.apache.manifoldcf.core.database.BaseTable

dbInterface, tableName

Constructor Summary

Constructors

Constructor and Description
PrereqEventManager(IDBInterface database) Constructor.

Method Summary

Modifier and Type	Method and Description
void	addRows(java.lang.Long recordID, java.lang.String[] eventNames) Add rows pertaining to a single entry
void	deinstall() Uninstall.
void	deleteRows(java.util.ArrayList list) Delete specified rows, as directly specified without a join.
void	deleteRows(java.lang.Long recordID) Delete rows pertaining to a single entry
void	deleteRows(java.lang.String parentTableName, java.lang.String joinField, java.lang.String parentCriteria, java.util.ArrayList list) Delete specified rows, based on jobqueue criteria.
void	install(java.lang.String ownerTableName, java.lang.String ownerColumn) Install or upgrade this table.

Methods inherited from class org.apache.manifoldcf.core.database.BaseTable

addTableIndex, analyzeTable, beginTransaction, buildConjunctionClause, constructCountClause, constructDistinctOnClause, constructDoubleCastClause, constructOffsetLimitClause, constructRegexpClause, constructSubstringClause, endTransaction, findConjunctionClauseMax, getDatabaseCacheKey, getDBInterface, getMaxInClause, getMaxOrClause, getSleepAmt, getTableIndexes, getTableName, getTableSchema, getTransactionID, getWindowedReportMaxRows, makeTableKey, noteModifications, performAddIndex, performAlter, performCommit, performCreate, performDelete, performDrop, performInsert, performModification, performQuery, performQuery, performRemoveIndex, performUpdate, prepareRowForSave, readRow, reindexTable, signalRollback, sleepFor

Methods inherited from class java.lang.Object

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

Field Detail

_rcsid

public static final java.lang.String _rcsid

See Also:

Constant Field Values

ownerField

public static final java.lang.String ownerField

See Also:

Constant Field Values

eventNameField

public static final java.lang.String eventNameField

See Also:

Constant Field Values

Constructor Detail

PrereqEventManager

public PrereqEventManager(IDBInterface database)
                   throws ManifoldCFException

Constructor.

Parameters:

database - is the database handle.

Throws:

ManifoldCFException

Method Detail

install

public void install(java.lang.String ownerTableName,
                    java.lang.String ownerColumn)
             throws ManifoldCFException

Install or upgrade this table.

Throws:

ManifoldCFException

deinstall

public void deinstall()
               throws ManifoldCFException

Uninstall.

Throws:

ManifoldCFException

deleteRows

public void deleteRows(java.lang.String parentTableName,
                       java.lang.String joinField,
                       java.lang.String parentCriteria,
                       java.util.ArrayList list)
                throws ManifoldCFException

Delete specified rows, based on jobqueue criteria.

Throws:

ManifoldCFException

deleteRows

public void deleteRows(java.util.ArrayList list)
                throws ManifoldCFException

Delete specified rows, as directly specified without a join.

Throws:

ManifoldCFException

deleteRows

public void deleteRows(java.lang.Long recordID)
                throws ManifoldCFException

Delete rows pertaining to a single entry

Throws:

ManifoldCFException

addRows

public void addRows(java.lang.Long recordID,
                    java.lang.String[] eventNames)
             throws ManifoldCFException

Add rows pertaining to a single entry

Throws:

ManifoldCFException