com.bigdata.journal

Class TestTx

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.io.TestCase3

com.bigdata.journal.AbstractIndexManagerTestCase<S>

com.bigdata.journal.ProxyTestCase<Journal>

com.bigdata.journal.TestTx

All Implemented Interfaces:

IProxyTest, junit.framework.Test

public class TestTx
extends ProxyTestCase<Journal>

Test suite for fully-isolated read-write transactions.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class junit.framework.TestCase2

TestCase2.MyProperties, TestCase2.RandomType

Field Summary

Fields inherited from class com.bigdata.io.TestCase3

r

Fields inherited from class junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
TestTx()
TestTx(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	test_commit_noConflict01() Simple test of commit semantics (no conflict).
void	test_delete001() Two transactions (tx0, tx1) are created.
void	test_delete002() Two transactions (tx0, tx1) are created.
void	test_delete003() Two transactions (tx0, tx1) are created.
void	test_deletePreExistingVersion_noConflict() Test in which a transaction deletes a pre-existing version (that is, a version that existed in global scope when the transaction was started).
void	test_indexNotVisibleUnlessCommitted() Verify that an index is not visible in the tx unless the native transaction in which it is registered has already committed before the tx starts.
void	test_noIndicesRegistered() Test verifies that a transaction may start when there are (a) no commits on the journal; and (b) no indices have been registered.
void	test_readIsolation() Create a journal, setup an index, write an entry on that index, and commit the store.
void	test_readOnlyTx() Unit test written to verify that a read-only tx gets the same view of an index when it has the same ground state as another read-only tx.
void	test_sameIndexObject() Test verifies that you always get the same object back when you ask for an isolated named index.
void	test_writeIsolation() Test verifies that an isolated write is visible inside of a transaction (tx1) but not in a concurrent transaction (tx2) and not in the unisolated index until the tx1 commits.
void	testStress() Stress test for concurrent transactions against a single named index.

Methods inherited from class com.bigdata.journal.ProxyTestCase

getDelegate, getOurDelegate, getProperties, getStore, getStore, reopenStore, setDelegate, setUp, tearDown

Methods inherited from class com.bigdata.journal.AbstractIndexManagerTestCase

checkIfProxy, fail, getRandomData, setUp, tearDown

Methods inherited from class com.bigdata.io.TestCase3

assertCondition, assertCondition, assertEquals, assertEquals, getBytes, getPort, getRandomData, getRandomData

Methods inherited from class junit.framework.TestCase2

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEqualsWithinUlps, assertSameArray, assertSameArray, assertSameBigDecimal, assertSameBigDecimal, assertSameBigInteger, assertSameBigInteger, assertSameIterator, assertSameIterator, assertSameIteratorAnyOrder, assertSameIteratorAnyOrder, assertSameValue, assertSameValue, assertZeroUlps, assertZeroUlps, fail, getInnerCause, getNormalInt, getProjectBuildPath, getRandomObject, getRandomObject, getRandomOrder, getRandomString, getTestInputStream, getTestResource, getTestResource, getUlps, getUlps, isDEBUG, isDEBUG, isINFO, isINFO, isInnerCause, logProperties

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, runBare, runTest, setName, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface junit.framework.Test

countTestCases, run

Constructor Detail

TestTx

public TestTx()

TestTx

public TestTx(String name)

Method Detail

test_noIndicesRegistered

public void test_noIndicesRegistered()

Test verifies that a transaction may start when there are (a) no commits on the journal; and (b) no indices have been registered.

Note: The transaction will be unable to isolate an index if the index has not been registered already by an unisolated operation.

test_indexNotVisibleUnlessCommitted

public void test_indexNotVisibleUnlessCommitted()

Verify that an index is not visible in the tx unless the native transaction in which it is registered has already committed before the tx starts.

test_sameIndexObject

public void test_sameIndexObject()

Test verifies that you always get the same object back when you ask for an isolated named index. This is important both to conserve resources and since the write set is in the isolated index -- you lose it and it is gone.

test_readIsolation

public void test_readIsolation()

Create a journal, setup an index, write an entry on that index, and commit the store. Setup a transaction and verify that we can isolate that index and read the written value. Write a value on the unisolated index and verify that it is not visible within the transaction.

test_writeIsolation

public void test_writeIsolation()

Test verifies that an isolated write is visible inside of a transaction (tx1) but not in a concurrent transaction (tx2) and not in the unisolated index until the tx1 commits. Once the tx1 commits, the write is visible in the unisolated index. The write never becomes visible in tx2. If tx2 attempts to write a value under the same key then a write-write conflict is reported and validation fails.

test_delete001

public void test_delete001()

Two transactions (tx0, tx1) are created. A version (v0) is written onto tx0 for a key (id0). The test verifies the write and verifies that the write is not visible in tx1. The v0 is then deleted from tx0 and then another version (v1) is written on tx0 under the same key. Both transactions prepare and commit. The end state is that (id0,v1) is visible in the database after the commit.

test_delete002

public void test_delete002()

Two transactions (tx0, tx1) are created. A version (v0) is written onto tx0 for a key (id0). The test verifies the write and verifies that the write is not visible in tx1. The v0 is then deleted from tx0 and then another version (v1) is written on tx0 under the same key and isolation is re-verified. Finally, v1 is deleted from tx0. Both transactions prepare and commit. The end state is that no entry for id0 is visible in the database after the commit.

test_delete003

public void test_delete003()

Two transactions (tx0, tx1) are created. A version (v0) is written onto tx0 for a key (id0). The test verifies the write and verifies that the write is not visible in tx1. The v0 is then deleted from tx0. Another version (v1) is written on tx1 under the same key and isolation is re-verified. Both transactions prepare and commit. Since no entry for id0 was pre-existing in the global scope the delete in tx0 does not propagate into the global scope and the end state is that the write (id0,v1) from tx1 is visible in the database after the commit.

test_commit_noConflict01

public void test_commit_noConflict01()

Simple test of commit semantics (no conflict). Four transactions are started: tx0, which starts first. tx1 which starts next and on which we will write one data version; tx2, which begins after tx1 but before tx1 commits - the change will NOT be visible in this transaction; and tx3, which begins after tx1 commits - the change will be visible in this transaction.

test_deletePreExistingVersion_noConflict

public void test_deletePreExistingVersion_noConflict()

Test in which a transaction deletes a pre-existing version (that is, a version that existed in global scope when the transaction was started).

test_readOnlyTx

public void test_readOnlyTx()

Unit test written to verify that a read-only tx gets the same view of an index when it has the same ground state as another read-only tx. That view should be a simple BTree rather than an IsolatedFusedView.

See Also:

Refactor native long tx id to thin object, Add cache for access to historical index views on the Journal by name and commitTime.

testStress

public void testStress()
                throws InterruptedException,
                       ExecutionException

Stress test for concurrent transactions against a single named index.

Throws:

InterruptedException

ExecutionException