org.apache.oozie.executor.jpa

Class BatchQueryExecutor

java.lang.Object

org.apache.oozie.executor.jpa.BatchQueryExecutor

public class BatchQueryExecutor
extends Object

Query Executor that provides API to run multiple update/insert queries in one transaction. This guarantees entire change to be rolled back when one of queries fails.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BatchQueryExecutor.UpdateEntry<E extends Enum<E>>

Method Summary

Methods

Modifier and Type	Method and Description
void	executeBatchInsertUpdateDelete(Collection<JsonBean> insertList, Collection<BatchQueryExecutor.UpdateEntry> updateList, Collection<JsonBean> deleteList)
static BatchQueryExecutor	getInstance()

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static BatchQueryExecutor getInstance()

executeBatchInsertUpdateDelete

public void executeBatchInsertUpdateDelete(Collection<JsonBean> insertList,
                                  Collection<BatchQueryExecutor.UpdateEntry> updateList,
                                  Collection<JsonBean> deleteList)
                                    throws JPAExecutorException

Throws:

JPAExecutorException