org.apache.jackrabbit.oak.plugins.document.util

Class MongoConnection

java.lang.Object

org.apache.jackrabbit.oak.plugins.document.util.MongoConnection

public class MongoConnection
extends Object

The MongoConnection abstracts connection to the MongoDB.

Constructor Summary

Constructors

Constructor and Description
MongoConnection(String uri) Constructs a new connection using the specified MongoDB connection string.
MongoConnection(String host, int port, String database) Constructs a new MongoConnection.
MongoConnection(String uri, com.mongodb.MongoClientOptions.Builder builder) Constructs a new connection using the specified MongoDB connection String.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the underlying Mongo instance
com.mongodb.client.MongoDatabase	getDatabase() Returns the MongoDatabase as passed in the URI of the constructor.
com.mongodb.client.MongoDatabase	getDatabase(String name) Returns the MongoDatabase with the given name.
com.mongodb.DB	getDB() Returns the DB as passed in the URI of the constructor.
com.mongodb.DB	getDB(String name) Returns the DB with the given name.
String	getDBName()
static com.mongodb.MongoClientOptions.Builder	getDefaultBuilder() Constructs a builder with default options set.
static com.mongodb.ReadConcern	getDefaultReadConcern(com.mongodb.DB db) Deprecated. use getDefaultReadConcern(Mongo, MongoDatabase) instead.
static com.mongodb.ReadConcern	getDefaultReadConcern(com.mongodb.Mongo client, com.mongodb.client.MongoDatabase db) Returns the default read concern depending on MongoDB deployment.
static com.mongodb.WriteConcern	getDefaultWriteConcern(com.mongodb.DB db) Deprecated. use getDefaultWriteConcern(Mongo) instead.
static com.mongodb.WriteConcern	getDefaultWriteConcern(com.mongodb.Mongo client) Returns the default write concern depending on MongoDB deployment.
com.mongodb.MongoClient	getMongoClient()
static boolean	hasReadConcern(String uri) Returns true if the given uri has a read concern set.
static boolean	hasSufficientReadConcern(com.mongodb.DB db) Deprecated. use isSufficientReadConcern(Mongo, ReadConcern) instead.
static boolean	hasSufficientWriteConcern(com.mongodb.DB db) Deprecated. use isSufficientWriteConcern(Mongo, WriteConcern) instead.
static boolean	hasWriteConcern(String uri) Returns true if the given uri has a write concern set.
static boolean	isMajorityWriteConcern(com.mongodb.DB db) Returns true if the majority write concern is used for the given DB.
static boolean	isMajorityWriteConcern(com.mongodb.client.MongoDatabase db) Returns true if the majority write concern is used for the given DB.
static boolean	isSufficientReadConcern(com.mongodb.Mongo client, com.mongodb.ReadConcern rc) Returns true if the given read concern is sufficient for Oak.
static boolean	isSufficientWriteConcern(com.mongodb.Mongo client, com.mongodb.WriteConcern wc) Returns true if the given write concern is sufficient for Oak.
static com.mongodb.ReadConcernLevel	readConcernLevel(com.mongodb.ReadConcern readConcern)
static String	toString(com.mongodb.MongoClientOptions opts)

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoConnection

public MongoConnection(String uri)
                throws com.mongodb.MongoException

Constructs a new connection using the specified MongoDB connection string. See also http://docs.mongodb.org/manual/reference/connection-string/

Parameters:

uri - the MongoDB URI

Throws:

com.mongodb.MongoException - if there are failures

MongoConnection

public MongoConnection(String uri,
                       com.mongodb.MongoClientOptions.Builder builder)
                throws com.mongodb.MongoException

Constructs a new connection using the specified MongoDB connection String. The default client options are taken from the provided builder.

Parameters:

uri - the connection URI.

builder - the client option defaults.

Throws:

com.mongodb.MongoException - if there are failures

MongoConnection

public MongoConnection(String host,
                       int port,
                       String database)
                throws com.mongodb.MongoException

Constructs a new MongoConnection.

Parameters:

host - The host address.

port - The port.

database - The database name.

Throws:

com.mongodb.MongoException - if there are failures

Method Detail

getMongoClient

public com.mongodb.MongoClient getMongoClient()

Returns:

the MongoClient for this connection.

getDB

public com.mongodb.DB getDB()

Returns the DB as passed in the URI of the constructor.

Returns:

The DB.

getDatabase

public com.mongodb.client.MongoDatabase getDatabase()

Returns the MongoDatabase as passed in the URI of the constructor.

Returns:

the MongoDatabase.

getDB

public com.mongodb.DB getDB(@Nonnull
                            String name)

Returns the DB with the given name.

Returns:

The DB.

getDatabase

public com.mongodb.client.MongoDatabase getDatabase(@Nonnull
                                                    String name)

Returns the MongoDatabase with the given name.

Returns:

The MongoDatabase.

getDBName

public String getDBName()

Returns:

the database name specified in the URI.

close

public void close()

Closes the underlying Mongo instance

getDefaultBuilder

public static com.mongodb.MongoClientOptions.Builder getDefaultBuilder()

Constructs a builder with default options set. These can be overridden later

Returns:

builder with default options set

toString

public static String toString(com.mongodb.MongoClientOptions opts)

hasWriteConcern

public static boolean hasWriteConcern(@Nonnull
                                      String uri)

Returns true if the given uri has a write concern set.

Parameters:

uri - the URI to check.

Returns:

true if the URI has a write concern set, false otherwise.

hasReadConcern

public static boolean hasReadConcern(@Nonnull
                                     String uri)

Returns true if the given uri has a read concern set.

Parameters:

uri - the URI to check.

Returns:

true if the URI has a read concern set, false otherwise.

getDefaultWriteConcern

public static com.mongodb.WriteConcern getDefaultWriteConcern(@Nonnull
                                                              com.mongodb.DB db)

Deprecated. use getDefaultWriteConcern(Mongo) instead.

Returns the default write concern depending on MongoDB deployment.

• WriteConcern.MAJORITY: for a MongoDB replica set
• WriteConcern.ACKNOWLEDGED: for single MongoDB instance

Parameters:

db - the connection to MongoDB.

Returns:

the default write concern to use for Oak.

getDefaultWriteConcern

public static com.mongodb.WriteConcern getDefaultWriteConcern(@Nonnull
                                                              com.mongodb.Mongo client)

Returns the default write concern depending on MongoDB deployment.

• WriteConcern.MAJORITY: for a MongoDB replica set
• WriteConcern.ACKNOWLEDGED: for single MongoDB instance

Parameters:

client - the connection to MongoDB.

Returns:

the default write concern to use for Oak.

getDefaultReadConcern

public static com.mongodb.ReadConcern getDefaultReadConcern(@Nonnull
                                                            com.mongodb.DB db)

Deprecated. use getDefaultReadConcern(Mongo, MongoDatabase) instead.

Returns the default read concern depending on MongoDB deployment.

• ReadConcern.MAJORITY: for a MongoDB replica set with w=majority
• ReadConcern.LOCAL: for other cases

Parameters:

db - the connection to MongoDB.

Returns:

the default write concern to use for Oak.

getDefaultReadConcern

public static com.mongodb.ReadConcern getDefaultReadConcern(@Nonnull
                                                            com.mongodb.Mongo client,
                                                            @Nonnull
                                                            com.mongodb.client.MongoDatabase db)

Returns the default read concern depending on MongoDB deployment.

• ReadConcern.MAJORITY: for a MongoDB replica set with w=majority
• ReadConcern.LOCAL: for other cases

Parameters:

db - the connection to MongoDB.

Returns:

the default write concern to use for Oak.

isMajorityWriteConcern

public static boolean isMajorityWriteConcern(@Nonnull
                                             com.mongodb.DB db)

Returns true if the majority write concern is used for the given DB.

Parameters:

db - the connection to MongoDB.

Returns:

true if the majority write concern has been configured; false otherwise

isMajorityWriteConcern

public static boolean isMajorityWriteConcern(@Nonnull
                                             com.mongodb.client.MongoDatabase db)

Returns true if the majority write concern is used for the given DB.

Parameters:

db - the connection to MongoDB.

Returns:

true if the majority write concern has been configured; false otherwise

hasSufficientWriteConcern

public static boolean hasSufficientWriteConcern(@Nonnull
                                                com.mongodb.DB db)

Deprecated. use isSufficientWriteConcern(Mongo, WriteConcern) instead.

Returns true if the default write concern on the db is sufficient for Oak. On a replica set Oak expects at least w=2. For a single MongoDB node deployment w=1 is sufficient.

Parameters:

db - the database.

Returns:

whether the write concern is sufficient.

isSufficientWriteConcern

public static boolean isSufficientWriteConcern(@Nonnull
                                               com.mongodb.Mongo client,
                                               @Nonnull
                                               com.mongodb.WriteConcern wc)

Returns true if the given write concern is sufficient for Oak. On a replica set Oak expects at least w=2. For a single MongoDB node deployment w=1 is sufficient.

Parameters:

client - the client.

wc - the write concern.

Returns:

whether the write concern is sufficient.

hasSufficientReadConcern

public static boolean hasSufficientReadConcern(@Nonnull
                                               com.mongodb.DB db)

Deprecated. use isSufficientReadConcern(Mongo, ReadConcern) instead.

Returns true if the default read concern on the db is sufficient for Oak. On a replica set Oak expects majority or linear. For a single MongoDB node deployment local is sufficient.

Parameters:

db - the database.

Returns:

whether the read concern is sufficient.

isSufficientReadConcern

public static boolean isSufficientReadConcern(@Nonnull
                                              com.mongodb.Mongo client,
                                              @Nonnull
                                              com.mongodb.ReadConcern rc)

Returns true if the given read concern is sufficient for Oak. On a replica set Oak expects majority or linear. For a single MongoDB node deployment local is sufficient.

Parameters:

client - the client.

rc - the read concern.

Returns:

whether the read concern is sufficient.

readConcernLevel

public static com.mongodb.ReadConcernLevel readConcernLevel(com.mongodb.ReadConcern readConcern)