org.apache.oozie.executor.jpa

Class BundleJobQueryExecutor

java.lang.Object

org.apache.oozie.executor.jpa.QueryExecutor<BundleJobBean,BundleJobQueryExecutor.BundleJobQuery>

org.apache.oozie.executor.jpa.BundleJobQueryExecutor

public class BundleJobQueryExecutor
extends QueryExecutor<BundleJobBean,BundleJobQueryExecutor.BundleJobQuery>

Query Executor that provides API to run query for Bundle Job

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BundleJobQueryExecutor.BundleJobQuery

Method Summary

Methods

Modifier and Type	Method and Description
int	executeUpdate(BundleJobQueryExecutor.BundleJobQuery namedQuery, BundleJobBean jobBean)
BundleJobBean	get(BundleJobQueryExecutor.BundleJobQuery namedQuery, Object... parameters)
BundleJobBean	getIfExist(BundleJobQueryExecutor.BundleJobQuery namedQuery, Object... parameters)
static QueryExecutor<BundleJobBean,BundleJobQueryExecutor.BundleJobQuery>	getInstance()
List<BundleJobBean>	getList(BundleJobQueryExecutor.BundleJobQuery namedQuery, Object... parameters)
javax.persistence.Query	getSelectQuery(BundleJobQueryExecutor.BundleJobQuery namedQuery, javax.persistence.EntityManager em, Object... parameters)
Object	getSingleValue(BundleJobQueryExecutor.BundleJobQuery namedQuery, Object... parameters)
javax.persistence.Query	getUpdateQuery(BundleJobQueryExecutor.BundleJobQuery namedQuery, BundleJobBean bjBean, javax.persistence.EntityManager em)

Methods inherited from class org.apache.oozie.executor.jpa.QueryExecutor

insert

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static QueryExecutor<BundleJobBean,BundleJobQueryExecutor.BundleJobQuery> getInstance()

getUpdateQuery

public javax.persistence.Query getUpdateQuery(BundleJobQueryExecutor.BundleJobQuery namedQuery,
                                     BundleJobBean bjBean,
                                     javax.persistence.EntityManager em)
                                       throws JPAExecutorException

Specified by:

getUpdateQuery in class QueryExecutor<BundleJobBean,BundleJobQueryExecutor.BundleJobQuery>

Throws:

JPAExecutorException

getSelectQuery

public javax.persistence.Query getSelectQuery(BundleJobQueryExecutor.BundleJobQuery namedQuery,
                                     javax.persistence.EntityManager em,
                                     Object... parameters)
                                       throws JPAExecutorException

Specified by:

getSelectQuery in class QueryExecutor<BundleJobBean,BundleJobQueryExecutor.BundleJobQuery>

Throws:

JPAExecutorException

executeUpdate

public int executeUpdate(BundleJobQueryExecutor.BundleJobQuery namedQuery,
                BundleJobBean jobBean)
                  throws JPAExecutorException

Specified by:

executeUpdate in class QueryExecutor<BundleJobBean,BundleJobQueryExecutor.BundleJobQuery>

Throws:

JPAExecutorException

get

public BundleJobBean get(BundleJobQueryExecutor.BundleJobQuery namedQuery,
                Object... parameters)
                  throws JPAExecutorException

Specified by:

get in class QueryExecutor<BundleJobBean,BundleJobQueryExecutor.BundleJobQuery>

Throws:

JPAExecutorException

getIfExist

public BundleJobBean getIfExist(BundleJobQueryExecutor.BundleJobQuery namedQuery,
                       Object... parameters)
                         throws JPAExecutorException

Specified by:

getIfExist in class QueryExecutor<BundleJobBean,BundleJobQueryExecutor.BundleJobQuery>

Throws:

JPAExecutorException

getList

public List<BundleJobBean> getList(BundleJobQueryExecutor.BundleJobQuery namedQuery,
                          Object... parameters)
                            throws JPAExecutorException

Specified by:

getList in class QueryExecutor<BundleJobBean,BundleJobQueryExecutor.BundleJobQuery>

Throws:

JPAExecutorException

getSingleValue

public Object getSingleValue(BundleJobQueryExecutor.BundleJobQuery namedQuery,
                    Object... parameters)
                      throws JPAExecutorException

Specified by:

getSingleValue in class QueryExecutor<BundleJobBean,BundleJobQueryExecutor.BundleJobQuery>

Throws:

JPAExecutorException