org.apache.oozie.service

Class JPAService

java.lang.Object

org.apache.oozie.service.JPAService

All Implemented Interfaces:

Service, Instrumentable

public class JPAService
extends java.lang.Object
implements Service, Instrumentable

Service that manages JPA and executes JPAExecutor.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JPAService.QueryEntry<E extends java.lang.Enum<E>>

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONF_CONN_DATA_SOURCE
static java.lang.String	CONF_CONN_PROPERTIES
static java.lang.String	CONF_CREATE_DB_SCHEMA
static java.lang.String	CONF_DB_SCHEMA
static java.lang.String	CONF_DRIVER
static java.lang.String	CONF_MAX_ACTIVE_CONN
static java.lang.String	CONF_OPENJPA_BROKER_IMPL
static java.lang.String	CONF_PASSWORD
static java.lang.String	CONF_PREFIX
static java.lang.String	CONF_URL
static java.lang.String	CONF_USERNAME
static java.lang.String	CONF_VALIDATE_DB_CONN
static java.lang.String	CONF_VALIDATE_DB_CONN_EVICTION_INTERVAL
static java.lang.String	CONF_VALIDATE_DB_CONN_EVICTION_NUM
static long	DEFAULT_INITIAL_WAIT_TIME
static int	DEFAULT_MAX_RETRY_COUNT
static long	DEFAULT_MAX_WAIT_TIME
static java.lang.String	INITIAL_WAIT_TIME
static java.lang.String	MAX_RETRY_COUNT
static java.lang.String	MAX_WAIT_TIME
static java.lang.String	SKIP_COMMIT_FAULT_INJECTION_CLASS

Fields inherited from interface org.apache.oozie.service.Service

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
JPAService()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy() Destroy the JPAService
<T> T	execute(JPAExecutor<T> executor) Execute a JPAExecutor.
void	executeBatchInsertUpdateDelete(java.util.Collection<JsonBean> insertBeans, java.util.List<JPAService.QueryEntry> updateQueryList, java.util.Collection<JsonBean> deleteBeans, javax.persistence.EntityManager em) Execute multiple update/insert queries in one transaction
java.lang.Object	executeGet(java.lang.String namedQueryName, javax.persistence.Query query, javax.persistence.EntityManager em) Execute a SELECT query
java.util.List<?>	executeGetList(java.lang.String namedQueryName, javax.persistence.Query query, javax.persistence.EntityManager em) Execute a SELECT query to get list of results
int	executeUpdate(java.lang.String namedQueryName, javax.persistence.Query query, javax.persistence.EntityManager em) Execute an UPDATE query
javax.persistence.EntityManager	getEntityManager() Return an EntityManager.
java.lang.Class<? extends Service>	getInterface() Return the public interface of the service.
void	init(Services services) Initializes the JPAService.
void	instrument(Instrumentation instr) Set the system instrumentation.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_INITIAL_WAIT_TIME

public static final long DEFAULT_INITIAL_WAIT_TIME

See Also:

Constant Field Values

DEFAULT_MAX_WAIT_TIME

public static final long DEFAULT_MAX_WAIT_TIME

See Also:

Constant Field Values

DEFAULT_MAX_RETRY_COUNT

public static final int DEFAULT_MAX_RETRY_COUNT

See Also:

Constant Field Values

CONF_DB_SCHEMA

public static final java.lang.String CONF_DB_SCHEMA

See Also:

Constant Field Values

CONF_PREFIX

public static final java.lang.String CONF_PREFIX

See Also:

Constant Field Values

CONF_URL

public static final java.lang.String CONF_URL

See Also:

Constant Field Values

CONF_DRIVER

public static final java.lang.String CONF_DRIVER

See Also:

Constant Field Values

CONF_USERNAME

public static final java.lang.String CONF_USERNAME

See Also:

Constant Field Values

CONF_PASSWORD

public static final java.lang.String CONF_PASSWORD

See Also:

Constant Field Values

CONF_CONN_DATA_SOURCE

public static final java.lang.String CONF_CONN_DATA_SOURCE

See Also:

Constant Field Values

CONF_CONN_PROPERTIES

public static final java.lang.String CONF_CONN_PROPERTIES

See Also:

Constant Field Values

CONF_MAX_ACTIVE_CONN

public static final java.lang.String CONF_MAX_ACTIVE_CONN

See Also:

Constant Field Values

CONF_CREATE_DB_SCHEMA

public static final java.lang.String CONF_CREATE_DB_SCHEMA

See Also:

Constant Field Values

CONF_VALIDATE_DB_CONN

public static final java.lang.String CONF_VALIDATE_DB_CONN

See Also:

Constant Field Values

CONF_VALIDATE_DB_CONN_EVICTION_INTERVAL

public static final java.lang.String CONF_VALIDATE_DB_CONN_EVICTION_INTERVAL

See Also:

Constant Field Values

CONF_VALIDATE_DB_CONN_EVICTION_NUM

public static final java.lang.String CONF_VALIDATE_DB_CONN_EVICTION_NUM

See Also:

Constant Field Values

CONF_OPENJPA_BROKER_IMPL

public static final java.lang.String CONF_OPENJPA_BROKER_IMPL

See Also:

Constant Field Values

INITIAL_WAIT_TIME

public static final java.lang.String INITIAL_WAIT_TIME

See Also:

Constant Field Values

MAX_WAIT_TIME

public static final java.lang.String MAX_WAIT_TIME

See Also:

Constant Field Values

MAX_RETRY_COUNT

public static final java.lang.String MAX_RETRY_COUNT

See Also:

Constant Field Values

SKIP_COMMIT_FAULT_INJECTION_CLASS

public static final java.lang.String SKIP_COMMIT_FAULT_INJECTION_CLASS

Constructor Detail

JPAService

public JPAService()

Method Detail

getInterface

public java.lang.Class<? extends Service> getInterface()

Return the public interface of the service.

Specified by:

getInterface in interface Service

Returns:

JPAService.

instrument

public void instrument(Instrumentation instr)

Description copied from interface: Instrumentable

Set the system instrumentation.

Specified by:

instrument in interface Instrumentable

Parameters:

instr - system instrumentation.

init

public void init(Services services)
          throws ServiceException

Initializes the JPAService.

Specified by:

init in interface Service

Parameters:

services - services instance.

Throws:

ServiceException - thrown if the service could not initialize.

destroy

public void destroy()

Destroy the JPAService

Specified by:

destroy in interface Service

execute

public <T> T execute(JPAExecutor<T> executor)
          throws JPAExecutorException

Execute a JPAExecutor.

Parameters:

executor - JPAExecutor to execute.

Returns:

return value of the JPAExecutor.

Throws:

JPAExecutorException - thrown if an jpa executor failed

executeUpdate

public int executeUpdate(java.lang.String namedQueryName,
                javax.persistence.Query query,
                javax.persistence.EntityManager em)
                  throws JPAExecutorException

Execute an UPDATE query

Parameters:

namedQueryName - the name of query to be executed

query - query instance to be executed

em - Entity Manager

Returns:

Integer that query returns, which corresponds to the number of rows updated

Throws:

JPAExecutorException

executeBatchInsertUpdateDelete

public void executeBatchInsertUpdateDelete(java.util.Collection<JsonBean> insertBeans,
                                  java.util.List<JPAService.QueryEntry> updateQueryList,
                                  java.util.Collection<JsonBean> deleteBeans,
                                  javax.persistence.EntityManager em)
                                    throws JPAExecutorException

Execute multiple update/insert queries in one transaction

Parameters:

insertBeans - list of beans to be inserted

updateQueryList - list of update queries

deleteBeans - list of beans to be deleted

em - Entity Manager

Throws:

JPAExecutorException

executeGet

public java.lang.Object executeGet(java.lang.String namedQueryName,
                          javax.persistence.Query query,
                          javax.persistence.EntityManager em)
                            throws JPAExecutorException

Execute a SELECT query

Parameters:

namedQueryName - the name of query to be executed

query - query instance to be executed

em - Entity Manager

Returns:

object that matches the query

Throws:

JPAExecutorException

executeGetList

public java.util.List<?> executeGetList(java.lang.String namedQueryName,
                               javax.persistence.Query query,
                               javax.persistence.EntityManager em)
                                 throws JPAExecutorException

Execute a SELECT query to get list of results

Parameters:

namedQueryName - the name of query to be executed

query - query instance to be executed

em - Entity Manager

Returns:

list containing results that match the query

Throws:

JPAExecutorException

getEntityManager

public javax.persistence.EntityManager getEntityManager()

Return an EntityManager. Used by the StoreService. Once the StoreService is removed this method must be removed.

Returns:

an entity manager