com.atlassian.crowd.util.persistence.hibernate.batch.hibernate5

Class AbstractHibernateBatchProcessor<T extends org.hibernate.SharedSessionContract>

java.lang.Object

com.atlassian.crowd.util.persistence.hibernate.batch.AbstractBatchProcessor<T>

com.atlassian.crowd.util.persistence.hibernate.batch.hibernate5.AbstractHibernateBatchProcessor<T>

All Implemented Interfaces:

BatchProcessor<T>

Direct Known Subclasses:

Hibernate5BatchProcessor, Hibernate5StatelessSessionBatchProcessor

public abstract class AbstractHibernateBatchProcessor<T extends org.hibernate.SharedSessionContract>
extends AbstractBatchProcessor<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected org.hibernate.SessionFactory	sessionFactory

Fields inherited from class com.atlassian.crowd.util.persistence.hibernate.batch.AbstractBatchProcessor

batchSize, log

Constructor Summary

Constructors

Constructor and Description
AbstractHibernateBatchProcessor(org.hibernate.SessionFactory sessionFactory)

Method Summary

Modifier and Type	Method and Description
protected void	afterProcessBatch() Called after successfully processing each batch.
protected void	afterProcessCollection() Called when processing the collection has completed successfully.
protected void	afterProcessIndividual() Called after successully processing an item individually.
protected void	beforeProcessBatch() Called before processing each batch.
protected void	beforeProcessCollection() Called before the collection is processed into a batch.
protected void	beforeProcessIndividual() Called before processing an individual item.
protected abstract void	clearSession()
protected abstract void	closeSession()
protected void	commitTransaction() Method is protected to allow subclasses to override the transaction management if they need to (e.g.
protected abstract void	flushSession()
protected abstract T	openSession()
protected void	rollbackProcessBatch() Called after processing each batch where an exception was encountered.
protected void	rollbackProcessIndividual() Called after processing an individual item where an exception was encountered.
protected void	rollbackTransaction() Method is protected to allow subclasses to override the transaction management if they need to (e.g.
protected void	startTransaction() Method is protected to allow subclasses to override the transaction management if they need to (e.g.

Methods inherited from class com.atlassian.crowd.util.persistence.hibernate.batch.AbstractBatchProcessor

auditOperations, execute, execute, getSession, setBatchSize

Methods inherited from class java.lang.Object

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

Field Detail

sessionFactory

protected final org.hibernate.SessionFactory sessionFactory

Constructor Detail

AbstractHibernateBatchProcessor

public AbstractHibernateBatchProcessor(org.hibernate.SessionFactory sessionFactory)

Method Detail

afterProcessBatch

protected void afterProcessBatch()

Description copied from class: AbstractBatchProcessor

Called after successfully processing each batch.

Specified by:

afterProcessBatch in class AbstractBatchProcessor<T extends org.hibernate.SharedSessionContract>

afterProcessCollection

protected void afterProcessCollection()

Description copied from class: AbstractBatchProcessor

Called when processing the collection has completed successfully.

Specified by:

afterProcessCollection in class AbstractBatchProcessor<T extends org.hibernate.SharedSessionContract>

afterProcessIndividual

protected void afterProcessIndividual()

Description copied from class: AbstractBatchProcessor

Called after successully processing an item individually.

Specified by:

afterProcessIndividual in class AbstractBatchProcessor<T extends org.hibernate.SharedSessionContract>

beforeProcessBatch

protected void beforeProcessBatch()

Description copied from class: AbstractBatchProcessor

Called before processing each batch. Can be used to start session or transaction that will cover this particular batch.

Specified by:

beforeProcessBatch in class AbstractBatchProcessor<T extends org.hibernate.SharedSessionContract>

beforeProcessCollection

protected void beforeProcessCollection()

Description copied from class: AbstractBatchProcessor

Called before the collection is processed into a batch. Can be used to start session or transaction that will cover the execution of the entire collection which could involve multiple batches.

Specified by:

beforeProcessCollection in class AbstractBatchProcessor<T extends org.hibernate.SharedSessionContract>

beforeProcessIndividual

protected void beforeProcessIndividual()

Description copied from class: AbstractBatchProcessor

Called before processing an individual item. This method will be called if the batch failed and the processor falls back to processing each item seperately.

Specified by:

beforeProcessIndividual in class AbstractBatchProcessor<T extends org.hibernate.SharedSessionContract>

rollbackProcessBatch

protected void rollbackProcessBatch()

Description copied from class: AbstractBatchProcessor

Called after processing each batch where an exception was encountered.

Specified by:

rollbackProcessBatch in class AbstractBatchProcessor<T extends org.hibernate.SharedSessionContract>

rollbackProcessIndividual

protected void rollbackProcessIndividual()

Description copied from class: AbstractBatchProcessor

Called after processing an individual item where an exception was encountered.

Specified by:

rollbackProcessIndividual in class AbstractBatchProcessor<T extends org.hibernate.SharedSessionContract>

commitTransaction

protected void commitTransaction()

Method is protected to allow subclasses to override the transaction management if they need to (e.g. use a transaction manager instead of manipulating the Hibernate session directly)

rollbackTransaction

protected void rollbackTransaction()

Method is protected to allow subclasses to override the transaction management if they need to (e.g. use a transaction manager instead of manipulating the Hibernate session directly)

clearSession

protected abstract void clearSession()

closeSession

protected abstract void closeSession()

flushSession

protected abstract void flushSession()

openSession

protected abstract T openSession()

startTransaction

protected void startTransaction()

Method is protected to allow subclasses to override the transaction management if they need to (e.g. use a transaction manager instead of manipulating the Hibernate session directly)