org.apache.ambari.server.upgrade

Class SchemaUpgradeHelper

java.lang.Object

org.apache.ambari.server.upgrade.SchemaUpgradeHelper

public class SchemaUpgradeHelper
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SchemaUpgradeHelper.UpgradeHelperModule Extension of main controller module

Constructor Summary

Constructors

Constructor and Description
SchemaUpgradeHelper(Set<UpgradeCatalog> allUpgradeCatalogs, com.google.inject.persist.PersistService persistService, DBAccessor dbAccessor, Configuration configuration)

Method Summary

Modifier and Type	Method and Description
void	cleanUpRCATables()
void	executeDMLUpdates(List<UpgradeCatalog> upgradeCatalogs, String ambariUpgradeConfigUpdatesFileName)
void	executeOnPostUpgrade(List<UpgradeCatalog> upgradeCatalogs)
void	executePreDMLUpdates(List<UpgradeCatalog> upgradeCatalogs)
void	executeUpgrade(List<UpgradeCatalog> upgradeCatalogs)
Set<UpgradeCatalog>	getAllUpgradeCatalogs()
protected String	getAmbariServerVersion() Read server version file
protected List<UpgradeCatalog>	getUpgradePath(String sourceVersion, String targetVersion) Return a set Upgrade catalogs to be applied to upgrade from
static void	main(String[] args) Upgrade Ambari DB schema to the target version passed in as the only argument.
void	outputUpgradeJsonOutput(List<UpgradeCatalog> upgradeCatalogs)
String	readSourceVersion()
void	resetUIState()
void	startPersistenceService()
void	stopPersistenceService()

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaUpgradeHelper

@Inject
public SchemaUpgradeHelper(Set<UpgradeCatalog> allUpgradeCatalogs,
                                   com.google.inject.persist.PersistService persistService,
                                   DBAccessor dbAccessor,
                                   Configuration configuration)

Method Detail

startPersistenceService

public void startPersistenceService()

stopPersistenceService

public void stopPersistenceService()

getAllUpgradeCatalogs

public Set<UpgradeCatalog> getAllUpgradeCatalogs()

readSourceVersion

public String readSourceVersion()

getAmbariServerVersion

protected String getAmbariServerVersion()

Read server version file

Returns:

getUpgradePath

protected List<UpgradeCatalog> getUpgradePath(String sourceVersion,
                                              String targetVersion)
                                       throws org.apache.ambari.server.AmbariException

Return a set Upgrade catalogs to be applied to upgrade from

Parameters:

sourceVersion -

targetVersion -

Returns:

Throws:

org.apache.ambari.server.AmbariException

executeUpgrade

public void executeUpgrade(List<UpgradeCatalog> upgradeCatalogs)
                    throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

executePreDMLUpdates

public void executePreDMLUpdates(List<UpgradeCatalog> upgradeCatalogs)
                          throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

executeDMLUpdates

public void executeDMLUpdates(List<UpgradeCatalog> upgradeCatalogs,
                              String ambariUpgradeConfigUpdatesFileName)
                       throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

executeOnPostUpgrade

public void executeOnPostUpgrade(List<UpgradeCatalog> upgradeCatalogs)
                          throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

outputUpgradeJsonOutput

public void outputUpgradeJsonOutput(List<UpgradeCatalog> upgradeCatalogs)
                             throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

resetUIState

public void resetUIState()
                  throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

cleanUpRCATables

public void cleanUpRCATables()

main

public static void main(String[] args)
                 throws Exception

Upgrade Ambari DB schema to the target version passed in as the only argument.

Parameters:

args - args[0] = target version to upgrade to.

Throws:

Exception