org.apache.derbyTesting.functionTests.tests.store

Class InterruptResilienceTest

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

org.apache.derbyTesting.junit.BaseTestCase

org.apache.derbyTesting.junit.BaseJDBCTestCase

org.apache.derbyTesting.functionTests.tests.store.InterruptResilienceTest

All Implemented Interfaces:

junit.framework.Test

public class InterruptResilienceTest
extends BaseJDBCTestCase

This test started out as a test reproduce and verify fix for DERBY-151. Later evolved into test for DERBY-4741.

The use of stored procedures was done to make the tests meaningful in client server mode as well, but be removed/simplified as long as we only make claims about the resilience of embedded Derby.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	InterruptResilienceTest.InterruptorThread
(package private) static class	InterruptResilienceTest.WorkerThread

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static boolean	allDone
(package private) static long	NO_OF_MT_OPS
(package private) static int	NO_OF_THREADS
private static TestConfiguration	thisConf
private static int	threadNo

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

DEFAULT_DB_DIR, DERBY_LOG, ERRORSTACKTRACEFILE

Constructor Summary

Constructors

Constructor and Description
InterruptResilienceTest(java.lang.String name)

Method Summary

Modifier and Type	Method and Description
(package private) static int	getThreadNo()
protected static junit.framework.Test	makeSuite(java.lang.String name)
private static long	randAbs(long l)
protected void	setUp()
static junit.framework.Test	suite()
protected void	tearDown() Clean up the connection maintained by this test.
void	testCreateDropInterrupted() DERBY-5233: verify that CREATE TABLE (i.e. container creation) survives interrupts with NIO.
void	testInterruptBatch()
void	testInterruptShutdown()
void	testLongQueryInterrupt()
void	testRAFReadWriteMultipleThreads() MT write (part 1) and read (part 2) test under interrupt shower.
void	testRAFWriteInterrupted()
static void	tstInterruptBatch()
static void	tstInterruptLongQuery()
static void	tstRAFReadWriteMultipleThreads()
static void	tstRAFwriteInterrupted()

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

assertCallError, assertCheckTable, assertCompileError, assertEquals, assertEquals, assertEquals, assertEquivalentDataType, assertErrorCode, assertGetIntError, assertNextError, assertPreparedStatementError, assertSQLExceptionEquals, assertSQLState, assertSQLState, assertStatementError, assertStatementError, assertStatementError, assertStatementError, assertStatementErrorUnordered, assertTableRowCount, assertUpdateCount, assertUpdateCount, assertWarning, checkAllConsistency, checkEstimatedRowCount, closeStatement, commit, createStatement, createStatement, createStatement, dropTable, dropTable, dropView, dropView, emptyStatementCache, getClientTransactionID, getConnection, getDatabaseProperty, getLastSQLException, initializeConnection, openConnection, openDefaultConnection, openDefaultConnection, openDefaultConnection, openUserConnection, prepareCall, prepareCall, prepareCall, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, rollback, runBare, runBareOverridable, runScript, runScript, runSQLCommands, setAutoCommit, usingDB2Client, usingDerbyNetClient, usingEmbedded

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

thisConf

private static volatile TestConfiguration thisConf

NO_OF_THREADS

static int NO_OF_THREADS

NO_OF_MT_OPS

static long NO_OF_MT_OPS

threadNo

private static int threadNo

allDone

static volatile boolean allDone

Constructor Detail

InterruptResilienceTest

public InterruptResilienceTest(java.lang.String name)

Method Detail

makeSuite

protected static junit.framework.Test makeSuite(java.lang.String name)

suite

public static junit.framework.Test suite()

setUp

protected void setUp()
              throws java.lang.Exception

Overrides:

setUp in class junit.framework.TestCase

Throws:

java.lang.Exception

tearDown

protected void tearDown()
                 throws java.lang.Exception

Clean up the connection maintained by this test.

Overrides:

tearDown in class BaseJDBCTestCase

Throws:

java.lang.Exception

tstRAFwriteInterrupted

public static void tstRAFwriteInterrupted()
                                   throws java.sql.SQLException

Throws:

java.sql.SQLException

testRAFWriteInterrupted

public void testRAFWriteInterrupted()
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

tstRAFReadWriteMultipleThreads

public static void tstRAFReadWriteMultipleThreads()
                                           throws java.lang.Exception

Throws:

java.lang.Exception

getThreadNo

static int getThreadNo()

randAbs

private static long randAbs(long l)

testRAFReadWriteMultipleThreads

public void testRAFReadWriteMultipleThreads()
                                     throws java.sql.SQLException

MT write (part 1) and read (part 2) test under interrupt shower. This stess tests the NIO random access file interrupt channel recovery in RAFContainer4.

Throws:

java.sql.SQLException

tstInterruptLongQuery

public static void tstInterruptLongQuery()
                                  throws java.lang.Exception

Throws:

java.lang.Exception

testLongQueryInterrupt

public void testLongQueryInterrupt()
                            throws java.sql.SQLException

Throws:

java.sql.SQLException

tstInterruptBatch

public static void tstInterruptBatch()
                              throws java.lang.Exception

Throws:

java.lang.Exception

testInterruptBatch

public void testInterruptBatch()
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

testInterruptShutdown

public void testInterruptShutdown()
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

testCreateDropInterrupted

public void testCreateDropInterrupted()
                               throws java.sql.SQLException

DERBY-5233: verify that CREATE TABLE (i.e. container creation) survives interrupts with NIO.

Throws:

java.sql.SQLException