org.apache.ambari.server.orm.dao

Class ExtensionDAO

java.lang.Object

org.apache.ambari.server.orm.dao.ExtensionDAO

public class ExtensionDAO
extends Object

The ExtensionDAO class is used to manage the persistence and retrieval of ExtensionEntity instances. An extension version is like a stack version but it contains custom services. Linking an extension version to the current stack version allows the cluster to install the custom services contained in the extension version.

Constructor Summary

Constructors

Constructor and Description
ExtensionDAO()

Method Summary

Modifier and Type	Method and Description
void	create(ExtensionEntity extension) Persists a new extension instance.
void	createOrUpdate(ExtensionEntity extension) Creates or updates the specified entity.
ExtensionEntity	find(String extensionName, String extensionVersion) Gets the extension that matches the specified name and version.
List<ExtensionEntity>	findAll() Gets all of the defined extensions.
ExtensionEntity	findById(long extensionId) Gets a extension with the specified ID.
ExtensionEntity	merge(ExtensionEntity extension) Merge the specified extension with the existing extension in the database.
void	refresh(ExtensionEntity extension) Refresh the state of the extension instance from the database.
void	remove(ExtensionEntity extension) Removes the specified extension and all related clusters, services and components.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExtensionDAO

public ExtensionDAO()

Method Detail

findById

public ExtensionEntity findById(long extensionId)

Gets a extension with the specified ID.

Parameters:

extensionId - the ID of the extension to retrieve.

Returns:

the extension or null if none exists.

findAll

public List<ExtensionEntity> findAll()

Gets all of the defined extensions.

Returns:

all of the extensions loaded from resources or an empty list (never null).

find

public ExtensionEntity find(String extensionName,
                            String extensionVersion)

Gets the extension that matches the specified name and version.

Returns:

the extension matching the specified name and version or null if none.

create

public void create(ExtensionEntity extension)
            throws org.apache.ambari.server.AmbariException

Persists a new extension instance.

Parameters:

extension - the extension to persist (not null).

Throws:

org.apache.ambari.server.AmbariException

refresh

public void refresh(ExtensionEntity extension)

Refresh the state of the extension instance from the database.

Parameters:

extension - the extension to refresh (not null).

merge

public ExtensionEntity merge(ExtensionEntity extension)

Merge the specified extension with the existing extension in the database.

Parameters:

extension - the extension to merge (not null).

Returns:

the updated extension with merged content (never null).

createOrUpdate

public void createOrUpdate(ExtensionEntity extension)
                    throws org.apache.ambari.server.AmbariException

Creates or updates the specified entity. This method will check ExtensionEntity.getExtensionId() in order to determine whether the entity should be created or merged.

Parameters:

extension - the extension to create or update (not null).

Throws:

org.apache.ambari.server.AmbariException

remove

public void remove(ExtensionEntity extension)

Removes the specified extension and all related clusters, services and components.

Parameters:

extension - the extension to remove.