org.apache.calcite.test.concurrent

Class ConcurrentTestCommandScript

java.lang.Object

org.apache.calcite.test.concurrent.ConcurrentTestCommandGenerator

org.apache.calcite.test.concurrent.ConcurrentTestCommandScript

public class ConcurrentTestCommandScript
extends ConcurrentTestCommandGenerator

ConcurrentTestCommandScript creates instances of ConcurrentTestCommand that perform specific actions in a specific order and within the context of a test thread (ConcurrentTestCommandExecutor).

Actions are loaded from a script (see package javadoc for script format).

A single ConcurrentTestCommandScript creates commands for multiple threads. Each thread is represented by an integer "thread ID" and, optionally, a String thread name. Thread IDs may take on any positive integer value and may be a sparse set (e.g. 1, 2, 5). Thread names may be any String.

When each command is created, it is associated with a thread and given an execution order. Execution order values are positive integers, must be unique within a thread, and may be a sparse set. See ConcurrentTestCommandGenerator.synchronizeCommandSets() for other considerations.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.calcite.test.concurrent.ConcurrentTestCommandGenerator

ConcurrentTestCommandGenerator.AbstractCommand, ConcurrentTestCommandGenerator.FailedThread

Field Summary

Fields inherited from class org.apache.calcite.test.concurrent.ConcurrentTestCommandGenerator

debug, debugStream, jdbcProps, jdbcURL

Constructor Summary

Constructors

Constructor and Description
ConcurrentTestCommandScript()
ConcurrentTestCommandScript(String filename) Constructs and prepares a new ConcurrentTestCommandScript.

Method Summary

Modifier and Type	Method and Description
void	execute() Executes the script
void	executeCleanup()
protected void	executeCommands(int threadId, List<String> commands)
void	executeSetup()
boolean	isDisabled()
static void	main(String[] args) Client tool that connects via jdbc and runs one or more mtsql on that connection.
void	printResults(PrintWriter out)
void	setQuiet(boolean val)
void	setVerbose(boolean val)
boolean	useLockstep()

Methods inherited from class org.apache.calcite.test.concurrent.ConcurrentTestCommandGenerator

addCloseCommand, addCommand, addCommitCommand, addDdlCommand, addExplainCommand, addFetchAndCompareCommand, addInsertCommand, addPrepareCommand, addRollbackCommand, addSleepCommand, addSynchronizationCommand, failed, getFailedThreads, getThreadIds, getThreadName, hasValidSynchronization, innerExecute, postExecute, setDataSource, setDebug, setDebug, setThreadName, synchronizeCommandSets

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentTestCommandScript

public ConcurrentTestCommandScript()
                            throws IOException

Throws:

IOException

ConcurrentTestCommandScript

public ConcurrentTestCommandScript(String filename)
                            throws IOException

Constructs and prepares a new ConcurrentTestCommandScript.

Throws:

IOException

Method Detail

execute

public void execute()
             throws Exception

Executes the script

Overrides:

execute in class ConcurrentTestCommandGenerator

Throws:

Exception - if no connection found or if a thread operation is interrupted

setQuiet

public void setQuiet(boolean val)

setVerbose

public void setVerbose(boolean val)

useLockstep

public boolean useLockstep()

isDisabled

public boolean isDisabled()

executeSetup

public void executeSetup()
                  throws Exception

Throws:

Exception

executeCleanup

public void executeCleanup()
                    throws Exception

Throws:

Exception

executeCommands

protected void executeCommands(int threadId,
                               List<String> commands)
                        throws Exception

Throws:

Exception

printResults

public void printResults(PrintWriter out)
                  throws IOException

Throws:

IOException

main

public static void main(String[] args)

Client tool that connects via jdbc and runs one or more mtsql on that connection.

Usage: mtsql [-vgq] -u SERVER -d DRIVER [-n USER][-p PASSWORD] [VAR=VAL]... SCRIPT [SCRIPT]...