org.apache.brooklyn.entity.database.mysql

Class MySqlSshDriver

java.lang.Object

org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessDriver

org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

org.apache.brooklyn.entity.database.mysql.MySqlSshDriver

All Implemented Interfaces:

EntityDriver, MySqlDriver, NaiveScriptRunner, SoftwareProcessDriver

Direct Known Subclasses:

SimulatedMySqlNodeImpl.SimulatedMySqlSshDriver

public class MySqlSshDriver
extends AbstractSoftwareProcessSshDriver
implements MySqlDriver

The SSH implementation of the MySqlDriver.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	log

Fields inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

CHECK_RUNNING, CUSTOMIZING, DEBUG, IGNORE_ENTITY_SSH_FLAGS, INSTALL_INCOMPLETE, INSTALLING, KILLING, LAUNCHING, logSsh, NON_STANDARD_LAYOUT, PID_FILENAME, PROCESS_OWNER, RESTARTING, STOPPING, USE_PID_FILE, VALID_FLAGS

Constructor Summary

Constructors

Constructor and Description
MySqlSshDriver(MySqlNodeImpl entity, SshMachineLocation machine)

Method Summary

Modifier and Type	Method and Description
void	changePassword(java.lang.String oldPass, java.lang.String newPass) Updates the password, tries both the old and new password in-case the password has already been changed
void	customize() Implementations should fail if the return code is non-zero, by throwing some appropriate exception.
ProcessTaskWrapper<java.lang.Integer>	dumpDatabase(java.lang.String additionalOptions, java.lang.String dumpDestination)
ProcessTaskWrapper<java.lang.Integer>	executeScriptAsync(java.lang.String commands)
ProcessTaskWrapper<java.lang.Integer>	executeScriptFromInstalledFileAsync(java.lang.String filenameAlreadyInstalledAtServer)
java.lang.String	getBaseDir()
java.lang.String	getConfigFile()
java.lang.String	getDataDir()
java.lang.String	getDefaultUnpackedDirectoryName()
MySqlNodeImpl	getEntity() The entity whose components we are controlling.
java.lang.String	getLogFile()
java.lang.String	getMajorVersion()
java.lang.String	getMySqlServerOptionsString()
java.lang.String	getOsTag()
java.lang.String	getPassword()
int	getPort()
java.lang.String	getSocketUid()
java.lang.String	getStatusCmd()
void	install() Implementations should fail if the return code is non-zero, by throwing some appropriate exception.
boolean	isRunning() Whether the entity components have started.
void	kill() Kills the process, ungracefully and immediately where possible (e.g.
void	launch() Implementations should fail if the return code is non-zero, by throwing some appropriate exception.
void	prepare() Prepare the entity instance before running any commands.
void	stop() Performs software stop (or queues tasks to do this)

Methods inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

checkNoHostnameBug, copyCustomizeResources, copyInstallResources, copyPreInstallResources, copyResource, copyResource, execute, execute, execute, getAddress, getHostname, getLocation, getMachine, getPortsUsed, getSubnetAddress, getSubnetHostname, runPostCustomizeCommand, runPostInstallCommand, runPostLaunchCommand, runPreCustomizeCommand, runPreInstallCommand, runPreLaunchCommand, setup

Methods inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessDriver

copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyRuntimeResources, copyTemplate, copyTemplate, copyTemplate, getArchiveNameFormat, getExpandedInstallDir, getInstallDir, getResource, getResourceAsString, getRunDir, getShellEnvironment, getVersion, postLaunch, preInstall, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, setExpandedInstallDir, start

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcessDriver

rebind, restart, start

Methods inherited from interface org.apache.brooklyn.api.entity.drivers.EntityDriver

getLocation

Field Detail

log

public static final org.slf4j.Logger log

Constructor Detail

MySqlSshDriver

public MySqlSshDriver(MySqlNodeImpl entity,
                      SshMachineLocation machine)

Method Detail

getOsTag

public java.lang.String getOsTag()

getBaseDir

public java.lang.String getBaseDir()

getDataDir

public java.lang.String getDataDir()

getLogFile

public java.lang.String getLogFile()

getConfigFile

public java.lang.String getConfigFile()

getMajorVersion

public java.lang.String getMajorVersion()

getDefaultUnpackedDirectoryName

public java.lang.String getDefaultUnpackedDirectoryName()

prepare

public void prepare()

Description copied from class: AbstractSoftwareProcessDriver

Prepare the entity instance before running any commands. Always executed during AbstractSoftwareProcessDriver.start().

Overrides:

prepare in class AbstractSoftwareProcessSshDriver

install

public void install()

Description copied from class: AbstractSoftwareProcessDriver

Implementations should fail if the return code is non-zero, by throwing some appropriate exception.

Specified by:

install in class AbstractSoftwareProcessDriver

getEntity

public MySqlNodeImpl getEntity()

Description copied from interface: SoftwareProcessDriver

The entity whose components we are controlling.

Specified by:

getEntity in interface EntityDriver

Specified by:

getEntity in interface SoftwareProcessDriver

Overrides:

getEntity in class AbstractSoftwareProcessDriver

getPort

public int getPort()

getSocketUid

public java.lang.String getSocketUid()

getPassword

public java.lang.String getPassword()

customize

public void customize()

Description copied from class: AbstractSoftwareProcessDriver

Implementations should fail if the return code is non-zero, by throwing some appropriate exception.

Specified by:

customize in class AbstractSoftwareProcessDriver

changePassword

public void changePassword(java.lang.String oldPass,
                           java.lang.String newPass)

Updates the password, tries both the old and new password in-case the password has already been changed

Specified by:

changePassword in interface MySqlDriver

Parameters:

oldPass -

newPass -

getMySqlServerOptionsString

public java.lang.String getMySqlServerOptionsString()

launch

public void launch()

Description copied from class: AbstractSoftwareProcessDriver

Implementations should fail if the return code is non-zero, by throwing some appropriate exception.

Specified by:

launch in class AbstractSoftwareProcessDriver

isRunning

public boolean isRunning()

Description copied from interface: SoftwareProcessDriver

Whether the entity components have started.

Specified by:

isRunning in interface SoftwareProcessDriver

stop

public void stop()

Description copied from interface: SoftwareProcessDriver

Performs software stop (or queues tasks to do this)

Specified by:

stop in interface SoftwareProcessDriver

Specified by:

stop in class AbstractSoftwareProcessDriver

See Also:

Startable.stop()

kill

public void kill()

Description copied from interface: SoftwareProcessDriver

Kills the process, ungracefully and immediately where possible (e.g. with `kill -9`).

Specified by:

kill in interface SoftwareProcessDriver

Overrides:

kill in class AbstractSoftwareProcessDriver

getStatusCmd

public java.lang.String getStatusCmd()

Specified by:

getStatusCmd in interface MySqlDriver

executeScriptAsync

public ProcessTaskWrapper<java.lang.Integer> executeScriptAsync(java.lang.String commands)

Specified by:

executeScriptAsync in interface MySqlDriver

executeScriptFromInstalledFileAsync

public ProcessTaskWrapper<java.lang.Integer> executeScriptFromInstalledFileAsync(java.lang.String filenameAlreadyInstalledAtServer)

Specified by:

executeScriptFromInstalledFileAsync in interface MySqlDriver

dumpDatabase

public ProcessTaskWrapper<java.lang.Integer> dumpDatabase(java.lang.String additionalOptions,
                                                          java.lang.String dumpDestination)

Specified by:

dumpDatabase in interface MySqlDriver