org.apache.ambari.server.orm.dao

Class ClusterDAO

java.lang.Object

org.apache.ambari.server.orm.dao.ClusterDAO

public class ClusterDAO
extends Object

Constructor Summary

Constructors

Constructor and Description
ClusterDAO()

Method Summary

Modifier and Type	Method and Description
void	create(ClusterEntity clusterEntity) Create Cluster entity in Database
void	createConfig(ClusterConfigEntity entity) Creates a cluster configuration in the DB.
List<ClusterEntity>	findAll()
ClusterEntity	findById(long id) Looks for Cluster by ID
ClusterEntity	findByName(String clusterName)
ClusterEntity	findByResourceId(long resourceId)
ClusterConfigEntity	findConfig(Long configEntityPK)
ClusterConfigEntity	findConfig(Long clusterId, String type, Long version)
ClusterConfigEntity	findConfig(Long clusterId, String type, String tag)
ClusterConfigEntity	findEnabledConfigByType(long clusterId, String type) Gets the latest config in the given cluster by type name.
Long	findNextConfigVersion(long clusterId, String configType) Gets the next version that will be created for a given ClusterConfigEntity.
List<ClusterConfigEntity>	getAllConfigurations(Long clusterId, StackId stackId) Get all configurations for the specified cluster and stack.
List<ClusterConfigEntity>	getEnabledConfigs(long clusterId) Gets the latest configurations for the specified cluster.
List<ClusterConfigEntity>	getEnabledConfigsByStack(long clusterId, StackId stackId) Gets the latest configurations for a given stack for all of the configurations of the specified cluster.
List<ClusterConfigEntity>	getEnabledConfigsByTypes(Long clusterId, Collection<String> types)
List<ClusterConfigEntity>	getLatestConfigurations(long clusterId, StackId stackId) Gets the latest configurations for a given stack for all of the configurations of the specified cluster.
List<ClusterConfigEntity>	getLatestConfigurationsWithTypes(long clusterId, StackId stackId, Collection<String> configTypes) Gets the latest configurations for a given stack with any of the given config types.
boolean	isManaged(ClusterEntity entity)
ClusterConfigEntity	merge(ClusterConfigEntity clusterConfigEntity) Merge the specified entity into the current persistence context.
ClusterConfigEntity	merge(ClusterConfigEntity clusterConfigEntity, boolean flush) Merge the specified entity into the current persistence context.
ClusterEntity	merge(ClusterEntity clusterEntity) Merge the specified entity into the current persistence context.
ClusterEntity	merge(ClusterEntity clusterEntity, boolean flush) Merge the specified entity into the current persistence context, optionally instructing the EntityManager to write any queued persist/merges into the database immediately.
void	refresh(ClusterEntity clusterEntity) Retrieve entity data from DB
void	remove(ClusterEntity clusterEntity)
void	removeByName(String clusterName)
void	removeByPK(long id)
void	removeConfig(ClusterConfigEntity entity) Remove a cluster configuration in the DB.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterDAO

public ClusterDAO()

Method Detail

findById

public ClusterEntity findById(long id)

Looks for Cluster by ID

Parameters:

id - ID of Cluster

Returns:

Found entity or NULL

findByName

public ClusterEntity findByName(String clusterName)

findByResourceId

public ClusterEntity findByResourceId(long resourceId)

findAll

public List<ClusterEntity> findAll()

findConfig

public ClusterConfigEntity findConfig(Long configEntityPK)

findConfig

public ClusterConfigEntity findConfig(Long clusterId,
                                      String type,
                                      String tag)

getEnabledConfigsByTypes

public List<ClusterConfigEntity> getEnabledConfigsByTypes(Long clusterId,
                                                          Collection<String> types)

findConfig

public ClusterConfigEntity findConfig(Long clusterId,
                                      String type,
                                      Long version)

findNextConfigVersion

public Long findNextConfigVersion(long clusterId,
                                  String configType)

Gets the next version that will be created for a given ClusterConfigEntity.

Parameters:

clusterId - the cluster that the service is a part of.

configType - the name of the configuration type (not null).

Returns:

the highest existing value of the version column + 1

getAllConfigurations

public List<ClusterConfigEntity> getAllConfigurations(Long clusterId,
                                                      StackId stackId)

Get all configurations for the specified cluster and stack. This will return different versions of the same configuration type (cluster-env v1 and cluster-env v2) if they exist.

Parameters:

clusterId - the cluster (not null).

stackId - the stack (not null).

Returns:

all service configurations for the cluster and stack.

getLatestConfigurations

public List<ClusterConfigEntity> getLatestConfigurations(long clusterId,
                                                         StackId stackId)

Gets the latest configurations for a given stack for all of the configurations of the specified cluster. This method does not take into account the configuration being enabled, as the latest for a given stack may not be "selected".

Parameters:

clusterId - the cluster that the service is a part of.

stackId - the stack to get the latest configurations for (not null).

Returns:

the latest configurations for the specified cluster and stack.

getLatestConfigurationsWithTypes

public List<ClusterConfigEntity> getLatestConfigurationsWithTypes(long clusterId,
                                                                  StackId stackId,
                                                                  Collection<String> configTypes)

Gets the latest configurations for a given stack with any of the given config types. This method does not take into account the configuration being enabled.

getEnabledConfigsByStack

public List<ClusterConfigEntity> getEnabledConfigsByStack(long clusterId,
                                                          StackId stackId)

Gets the latest configurations for a given stack for all of the configurations of the specified cluster.

Parameters:

clusterId - the cluster that the service is a part of.

stackId - the stack to get the latest configurations for (not null).

Returns:

the latest configurations for the specified cluster and stack.

getEnabledConfigs

public List<ClusterConfigEntity> getEnabledConfigs(long clusterId)

Gets the latest configurations for the specified cluster.

Parameters:

clusterId - the cluster that the service is a part of.

Returns:

the latest configurations for the specified cluster.

findEnabledConfigByType

public ClusterConfigEntity findEnabledConfigByType(long clusterId,
                                                   String type)

Gets the latest config in the given cluster by type name. Only a config which is enabled can be returned.

Parameters:

clusterId - the ID of the cluster.

type - the config type (not null).

Returns:

a config, or null if there is none enabled.

create

public void create(ClusterEntity clusterEntity)

Create Cluster entity in Database

Parameters:

clusterEntity - entity to create

createConfig

public void createConfig(ClusterConfigEntity entity)

Creates a cluster configuration in the DB.

removeConfig

public void removeConfig(ClusterConfigEntity entity)

Remove a cluster configuration in the DB.

refresh

public void refresh(ClusterEntity clusterEntity)

Retrieve entity data from DB

Parameters:

clusterEntity - entity to refresh

merge

public ClusterEntity merge(ClusterEntity clusterEntity)

Merge the specified entity into the current persistence context.

Parameters:

clusterEntity - the entity to merge (not null).

Returns:

the managed entity which was merged (never null).

merge

public ClusterEntity merge(ClusterEntity clusterEntity,
                           boolean flush)

Merge the specified entity into the current persistence context, optionally instructing the EntityManager to write any queued persist/merges into the database immediately.

Parameters:

clusterEntity - the entity to merge (not null).

flush - if true then EntityManager.flush() will be invoked immediately after the merge.

Returns:

the managed entity which was merged (never null).

merge

public ClusterConfigEntity merge(ClusterConfigEntity clusterConfigEntity)

Merge the specified entity into the current persistence context.

Parameters:

clusterConfigEntity - the entity to merge (not null).

Returns:

the managed entity which was merged (never null).

merge

public ClusterConfigEntity merge(ClusterConfigEntity clusterConfigEntity,
                                 boolean flush)

Merge the specified entity into the current persistence context.

Parameters:

clusterConfigEntity - the entity to merge (not null).

flush - if true then EntityManager.flush() will be invoked immediately after the merge.

Returns:

the managed entity which was merged (never null).

remove

public void remove(ClusterEntity clusterEntity)

removeByName

public void removeByName(String clusterName)

removeByPK

public void removeByPK(long id)

isManaged

public boolean isManaged(ClusterEntity entity)