Package org.operaton.bpm.engine.impl.db.entitymanager.operation

Class DbOperationManager

java.lang.Object

org.operaton.bpm.engine.impl.db.entitymanager.operation.DbOperationManager

public class DbOperationManager
extends Object

Manages a set of database operations.

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field	Description
static final Comparator<DbBulkOperation>	BULK_OPERATION_COMPARATOR
static final Comparator<DbEntityOperation>	INSERT_OPERATION_COMPARATOR
static final Comparator<Class<?>>	INSERT_TYPE_COMPARATOR
static final Comparator<DbEntityOperation>	MODIFICATION_OPERATION_COMPARATOR
static final Comparator<Class<?>>	MODIFICATION_TYPE_COMPARATOR

Constructor Summary

Constructors

Constructor	Description
DbOperationManager()

Method Summary

Modifier and Type	Method	Description
boolean	addOperation(DbBulkOperation newOperation)
boolean	addOperation(DbEntityOperation newOperation)
boolean	addOperationPreserveOrder(DbBulkOperation newOperation)
protected void	addSortedInserts(List<DbOperation> flush)	Adds the insert operations to the flush (in correct order).
protected void	addSortedModifications(List<DbOperation> flush)	Adds a correctly ordered list of UPDATE and DELETE operations to the flush.
protected void	addSortedModificationsForType(Class<?> type, SortedSet<DbEntityOperation> preSortedOperations, List<DbOperation> flush)
List<DbOperation>	calculateFlush()
protected void	determineDependencies(List<DbOperation> flush)
protected SortedSet<DbEntityOperation>	getDeletesByType(Class<? extends DbEntity> type, boolean create)
protected SortedSet<DbEntityOperation>	getInsertsForType(Class<? extends DbEntity> type, boolean create)
protected SortedSet<DbEntityOperation>	getUpdatesByType(Class<? extends DbEntity> type, boolean create)
protected List<DbEntityOperation>	sortByReferences(SortedSet<DbEntityOperation> preSorted)	Assumptions: a) all operations in the set work on entities such that the entities implement HasDbReferences.

Methods inherited from class java.lang.Object

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

Field Details

INSERT_TYPE_COMPARATOR

public static final Comparator<Class<?>> INSERT_TYPE_COMPARATOR

MODIFICATION_TYPE_COMPARATOR

public static final Comparator<Class<?>> MODIFICATION_TYPE_COMPARATOR

INSERT_OPERATION_COMPARATOR

public static final Comparator<DbEntityOperation> INSERT_OPERATION_COMPARATOR

MODIFICATION_OPERATION_COMPARATOR

public static final Comparator<DbEntityOperation> MODIFICATION_OPERATION_COMPARATOR

BULK_OPERATION_COMPARATOR

public static final Comparator<DbBulkOperation> BULK_OPERATION_COMPARATOR

Constructor Details

DbOperationManager

public DbOperationManager()

Method Details

addOperation

public boolean addOperation(DbEntityOperation newOperation)

getDeletesByType

protected SortedSet<DbEntityOperation> getDeletesByType(Class<? extends DbEntity> type,
 boolean create)

getUpdatesByType

protected SortedSet<DbEntityOperation> getUpdatesByType(Class<? extends DbEntity> type,
 boolean create)

getInsertsForType

protected SortedSet<DbEntityOperation> getInsertsForType(Class<? extends DbEntity> type,
 boolean create)

addOperation

public boolean addOperation(DbBulkOperation newOperation)

addOperationPreserveOrder

public boolean addOperationPreserveOrder(DbBulkOperation newOperation)

calculateFlush

public List<DbOperation> calculateFlush()

addSortedInserts

protected void addSortedInserts(List<DbOperation> flush)

Adds the insert operations to the flush (in correct order).

Parameters:

operationsForFlush -

addSortedModifications

protected void addSortedModifications(List<DbOperation> flush)

Adds a correctly ordered list of UPDATE and DELETE operations to the flush.

Parameters:

flush -

addSortedModificationsForType

protected void addSortedModificationsForType(Class<?> type,
 SortedSet<DbEntityOperation> preSortedOperations,
 List<DbOperation> flush)

sortByReferences

protected List<DbEntityOperation> sortByReferences(SortedSet<DbEntityOperation> preSorted)

Assumptions: a) all operations in the set work on entities such that the entities implement HasDbReferences. b) all operations in the set work on the same type (ie. all operations are INSERTs or DELETEs).

determineDependencies

protected void determineDependencies(List<DbOperation> flush)