public class SimpleReactiveMongoDatabaseFactory extends Object implements DisposableBean, ReactiveMongoDatabaseFactory
MongoDatabase
instances from a MongoClient
instance.Constructor and Description |
---|
SimpleReactiveMongoDatabaseFactory(com.mongodb.ConnectionString connectionString)
Creates a new
SimpleReactiveMongoDatabaseFactory instance from the given ConnectionString . |
SimpleReactiveMongoDatabaseFactory(com.mongodb.reactivestreams.client.MongoClient mongoClient,
String databaseName)
Creates a new
SimpleReactiveMongoDatabaseFactory instance from the given MongoClient . |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Clean up the Mongo instance if it was created by the factory itself.
|
PersistenceExceptionTranslator |
getExceptionTranslator()
Exposes a shared
MongoExceptionTranslator . |
com.mongodb.reactivestreams.client.MongoDatabase |
getMongoDatabase()
Creates a default
MongoDatabase instance. |
com.mongodb.reactivestreams.client.MongoDatabase |
getMongoDatabase(String dbName)
Creates 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. |
public SimpleReactiveMongoDatabaseFactory(com.mongodb.ConnectionString connectionString) throws UnknownHostException
SimpleReactiveMongoDatabaseFactory
instance from the given ConnectionString
.connectionString
- must not be null.UnknownHostException
public SimpleReactiveMongoDatabaseFactory(com.mongodb.reactivestreams.client.MongoClient mongoClient, String databaseName)
SimpleReactiveMongoDatabaseFactory
instance from the given MongoClient
.mongoClient
- must not be null.databaseName
- must not be null.public void setWriteConcern(com.mongodb.WriteConcern writeConcern)
WriteConcern
to be used on the MongoDatabase
instance being created.writeConcern
- the writeConcern to setpublic com.mongodb.reactivestreams.client.MongoDatabase getMongoDatabase() throws DataAccessException
ReactiveMongoDatabaseFactory
MongoDatabase
instance.getMongoDatabase
in interface ReactiveMongoDatabaseFactory
DataAccessException
public com.mongodb.reactivestreams.client.MongoDatabase getMongoDatabase(String dbName) throws DataAccessException
ReactiveMongoDatabaseFactory
MongoDatabase
instance to access the database with the given name.getMongoDatabase
in interface ReactiveMongoDatabaseFactory
dbName
- must not be null or empty.DataAccessException
public void destroy() throws Exception
destroy
in interface DisposableBean
Exception
DisposableBean.destroy()
public PersistenceExceptionTranslator getExceptionTranslator()
ReactiveMongoDatabaseFactory
MongoExceptionTranslator
.getExceptionTranslator
in interface ReactiveMongoDatabaseFactory
Copyright © 2011–2018 Pivotal Software, Inc.. All rights reserved.