org.apache.derbyTesting.functionTests.tests.replicationTests

Class ReplicationRun

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

org.apache.derbyTesting.junit.BaseTestCase

org.apache.derbyTesting.functionTests.tests.replicationTests.ReplicationRun

All Implemented Interfaces:

junit.framework.Test

Direct Known Subclasses:

ReplicationRun_CleanUp, ReplicationRun_Distributed, ReplicationRun_Full, ReplicationRun_Local, ReplicationRun_Local_1, ReplicationRun_Local_1Indexing, ReplicationRun_Local_3, ReplicationRun_Local_3_p4, ReplicationRun_Local_Derby4910, ReplicationRun_Local_Encrypted_1, ReplicationRun_Local_showStateChange, ReplicationRun_Local_StateTest_part1, ReplicationRun_Local_StateTest_part1_1, ReplicationRun_Local_StateTest_part1_2, ReplicationRun_Local_StateTest_part1_3, ReplicationRun_Local_StateTest_part2

public class ReplicationRun
extends BaseTestCase

Framework to run replication tests. Subclass to create specific tests as in ReplicationRun_Local and ReplicationRun_Distributed.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	ReplicationRun.Load
(package private) class	ReplicationRun.State

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static java.lang.String	ALL_INTERFACES
(package private) static java.lang.String	bootLoad
(package private) java.lang.String	classPath
(package private) static int	commitFreq
(package private) static java.lang.String	dataEncryption
private java.lang.String	db_passwd
(package private) static java.lang.String	DB_PROTOCOL
private java.lang.String	db_uid
(package private) static java.lang.String	derbyMasterVersion
(package private) static java.lang.String	derbyProperties
(package private) static java.lang.String	derbySlaveVersion
(package private) static java.lang.String	derbyVersion
(package private) static java.lang.String	DRIVER_CLASS_NAME
(package private) static java.lang.String	freezeDB
(package private) static java.lang.String	FS
private java.util.ArrayList	helperThreads List of threads that have been started by the tests and not explicitly waited for.
(package private) static java.lang.String	junit_jar
(package private) static boolean	junitTest
(package private) static java.lang.String	jvmVersion
(package private) static java.lang.String	LF
(package private) static boolean	localEnv
private java.sql.Connection	masterConn A Connection to the master database
(package private) static java.lang.String	masterDatabasePath
(package private) static java.lang.String	masterDbSubPath
(package private) static java.lang.String	masterJvmVersion
(package private) static ReplicationRun.Load	masterPostRepl
(package private) static ReplicationRun.Load	masterPostSlave
(package private) static ReplicationRun.Load	masterPreRepl
(package private) static java.lang.String	masterServerHost
(package private) static int	masterServerPort
(package private) static int	MINUTES
(package private) static java.lang.String	networkServerControl
(package private) static java.lang.String	PS
(package private) static java.lang.String	remoteShell
(package private) static java.lang.String	replicatedDb
(package private) static java.lang.String	REPLICATION_DB_NOT_BOOTED
(package private) static java.lang.String	REPLICATION_MASTER_TIMED_OUT
(package private) static java.lang.String	REPLICATION_SLAVE_SHUTDOWN_OK
(package private) static java.lang.String	REPLICATION_SLAVE_STARTED_OK
(package private) static java.lang.String	replicationTest
(package private) static java.lang.String	REPLICATIONTEST_PROPFILE Name of properties file defining the test environment and replication tests to be run.
(package private) static java.lang.String	replicationVerify
(package private) static boolean	runUnReplicated
(package private) static boolean	showSysinfo
(package private) static boolean	simpleLoad
(package private) static int	simpleLoadTuples
(package private) static java.lang.String	SLAVE_OPERATION_DENIED_WHILE_CONNECTED
private java.sql.Connection	slaveConn A Connection to the slave database
(package private) static java.lang.String	slaveDatabasePath
(package private) static java.lang.String	slaveDbSubPath
(package private) static java.lang.String	slaveJvmVersion
(package private) static ReplicationRun.Load	slavePostSlave
(package private) static ReplicationRun.Load	slavePreSlave
(package private) static int	slaveReplPort
(package private) static java.lang.String	slaveServerHost
(package private) static int	slaveServerPort
(package private) static long	sleepTime
(package private) static java.lang.String	specialTestingJar
(package private) static java.lang.String	sqlLoadInit
private java.lang.Exception	startSlaveException The exception thrown as a result of a startSlave connection attempt
(package private) ReplicationRun.State	state
(package private) static java.lang.String	test_jars
(package private) static java.lang.String	testClientHost
(package private) static java.lang.String	testUser
(package private) static int	THREADS
(package private) static int	tuplesToInsertPerf
(package private) static java.lang.String	unFreezeDB
(package private) static java.lang.String	userDir
(package private) static java.lang.String	userHome
(package private) Utils	util

Fields inherited from class org.apache.derbyTesting.junit.BaseTestCase

DEFAULT_DB_DIR, DERBY_LOG, ERRORSTACKTRACEFILE

Constructor Summary

Constructors

Constructor and Description
ReplicationRun(java.lang.String testcaseName) Creates a new instance of ReplicationRun
ReplicationRun(java.lang.String testcaseName, java.lang.String user, java.lang.String password) Creates a new instance of ReplicationRun running with authentication.

Method Summary

Modifier and Type	Method and Description
(package private) void	_testInsertUpdateDeleteOnMaster(java.lang.String serverHost, int serverPort, java.lang.String dbPath, int _noTuplesToInsert)
(package private) void	_verify(java.sql.Connection conn, int _noTuplesInserted)
(package private) void	_verifyDatabase(java.lang.String serverHost, int serverPort, java.lang.String dbPath, int _noTuplesInserted)
(package private) void	assertException(java.sql.SQLException se, java.lang.String expectedSqlState)
protected void	assertSqlStateSlaveConn(java.lang.String expected) Assert that the latest startSlave connection attempt got the expected SQLState.
(package private) void	bootMasterDatabase(java.lang.String clientVM, java.lang.String dbSubPath, java.lang.String dbName, java.lang.String masterHost, int masterServerPort, java.lang.String load)
(package private) void	cleanAllTestHosts()
private static void	close(java.sql.Connection conn) Close a connection.
(package private) org.apache.derby.jdbc.ClientDataSourceInterface	configureDataSource(java.lang.String dbName, java.lang.String serverHost, int serverPort, java.lang.String connectionAttributes) Set up a data source.
(package private) void	connectPing(java.lang.String fullDbPath, java.lang.String serverHost, int serverPort, java.lang.String testClientHost)
(package private) java.lang.String	credentials()
(package private) void	destroySlaveDB(java.lang.String slaveServerHost)
protected void	executeOnMaster(java.lang.String sql) Execute SQL on the master database through a Statement
protected void	executeOnSlave(java.lang.String sql) Execute SQL on the slave database through a Statement
private void	failOver_direct(java.lang.String dbName)
private void	failOver_ij(java.lang.String dbName, java.lang.String host, java.lang.String testClientHost)
(package private) void	failOver(java.lang.String jvmVersion, java.lang.String dbPath, java.lang.String dbSubPath, java.lang.String dbName, java.lang.String host, int serverPort, java.lang.String testClientHost)
private static java.lang.String	getClientJavaExecutableName()
(package private) java.sql.Connection	getConnection(java.lang.String serverHost, int serverPort, java.lang.String databasePath, java.lang.String dbSubPath, java.lang.String replicatedDb)
protected java.sql.Connection	getMasterConnection() Get a connection to the master database.
private static java.lang.String	getMasterJavaExecutableName()
private static java.lang.String	getServerJavaExecutableName(java.lang.String serverHost, java.lang.String serverVM)
protected java.sql.Connection	getSlaveConnection() Get a connection to the slave database.
private static java.lang.String	getSlaveJavaExecutableName()
(package private) void	initEnvironment()
(package private) void	initMaster(java.lang.String host, java.lang.String dbName)
(package private) void	initSlave(java.lang.String host, java.lang.String clientVM, java.lang.String dbName)
(package private) void	killMaster(java.lang.String masterServerHost, int masterServerPort)
(package private) void	killSlave(java.lang.String slaveServerHost, int slaveServerPort)
(package private) void	makeReadyForReplication()
(package private) java.lang.String	masterDbPath(java.lang.String dbName)
(package private) java.lang.String	masterLoadURL(java.lang.String dbSubPath)
(package private) java.lang.String	masterURL(java.lang.String dbName)
private void	pingServer(java.lang.String hostName, int port)
private void	processDEBUGOutput(java.lang.String id, java.lang.Process proc)
private java.lang.String	processOutput(java.lang.String id, java.lang.Process proc)
private void	registerThread(java.lang.Thread thread) Register that a thread has been started so that we can wait for it to complete in tearDown().
private void	removeSlaveDBfiles(java.lang.String host, java.lang.String dbName)
(package private) void	restartServer(java.lang.String serverVM, java.lang.String serverVersion, java.lang.String serverHost, java.lang.String interfacesToListenOn, int serverPort, java.lang.String dbSubDirPath)
void	runBare() Run the test.
private void	runLoad(java.lang.String load, java.lang.String clientVM, java.lang.String testClientHost, java.lang.String masterHost, int masterPort, java.lang.String dbSubPath)
private void	runMasterVerificationCLient(java.lang.String jvmVersion, java.lang.String testClientHost, java.lang.String dbName, java.lang.String serverHost, int serverPort)
private void	runSlaveVerificationCLient(java.lang.String jvmVersion, java.lang.String testClientHost, java.lang.String dbName, java.lang.String serverHost, int serverPort)
private void	runStateTest(java.lang.String stateTest, java.lang.String clientVM, java.lang.String testClientHost, java.lang.String masterHost, int masterPort, java.lang.String dbSubPath)
(package private) void	runTest(java.lang.String replicationTest, java.lang.String clientVM, java.lang.String testClientHost, java.lang.String serverHost, int serverPort, java.lang.String dbName)
(package private) void	runTestOnSlave(java.lang.String replicationTest, java.lang.String clientVM, java.lang.String testClientHost, java.lang.String serverHost, int serverPort, java.lang.String dbName)
private void	runUserCommandInThreadLocally(java.lang.String[] command, java.lang.String dbDir, java.lang.String id) Run a Java command locally on the test host in a separate thread.
private void	runUserCommandInThreadRemotely(java.lang.String command, java.lang.String host, java.lang.String testUser, java.lang.String id)
private void	runUserCommandLocally(java.lang.String[] command, java.lang.String ID, java.io.File workingDir) Run a Java command locally on the test host.
private java.lang.String	runUserCommandRemotely(java.lang.String command, java.lang.String host, java.lang.String testUser, java.lang.String id)
(package private) java.lang.String	serverURL(java.lang.String fullDbPath, java.lang.String serverHost, int serverPort)
protected void	setUp() Parent super()
(package private) java.lang.String	showCurrentState(java.lang.String ID, long waitTime, java.lang.String fullDbPath, java.lang.String serverHost, int serverPort)
(package private) void	shutdownDb(java.lang.String jvmVersion, java.lang.String serverHost, int serverPort, java.lang.String dbPath, java.lang.String replicatedDb, java.lang.String clientHost)
private void	simpleVerify(java.sql.Connection conn)
(package private) java.lang.String	slaveDbPath(java.lang.String dbName)
(package private) java.lang.String	slaveURL(java.lang.String dbName)
private void	startMaster_direct(java.lang.String dbName, java.lang.String masterHost, int masterServerPort, java.lang.String slaveReplInterface, int slaveReplPort)
private void	startMaster_ij(java.lang.String dbName, java.lang.String masterHost, java.lang.String slaveReplInterface, int slaveReplPort)
(package private) void	startMaster(java.lang.String clientVM, java.lang.String dbName, java.lang.String masterHost, int masterServerPort, java.lang.String slaveClientInterface, int slaveServerPort, java.lang.String slaveReplInterface, int slaveReplPort) Set master db in replication master mode.
(package private) void	startOptionalLoad(ReplicationRun.Load load, java.lang.String dbSubPath, java.lang.String serverHost, int serverPort)
(package private) void	startServer(java.lang.String serverVM, java.lang.String serverVersion, java.lang.String serverHost, java.lang.String interfacesToListenOn, int serverPort, java.lang.String dbSubDirPath)
(package private) void	startServerMonitor(java.lang.String slaveHost)
private void	startSlave_direct(java.lang.String dbName, java.lang.String slaveHost, int slaveServerPort, java.lang.String slaveReplInterface, int slaveReplPort)
private void	startSlave_ij(java.lang.String dbName, java.lang.String slaveHost, java.lang.String slaveReplInterface, int slaveReplPort)
(package private) void	startSlave(java.lang.String clientVM, java.lang.String dbName, java.lang.String slaveClientInterface, int slaveServerPort, java.lang.String slaveReplInterface, int slaveReplPort, java.lang.String testClientHost) Set slave db in replication slave mode
(package private) void	stopServer(java.lang.String serverVM, java.lang.String serverVersion, java.lang.String serverHost, int serverPort)
(package private) java.sql.SQLException	stopSlave(java.lang.String slaveServerHost, int slaveServerPort, java.lang.String slaveDatabasePath, java.lang.String replicatedDb, boolean masterServerAlive)
(package private) java.sql.SQLException	stopSlave(java.lang.String slaveServerHost, int slaveServerPort, java.lang.String slaveDatabasePath, java.lang.String subPath, java.lang.String replicatedDb, boolean masterServerAlive)
protected void	tearDown() Parent super()
(package private) java.lang.String	useEncryption(boolean create)
(package private) void	verifyMaster()
(package private) void	verifySlave()
(package private) void	waitForConnect(long sleepTime, int tries, java.lang.String fullDbPath, java.lang.String serverHost, int serverPort)
(package private) void	waitForSQLState(java.lang.String expectedState, long sleepTime, int tries, java.lang.String fullDbPath, java.lang.String serverHost, int serverPort)
(package private) int	xFindServerPID(java.lang.String serverHost, int serverPort)
(package private) void	xStopServer(java.lang.String serverHost, int serverPID)

Methods inherited from class org.apache.derbyTesting.junit.BaseTestCase

alarm, assertDirectoryDeleted, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertExecJavaCmdAsExpected, assertLaunchedJUnitTestMethod, assertLaunchedJUnitTestMethod, assertSecurityManager, assertThrowableEquals, currentDirectory, execJavaCmd, execJavaCmd, fail, getClassVersionMajor, getEmmaJar, getFailureFolder, getFilesWith, getJavaExecutableName, getSystemProperty, getTestConfiguration, getTestResource, hasInterruptibleIO, isCVM, isIBMJVM, isJ9Platform, isJava5, isJava7, isJava8, isPhoneME, isPlatform, isSunJVM, isWindowsPlatform, openTestResource, println, printStackTrace, readProcessOutput, removeDirectory, removeDirectory, removeFiles, removeSystemProperty, runsWithEmma, runsWithJaCoCo, setSystemProperty, sleep, sleepAtLeastOneTick, traceit

Methods inherited from class junit.framework.TestCase

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, countTestCases, createResult, fail, fail, failNotEquals, failNotSame, failSame, format, getName, run, run, runTest, setName, toString

Methods inherited from class java.lang.Object

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

Field Detail

REPLICATIONTEST_PROPFILE

static final java.lang.String REPLICATIONTEST_PROPFILE

Name of properties file defining the test environment and replication tests to be run. Located in ${user.dir}

See Also:

Constant Field Values

REPLICATION_MASTER_TIMED_OUT

static final java.lang.String REPLICATION_MASTER_TIMED_OUT

See Also:

Constant Field Values

REPLICATION_SLAVE_STARTED_OK

static final java.lang.String REPLICATION_SLAVE_STARTED_OK

See Also:

Constant Field Values

REPLICATION_DB_NOT_BOOTED

static final java.lang.String REPLICATION_DB_NOT_BOOTED

See Also:

Constant Field Values

SLAVE_OPERATION_DENIED_WHILE_CONNECTED

static final java.lang.String SLAVE_OPERATION_DENIED_WHILE_CONNECTED

See Also:

Constant Field Values

REPLICATION_SLAVE_SHUTDOWN_OK

static final java.lang.String REPLICATION_SLAVE_SHUTDOWN_OK

See Also:

Constant Field Values

testUser

static java.lang.String testUser

userDir

static java.lang.String userDir

userHome

static java.lang.String userHome

dataEncryption

static java.lang.String dataEncryption

masterServerHost

static java.lang.String masterServerHost

masterServerPort

static int masterServerPort

slaveServerHost

static java.lang.String slaveServerHost

slaveServerPort

static int slaveServerPort

testClientHost

static java.lang.String testClientHost

slaveReplPort

static int slaveReplPort

masterDatabasePath

static java.lang.String masterDatabasePath

slaveDatabasePath

static java.lang.String slaveDatabasePath

replicatedDb

static java.lang.String replicatedDb

bootLoad

static java.lang.String bootLoad

freezeDB

static java.lang.String freezeDB

unFreezeDB

static java.lang.String unFreezeDB

junitTest

static boolean junitTest

runUnReplicated

static boolean runUnReplicated

simpleLoad

static boolean simpleLoad

simpleLoadTuples

static int simpleLoadTuples

tuplesToInsertPerf

static int tuplesToInsertPerf

commitFreq

static int commitFreq

masterDbSubPath

static java.lang.String masterDbSubPath

slaveDbSubPath

static java.lang.String slaveDbSubPath

replicationTest

static java.lang.String replicationTest

replicationVerify

static java.lang.String replicationVerify

THREADS

static int THREADS

MINUTES

static int MINUTES

sqlLoadInit

static java.lang.String sqlLoadInit

networkServerControl

static final java.lang.String networkServerControl

See Also:

Constant Field Values

specialTestingJar

static java.lang.String specialTestingJar

jvmVersion

static java.lang.String jvmVersion

masterJvmVersion

static java.lang.String masterJvmVersion

slaveJvmVersion

static java.lang.String slaveJvmVersion

derbyVersion

static java.lang.String derbyVersion

derbyMasterVersion

static java.lang.String derbyMasterVersion

derbySlaveVersion

static java.lang.String derbySlaveVersion

junit_jar

static java.lang.String junit_jar

test_jars

static java.lang.String test_jars

FS

static final java.lang.String FS

PS

static final java.lang.String PS

showSysinfo

static boolean showSysinfo

sleepTime

static long sleepTime

DRIVER_CLASS_NAME

static final java.lang.String DRIVER_CLASS_NAME

See Also:

Constant Field Values

DB_PROTOCOL

static final java.lang.String DB_PROTOCOL

See Also:

Constant Field Values

ALL_INTERFACES

static final java.lang.String ALL_INTERFACES

See Also:

Constant Field Values

LF

static java.lang.String LF

remoteShell

static final java.lang.String remoteShell

See Also:

Constant Field Values

util

Utils util

state

ReplicationRun.State state

localEnv

static boolean localEnv

derbyProperties

static java.lang.String derbyProperties

classPath

java.lang.String classPath

masterConn

private java.sql.Connection masterConn

A Connection to the master database

slaveConn

private java.sql.Connection slaveConn

A Connection to the slave database

startSlaveException

private volatile java.lang.Exception startSlaveException

The exception thrown as a result of a startSlave connection attempt

helperThreads

private java.util.ArrayList helperThreads

List of threads that have been started by the tests and not explicitly waited for. Wait for these to complete in tearDown() so that they don't interfere with subsequent test cases.

db_uid

private java.lang.String db_uid

db_passwd

private java.lang.String db_passwd

masterPreRepl

static ReplicationRun.Load masterPreRepl

masterPostRepl

static ReplicationRun.Load masterPostRepl

slavePreSlave

static ReplicationRun.Load slavePreSlave

masterPostSlave

static ReplicationRun.Load masterPostSlave

slavePostSlave

static ReplicationRun.Load slavePostSlave

Constructor Detail

ReplicationRun

public ReplicationRun(java.lang.String testcaseName)

Creates a new instance of ReplicationRun

Parameters:

testcaseName - Identifying the test.

ReplicationRun

public ReplicationRun(java.lang.String testcaseName,
                      java.lang.String user,
                      java.lang.String password)

Creates a new instance of ReplicationRun running with authentication.

Method Detail

setUp

protected void setUp()
              throws java.lang.Exception

Parent super()

Overrides:

setUp in class junit.framework.TestCase

Throws:

java.lang.Exception - .

tearDown

protected void tearDown()
                 throws java.lang.Exception

Parent super()

Overrides:

tearDown in class junit.framework.TestCase

Throws:

java.lang.Exception - .

close

private static void close(java.sql.Connection conn)
                   throws java.sql.SQLException

Close a connection.

Throws:

java.sql.SQLException

runBare

public void runBare()
             throws java.lang.Throwable

Run the test. Extra logic in addition to BaseTestCase's similar logic, to save derby.log and database files for replication directories if a failure happens.

Overrides:

runBare in class BaseTestCase

Throws:

java.lang.Throwable

useEncryption

java.lang.String useEncryption(boolean create)

connectPing

void connectPing(java.lang.String fullDbPath,
                 java.lang.String serverHost,
                 int serverPort,
                 java.lang.String testClientHost)
          throws java.lang.Exception

Throws:

java.lang.Exception

showCurrentState

java.lang.String showCurrentState(java.lang.String ID,
                                  long waitTime,
                                  java.lang.String fullDbPath,
                                  java.lang.String serverHost,
                                  int serverPort)
                           throws java.lang.Exception

Throws:

java.lang.Exception

waitForConnect

void waitForConnect(long sleepTime,
                    int tries,
                    java.lang.String fullDbPath,
                    java.lang.String serverHost,
                    int serverPort)
             throws java.lang.Exception

Throws:

java.lang.Exception

waitForSQLState

void waitForSQLState(java.lang.String expectedState,
                     long sleepTime,
                     int tries,
                     java.lang.String fullDbPath,
                     java.lang.String serverHost,
                     int serverPort)
              throws java.lang.Exception

Throws:

java.lang.Exception

shutdownDb

void shutdownDb(java.lang.String jvmVersion,
                java.lang.String serverHost,
                int serverPort,
                java.lang.String dbPath,
                java.lang.String replicatedDb,
                java.lang.String clientHost)
         throws java.lang.Exception

Throws:

java.lang.Exception

startServerMonitor

void startServerMonitor(java.lang.String slaveHost)

runTest

void runTest(java.lang.String replicationTest,
             java.lang.String clientVM,
             java.lang.String testClientHost,
             java.lang.String serverHost,
             int serverPort,
             java.lang.String dbName)
      throws java.lang.Exception

Throws:

java.lang.Exception

runTestOnSlave

void runTestOnSlave(java.lang.String replicationTest,
                    java.lang.String clientVM,
                    java.lang.String testClientHost,
                    java.lang.String serverHost,
                    int serverPort,
                    java.lang.String dbName)
             throws java.lang.Exception

Throws:

java.lang.Exception

runLoad

private void runLoad(java.lang.String load,
                     java.lang.String clientVM,
                     java.lang.String testClientHost,
                     java.lang.String masterHost,
                     int masterPort,
                     java.lang.String dbSubPath)
              throws java.lang.Exception

Throws:

java.lang.Exception

runStateTest

private void runStateTest(java.lang.String stateTest,
                          java.lang.String clientVM,
                          java.lang.String testClientHost,
                          java.lang.String masterHost,
                          int masterPort,
                          java.lang.String dbSubPath)
                   throws java.lang.Exception

Throws:

java.lang.Exception

bootMasterDatabase

void bootMasterDatabase(java.lang.String clientVM,
                        java.lang.String dbSubPath,
                        java.lang.String dbName,
                        java.lang.String masterHost,
                        int masterServerPort,
                        java.lang.String load)
                 throws java.lang.Exception

Throws:

java.lang.Exception

startMaster

void startMaster(java.lang.String clientVM,
                 java.lang.String dbName,
                 java.lang.String masterHost,
                 int masterServerPort,
                 java.lang.String slaveClientInterface,
                 int slaveServerPort,
                 java.lang.String slaveReplInterface,
                 int slaveReplPort)
          throws java.lang.Exception

Set master db in replication master mode.

Throws:

java.lang.Exception

startMaster_ij

private void startMaster_ij(java.lang.String dbName,
                            java.lang.String masterHost,
                            java.lang.String slaveReplInterface,
                            int slaveReplPort)
                     throws java.lang.Exception

Throws:

java.lang.Exception

startMaster_direct

private void startMaster_direct(java.lang.String dbName,
                                java.lang.String masterHost,
                                int masterServerPort,
                                java.lang.String slaveReplInterface,
                                int slaveReplPort)
                         throws java.lang.Exception

Throws:

java.lang.Exception

getMasterConnection

protected java.sql.Connection getMasterConnection()
                                           throws java.sql.SQLException

Get a connection to the master database.

Returns:

A connection to the master database

Throws:

java.sql.SQLException

getSlaveConnection

protected java.sql.Connection getSlaveConnection()
                                          throws java.sql.SQLException

Get a connection to the slave database.

Returns:

A connection to the slave database

Throws:

java.sql.SQLException

executeOnMaster

protected void executeOnMaster(java.lang.String sql)
                        throws java.sql.SQLException

Execute SQL on the master database through a Statement

Parameters:

sql - The sql that should be executed on the master database

Throws:

java.sql.SQLException - thrown if an error occured while executing the sql

executeOnSlave

protected void executeOnSlave(java.lang.String sql)
                       throws java.sql.SQLException

Execute SQL on the slave database through a Statement

Parameters:

sql - The sql that should be executed on the slave database

Throws:

java.sql.SQLException - thrown if an error occured while executing the sql

startSlave

void startSlave(java.lang.String clientVM,
                java.lang.String dbName,
                java.lang.String slaveClientInterface,
                int slaveServerPort,
                java.lang.String slaveReplInterface,
                int slaveReplPort,
                java.lang.String testClientHost)
         throws java.lang.Exception

Set slave db in replication slave mode

Throws:

java.lang.Exception

startSlave_ij

private void startSlave_ij(java.lang.String dbName,
                           java.lang.String slaveHost,
                           java.lang.String slaveReplInterface,
                           int slaveReplPort)
                    throws java.lang.Exception

Throws:

java.lang.Exception

startSlave_direct

private void startSlave_direct(java.lang.String dbName,
                               java.lang.String slaveHost,
                               int slaveServerPort,
                               java.lang.String slaveReplInterface,
                               int slaveReplPort)
                        throws java.lang.Exception

Throws:

java.lang.Exception

failOver

void failOver(java.lang.String jvmVersion,
              java.lang.String dbPath,
              java.lang.String dbSubPath,
              java.lang.String dbName,
              java.lang.String host,
              int serverPort,
              java.lang.String testClientHost)
       throws java.lang.Exception

Throws:

java.lang.Exception

failOver_ij

private void failOver_ij(java.lang.String dbName,
                         java.lang.String host,
                         java.lang.String testClientHost)
                  throws java.lang.Exception

Throws:

java.lang.Exception

failOver_direct

private void failOver_direct(java.lang.String dbName)
                      throws java.lang.Exception

Throws:

java.lang.Exception

xFindServerPID

int xFindServerPID(java.lang.String serverHost,
                   int serverPort)
            throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

xStopServer

void xStopServer(java.lang.String serverHost,
                 int serverPID)
          throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

verifySlave

void verifySlave()
          throws java.lang.Exception

Throws:

java.lang.Exception

verifyMaster

void verifyMaster()
           throws java.lang.Exception

Throws:

java.lang.Exception

simpleVerify

private void simpleVerify(java.sql.Connection conn)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

runSlaveVerificationCLient

private void runSlaveVerificationCLient(java.lang.String jvmVersion,
                                        java.lang.String testClientHost,
                                        java.lang.String dbName,
                                        java.lang.String serverHost,
                                        int serverPort)
                                 throws java.lang.Exception

Throws:

java.lang.Exception

runMasterVerificationCLient

private void runMasterVerificationCLient(java.lang.String jvmVersion,
                                         java.lang.String testClientHost,
                                         java.lang.String dbName,
                                         java.lang.String serverHost,
                                         int serverPort)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

runUserCommandLocally

private void runUserCommandLocally(java.lang.String[] command,
                                   java.lang.String ID,
                                   java.io.File workingDir)

Run a Java command locally on the test host. The spawned process inherits the class path from the main test process.

Parameters:

command - the arguments to pass to the Java executable

ID - an identifier used to prefix debug output

workingDir - the directory in which the sub-process should run, or null to run in the same directory as the parent process

runUserCommandRemotely

private java.lang.String runUserCommandRemotely(java.lang.String command,
                                                java.lang.String host,
                                                java.lang.String testUser,
                                                java.lang.String id)

runUserCommandInThreadLocally

private void runUserCommandInThreadLocally(java.lang.String[] command,
                                           java.lang.String dbDir,
                                           java.lang.String id)

Run a Java command locally on the test host in a separate thread. The spawned process inherits the class path from the main test process.

Parameters:

command - the arguments to pass to the Java executable

dbDir - the name of the sub-directory in which the sub-process should run, or null to run in the same directory as the parent process

id - an identifier used to prefix debug output

runUserCommandInThreadRemotely

private void runUserCommandInThreadRemotely(java.lang.String command,
                                            java.lang.String host,
                                            java.lang.String testUser,
                                            java.lang.String id)

initEnvironment

void initEnvironment()
              throws java.io.IOException

Throws:

java.io.IOException

initMaster

void initMaster(java.lang.String host,
                java.lang.String dbName)
         throws java.lang.Exception

Throws:

java.lang.Exception

removeSlaveDBfiles

private void removeSlaveDBfiles(java.lang.String host,
                                java.lang.String dbName)
                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

initSlave

void initSlave(java.lang.String host,
               java.lang.String clientVM,
               java.lang.String dbName)
        throws java.lang.Exception

Throws:

java.lang.Exception

restartServer

void restartServer(java.lang.String serverVM,
                   java.lang.String serverVersion,
                   java.lang.String serverHost,
                   java.lang.String interfacesToListenOn,
                   int serverPort,
                   java.lang.String dbSubDirPath)
            throws java.lang.Exception

Throws:

java.lang.Exception

startServer

void startServer(java.lang.String serverVM,
                 java.lang.String serverVersion,
                 java.lang.String serverHost,
                 java.lang.String interfacesToListenOn,
                 int serverPort,
                 java.lang.String dbSubDirPath)
          throws java.lang.Exception

Throws:

java.lang.Exception

killMaster

void killMaster(java.lang.String masterServerHost,
                int masterServerPort)
         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

killSlave

void killSlave(java.lang.String slaveServerHost,
               int slaveServerPort)
        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

destroySlaveDB

void destroySlaveDB(java.lang.String slaveServerHost)
             throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

stopServer

void stopServer(java.lang.String serverVM,
                java.lang.String serverVersion,
                java.lang.String serverHost,
                int serverPort)

processOutput

private java.lang.String processOutput(java.lang.String id,
                                       java.lang.Process proc)
                                throws java.lang.Exception

Throws:

java.lang.Exception

processDEBUGOutput

private void processDEBUGOutput(java.lang.String id,
                                java.lang.Process proc)
                         throws java.lang.Exception

Throws:

java.lang.Exception

registerThread

private void registerThread(java.lang.Thread thread)

Register that a thread has been started so that we can wait for it to complete in tearDown().

Parameters:

thread - a thread that has been started

pingServer

private void pingServer(java.lang.String hostName,
                        int port)
                 throws java.lang.Exception

Throws:

java.lang.Exception

startOptionalLoad

void startOptionalLoad(ReplicationRun.Load load,
                       java.lang.String dbSubPath,
                       java.lang.String serverHost,
                       int serverPort)
                throws java.lang.Exception

Throws:

java.lang.Exception

makeReadyForReplication

void makeReadyForReplication()
                      throws java.lang.Exception

Throws:

java.lang.Exception

cleanAllTestHosts

void cleanAllTestHosts()

assertSqlStateSlaveConn

protected void assertSqlStateSlaveConn(java.lang.String expected)
                                throws java.lang.Exception

Assert that the latest startSlave connection attempt got the expected SQLState. The method will wait for upto 5 seconds for the startSlave connection attemt to complete. If the connection attempt has not completed after 5 seconds it is assumed to have failed.

Parameters:

expected - the expected SQLState

Throws:

java.lang.Exception - the Exception to check the SQLState of

assertException

void assertException(java.sql.SQLException se,
                     java.lang.String expectedSqlState)

_testInsertUpdateDeleteOnMaster

void _testInsertUpdateDeleteOnMaster(java.lang.String serverHost,
                                     int serverPort,
                                     java.lang.String dbPath,
                                     int _noTuplesToInsert)
                              throws java.sql.SQLException,
                                     java.lang.ClassNotFoundException,
                                     java.lang.IllegalAccessException,
                                     java.lang.InstantiationException

Throws:

java.sql.SQLException

java.lang.ClassNotFoundException

java.lang.IllegalAccessException

java.lang.InstantiationException

_verifyDatabase

void _verifyDatabase(java.lang.String serverHost,
                     int serverPort,
                     java.lang.String dbPath,
                     int _noTuplesInserted)
              throws java.sql.SQLException,
                     java.lang.ClassNotFoundException,
                     java.lang.IllegalAccessException,
                     java.lang.InstantiationException

Throws:

java.sql.SQLException

java.lang.ClassNotFoundException

java.lang.IllegalAccessException

java.lang.InstantiationException

_verify

void _verify(java.sql.Connection conn,
             int _noTuplesInserted)
      throws java.sql.SQLException

Throws:

java.sql.SQLException

getConnection

java.sql.Connection getConnection(java.lang.String serverHost,
                                  int serverPort,
                                  java.lang.String databasePath,
                                  java.lang.String dbSubPath,
                                  java.lang.String replicatedDb)
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

masterDbPath

java.lang.String masterDbPath(java.lang.String dbName)

slaveDbPath

java.lang.String slaveDbPath(java.lang.String dbName)

masterURL

java.lang.String masterURL(java.lang.String dbName)

masterLoadURL

java.lang.String masterLoadURL(java.lang.String dbSubPath)

slaveURL

java.lang.String slaveURL(java.lang.String dbName)

serverURL

java.lang.String serverURL(java.lang.String fullDbPath,
                           java.lang.String serverHost,
                           int serverPort)

credentials

java.lang.String credentials()

stopSlave

java.sql.SQLException stopSlave(java.lang.String slaveServerHost,
                                int slaveServerPort,
                                java.lang.String slaveDatabasePath,
                                java.lang.String replicatedDb,
                                boolean masterServerAlive)
                         throws java.lang.Exception

Throws:

java.lang.Exception

stopSlave

java.sql.SQLException stopSlave(java.lang.String slaveServerHost,
                                int slaveServerPort,
                                java.lang.String slaveDatabasePath,
                                java.lang.String subPath,
                                java.lang.String replicatedDb,
                                boolean masterServerAlive)
                         throws java.lang.Exception

Throws:

java.lang.Exception

getMasterJavaExecutableName

private static java.lang.String getMasterJavaExecutableName()

getSlaveJavaExecutableName

private static java.lang.String getSlaveJavaExecutableName()

getClientJavaExecutableName

private static java.lang.String getClientJavaExecutableName()

getServerJavaExecutableName

private static java.lang.String getServerJavaExecutableName(java.lang.String serverHost,
                                                            java.lang.String serverVM)

configureDataSource

org.apache.derby.jdbc.ClientDataSourceInterface configureDataSource(java.lang.String dbName,
                                                                    java.lang.String serverHost,
                                                                    int serverPort,
                                                                    java.lang.String connectionAttributes)
                                                             throws java.lang.ClassNotFoundException,
                                                                    java.lang.IllegalAccessException,
                                                                    java.lang.InstantiationException

Set up a data source.

Throws:

java.lang.ClassNotFoundException

java.lang.IllegalAccessException

java.lang.InstantiationException