DatabaseTestBase (rxjava-jdbc 0.6.2 Test API)

java.lang.Object
- com.github.davidmoten.rx.jdbc.DatabaseTestBase

Direct Known Subclasses:

DatabaseAsyncTest, DatabaseSyncTest, DatabaseViaDataSourceTest
```
public abstract class DatabaseTestBase
extends Object
```

Constructor Summary

Constructors
Constructor and Description

DatabaseTestBase(boolean async)

Constructors
Constructor and Description
`DatabaseTestBase(boolean async)`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`insertBlobAndReadAsByteArray()`
`void`	`insertClobAndReadAsReader()`
`void`	`insertClobAndReadAsString()`
`void`	`insertNullBlobAndReadAsByteArray()`
`void`	`insertNullClobAndReadAsString()`
`void`	`testAutoMap()`
`void`	`testAutoMapBlob()`
`void`	`testAutoMapCannotFindConstructorWithEnoughParameters()`
`void`	`testAutoMapClob()`
`void`	`testAutoMapConvertsCamelCaseToUnderscoreColumnNames()`
`void`	`testAutoMapInterface()`
`void`	`testAutoMapThrowsExceptionIfMappedInterfaceColumnMethodHasParameters()`
`void`	`testAutoMapWillMapStringToStringAndIntToDouble()`
`void`	`testAutoMapWithQueryAnnotation()`
`void`	`testBeginTransactionEmitsOneItem()`
`void`	`testBeginTransactionOnNextForThreePasses()`
`void`	`testCalendarParameter()`
`void`	`testCanChainUpdateStatementsWithinTransaction()`
`void`	`testCanExecuteCreateSchema()`
`void`	`testCanExecuteCreateTable()`
`void`	`testCannotPassObservableAsSingleParameter()`
`void`	`testChainSelectUsingOperators()`
`void`	`testCloseAutoCommittingConnectionProviderClosesInternalConnectionProvider()`
`void`	`testCloseConnectionProviderFromUrlClosesInternalConnectionProvider()`
`void`	`testCloseDatabaseClosesConnectionProvider()`
`void`	`testCloseSingletonManualCommitConnectionProviderClosesInternalConnectionProvider()`
`void`	`testCommitOnLastOperator()`
`void`	`testCommitOperator()`
`void`	`testComposition()`
`void`	`testComposition2()`
`void`	`testCompositionTwoLevels()`
`void`	`testCompositionUsingLift()`
`void`	`testConnectionPool()`
`void`	`testConnectionPoolDoesNotRunOutOfConnectionsWhenQueryRunRepeatedly()`
`void`	`testConnectionPoolWhenExceptionThrown()`
`void`	`testConnectionsReleasedByCommitBeforeOnNext()`
`void`	`testConnectionsReleasedByRollbackBeforeOnNext()`
`void`	`testConnectionsReleasedByUpdateStatementBeforeOnNext()`
`void`	`testCountQuery()`
`void`	`testCreateFromScript()`
`void`	`testCustomMapper()`
`void`	`testDatabaseBuilder()`
`void`	`testDatabaseBuilderWithPool()`
`void`	`testDatabaseFromConnectionCanUseConnectionTwiceWithoutItBeingClosedInReality()`
`void`	`testDetector()`
`void`	`testEmptyResultSet()`
`void`	`testException()`
`void`	`testGetTimestamp()`
`void`	`testInsertNull()`
`void`	`testInstantiateDatabaseWithUrl()`
`void`	`testJdbcObservableCountLettersInAllNames()`
`void`	`testLastTransactionWithoutTransaction()`
`void`	`testLiftSelectWithDependencies()`
`void`	`testLiftUpdateWithDependencies()`
`void`	`testLiftUpdateWithParameters()`
`void`	`testLiftWithManyParameters()`
`void`	`testLiftWithParameters()`
`void`	`testMixingExplicitAndObservableParameters()`
`void`	`testMultipleSetsOfParameters()`
`void`	`testNamedParameters()`
`void`	`testNamedParametersOneMissingParameterShouldThrowException()`
`void`	`testNamedParametersWithMapParameter()`
`void`	`testNamedParametersWithMapParameterInObservable()`
`void`	`testNamedParametersWithMapParameterNoNamesInSql()`
`void`	`testNamedParametersWithUpdateStatement()`
`void`	`testNonTransactionalMultipleQueries()`
`void`	`testNoParameters()`
`void`	`testNoParams()`
`void`	`testOneConnectionOpenAndClosedAfterOneSelect()`
`void`	`testOneConnectionOpenAndClosedAfterOneUpdate()`
`void`	`testOneConnectionOpenedAndClosedAfterTwoSelectsWithinTransaction()`
`void`	`testOneConnectionOpenedAndClosedAfterTwoUpdatesWithinTransaction()`
`void`	`testParameterListOperator()`
`void`	`testParameterListOperatorWhenQueryNeedsTwoParameters()`
`void`	`testParametersAreUnsubscribed()`
`void`	`testParametersAreUnsubscribedIfUnsubscribedPostParameterOperatorLift()`
`void`	`testPushEmptyList()`
`void`	`testRC4()`
`void`	`testReturnGeneratedKeysForMultipleCallsOfInsert()`
`void`	`testReturnGeneratedKeysForMultipleInsertedValuesInOneStatement()`
`void`	`testReturnGeneratedKeysForOneInsertedValue()`
`void`	`testRollbackOnLastOperator()`
`void`	`testRunScript()`
`void`	`testSelectErrorResetsTransactionContextInDatabaseClass()`
`void`	`testSimpleExample()`
`void`	`testSqlProblem()`
`void`	`testTakeFewerThanAvailable()`
`void`	`testTakeShouldNotHang()`
`void`	`testTransaction()`
`void`	`testTransactionOnCommit()`
`void`	`testTransactionOnCommitDoesntOccurUnlessSubscribedTo()`
`void`	`testTransactionOnRollback()`
`void`	`testTransactionUsingCount()`
`void`	`testTransformToTuple2AndTestActionsPrintln()`
`void`	`testTransformToTupleN()`
`void`	`testTryCatch()`
`void`	`testTuple3()`
`void`	`testTuple4()`
`void`	`testTuple5()`
`void`	`testTuple6()`
`void`	`testTuple7()`
`void`	`testTwoConnectionsOpenedAndClosedAfterTwoSelects()`
`void`	`testTwoConnectionsOpenedAndClosedAfterTwoUpdates()`
`void`	`testTwoConnectionsOpenedAndClosedWhenTakeOneUsedWithSelectThatReturnsOneRow()`
`void`	`testTwoParameters()`
`void`	`testUnsubscribeOfBufferAndFlatMap()`
`void`	`testUpdateAndSelectWithTransaction()`
`void`	`testUpdateErrorResetsTransactionContextInDatabaseClass()`
`void`	`testUseParameterObservable()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DatabaseTestBase

public DatabaseTestBase(boolean async)

Method Detail

testSimpleExample
```
public void testSimpleExample()
```

testCountQuery
```
public void testCountQuery()
```

testTransactionUsingCount

public void testTransactionUsingCount()

testTransactionOnCommit
```
public void testTransactionOnCommit()
```

testSelectErrorResetsTransactionContextInDatabaseClass

public void testSelectErrorResetsTransactionContextInDatabaseClass()

testUpdateErrorResetsTransactionContextInDatabaseClass

public void testUpdateErrorResetsTransactionContextInDatabaseClass()

testPushEmptyList
```
public void testPushEmptyList()
```

testRunScript
```
public void testRunScript()
```

testTransactionOnCommitDoesntOccurUnlessSubscribedTo

public void testTransactionOnCommitDoesntOccurUnlessSubscribedTo()

testTransactionOnRollback

public void testTransactionOnRollback()

testUpdateAndSelectWithTransaction

public void testUpdateAndSelectWithTransaction()

testUseParameterObservable

public void testUseParameterObservable()

testTwoParameters
```
public void testTwoParameters()
```

testTakeFewerThanAvailable

public void testTakeFewerThanAvailable()

testJdbcObservableCountLettersInAllNames

public void testJdbcObservableCountLettersInAllNames()

testTransformToTuple2AndTestActionsPrintln

public void testTransformToTuple2AndTestActionsPrintln()

testTransformToTupleN
```
public void testTransformToTupleN()
```

testMultipleSetsOfParameters

public void testMultipleSetsOfParameters()

testNoParams
```
public void testNoParams()
```

testCreateFromScript
```
public void testCreateFromScript()
```

testComposition2
```
public void testComposition2()
```

testEmptyResultSet
```
public void testEmptyResultSet()
```

testMixingExplicitAndObservableParameters

public void testMixingExplicitAndObservableParameters()

testInstantiateDatabaseWithUrl

public void testInstantiateDatabaseWithUrl()
                                    throws SQLException

Throws:: SQLException

testComposition
```
public void testComposition()
```

testCompositionUsingLift

public void testCompositionUsingLift()

testCompositionTwoLevels

public void testCompositionTwoLevels()

testSqlProblem
```
public void testSqlProblem()
```

testException
```
public void testException()
```

testAutoMapWillMapStringToStringAndIntToDouble

public void testAutoMapWillMapStringToStringAndIntToDouble()

testAutoMapCannotFindConstructorWithEnoughParameters

public void testAutoMapCannotFindConstructorWithEnoughParameters()

testGetTimestamp
```
public void testGetTimestamp()
```

insertClobAndReadAsString

public void insertClobAndReadAsString()
                               throws SQLException

Throws:: SQLException

insertNullClobAndReadAsString

public void insertNullClobAndReadAsString()
                                   throws SQLException

Throws:: SQLException

insertNullBlobAndReadAsByteArray

public void insertNullBlobAndReadAsByteArray()
                                      throws SQLException

Throws:: SQLException

insertClobAndReadAsReader

public void insertClobAndReadAsReader()
                               throws SQLException,
                                      IOException

Throws:: SQLException; IOException

insertBlobAndReadAsByteArray

public void insertBlobAndReadAsByteArray()
                                  throws SQLException

Throws:: SQLException

testInsertNull
```
public void testInsertNull()
```

testRC4
```
public void testRC4()
```

testAutoMap
```
public void testAutoMap()
```

testLastTransactionWithoutTransaction

public void testLastTransactionWithoutTransaction()

testTuple3
```
public void testTuple3()
```

testTuple4
```
public void testTuple4()
```

testTuple5
```
public void testTuple5()
```

testTuple6
```
public void testTuple6()
```

testTuple7
```
public void testTuple7()
```

testAutoMapClob
```
public void testAutoMapClob()
```

testAutoMapBlob
```
public void testAutoMapBlob()
```

testCalendarParameter

public void testCalendarParameter()
                           throws SQLException

Throws:: SQLException

testDatabaseBuilder
```
public void testDatabaseBuilder()
```

testConnectionPool
```
public void testConnectionPool()
```

testConnectionPoolWhenExceptionThrown

public void testConnectionPoolWhenExceptionThrown()
                                           throws SQLException

Throws:: SQLException

testConnectionPoolDoesNotRunOutOfConnectionsWhenQueryRunRepeatedly

public void testConnectionPoolDoesNotRunOutOfConnectionsWhenQueryRunRepeatedly()
                                                                        throws SQLException

Throws:: SQLException

testDatabaseBuilderWithPool

public void testDatabaseBuilderWithPool()

testOneConnectionOpenAndClosedAfterOneSelect

public void testOneConnectionOpenAndClosedAfterOneSelect()
                                                  throws InterruptedException

Throws:: InterruptedException

testOneConnectionOpenAndClosedAfterOneUpdate

public void testOneConnectionOpenAndClosedAfterOneUpdate()
                                                  throws InterruptedException

Throws:: InterruptedException

testLiftWithParameters
```
public void testLiftWithParameters()
```

testLiftWithManyParameters

public void testLiftWithManyParameters()

testDetector

public void testDetector()
                  throws InterruptedException

Throws:: InterruptedException

testUnsubscribeOfBufferAndFlatMap

public void testUnsubscribeOfBufferAndFlatMap()
                                       throws InterruptedException

Throws:: InterruptedException

testParametersAreUnsubscribedIfUnsubscribedPostParameterOperatorLift

public void testParametersAreUnsubscribedIfUnsubscribedPostParameterOperatorLift()
                                                                          throws InterruptedException

Throws:: InterruptedException

testParametersAreUnsubscribed

public void testParametersAreUnsubscribed()
                                   throws InterruptedException

Throws:: InterruptedException

testTakeShouldNotHang
```
public void testTakeShouldNotHang()
```

testLiftSelectWithDependencies

public void testLiftSelectWithDependencies()

testLiftUpdateWithParameters

public void testLiftUpdateWithParameters()

testLiftUpdateWithDependencies

public void testLiftUpdateWithDependencies()

testTwoConnectionsOpenedAndClosedAfterTwoSelects

public void testTwoConnectionsOpenedAndClosedAfterTwoSelects()
                                                      throws InterruptedException

Throws:: InterruptedException

testTwoConnectionsOpenedAndClosedAfterTwoUpdates

public void testTwoConnectionsOpenedAndClosedAfterTwoUpdates()
                                                      throws InterruptedException

Throws:: InterruptedException

testOneConnectionOpenedAndClosedAfterTwoSelectsWithinTransaction

public void testOneConnectionOpenedAndClosedAfterTwoSelectsWithinTransaction()
                                                                      throws InterruptedException

Throws:: InterruptedException

testOneConnectionOpenedAndClosedAfterTwoUpdatesWithinTransaction

public void testOneConnectionOpenedAndClosedAfterTwoUpdatesWithinTransaction()
                                                                      throws InterruptedException

Throws:: InterruptedException

testCloseDatabaseClosesConnectionProvider

public void testCloseDatabaseClosesConnectionProvider()

testCloseAutoCommittingConnectionProviderClosesInternalConnectionProvider

public void testCloseAutoCommittingConnectionProviderClosesInternalConnectionProvider()

testCloseSingletonManualCommitConnectionProviderClosesInternalConnectionProvider

public void testCloseSingletonManualCommitConnectionProviderClosesInternalConnectionProvider()

testCloseConnectionProviderFromUrlClosesInternalConnectionProvider

public void testCloseConnectionProviderFromUrlClosesInternalConnectionProvider()

testCannotPassObservableAsSingleParameter

public void testCannotPassObservableAsSingleParameter()

testConnectionsReleasedByUpdateStatementBeforeOnNext

public void testConnectionsReleasedByUpdateStatementBeforeOnNext()
                                                          throws InterruptedException

Throws:: InterruptedException

testConnectionsReleasedByCommitBeforeOnNext

public void testConnectionsReleasedByCommitBeforeOnNext()
                                                 throws InterruptedException

Throws:: InterruptedException

testConnectionsReleasedByRollbackBeforeOnNext

public void testConnectionsReleasedByRollbackBeforeOnNext()
                                                   throws InterruptedException

Throws:: InterruptedException

testCanChainUpdateStatementsWithinTransaction

public void testCanChainUpdateStatementsWithinTransaction()

testCommitOperator
```
public void testCommitOperator()
```

testTryCatch
```
public void testTryCatch()
```

testChainSelectUsingOperators

public void testChainSelectUsingOperators()

testBeginTransactionEmitsOneItem

public void testBeginTransactionEmitsOneItem()

testCommitOnLastOperator

public void testCommitOnLastOperator()

testRollbackOnLastOperator

public void testRollbackOnLastOperator()

testBeginTransactionOnNextForThreePasses

public void testBeginTransactionOnNextForThreePasses()

testParameterListOperator

public void testParameterListOperator()

testParameterListOperatorWhenQueryNeedsTwoParameters

public void testParameterListOperatorWhenQueryNeedsTwoParameters()

testCanExecuteCreateSchema

public void testCanExecuteCreateSchema()

testCanExecuteCreateTable

public void testCanExecuteCreateTable()

testDatabaseFromConnectionCanUseConnectionTwiceWithoutItBeingClosedInReality

public void testDatabaseFromConnectionCanUseConnectionTwiceWithoutItBeingClosedInReality()
                                                                                  throws SQLException

Throws:: SQLException

testNonTransactionalMultipleQueries

public void testNonTransactionalMultipleQueries()

testTransaction
```
public void testTransaction()
```

testTwoConnectionsOpenedAndClosedWhenTakeOneUsedWithSelectThatReturnsOneRow

public void testTwoConnectionsOpenedAndClosedWhenTakeOneUsedWithSelectThatReturnsOneRow()
                                                                                 throws InterruptedException

Throws:: InterruptedException

testAutoMapInterface
```
public void testAutoMapInterface()
```

testAutoMapConvertsCamelCaseToUnderscoreColumnNames

public void testAutoMapConvertsCamelCaseToUnderscoreColumnNames()

testAutoMapWithQueryAnnotation

public void testAutoMapWithQueryAnnotation()

testAutoMapThrowsExceptionIfMappedInterfaceColumnMethodHasParameters

public void testAutoMapThrowsExceptionIfMappedInterfaceColumnMethodHasParameters()

testCustomMapper
```
public void testCustomMapper()
```

testReturnGeneratedKeysForOneInsertedValue

public void testReturnGeneratedKeysForOneInsertedValue()

testReturnGeneratedKeysForMultipleInsertedValuesInOneStatement

public void testReturnGeneratedKeysForMultipleInsertedValuesInOneStatement()

testReturnGeneratedKeysForMultipleCallsOfInsert

public void testReturnGeneratedKeysForMultipleCallsOfInsert()

testNamedParameters
```
public void testNamedParameters()
```

testNamedParametersWithMapParameter

public void testNamedParametersWithMapParameter()

testNamedParametersWithMapParameterInObservable

public void testNamedParametersWithMapParameterInObservable()

testNamedParametersWithUpdateStatement

public void testNamedParametersWithUpdateStatement()

testNamedParametersOneMissingParameterShouldThrowException

public void testNamedParametersOneMissingParameterShouldThrowException()

testNamedParametersWithMapParameterNoNamesInSql

public void testNamedParametersWithMapParameterNoNamesInSql()

testNoParameters
```
public void testNoParameters()
```

Class DatabaseTestBase

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

DatabaseTestBase

Method Detail

testSimpleExample

testCountQuery

testTransactionUsingCount

testTransactionOnCommit

testSelectErrorResetsTransactionContextInDatabaseClass

testUpdateErrorResetsTransactionContextInDatabaseClass

testPushEmptyList

testRunScript

testTransactionOnCommitDoesntOccurUnlessSubscribedTo

testTransactionOnRollback

testUpdateAndSelectWithTransaction

testUseParameterObservable

testTwoParameters

testTakeFewerThanAvailable

testJdbcObservableCountLettersInAllNames

testTransformToTuple2AndTestActionsPrintln

testTransformToTupleN

testMultipleSetsOfParameters

testNoParams

testCreateFromScript

testComposition2

testEmptyResultSet

testMixingExplicitAndObservableParameters

testInstantiateDatabaseWithUrl

testComposition

testCompositionUsingLift

testCompositionTwoLevels

testSqlProblem

testException

testAutoMapWillMapStringToStringAndIntToDouble

testAutoMapCannotFindConstructorWithEnoughParameters

testGetTimestamp

insertClobAndReadAsString

insertNullClobAndReadAsString

insertNullBlobAndReadAsByteArray

insertClobAndReadAsReader

insertBlobAndReadAsByteArray

testInsertNull

testRC4

testAutoMap

testLastTransactionWithoutTransaction

testTuple3

testTuple4

testTuple5

testTuple6

testTuple7

testAutoMapClob

testAutoMapBlob

testCalendarParameter

testDatabaseBuilder

testConnectionPool

testConnectionPoolWhenExceptionThrown

testConnectionPoolDoesNotRunOutOfConnectionsWhenQueryRunRepeatedly

testDatabaseBuilderWithPool

testOneConnectionOpenAndClosedAfterOneSelect

testOneConnectionOpenAndClosedAfterOneUpdate

testLiftWithParameters

testLiftWithManyParameters

testDetector

testUnsubscribeOfBufferAndFlatMap

testParametersAreUnsubscribedIfUnsubscribedPostParameterOperatorLift

testParametersAreUnsubscribed

testTakeShouldNotHang

testLiftSelectWithDependencies

testLiftUpdateWithParameters

testLiftUpdateWithDependencies

testTwoConnectionsOpenedAndClosedAfterTwoSelects

testTwoConnectionsOpenedAndClosedAfterTwoUpdates

testOneConnectionOpenedAndClosedAfterTwoSelectsWithinTransaction

testOneConnectionOpenedAndClosedAfterTwoUpdatesWithinTransaction

testCloseDatabaseClosesConnectionProvider

testCloseAutoCommittingConnectionProviderClosesInternalConnectionProvider

testCloseSingletonManualCommitConnectionProviderClosesInternalConnectionProvider