org.apache.oozie.executor.jpa

Class WorkflowJobQueryExecutor

java.lang.Object

org.apache.oozie.executor.jpa.QueryExecutor<WorkflowJobBean,WorkflowJobQueryExecutor.WorkflowJobQuery>

org.apache.oozie.executor.jpa.WorkflowJobQueryExecutor

public class WorkflowJobQueryExecutor
extends QueryExecutor<WorkflowJobBean,WorkflowJobQueryExecutor.WorkflowJobQuery>

Query Executor that provides API to run query for Workflow Job

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WorkflowJobQueryExecutor.WorkflowJobQuery

Method Summary

Methods

Modifier and Type	Method and Description
int	executeUpdate(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, WorkflowJobBean jobBean)
WorkflowJobBean	get(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, Object... parameters)
static QueryExecutor<WorkflowJobBean,WorkflowJobQueryExecutor.WorkflowJobQuery>	getInstance()
List<WorkflowJobBean>	getList(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, Object... parameters)
javax.persistence.Query	getSelectQuery(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, javax.persistence.EntityManager em, Object... parameters)
Object	getSingleValue(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, Object... parameters)
javax.persistence.Query	getUpdateQuery(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, WorkflowJobBean wfBean, 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<WorkflowJobBean,WorkflowJobQueryExecutor.WorkflowJobQuery> getInstance()

getUpdateQuery

public javax.persistence.Query getUpdateQuery(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery,
                                     WorkflowJobBean wfBean,
                                     javax.persistence.EntityManager em)
                                       throws JPAExecutorException

Specified by:

getUpdateQuery in class QueryExecutor<WorkflowJobBean,WorkflowJobQueryExecutor.WorkflowJobQuery>

Throws:

JPAExecutorException

getSelectQuery

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

Specified by:

getSelectQuery in class QueryExecutor<WorkflowJobBean,WorkflowJobQueryExecutor.WorkflowJobQuery>

Throws:

JPAExecutorException

executeUpdate

public int executeUpdate(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery,
                WorkflowJobBean jobBean)
                  throws JPAExecutorException

Specified by:

executeUpdate in class QueryExecutor<WorkflowJobBean,WorkflowJobQueryExecutor.WorkflowJobQuery>

Throws:

JPAExecutorException

get

public WorkflowJobBean get(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery,
                  Object... parameters)
                    throws JPAExecutorException

Specified by:

get in class QueryExecutor<WorkflowJobBean,WorkflowJobQueryExecutor.WorkflowJobQuery>

Throws:

JPAExecutorException

getList

public List<WorkflowJobBean> getList(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery,
                            Object... parameters)
                              throws JPAExecutorException

Specified by:

getList in class QueryExecutor<WorkflowJobBean,WorkflowJobQueryExecutor.WorkflowJobQuery>

Throws:

JPAExecutorException

getSingleValue

public Object getSingleValue(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery,
                    Object... parameters)
                      throws JPAExecutorException

Specified by:

getSingleValue in class QueryExecutor<WorkflowJobBean,WorkflowJobQueryExecutor.WorkflowJobQuery>

Throws:

JPAExecutorException