org.jsimpledb.kv.test

Class KVDatabaseTest

java.lang.Object

org.jsimpledb.test.TestSupport

org.jsimpledb.kv.test.KVTestSupport

org.jsimpledb.kv.test.KVDatabaseTest

public abstract class KVDatabaseTest
extends KVTestSupport

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	KVDatabaseTest.Committer
class	KVDatabaseTest.RandomTask
class	KVDatabaseTest.Reader
protected static interface	KVDatabaseTest.Transactional<V>
class	KVDatabaseTest.Writer

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutorService	executor

Fields inherited from class org.jsimpledb.test.TestSupport

log, random, validator

Constructor Summary

Constructors

Constructor and Description
KVDatabaseTest()

Method Summary

Modifier and Type	Method and Description
protected boolean	allowBothTransactionsToFail()
protected KVTransaction	createKVTransaction(KVDatabase kvdb)
protected KVDatabase[][]	getDBs()
protected abstract KVDatabase	getKVDatabase()
protected int	getNonconflictingTransactionCount()
protected int	getNumTries()
protected int	getParallelTransactionLoopCount()
protected int	getParallelTransactionTaskCount()
protected int	getRandomTaskMaxIterations()
protected int	getSequentialTransactionLoopCount()
protected String	mapRetryExceptionMessage(String message)
void	setup()
void	teardown()
void	testConflictingTransactions(KVDatabase store)
void	testKeyWatch(KVDatabase store)
void	testMultipleThreadsTransaction(KVDatabase store) This test has multiple threads banging away on a single transaction to verify that the transaction is thread safe.
void	testNonconflictingTransactions(KVDatabase store)
void	testParallelTransactions(KVDatabase store) This test runs transactions in parallel and verifies there is no "leakage" between them.
void	testParallelTransactions(KVDatabase[] stores)
void	testSequentialTransactions(KVDatabase store) This test runs transactions sequentially and verifies that each transaction sees the changes that were committed in the previous transaction.
void	testSimpleStuff(KVDatabase store)
protected <V> V	tryNtimes(KVDatabase kvdb, KVDatabaseTest.Transactional<V> transactional)
protected void	updateRetryStats(RetryTransactionException e)

Methods inherited from class org.jsimpledb.kv.test.KVTestSupport

kv, s, showKV, showKV, stringView, stringView

Methods inherited from class org.jsimpledb.test.TestSupport

b, ba, buildList, buildMap, buildSet, buildSortedMap, buildSortedSet, checkMap, checkSet, checkValid, createTempDirectory, deleteDirectoryHierarchy, getRandom, randomBytes, readResource, readResource, readResource, s, seedRandom, setUpValidator, show

Methods inherited from class java.lang.Object

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

Field Detail

executor

protected ExecutorService executor

Constructor Detail

KVDatabaseTest

public KVDatabaseTest()

Method Detail

setup

public void setup()
           throws Exception

Throws:

Exception

teardown

public void teardown()
              throws Exception

Throws:

Exception

getDBs

protected KVDatabase[][] getDBs()

getKVDatabase

protected abstract KVDatabase getKVDatabase()

testSimpleStuff

public void testSimpleStuff(KVDatabase store)
                     throws Exception

Throws:

Exception

testKeyWatch

public void testKeyWatch(KVDatabase store)
                  throws Exception

Throws:

Exception

testConflictingTransactions

public void testConflictingTransactions(KVDatabase store)
                                 throws Exception

Throws:

Exception

allowBothTransactionsToFail

protected boolean allowBothTransactionsToFail()

testNonconflictingTransactions

public void testNonconflictingTransactions(KVDatabase store)
                                    throws Exception

Throws:

Exception

getNonconflictingTransactionCount

protected int getNonconflictingTransactionCount()

testParallelTransactions

public void testParallelTransactions(KVDatabase store)
                              throws Exception

This test runs transactions in parallel and verifies there is no "leakage" between them. Database must be configured for linearizable isolation.

Parameters:

store - underlying store

Throws:

Exception - if an error occurs

testParallelTransactions

public void testParallelTransactions(KVDatabase[] stores)
                              throws Exception

Throws:

Exception

getParallelTransactionLoopCount

protected int getParallelTransactionLoopCount()

getParallelTransactionTaskCount

protected int getParallelTransactionTaskCount()

testSequentialTransactions

public void testSequentialTransactions(KVDatabase store)
                                throws Exception

This test runs transactions sequentially and verifies that each transaction sees the changes that were committed in the previous transaction.

Parameters:

store - underlying store

Throws:

Exception - if an error occurs

getSequentialTransactionLoopCount

protected int getSequentialTransactionLoopCount()

testMultipleThreadsTransaction

public void testMultipleThreadsTransaction(KVDatabase store)
                                    throws Exception

This test has multiple threads banging away on a single transaction to verify that the transaction is thread safe.

Parameters:

store - underlying store

Throws:

Exception - if an error occurs

tryNtimes

protected <V> V tryNtimes(KVDatabase kvdb,
                          KVDatabaseTest.Transactional<V> transactional)

getNumTries

protected int getNumTries()

createKVTransaction

protected KVTransaction createKVTransaction(KVDatabase kvdb)

updateRetryStats

protected void updateRetryStats(RetryTransactionException e)

mapRetryExceptionMessage

protected String mapRetryExceptionMessage(String message)

getRandomTaskMaxIterations

protected int getRandomTaskMaxIterations()