org.apache.oozie.executor.jpa

Class CoordJobQueryExecutor

java.lang.Object

org.apache.oozie.executor.jpa.QueryExecutor<CoordinatorJobBean,CoordJobQueryExecutor.CoordJobQuery>

org.apache.oozie.executor.jpa.CoordJobQueryExecutor

public class CoordJobQueryExecutor
extends QueryExecutor<CoordinatorJobBean,CoordJobQueryExecutor.CoordJobQuery>

Query Executor that provides API to run query for Coordinator Job

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CoordJobQueryExecutor.CoordJobQuery

Method Summary

Methods

Modifier and Type	Method and Description
int	executeUpdate(CoordJobQueryExecutor.CoordJobQuery namedQuery, CoordinatorJobBean jobBean)
CoordinatorJobBean	get(CoordJobQueryExecutor.CoordJobQuery namedQuery, Object... parameters)
CoordinatorJobBean	getIfExist(CoordJobQueryExecutor.CoordJobQuery namedQuery, Object... parameters)
static CoordJobQueryExecutor	getInstance()
List<CoordinatorJobBean>	getList(CoordJobQueryExecutor.CoordJobQuery namedQuery, Object... parameters)
javax.persistence.Query	getSelectQuery(CoordJobQueryExecutor.CoordJobQuery namedQuery, javax.persistence.EntityManager em, Object... parameters)
Object	getSingleValue(CoordJobQueryExecutor.CoordJobQuery namedQuery, Object... parameters)
javax.persistence.Query	getUpdateQuery(CoordJobQueryExecutor.CoordJobQuery namedQuery, CoordinatorJobBean cjBean, 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 CoordJobQueryExecutor getInstance()

getUpdateQuery

public javax.persistence.Query getUpdateQuery(CoordJobQueryExecutor.CoordJobQuery namedQuery,
                                     CoordinatorJobBean cjBean,
                                     javax.persistence.EntityManager em)
                                       throws JPAExecutorException

Specified by:

getUpdateQuery in class QueryExecutor<CoordinatorJobBean,CoordJobQueryExecutor.CoordJobQuery>

Throws:

JPAExecutorException

getSelectQuery

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

Specified by:

getSelectQuery in class QueryExecutor<CoordinatorJobBean,CoordJobQueryExecutor.CoordJobQuery>

Throws:

JPAExecutorException

executeUpdate

public int executeUpdate(CoordJobQueryExecutor.CoordJobQuery namedQuery,
                CoordinatorJobBean jobBean)
                  throws JPAExecutorException

Specified by:

executeUpdate in class QueryExecutor<CoordinatorJobBean,CoordJobQueryExecutor.CoordJobQuery>

Throws:

JPAExecutorException

get

public CoordinatorJobBean get(CoordJobQueryExecutor.CoordJobQuery namedQuery,
                     Object... parameters)
                       throws JPAExecutorException

Specified by:

get in class QueryExecutor<CoordinatorJobBean,CoordJobQueryExecutor.CoordJobQuery>

Throws:

JPAExecutorException

getList

public List<CoordinatorJobBean> getList(CoordJobQueryExecutor.CoordJobQuery namedQuery,
                               Object... parameters)
                                 throws JPAExecutorException

Specified by:

getList in class QueryExecutor<CoordinatorJobBean,CoordJobQueryExecutor.CoordJobQuery>

Throws:

JPAExecutorException

getSingleValue

public Object getSingleValue(CoordJobQueryExecutor.CoordJobQuery namedQuery,
                    Object... parameters)
                      throws JPAExecutorException

Specified by:

getSingleValue in class QueryExecutor<CoordinatorJobBean,CoordJobQueryExecutor.CoordJobQuery>

Throws:

JPAExecutorException

getIfExist

public CoordinatorJobBean getIfExist(CoordJobQueryExecutor.CoordJobQuery namedQuery,
                            Object... parameters)
                              throws JPAExecutorException

Specified by:

getIfExist in class QueryExecutor<CoordinatorJobBean,CoordJobQueryExecutor.CoordJobQuery>

Throws:

JPAExecutorException