com.allanbank.mongodb.acceptance

Class ShardedReplicaSetsAcceptanceTest

java.lang.Object

com.allanbank.mongodb.ServerTestDriverSupport

com.allanbank.mongodb.acceptance.BasicAcceptanceTestCases

com.allanbank.mongodb.acceptance.ShardedReplicaSetsAcceptanceTest

public class ShardedReplicaSetsAcceptanceTest
extends BasicAcceptanceTestCases

BasicAcceptanceTestCases performs acceptance tests for the driver against a sharded MongoDB configuration.

These are not meant to be exhaustive tests of the driver but instead attempt to demonstrate that interactions with the MongoDB processes work.

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
ShardedReplicaSetsAcceptanceTest()

Method Summary

Methods

Modifier and Type	Method and Description
void	connect() Sets up to create a connection to MongoDB.
protected int	countPrimaryCommands() Returns the number of commands seen on secondaries.
protected int	countSecondaryCommands() Returns the number of commands seen on secondaries.
protected MongoCollection	getGeoCollection() Returns a collection with a geospatial 2D index on the 'p' field.
protected boolean	isReplicaSetConfiguration() Returns true when running against a replica set configuration (may be shards of replica sets.
protected boolean	isShardedConfiguration() Returns true when running against a sharded configuration.
static void	startServer() Starts the sharded server before the tests.
static void	stopServer() Stops the servers running in a sharded mode.
void	testAggregationOnSecondaries() Test that a aggregate command for a secondary runs on the secondary.
void	testCountOnSecondaries() Verifies counting the number of documents in the collection.
void	testDistinctOnSecondaries() Verifies running a distinct command.
void	testExplain() Verifies the ability to get a query plan via explain.
void	testGroupBy() Verifies the function of a GroupBy command.
void	testGroupByOnSecondaries() Verifies the function of a GroupBy command.
void	testMapReduceOnSecondaries() Verifies the function of MapReduce via a sample Map/Reduce
void	testQueryWithNearDoubleDouble() Test method for ConditionBuilder.near(double, double).
void	testQueryWithNearDoubleDoubleDouble() Test method for ConditionBuilder.near(double, double, double).
void	testQueryWithNearIntInt() Test method for ConditionBuilder.near(int, int).
void	testQueryWithNearIntIntInt() Test method for ConditionBuilder.near(int, int, int).
void	testQueryWithNearLongLong() Test method for ConditionBuilder.near(long, long).
void	testQueryWithNearLongLongLong() Test method for ConditionBuilder.near(long, long, long).
void	testQueryWithNearSphereDoubleDouble() Test method for ConditionBuilder.nearSphere(double, double).
void	testQueryWithNearSphereDoubleDoubleDouble() Test method for ConditionBuilder.nearSphere(double, double, double).
void	testQueryWithNearSphereIntInt() Test method for ConditionBuilder.nearSphere(int, int).
void	testQueryWithNearSphereIntIntInt() Test method for ConditionBuilder.nearSphere(int, int, int).
void	testQueryWithNearSphereLongLong() Test method for ConditionBuilder.nearSphere(long, long).
void	testQueryWithNearSphereLongLongLong() Test method for ConditionBuilder.nearSphere(long, long, long).

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

buildLargeCollection, createAddress, disableBalancer, disconnect, distance, fatal, getGeoSphereCollection, 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, testFindAndModify, testFindAndModifyTimeout, testFindAndModifyWithNonExistantDocumentAndNoUpsert, testFindAndModifyWithUpsert, testFindOneWithSubsetOfFields, testFindTimeout, testFindWithComment, testFindWithCommentInProfile, testFindWithSubsetOfFields, testGridFs, testGridFsFsck, testGridFsVerify, 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, testQueryWithNearSphereDocumentAssignable, testQueryWithNearSphereDocumentAssignableDouble, 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

ShardedReplicaSetsAcceptanceTest

public ShardedReplicaSetsAcceptanceTest()

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

testAggregationOnSecondaries

public void testAggregationOnSecondaries()

Test that a aggregate command for a secondary runs on the secondary.

testCountOnSecondaries

public void testCountOnSecondaries()

Verifies counting the number of documents in the collection.

testDistinctOnSecondaries

public void testDistinctOnSecondaries()

Verifies running a distinct command.

 
 db.addresses.insert({"zip-code": 10010})
 db.addresses.insert({"zip-code": 10010})
 db.addresses.insert({"zip-code": 99701})
 
 db.addresses.distinct("zip-code");
 [ 10010, 99701 ]
 
 

testExplain

public void testExplain()

Verifies the ability to get a query plan via explain.

Overridden to adjust the expectations for the command due to delta's in responses for sharded collections.

Overrides:

testExplain in class BasicAcceptanceTestCases

testGroupBy

public void testGroupBy()

Verifies the function of a GroupBy command.

 
 { domain: "www.mongodb.org"
 , invoked_at: {d:"2009-11-03", t:"17:14:05"}
 , response_time: 0.05
 , http_action: "GET /display/DOCS/Aggregate"
 }
 
 db.test.group(
    { cond: {"invoked_at.d": {$gte: "2009-11", $lt: "2009-12"}}
    , key: {http_action: true}
    , initial: {count: 0, total_time:0}
    , reduce: function(doc, out){ out.count++; out.total_time+=doc.response_time }
    , finalize: function(out){ out.avg_time = out.total_time / out.count }
    } );
 
 [
   {
     "http_action" : "GET /display/DOCS/Aggregate",
     "count" : 1,
     "total_time" : 0.05,
     "avg_time" : 0.05
   }
 ]
 
 
 

Overridden to adjust the expectations for the command to fail due to the group command not being supported on sharded collections.

Overrides:

testGroupBy in class BasicAcceptanceTestCases

testGroupByOnSecondaries

public void testGroupByOnSecondaries()

Verifies the function of a GroupBy command.

 
 { domain: "www.mongodb.org"
 , invoked_at: {d:"2009-11-03", t:"17:14:05"}
 , response_time: 0.05
 , http_action: "GET /display/DOCS/Aggregate"
 }
 
 db.test.group(
    { cond: {"invoked_at.d": {$gte: "2009-11", $lt: "2009-12"}}
    , key: {http_action: true}
    , initial: {count: 0, total_time:0}
    , reduce: function(doc, out){ out.count++; out.total_time+=doc.response_time }
    , finalize: function(out){ out.avg_time = out.total_time / out.count }
    } );
 
 [
   {
     "http_action" : "GET /display/DOCS/Aggregate",
     "count" : 1,
     "total_time" : 0.05,
     "avg_time" : 0.05
   }
 ]
 
 
 

testMapReduceOnSecondaries

public void testMapReduceOnSecondaries()

Verifies the function of MapReduce via a sample Map/Reduce

 
 > db.things.insert( { _id : 1, tags : ['dog', 'cat'] } );
 > db.things.insert( { _id : 2, tags : ['cat'] } );
 > db.things.insert( { _id : 3, tags : ['mouse', 'cat', 'dog'] } );
 > db.things.insert( { _id : 4, tags : []  } );
 
 > // map function
 > m = function(){
 ...    this.tags.forEach(
 ...        function(z){
 ...            emit( z , { count : 1 } );
 ...        }
 ...    );
 ...};
 
 > // reduce function
 > r = function( key , values ){
 ...    var total = 0;
 ...    for ( var i=0; i res = db.things.mapReduce(m, r, { out : "inline" } );
 > res
 {
     "result" : "myoutput",
     "timeMillis" : 12,
     "counts" : {
         "input" : 4,
         "emit" : 6,
         "output" : 3
     },
     "ok" : 1,
 }
 > db.myoutput.find()
 {"_id" : "cat" , "value" : {"count" : 3}}
 {"_id" : "dog" , "value" : {"count" : 2}}
 {"_id" : "mouse" , "value" : {"count" : 1}}
 
 

testQueryWithNearDoubleDouble

public void testQueryWithNearDoubleDouble()

Test method for ConditionBuilder.near(double, double).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearDoubleDouble in class BasicAcceptanceTestCases

testQueryWithNearDoubleDoubleDouble

public void testQueryWithNearDoubleDoubleDouble()

Test method for ConditionBuilder.near(double, double, double).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearDoubleDoubleDouble in class BasicAcceptanceTestCases

testQueryWithNearIntInt

public void testQueryWithNearIntInt()

Test method for ConditionBuilder.near(int, int).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearIntInt in class BasicAcceptanceTestCases

testQueryWithNearIntIntInt

public void testQueryWithNearIntIntInt()

Test method for ConditionBuilder.near(int, int, int).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearIntIntInt in class BasicAcceptanceTestCases

testQueryWithNearLongLong

public void testQueryWithNearLongLong()

Test method for ConditionBuilder.near(long, long).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearLongLong in class BasicAcceptanceTestCases

testQueryWithNearLongLongLong

public void testQueryWithNearLongLongLong()

Test method for ConditionBuilder.near(long, long, long).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearLongLongLong in class BasicAcceptanceTestCases

testQueryWithNearSphereDoubleDouble

public void testQueryWithNearSphereDoubleDouble()

Test method for ConditionBuilder.nearSphere(double, double).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearSphereDoubleDouble in class BasicAcceptanceTestCases

testQueryWithNearSphereDoubleDoubleDouble

public void testQueryWithNearSphereDoubleDoubleDouble()

Test method for ConditionBuilder.nearSphere(double, double, double).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearSphereDoubleDoubleDouble in class BasicAcceptanceTestCases

testQueryWithNearSphereIntInt

public void testQueryWithNearSphereIntInt()

Test method for ConditionBuilder.nearSphere(int, int).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearSphereIntInt in class BasicAcceptanceTestCases

testQueryWithNearSphereIntIntInt

public void testQueryWithNearSphereIntIntInt()

Test method for ConditionBuilder.nearSphere(int, int, int).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearSphereIntIntInt in class BasicAcceptanceTestCases

testQueryWithNearSphereLongLong

public void testQueryWithNearSphereLongLong()

Test method for ConditionBuilder.nearSphere(long, long).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearSphereLongLong in class BasicAcceptanceTestCases

testQueryWithNearSphereLongLongLong

public void testQueryWithNearSphereLongLongLong()

Test method for ConditionBuilder.nearSphere(long, long, long).

Overridden to expect the query to fail on the sharded collection.

Overrides:

testQueryWithNearSphereLongLongLong in class BasicAcceptanceTestCases

countPrimaryCommands

protected int countPrimaryCommands()

Returns the number of commands seen on secondaries.

Returns:

The number of commands seen on secondaries.

countSecondaryCommands

protected int countSecondaryCommands()

Returns the number of commands seen on secondaries.

Returns:

The number of commands seen on secondaries.

getGeoCollection

protected MongoCollection getGeoCollection()

Returns a collection with a geospatial 2D index on the 'p' field.

Overrides:

getGeoCollection in class BasicAcceptanceTestCases

Returns:

The collection with a geospatial 2D index on the 'p' field.

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.

isShardedConfiguration

protected boolean isShardedConfiguration()

Returns true when running against a sharded configuration. Not all commands are supported in shared environments, e.g., when connected to a mongos.

Overridden to return true.

Overrides:

isShardedConfiguration in class BasicAcceptanceTestCases

Returns:

True when connecting to a mongos.