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.
|
org.bson.codecs.configuration.CodecRegistry |
getCodecRegistry()
Get the underlying
CodecRegistry used by the reactive MongoDB Java driver. |
PersistenceExceptionTranslator |
getExceptionTranslator()
Exposes a shared
MongoExceptionTranslator . |
reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.MongoDatabase> |
getMongoDatabase()
Creates a default
MongoDatabase instance. |
reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.MongoDatabase> |
getMongoDatabase(String dbName)
Obtain a
MongoDatabase instance to access the database with the given name. |
reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.ClientSession> |
getSession(com.mongodb.ClientSessionOptions options)
Obtain a
Mono emitting a ClientSession for given options . |
void |
setWriteConcern(com.mongodb.WriteConcern writeConcern)
Configures the
WriteConcern to be used on the MongoDatabase instance being created. |
ReactiveMongoDatabaseFactory |
withSession(com.mongodb.reactivestreams.client.ClientSession session)
Obtain a
ClientSession bound instance of ReactiveMongoDatabaseFactory returning
MongoDatabase instances that are aware and bound to the given session. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isTransactionActive
getCodecFor, hasCodecFor
public SimpleReactiveMongoDatabaseFactory(com.mongodb.ConnectionString connectionString)
SimpleReactiveMongoDatabaseFactory
instance from the given ConnectionString
.connectionString
- must not be null.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 reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.MongoDatabase> getMongoDatabase() throws DataAccessException
ReactiveMongoDatabaseFactory
MongoDatabase
instance.getMongoDatabase
in interface ReactiveMongoDatabaseFactory
DataAccessException
public reactor.core.publisher.Mono<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
public org.bson.codecs.configuration.CodecRegistry getCodecRegistry()
ReactiveMongoDatabaseFactory
CodecRegistry
used by the reactive MongoDB Java driver.getCodecRegistry
in interface CodecRegistryProvider
getCodecRegistry
in interface ReactiveMongoDatabaseFactory
public reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.ClientSession> getSession(com.mongodb.ClientSessionOptions options)
ReactiveMongoDatabaseFactory
Mono
emitting a ClientSession
for given options
.getSession
in interface ReactiveMongoDatabaseFactory
options
- must not be null.public ReactiveMongoDatabaseFactory withSession(com.mongodb.reactivestreams.client.ClientSession session)
ReactiveMongoDatabaseFactory
ClientSession
bound instance of ReactiveMongoDatabaseFactory
returning
MongoDatabase
instances that are aware and bound to the given session.withSession
in interface ReactiveMongoDatabaseFactory
session
- must not be null.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.