org.apache.ambari.server.orm.dao

Class RequestDAO

java.lang.Object

org.apache.ambari.server.orm.dao.RequestDAO

All Implemented Interfaces:

Cleanable

public class RequestDAO
extends Object
implements Cleanable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RequestDAO.StageEntityPK

Constructor Summary

Constructors

Constructor and Description
RequestDAO()

Method Summary

Modifier and Type	Method and Description
protected <T> int	cleanTableByIds(Set<Long> ids, String paramName, String entityName, Long beforeDateMillis, String entityQuery, Class<T> type) In this method we are removing entities using passed ids, To prevent issues we are using batch request to remove limited count of entities.
protected <T> int	cleanTableByStageEntityPK(List<RequestDAO.StageEntityPK> ids, LinkedList<String> paramNames, String entityName, Long beforeDateMillis, String entityQuery, Class<T> type) In this method we are removing entities using passed few ids, To prevent issues we are using batch request to remove limited count of entities.
long	cleanup(TimeBasedCleanupPolicy policy) Performs the cleanup for the entiries the implementing DAO is responsible for.
void	create(RequestEntity requestEntity)
List<RequestEntity>	findAll()
List<Long>	findAllRequestIds(int limit, boolean ascending)
List<Long>	findAllRequestIds(int limit, boolean sortAscending, Long clusterId) Retrieves from the database for a cluster, or specifically for non-cluster requests.
List<RequestResourceFilterEntity>	findAllResourceFilters()
RequestEntity	findByPK(Long requestId)
List<RequestEntity>	findByPks(Collection<Long> requestIds)
List<RequestEntity>	findByPks(Collection<Long> requestIds, boolean refreshHint) Given a collection of request ids, load the corresponding entities
List<RequestDAO.StageEntityPK>	findRequestAndStageIdsInClusterBeforeDate(Long clusterId, long beforeDateMillis) Search for all request and stage ids in Request and Stage tables
Long	getLastStageId(long requestId)
boolean	isAllTasksCompleted(long requestId)
RequestEntity	merge(RequestEntity requestEntity)
void	remove(RequestEntity requestEntity)
void	removeByPK(Long requestId)
RequestEntity	updateStatus(long requestId, HostRoleStatus status, HostRoleStatus displayStatus)

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestDAO

public RequestDAO()

Method Detail

findByPK

public RequestEntity findByPK(Long requestId)

findByPks

public List<RequestEntity> findByPks(Collection<Long> requestIds)

findByPks

public List<RequestEntity> findByPks(Collection<Long> requestIds,
                                     boolean refreshHint)

Given a collection of request ids, load the corresponding entities

Parameters:

requestIds - the collection of request ids

refreshHint - true to hint JPA that the list should be refreshed

Returns:

the list entities. An empty list if the requestIds are not provided

findAll

public List<RequestEntity> findAll()

findAllRequestIds

public List<Long> findAllRequestIds(int limit,
                                    boolean ascending)

findAllResourceFilters

public List<RequestResourceFilterEntity> findAllResourceFilters()

isAllTasksCompleted

public boolean isAllTasksCompleted(long requestId)

getLastStageId

public Long getLastStageId(long requestId)

updateStatus

public RequestEntity updateStatus(long requestId,
                                  HostRoleStatus status,
                                  HostRoleStatus displayStatus)

create

public void create(RequestEntity requestEntity)

merge

public RequestEntity merge(RequestEntity requestEntity)

remove

public void remove(RequestEntity requestEntity)

removeByPK

public void removeByPK(Long requestId)

findAllRequestIds

public List<Long> findAllRequestIds(int limit,
                                    boolean sortAscending,
                                    Long clusterId)

Retrieves from the database for a cluster, or specifically for non-cluster requests. This method should be considered temporary until Request/Stage/Task cleanup is achieved.

Parameters:

limit - the max number to return

sortAscending - true to sort by requestId ascending, false for descending

clusterId - the cluster to find, or null to search for requests without cluster

findRequestAndStageIdsInClusterBeforeDate

public List<RequestDAO.StageEntityPK> findRequestAndStageIdsInClusterBeforeDate(Long clusterId,
                                                                                long beforeDateMillis)

Search for all request and stage ids in Request and Stage tables

Returns:

the list of request/stage ids

cleanTableByIds

protected <T> int cleanTableByIds(Set<Long> ids,
                                  String paramName,
                                  String entityName,
                                  Long beforeDateMillis,
                                  String entityQuery,
                                  Class<T> type)

In this method we are removing entities using passed ids, To prevent issues we are using batch request to remove limited count of entities.

Parameters:

ids - list of ids that we are using to remove rows from table

paramName - name of parameter that we are using in sql query (taskIds, stageIds)

entityName - name of entity which we will remove

beforeDateMillis - timestamp which was set by user (remove all entities that were created before), we are using it only for logging

entityQuery - name of NamedQuery which we will use to remove needed entities

type - type of entity class which we will use for casting query result

Returns:

rows count that were removed

cleanTableByStageEntityPK

protected <T> int cleanTableByStageEntityPK(List<RequestDAO.StageEntityPK> ids,
                                            LinkedList<String> paramNames,
                                            String entityName,
                                            Long beforeDateMillis,
                                            String entityQuery,
                                            Class<T> type)

In this method we are removing entities using passed few ids, To prevent issues we are using batch request to remove limited count of entities.

Parameters:

ids - list of ids pairs that we are using to remove rows from table

paramNames - list of two names of parameters that we are using in sql query (taskIds, stageIds)

entityName - name of entity which we will remove

beforeDateMillis - timestamp which was set by user (remove all entities that were created before), we are using it only for logging

entityQuery - name of NamedQuery which we will use to remove needed entities

type - type of entity class which we will use for casting query result

Returns:

rows count that were removed

cleanup

public long cleanup(TimeBasedCleanupPolicy policy)

Description copied from interface: Cleanable

Performs the cleanup for the entiries the implementing DAO is responsible for.

Specified by:

cleanup in interface Cleanable

Parameters:

policy - the policy with the parameters of the cleanup

Returns:

the number of affected records if available