com.allanbank.mongodb.acceptance

Class ReplicaSetAcceptanceTest

java.lang.Object

com.allanbank.mongodb.ServerTestDriverSupport

com.allanbank.mongodb.acceptance.BasicAcceptanceTestCases

com.allanbank.mongodb.acceptance.ReplicaSetAcceptanceTest

public class ReplicaSetAcceptanceTest
extends BasicAcceptanceTestCases

BasicAcceptanceTestCases provides acceptance test cases for when interacting with a replica set.

Copyright ©:

2012-2014, Allanbank Consulting, Inc., All Rights Reserved

Nested Class Summary

Nested classes/interfaces inherited from class com.allanbank.mongodb.acceptance.BasicAcceptanceTestCases

BasicAcceptanceTestCases.DocumentCallback

Field Summary

Fields inherited from class com.allanbank.mongodb.acceptance.BasicAcceptanceTestCases

GEO_TEST_COLLECTION_NAME, GRIDFS_COLLECTION_ROOT_NAME, LARGE_COLLECTION_COUNT, myCollection, myConfig, myDb, myGeoCollection, myGeoSphereCollection, myMongo, myRandom, ourUniqueId, SMALL_COLLECTION_COUNT, TEST_COLLECTION_NAME, TEST_DB_NAME

Fields inherited from class com.allanbank.mongodb.ServerTestDriverSupport

ADMIN_USER_NAME, DEFAULT_PORT, ourClusterTestSupport, PASSWORD, USER_DB, USER_NAME

Constructor Summary

Constructors

Constructor and Description
ReplicaSetAcceptanceTest()

Method Summary

Methods

Modifier and Type	Method and Description
void	connect() Sets up to create a connection to MongoDB.
protected boolean	isReplicaSetConfiguration() Returns true when running against a replica set configuration (may be shards of replica sets.
static void	startServer() Starts the sharded server before the tests.
static void	stopServer() Stops the servers running in a sharded mode.
void	testGracefulStepdownRecovery() Tests recovery from a graceful step-down of a server.
void	testSecondaryPreferredLoading() Tests that using the secondary preferred read preference submits queries to secondaries.
void	testStillQuerySecondariesWhenNoPrimary() Test recovery from a sudden server failure.
void	testSuddenFailureRecovery() Test recovery from a sudden server failure.

Methods inherited from class com.allanbank.mongodb.acceptance.BasicAcceptanceTestCases

buildLargeCollection, createAddress, disableBalancer, disconnect, distance, fatal, getGeoCollection, getGeoSphereCollection, isShardedConfiguration, largeCollection, shardCollection, shardCollection, testAggregate, testAggregateCursor, testAggregateExplain, testAggregateStream, testAggregateTimeout, testAggregateWithGeoNear, testBatchedOperations, testBatchedWriteReordered, testBatchedWriteSerialized, testBatchedWriteSerializedAndStop, testCollectionStats, testCount, testCountDocumentToLarge, testCountTimeout, testCreateCappedCollection, testCreateCollection, testCreateIndex, testDatabaseStats, testDelete, testDeleteDocumentToLarge, testDistinct, testDistinctTimeout, testDropCollection, testDropDatabase, testDropIndex, testExplain, testFindAndModify, testFindAndModifyTimeout, testFindAndModifyWithNonExistantDocumentAndNoUpsert, testFindAndModifyWithUpsert, testFindOneWithSubsetOfFields, testFindTimeout, testFindWithComment, testFindWithCommentInProfile, testFindWithSubsetOfFields, testGridFs, testGridFsFsck, testGridFsVerify, testGroupBy, testGroupByTimeout, testInsertAlreadyExists, testInsertAndFindOne, testInsertDocumentToLarge, testIteratorAsync, testIteratorAsyncRead, testJournalDurabilityThrows, testListCollections, testListDatabases, testMapReduce, testMapReduceTimeout, testMultiFetchIterator, testMultiFetchIteratorWithLimit, testMultiFetchIteratorWithLimitRestart, testParallelScan, testParallelScanOnSecondary, testProfilingStatus, testQueryDocumentToLarge, testQueryWithAll, testQueryWithAnd, testQueryWithElementMatches, testQueryWithEqualsBoolean, testQueryWithEqualsByteArray, testQueryWithEqualsByteByteArray, testQueryWithEqualsDocumentAssignable, testQueryWithEqualsDoubleCloseToInteger, testQueryWithEqualsDoubleNotCloseToInt, testQueryWithEqualsInt, testQueryWithEqualsJavaScriptString, testQueryWithEqualsJavaScriptStringDocument, testQueryWithEqualsLong, testQueryWithEqualsMaxKey, testQueryWithEqualsMinKey, testQueryWithEqualsMongoTimestamp, testQueryWithEqualsMongoTimestampFailsWhenEncountersATimestamp, testQueryWithEqualsNull, testQueryWithEqualsObjectId, testQueryWithEqualsPattern, testQueryWithEqualsString, testQueryWithEqualsSymbol, testQueryWithEqualsTimestamp, testQueryWithExists, testQueryWithGeoWithinDocumentAssignable, testQueryWithGeoWithinUniqueDocsFalse, testQueryWithGeoWithinWithMultiPointField, testQueryWithGreaterThanByteArray, testQueryWithGreaterThanByteByteArray, testQueryWithGreaterThanDouble, testQueryWithGreaterThanInt, testQueryWithGreaterThanLong, testQueryWithGreaterThanMongoTimestamp, testQueryWithGreaterThanObjectId, testQueryWithGreaterThanOrEqualToByteArray, testQueryWithGreaterThanOrEqualToByteByteArray, testQueryWithGreaterThanOrEqualToDouble, testQueryWithGreaterThanOrEqualToInt, testQueryWithGreaterThanOrEqualToLong, testQueryWithGreaterThanOrEqualToMongoTimestamp, testQueryWithGreaterThanOrEqualToObjectId, testQueryWithGreaterThanOrEqualToString, testQueryWithGreaterThanOrEqualToSymbol, testQueryWithGreaterThanOrEqualToTimestamp, testQueryWithGreaterThanString, testQueryWithGreaterThanSymbol, testQueryWithGreaterThanTimestamp, testQueryWithIn, testQueryWithInstanceOf, testQueryWithIntersectsDocumentAssignable, testQueryWithLessThanByteArray, testQueryWithLessThanByteByteArray, testQueryWithLessThanDouble, testQueryWithLessThanInt, testQueryWithLessThanLong, testQueryWithLessThanMongoTimestamp, testQueryWithLessThanObjectId, testQueryWithLessThanOrEqualToByteArray, testQueryWithLessThanOrEqualToByteByteArray, testQueryWithLessThanOrEqualToDouble, testQueryWithLessThanOrEqualToInt, testQueryWithLessThanOrEqualToLong, testQueryWithLessThanOrEqualToMongoTimestamp, testQueryWithLessThanOrEqualToObjectId, testQueryWithLessThanOrEqualToString, testQueryWithLessThanOrEqualToSymbol, testQueryWithLessThanOrEqualToTimestamp, testQueryWithLessThanString, testQueryWithLessThanSymbol, testQueryWithLessThanTimestamp, testQueryWithMatches, testQueryWithModWithInt, testQueryWithModWithLong, testQueryWithNearDocumentAssignable, testQueryWithNearDocumentAssignableDouble, testQueryWithNearDoubleDouble, testQueryWithNearDoubleDoubleDouble, testQueryWithNearIntInt, testQueryWithNearIntIntInt, testQueryWithNearLongLong, testQueryWithNearLongLongLong, testQueryWithNearSphereDocumentAssignable, testQueryWithNearSphereDocumentAssignableDouble, testQueryWithNearSphereDoubleDouble, testQueryWithNearSphereDoubleDoubleDouble, testQueryWithNearSphereIntInt, testQueryWithNearSphereIntIntInt, testQueryWithNearSphereLongLong, testQueryWithNearSphereLongLongLong, testQueryWithNotEqualToBoolean, testQueryWithNotEqualToByteArray, testQueryWithNotEqualToByteByteArray, testQueryWithNotEqualToDocumentAssignable, testQueryWithNotEqualToDouble, testQueryWithNotEqualToInt, testQueryWithNotEqualToJavaScriptString, testQueryWithNotEqualToJavaScriptStringDocument, testQueryWithNotEqualToLong, testQueryWithNotEqualToMaxKey, testQueryWithNotEqualToMinKey, testQueryWithNotEqualToMongoTimestamp, testQueryWithNotEqualToNull, testQueryWithNotEqualToObjectId, testQueryWithNotEqualToPattern, testQueryWithNotEqualToString, testQueryWithNotEqualToSymbol, testQueryWithNotEqualToTimestamp, testQueryWithNotIn, testQueryWithSize, testQueryWithWhere, testQueryWithWithinBooleanPoint2DPoint2DPoint2DPoint2DArray, testQueryWithWithinDocumentAssignable, testQueryWithWithinDocumentAssignableBoolean, testQueryWithWithinDoubleDoubleDouble, testQueryWithWithinDoubleDoubleDoubleBoolean, testQueryWithWithinDoubleDoubleDoubleDouble, testQueryWithWithinDoubleDoubleDoubleDoubleBoolean, testQueryWithWithinIntIntInt, testQueryWithWithinIntIntIntBoolean, testQueryWithWithinIntIntIntInt, testQueryWithWithinIntIntIntIntBoolean, testQueryWithWithinLongLongLong, testQueryWithWithinLongLongLongBoolean, testQueryWithWithinLongLongLongLong, testQueryWithWithinLongLongLongLongBoolean, testQueryWithWithinOnSphereDoubleDoubleDouble, testQueryWithWithinOnSphereDoubleDoubleDoubleBoolean, testQueryWithWithinOnSphereIntIntInt, testQueryWithWithinOnSphereIntIntIntBoolean, testQueryWithWithinOnSphereLongLongLong, testQueryWithWithinOnSphereLongLongLongBoolean, testQueryWithWithinOnSphereWrapDoesNotWork, testQueryWithWithinPoint2DPoint2DPoint2DPoint2DArray, testRestartWithBadCursorIdFails, testSaveWithId, testSaveWithoutId, testStreamingFind, testStreamingFindLegacy, testTextSearch, testUpdate, testUpdateDocumentToLarge, testUpdateDurabilityFails, testUpdateOptions, testUpdateQueryToLarge, testUpdateWithSetAndUnset, testValidate

Methods inherited from class com.allanbank.mongodb.ServerTestDriverSupport

repairReplicaSet, startAuthenticated, startReplicaSet, startSharded, startShardedReplicaSets, startStandAlone, stopReplicaSet, stopSharded, stopShardedReplicaSets, stopStandAlone

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicaSetAcceptanceTest

public ReplicaSetAcceptanceTest()

Method Detail

startServer

public static void startServer()

Starts the sharded server before the tests.

stopServer

public static void stopServer()

Stops the servers running in a sharded mode.

connect

public void connect()

Sets up to create a connection to MongoDB.

Overrides:

connect in class BasicAcceptanceTestCases

testGracefulStepdownRecovery

public void testGracefulStepdownRecovery()

Tests recovery from a graceful step-down of a server.

testSecondaryPreferredLoading

public void testSecondaryPreferredLoading()
                                   throws IOException,
                                          InterruptedException,
                                          ExecutionException

Tests that using the secondary preferred read preference submits queries to secondaries.

Throws:

IOException - On a test failure.

ExecutionException - On a test failure.

InterruptedException - On a test failure.

testStillQuerySecondariesWhenNoPrimary

public void testStillQuerySecondariesWhenNoPrimary()
                                            throws InterruptedException

Test recovery from a sudden server failure.

Throws:

InterruptedException - On a failure to sleep in the test.

testSuddenFailureRecovery

public void testSuddenFailureRecovery()

Test recovery from a sudden server failure.

isReplicaSetConfiguration

protected boolean isReplicaSetConfiguration()

Returns true when running against a replica set configuration (may be shards of replica sets.

Overridden to return true.

Overrides:

isReplicaSetConfiguration in class BasicAcceptanceTestCases

Returns:

True when connecting to a replica set.