com.mongodb.async.client

Class MongoClientImpl

java.lang.Object

com.mongodb.async.client.MongoClientImpl

All Implemented Interfaces:

MongoClient, java.io.Closeable, java.lang.AutoCloseable

class MongoClientImpl
extends java.lang.Object
implements MongoClient

Field Summary

Fields

Modifier and Type	Field and Description
private ClientSessionHelper	clientSessionHelper
private Cluster	cluster
private AsyncOperationExecutor	executor
private java.io.Closeable	externalResourceCloser
private static Logger	LOGGER
private ServerSessionPool	serverSessionPool
private MongoClientSettings	settings

Constructor Summary

Constructors

Modifier	Constructor and Description
(package private)	MongoClientImpl(MongoClientSettings settings, Cluster cluster, AsyncOperationExecutor executor)
private	MongoClientImpl(MongoClientSettings settings, Cluster cluster, AsyncOperationExecutor executor, java.io.Closeable externalResourceCloser)
(package private)	MongoClientImpl(MongoClientSettings settings, Cluster cluster, java.io.Closeable externalResourceCloser)

Method Summary

Modifier and Type	Method and Description
void	close() Close the client, which will close all underlying cached resources, including, for example, sockets and background monitoring threads.
private MongoIterable<java.lang.String>	createListDatabaseNamesIterable(ClientSession clientSession)
private <T> ListDatabasesIterable<T>	createListDatabasesIterable(ClientSession clientSession, java.lang.Class<T> clazz)
(package private) Cluster	getCluster()
MongoDatabase	getDatabase(java.lang.String name) Gets the database with the given name.
(package private) ServerSessionPool	getServerSessionPool()
MongoClientSettings	getSettings() Gets the settings that this client uses to connect to server.
MongoIterable<java.lang.String>	listDatabaseNames() Get a list of the database names
MongoIterable<java.lang.String>	listDatabaseNames(ClientSession clientSession) Get a list of the database names
ListDatabasesIterable<Document>	listDatabases() Gets the list of databases
<T> ListDatabasesIterable<T>	listDatabases(java.lang.Class<T> resultClass) Gets the list of databases
ListDatabasesIterable<Document>	listDatabases(ClientSession clientSession) Gets the list of databases
<TResult> ListDatabasesIterable<TResult>	listDatabases(ClientSession clientSession, java.lang.Class<TResult> resultClass) Gets the list of databases
void	startSession(ClientSessionOptions options, SingleResultCallback<ClientSession> callback) Creates a client session.

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final Logger LOGGER

cluster

private final Cluster cluster

settings

private final MongoClientSettings settings

executor

private final AsyncOperationExecutor executor

externalResourceCloser

private final java.io.Closeable externalResourceCloser

serverSessionPool

private final ServerSessionPool serverSessionPool

clientSessionHelper

private final ClientSessionHelper clientSessionHelper

Constructor Detail

MongoClientImpl

MongoClientImpl(MongoClientSettings settings,
                Cluster cluster,
                java.io.Closeable externalResourceCloser)

MongoClientImpl

MongoClientImpl(MongoClientSettings settings,
                Cluster cluster,
                AsyncOperationExecutor executor)

MongoClientImpl

private MongoClientImpl(MongoClientSettings settings,
                        Cluster cluster,
                        AsyncOperationExecutor executor,
                        java.io.Closeable externalResourceCloser)

Method Detail

startSession

public void startSession(ClientSessionOptions options,
                         SingleResultCallback<ClientSession> callback)

Description copied from interface: MongoClient

Creates a client session.

Note: A ClientSession instance can not be used concurrently in multiple asynchronous operations.

Specified by:

startSession in interface MongoClient

Parameters:

options - the options for the client session

callback - the callback that is passed the clientSession or a MongoClientException if the MongoDB cluster to which this client is connected does not support sessions

getDatabase

public MongoDatabase getDatabase(java.lang.String name)

Description copied from interface: MongoClient

Gets the database with the given name.

Specified by:

getDatabase in interface MongoClient

Parameters:

name - the name of the database

Returns:

the database

See Also:

MongoNamespace.checkDatabaseNameValidity(String)

close

public void close()

Description copied from interface: MongoClient

Close the client, which will close all underlying cached resources, including, for example, sockets and background monitoring threads.

Specified by:

close in interface MongoClient

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

getSettings

public MongoClientSettings getSettings()

Description copied from interface: MongoClient

Gets the settings that this client uses to connect to server.

Note: MongoClientSettings is immutable.

Specified by:

getSettings in interface MongoClient

Returns:

the settings

listDatabaseNames

public MongoIterable<java.lang.String> listDatabaseNames()

Description copied from interface: MongoClient

Get a list of the database names

Specified by:

listDatabaseNames in interface MongoClient

Returns:

an iterable containing all the names of all the databases

listDatabaseNames

public MongoIterable<java.lang.String> listDatabaseNames(ClientSession clientSession)

Description copied from interface: MongoClient

Get a list of the database names

Specified by:

listDatabaseNames in interface MongoClient

Parameters:

clientSession - the client session with which to associate this operation

Returns:

an iterable containing all the names of all the databases

createListDatabaseNamesIterable

private MongoIterable<java.lang.String> createListDatabaseNamesIterable(ClientSession clientSession)

listDatabases

public ListDatabasesIterable<Document> listDatabases()

Description copied from interface: MongoClient

Gets the list of databases

Specified by:

listDatabases in interface MongoClient

Returns:

the list databases iterable interface

listDatabases

public ListDatabasesIterable<Document> listDatabases(ClientSession clientSession)

Description copied from interface: MongoClient

Gets the list of databases

Specified by:

listDatabases in interface MongoClient

Parameters:

clientSession - the client session with which to associate this operation

Returns:

the list databases iterable interface

listDatabases

public <T> ListDatabasesIterable<T> listDatabases(java.lang.Class<T> resultClass)

Description copied from interface: MongoClient

Gets the list of databases

Specified by:

listDatabases in interface MongoClient

Type Parameters:

T - the type of the class to use instead of Document.

Parameters:

resultClass - the class to cast the database documents to

Returns:

the list databases iterable interface

listDatabases

public <TResult> ListDatabasesIterable<TResult> listDatabases(ClientSession clientSession,
                                                              java.lang.Class<TResult> resultClass)

Description copied from interface: MongoClient

Gets the list of databases

Specified by:

listDatabases in interface MongoClient

Type Parameters:

TResult - the type of the class to use instead of Document.

Parameters:

clientSession - the client session with which to associate this operation

resultClass - the class to cast the database documents to

Returns:

the list databases iterable interface

createListDatabasesIterable

private <T> ListDatabasesIterable<T> createListDatabasesIterable(ClientSession clientSession,
                                                                 java.lang.Class<T> clazz)

getCluster

Cluster getCluster()

getServerSessionPool

ServerSessionPool getServerSessionPool()