org.apache.brooklyn.entity.nosql.mongodb

Class MongoDBClientSupport

java.lang.Object

org.apache.brooklyn.entity.nosql.mongodb.MongoDBClientSupport

public class MongoDBClientSupport
extends java.lang.Object

Manages connections to standalone MongoDB servers.

See Also:

MongoDB database command documentation

Constructor Summary

Constructors

Constructor and Description
MongoDBClientSupport(com.mongodb.ServerAddress standalone)
MongoDBClientSupport(com.mongodb.ServerAddress standalone, java.lang.String username, java.lang.String password, java.lang.String authenticationDatabase)

Method Summary

Modifier and Type	Method and Description
boolean	addMemberToReplicaSet(MongoDBServer secondary, java.lang.Integer id) Reconfigures the replica set that this client is the primary member of to include a new member.
boolean	addShardToRouter(java.lang.String hostAndPort)
static MongoDBClientSupport	forServer(AbstractMongoDBServer standalone) Creates a MongoDBClientSupport instance in standalone mode.
org.bson.BasicBSONObject	getReplicaSetStatus() Runs replSetGetStatus on the admin database.
org.bson.BasicBSONObject	getServerStatus()
long	getShardCount()
boolean	initializeReplicaSet(java.lang.String replicaSetName, java.lang.Integer id)
boolean	ping()
boolean	removeMemberFromReplicaSet(MongoDBServer server) Reconfigures the replica set that this client is the primary member of to remove the given server.
<any>	runDBCommand(java.lang.String database, java.lang.String command)

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoDBClientSupport

public MongoDBClientSupport(com.mongodb.ServerAddress standalone)

MongoDBClientSupport

public MongoDBClientSupport(com.mongodb.ServerAddress standalone,
                            java.lang.String username,
                            java.lang.String password,
                            java.lang.String authenticationDatabase)

Method Detail

forServer

public static MongoDBClientSupport forServer(AbstractMongoDBServer standalone)
                                      throws java.net.UnknownHostException

Creates a MongoDBClientSupport instance in standalone mode.

Throws:

java.net.UnknownHostException

runDBCommand

public <any> runDBCommand(java.lang.String database,
                          java.lang.String command)

getShardCount

public long getShardCount()

getServerStatus

public org.bson.BasicBSONObject getServerStatus()

ping

public boolean ping()

initializeReplicaSet

public boolean initializeReplicaSet(java.lang.String replicaSetName,
                                    java.lang.Integer id)

getReplicaSetStatus

public org.bson.BasicBSONObject getReplicaSetStatus()

Runs replSetGetStatus on the admin database.

Returns:

The result of replSetGetStatus, or an empty BasicBSONObject if the command threw an exception (e.g. if the connection was reset) or if the resultant CommandResult.ok() was false.

See Also:

Replica set status reference, replSetGetStatus documentation

addMemberToReplicaSet

public boolean addMemberToReplicaSet(MongoDBServer secondary,
                                     java.lang.Integer id)

Reconfigures the replica set that this client is the primary member of to include a new member.

Note that this can cause long downtime (typically 10-20s, even up to a minute).

Parameters:

secondary - New member of the set.

id - The id for the new set member. Must be unique within the set.

Returns:

True if successful

removeMemberFromReplicaSet

public boolean removeMemberFromReplicaSet(MongoDBServer server)

Reconfigures the replica set that this client is the primary member of to remove the given server.

Parameters:

server - The server to remove

Returns:

True if successful

addShardToRouter

public boolean addShardToRouter(java.lang.String hostAndPort)