Package org.springframework.data.mongodb.core

Class MongoDatabaseFactorySupport<C>

java.lang.Object

org.springframework.data.mongodb.core.MongoDatabaseFactorySupport<C>

Type Parameters:

C - Client type.

All Implemented Interfaces:

CodecRegistryProvider, MongoDatabaseFactory, MongoSessionProvider

Direct Known Subclasses:

SimpleMongoClientDatabaseFactory

public abstract class MongoDatabaseFactorySupport<C>
extends Object
implements MongoDatabaseFactory

Common base class for usage with both MongoClients defining common properties such as database name and exception translator.
Not intended to be used directly.

Since:

3.0

Author:

Christoph Strobl, Mark Paluch

See Also:

• SimpleMongoClientDatabaseFactory

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MongoDatabaseFactorySupport(C mongoClient, String databaseName, boolean mongoInstanceCreated, PersistenceExceptionTranslator exceptionTranslator)	Create a new MongoDatabaseFactorySupport object given mongoClient, databaseName, mongoInstanceCreated and PersistenceExceptionTranslator.

Method Summary

Modifier and Type	Method	Description
protected abstract void	closeClient()	Close the client instance.
void	destroy()
protected abstract com.mongodb.client.MongoDatabase	doGetMongoDatabase(String dbName)	Get the actual MongoDatabase from the client.
protected String	getDefaultDatabaseName()
PersistenceExceptionTranslator	getExceptionTranslator()	Exposes a shared MongoExceptionTranslator.
protected C	getMongoClient()
com.mongodb.client.MongoDatabase	getMongoDatabase()	Obtain a MongoDatabase from the underlying factory.
com.mongodb.client.MongoDatabase	getMongoDatabase(String dbName)	Obtain a MongoDatabase instance to access the database with the given name.
void	setWriteConcern(com.mongodb.WriteConcern writeConcern)	Configures the WriteConcern to be used on the MongoDatabase instance being created.
MongoDatabaseFactory	withSession(com.mongodb.client.ClientSession session)	Obtain a ClientSession bound instance of MongoDatabaseFactory returning MongoDatabase instances that are aware and bound to the given session.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.data.mongodb.CodecRegistryProvider

getCodecFor, hasCodecFor

Methods inherited from interface org.springframework.data.mongodb.MongoDatabaseFactory

getCodecRegistry, getSession, isTransactionActive, withSession

Constructor Details

MongoDatabaseFactorySupport

protected MongoDatabaseFactorySupport(C mongoClient,
 String databaseName,
 boolean mongoInstanceCreated,
 PersistenceExceptionTranslator exceptionTranslator)

Create a new MongoDatabaseFactorySupport object given mongoClient, databaseName, mongoInstanceCreated and PersistenceExceptionTranslator.

Parameters:

mongoClient - must not be null.

databaseName - must not be null or empty.

mongoInstanceCreated - true if the client instance was created by a subclass of MongoDatabaseFactorySupport to close the client on destroy().

exceptionTranslator - must not be null.

Method Details

setWriteConcern

public void setWriteConcern(com.mongodb.WriteConcern writeConcern)

Configures the WriteConcern to be used on the MongoDatabase instance being created.

Parameters:

writeConcern - the writeConcern to set

getMongoDatabase

public com.mongodb.client.MongoDatabase getMongoDatabase()
                                                  throws DataAccessException

Description copied from interface: MongoDatabaseFactory

Obtain a MongoDatabase from the underlying factory.

Specified by:

getMongoDatabase in interface MongoDatabaseFactory

Returns:

never null.

Throws:

DataAccessException

getMongoDatabase

public com.mongodb.client.MongoDatabase getMongoDatabase(String dbName)
                                                  throws DataAccessException

Description copied from interface: MongoDatabaseFactory

Obtain a MongoDatabase instance to access the database with the given name.

Specified by:

getMongoDatabase in interface MongoDatabaseFactory

Parameters:

dbName - must not be null.

Returns:

never null.

Throws:

DataAccessException

doGetMongoDatabase

protected abstract com.mongodb.client.MongoDatabase doGetMongoDatabase(String dbName)

Get the actual MongoDatabase from the client.

Parameters:

dbName - must not be null or empty.

Returns:

destroy

public void destroy()
             throws Exception

Throws:

Exception

getExceptionTranslator

public PersistenceExceptionTranslator getExceptionTranslator()

Description copied from interface: MongoDatabaseFactory

Exposes a shared MongoExceptionTranslator.

Specified by:

getExceptionTranslator in interface MongoDatabaseFactory

Returns:

will never be null.

withSession

public MongoDatabaseFactory withSession(com.mongodb.client.ClientSession session)

Description copied from interface: MongoDatabaseFactory

Obtain a ClientSession bound instance of MongoDatabaseFactory returning MongoDatabase instances that are aware and bound to the given session.

Specified by:

withSession in interface MongoDatabaseFactory

Parameters:

session - must not be null.

Returns:

never null.

closeClient

protected abstract void closeClient()

Close the client instance.

getMongoClient

protected C getMongoClient()

Returns:

the Mongo client object.

getDefaultDatabaseName

protected String getDefaultDatabaseName()

Returns:

the database name.