Constructor Detail

• MongoDBClientSupport

  public MongoDBClientSupport(com.mongodb.ServerAddress standalone)

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 com.google.common.base.Optional<com.mongodb.CommandResult> 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)