org.apache.ambari.server.orm.dao

Class UpgradeDAO

java.lang.Object

org.apache.ambari.server.orm.dao.UpgradeDAO

public class UpgradeDAO
extends Object

Manages the UpgradeEntity and UpgradeItemEntity classes

Constructor Summary

Constructors

Constructor and Description
UpgradeDAO()

Method Summary

Modifier and Type	Method and Description
void	create(UpgradeEntity entity) Creates the upgrade entity in the database
List<UpgradeEntity>	findAll() Get all items.
UpgradeEntity	findLastUpgradeForCluster(long clusterId, Direction direction)
UpgradeEntity	findLastUpgradeOrDowngradeForCluster(long clusterId)
UpgradeEntity	findRevertable(long clusterId) Gets the only revertable upgrade if one exists.
UpgradeEntity	findRevertableUsingJPQL(long clusterId) Gets the only revertable upgrade if one exists.
UpgradeEntity	findUpgrade(long upgradeId) Finds a specific upgrade
UpgradeEntity	findUpgradeByRequestId(Long requestId)
UpgradeGroupEntity	findUpgradeGroup(Long groupId)
UpgradeItemEntity	findUpgradeItemByRequestAndStage(Long requestId, Long stageId)
List<UpgradeEntity>	findUpgrades(long clusterId)
UpgradeEntity	merge(UpgradeEntity upgradeEntity)
void	removeAll(long clusterId) Removes all upgrades associated with the cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

UpgradeDAO

public UpgradeDAO()

Method Detail

findAll

public List<UpgradeEntity> findAll()

Get all items.

Returns:

List of all of the UpgradeEntity items.

findUpgrades

public List<UpgradeEntity> findUpgrades(long clusterId)

Parameters:

clusterId - the cluster id

Returns:

the list of upgrades initiated for the cluster

findUpgrade

public UpgradeEntity findUpgrade(long upgradeId)

Finds a specific upgrade

Parameters:

upgradeId - the id

Returns:

the entity, or null if not found

findUpgradeByRequestId

public UpgradeEntity findUpgradeByRequestId(Long requestId)

create

public void create(UpgradeEntity entity)

Creates the upgrade entity in the database

Parameters:

entity - the entity

removeAll

public void removeAll(long clusterId)

Removes all upgrades associated with the cluster.

Parameters:

clusterId - the cluster id

findUpgradeGroup

public UpgradeGroupEntity findUpgradeGroup(Long groupId)

Parameters:

groupId - the group id

Returns:

the group, or null if not found

findUpgradeItemByRequestAndStage

public UpgradeItemEntity findUpgradeItemByRequestAndStage(Long requestId,
                                                          Long stageId)

Parameters:

requestId - the request id

stageId - the stage id

Returns:

the upgrade entity, or null if not found

findLastUpgradeForCluster

public UpgradeEntity findLastUpgradeForCluster(long clusterId,
                                               Direction direction)

Parameters:

clusterId - the cluster id

direction - the direction (not null).

Returns:

the upgrade entity, or null if not found

findLastUpgradeOrDowngradeForCluster

public UpgradeEntity findLastUpgradeOrDowngradeForCluster(long clusterId)

Parameters:

clusterId - the cluster id

Returns:

the upgrade entity, or null if not found

findRevertable

public UpgradeEntity findRevertable(long clusterId)

Gets the only revertable upgrade if one exists. By definition, only the most recent RepositoryType#PATCH or RepositoryType#MAINT upgrade which doesn't have a downgrade already is revertable.

Parameters:

clusterId - the cluster id

Returns:

the upgrade which can be reverted, or null if not found

findRevertableUsingJPQL

public UpgradeEntity findRevertableUsingJPQL(long clusterId)

Gets the only revertable upgrade if one exists. By definition, only the most recent RepositoryType#PATCH or RepositoryType#MAINT upgrade which doesn't have a downgrade already is revertable.

This method tries to use some fancy SQL to do the work instead of relying on columns to be set correctly.

Parameters:

clusterId - the cluster id

Returns:

the upgrade which can be reverted, or null if not found

merge

public UpgradeEntity merge(UpgradeEntity upgradeEntity)