com.mongodb.async.client

Class MongoDatabaseImpl

java.lang.Object

com.mongodb.async.client.MongoDatabaseImpl

All Implemented Interfaces:

MongoDatabase

class MongoDatabaseImpl
extends java.lang.Object
implements MongoDatabase

Field Summary

Fields

Modifier and Type	Field and Description
private CodecRegistry	codecRegistry
private AsyncOperationExecutor	executor
private java.lang.String	name
private ReadConcern	readConcern
private ReadPreference	readPreference
private boolean	retryWrites
private WriteConcern	writeConcern

Constructor Summary

Constructors

Constructor and Description
MongoDatabaseImpl(java.lang.String name, CodecRegistry codecRegistry, ReadPreference readPreference, WriteConcern writeConcern, boolean retryWrites, ReadConcern readConcern, AsyncOperationExecutor executor)

Method Summary

Modifier and Type	Method and Description
private java.util.List<BsonDocument>	createBsonDocumentList(java.util.List<? extends Bson> pipeline)
void	createCollection(ClientSession clientSession, java.lang.String collectionName, CreateCollectionOptions options, SingleResultCallback<java.lang.Void> callback) Create a new collection with the selected options
void	createCollection(ClientSession clientSession, java.lang.String collectionName, SingleResultCallback<java.lang.Void> callback) Create a new collection with the given name.
void	createCollection(java.lang.String collectionName, CreateCollectionOptions createCollectionOptions, SingleResultCallback<java.lang.Void> callback) Create a new collection with the selected options
void	createCollection(java.lang.String collectionName, SingleResultCallback<java.lang.Void> callback) Create a new collection with the given name.
private MongoIterable<java.lang.String>	createListCollectionNamesIterable(ClientSession clientSession)
private <TResult> ListCollectionsIterable<TResult>	createListCollectionsIterable(ClientSession clientSession, java.lang.Class<TResult> resultClass)
void	createView(ClientSession clientSession, java.lang.String viewName, java.lang.String viewOn, java.util.List<? extends Bson> pipeline, CreateViewOptions createViewOptions, SingleResultCallback<java.lang.Void> callback) Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.
void	createView(ClientSession clientSession, java.lang.String viewName, java.lang.String viewOn, java.util.List<? extends Bson> pipeline, SingleResultCallback<java.lang.Void> callback) Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.
void	createView(java.lang.String viewName, java.lang.String viewOn, java.util.List<? extends Bson> pipeline, CreateViewOptions createViewOptions, SingleResultCallback<java.lang.Void> callback) Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.
void	createView(java.lang.String viewName, java.lang.String viewOn, java.util.List<? extends Bson> pipeline, SingleResultCallback<java.lang.Void> callback) Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.
void	drop(ClientSession clientSession, SingleResultCallback<java.lang.Void> callback) Drops this database.
void	drop(SingleResultCallback<java.lang.Void> callback) Drops this database.
private <TResult> void	executeCommand(ClientSession clientSession, Bson command, ReadPreference readPreference, java.lang.Class<TResult> resultClass, SingleResultCallback<TResult> callback)
private void	executeCreateCollection(ClientSession clientSession, java.lang.String collectionName, CreateCollectionOptions options, SingleResultCallback<java.lang.Void> callback)
private void	executeCreateView(ClientSession clientSession, java.lang.String viewName, java.lang.String viewOn, java.util.List<? extends Bson> pipeline, CreateViewOptions createViewOptions, SingleResultCallback<java.lang.Void> callback)
private void	executeDrop(ClientSession clientSession, SingleResultCallback<java.lang.Void> callback)
CodecRegistry	getCodecRegistry() Get the codec registry for the MongoDatabase.
MongoCollection<Document>	getCollection(java.lang.String collectionName) Gets a collection.
<TDocument> MongoCollection<TDocument>	getCollection(java.lang.String collectionName, java.lang.Class<TDocument> documentClass) Gets a collection, with a specific default document class.
java.lang.String	getName() Gets the name of the database.
ReadConcern	getReadConcern() Get the read concern for the MongoDatabase.
ReadPreference	getReadPreference() Get the read preference for the MongoDatabase.
WriteConcern	getWriteConcern() Get the write concern for the MongoDatabase.
MongoIterable<java.lang.String>	listCollectionNames() Gets the names of all the collections in this database.
MongoIterable<java.lang.String>	listCollectionNames(ClientSession clientSession) Gets the names of all the collections in this database.
ListCollectionsIterable<Document>	listCollections() Finds all the collections in this database.
<TResult> ListCollectionsIterable<TResult>	listCollections(java.lang.Class<TResult> resultClass) Finds all the collections in this database.
ListCollectionsIterable<Document>	listCollections(ClientSession clientSession) Finds all the collections in this database.
<TResult> ListCollectionsIterable<TResult>	listCollections(ClientSession clientSession, java.lang.Class<TResult> resultClass) Finds all the collections in this database.
<TResult> void	runCommand(Bson command, java.lang.Class<TResult> resultClass, SingleResultCallback<TResult> callback) Executes the given command in the context of the current database with a read preference of ReadPreference.primary().
<TResult> void	runCommand(Bson command, ReadPreference readPreference, java.lang.Class<TResult> resultClass, SingleResultCallback<TResult> callback) Executes the given command in the context of the current database with the given read preference.
void	runCommand(Bson command, ReadPreference readPreference, SingleResultCallback<Document> callback) Executes the given command in the context of the current database with the given read preference.
void	runCommand(Bson command, SingleResultCallback<Document> callback) Executes the given command in the context of the current database with a read preference of ReadPreference.primary().
<TResult> void	runCommand(ClientSession clientSession, Bson command, java.lang.Class<TResult> resultClass, SingleResultCallback<TResult> callback) Executes the given command in the context of the current database with a read preference of ReadPreference.primary().
<TResult> void	runCommand(ClientSession clientSession, Bson command, ReadPreference readPreference, java.lang.Class<TResult> resultClass, SingleResultCallback<TResult> callback) Executes the given command in the context of the current database with the given read preference.
void	runCommand(ClientSession clientSession, Bson command, ReadPreference readPreference, SingleResultCallback<Document> callback) Executes the given command in the context of the current database with the given read preference.
void	runCommand(ClientSession clientSession, Bson command, SingleResultCallback<Document> callback) Executes the given command in the context of the current database with a read preference of ReadPreference.primary().
private BsonDocument	toBsonDocument(Bson document)
MongoDatabase	withCodecRegistry(CodecRegistry codecRegistry) Create a new MongoDatabase instance with a different codec registry.
MongoDatabase	withReadConcern(ReadConcern readConcern) Create a new MongoDatabase instance with a different read concern.
MongoDatabase	withReadPreference(ReadPreference readPreference) Create a new MongoDatabase instance with a different read preference.
MongoDatabase	withWriteConcern(WriteConcern writeConcern) Create a new MongoDatabase instance with a different write concern.

Methods inherited from class java.lang.Object

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

Field Detail

name

private final java.lang.String name

readPreference

private final ReadPreference readPreference

codecRegistry

private final CodecRegistry codecRegistry

writeConcern

private final WriteConcern writeConcern

retryWrites

private final boolean retryWrites

readConcern

private final ReadConcern readConcern

executor

private final AsyncOperationExecutor executor

Constructor Detail

MongoDatabaseImpl

MongoDatabaseImpl(java.lang.String name,
                  CodecRegistry codecRegistry,
                  ReadPreference readPreference,
                  WriteConcern writeConcern,
                  boolean retryWrites,
                  ReadConcern readConcern,
                  AsyncOperationExecutor executor)

Method Detail

getName

public java.lang.String getName()

Description copied from interface: MongoDatabase

Gets the name of the database.

Specified by:

getName in interface MongoDatabase

Returns:

the database name

getCodecRegistry

public CodecRegistry getCodecRegistry()

Description copied from interface: MongoDatabase

Get the codec registry for the MongoDatabase.

Specified by:

getCodecRegistry in interface MongoDatabase

Returns:

the CodecRegistry

getReadPreference

public ReadPreference getReadPreference()

Description copied from interface: MongoDatabase

Get the read preference for the MongoDatabase.

Specified by:

getReadPreference in interface MongoDatabase

Returns:

the ReadPreference

getWriteConcern

public WriteConcern getWriteConcern()

Description copied from interface: MongoDatabase

Get the write concern for the MongoDatabase.

Specified by:

getWriteConcern in interface MongoDatabase

Returns:

the WriteConcern

getReadConcern

public ReadConcern getReadConcern()

Description copied from interface: MongoDatabase

Get the read concern for the MongoDatabase.

Specified by:

getReadConcern in interface MongoDatabase

Returns:

the ReadConcern

withCodecRegistry

public MongoDatabase withCodecRegistry(CodecRegistry codecRegistry)

Description copied from interface: MongoDatabase

Create a new MongoDatabase instance with a different codec registry.

Specified by:

withCodecRegistry in interface MongoDatabase

Parameters:

codecRegistry - the new CodecRegistry for the database

Returns:

a new MongoDatabase instance with the different codec registry

withReadPreference

public MongoDatabase withReadPreference(ReadPreference readPreference)

Description copied from interface: MongoDatabase

Create a new MongoDatabase instance with a different read preference.

Specified by:

withReadPreference in interface MongoDatabase

Parameters:

readPreference - the new ReadPreference for the database

Returns:

a new MongoDatabase instance with the different readPreference

withWriteConcern

public MongoDatabase withWriteConcern(WriteConcern writeConcern)

Description copied from interface: MongoDatabase

Create a new MongoDatabase instance with a different write concern.

Specified by:

withWriteConcern in interface MongoDatabase

Parameters:

writeConcern - the new WriteConcern for the database

Returns:

a new MongoDatabase instance with the different writeConcern

withReadConcern

public MongoDatabase withReadConcern(ReadConcern readConcern)

Description copied from interface: MongoDatabase

Create a new MongoDatabase instance with a different read concern.

Specified by:

withReadConcern in interface MongoDatabase

Parameters:

readConcern - the new ReadConcern for the database

Returns:

a new MongoDatabase instance with the different ReadConcern

listCollectionNames

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

Description copied from interface: MongoDatabase

Gets the names of all the collections in this database.

Specified by:

listCollectionNames in interface MongoDatabase

Returns:

an iterable containing all the names of all the collections in this database

listCollectionNames

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

Description copied from interface: MongoDatabase

Gets the names of all the collections in this database.

Specified by:

listCollectionNames in interface MongoDatabase

Parameters:

clientSession - the client session with which to associate this operation

Returns:

an iterable containing all the names of all the collections in this database

createListCollectionNamesIterable

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

listCollections

public ListCollectionsIterable<Document> listCollections()

Description copied from interface: MongoDatabase

Finds all the collections in this database.

Specified by:

listCollections in interface MongoDatabase

Returns:

the list collections iterable interface

listCollections

public <TResult> ListCollectionsIterable<TResult> listCollections(java.lang.Class<TResult> resultClass)

Description copied from interface: MongoDatabase

Finds all the collections in this database.

Specified by:

listCollections in interface MongoDatabase

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

resultClass - the class to decode each document into

Returns:

the list collections iterable interface

listCollections

public ListCollectionsIterable<Document> listCollections(ClientSession clientSession)

Description copied from interface: MongoDatabase

Finds all the collections in this database.

Specified by:

listCollections in interface MongoDatabase

Parameters:

clientSession - the client session with which to associate this operation

Returns:

the list collections iterable interface

listCollections

public <TResult> ListCollectionsIterable<TResult> listCollections(ClientSession clientSession,
                                                                  java.lang.Class<TResult> resultClass)

Description copied from interface: MongoDatabase

Finds all the collections in this database.

Specified by:

listCollections in interface MongoDatabase

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

clientSession - the client session with which to associate this operation

resultClass - the class to decode each document into

Returns:

the list collections iterable interface

createListCollectionsIterable

private <TResult> ListCollectionsIterable<TResult> createListCollectionsIterable(ClientSession clientSession,
                                                                                 java.lang.Class<TResult> resultClass)

getCollection

public MongoCollection<Document> getCollection(java.lang.String collectionName)

Description copied from interface: MongoDatabase

Gets a collection.

Specified by:

getCollection in interface MongoDatabase

Parameters:

collectionName - the name of the collection to return

Returns:

the collection

See Also:

MongoNamespace.checkCollectionNameValidity(String)

getCollection

public <TDocument> MongoCollection<TDocument> getCollection(java.lang.String collectionName,
                                                            java.lang.Class<TDocument> documentClass)

Description copied from interface: MongoDatabase

Gets a collection, with a specific default document class.

Specified by:

getCollection in interface MongoDatabase

Type Parameters:

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

Parameters:

collectionName - the name of the collection to return

documentClass - the default class to cast any documents returned from the database into.

Returns:

the collection

runCommand

public void runCommand(Bson command,
                       SingleResultCallback<Document> callback)

Description copied from interface: MongoDatabase

Executes the given command in the context of the current database with a read preference of ReadPreference.primary().

Specified by:

runCommand in interface MongoDatabase

Parameters:

command - the command to be run

callback - the callback that is passed the command result

runCommand

public void runCommand(Bson command,
                       ReadPreference readPreference,
                       SingleResultCallback<Document> callback)

Description copied from interface: MongoDatabase

Executes the given command in the context of the current database with the given read preference.

Specified by:

runCommand in interface MongoDatabase

Parameters:

command - the command to be run

readPreference - the ReadPreference to be used when executing the command

callback - the callback that is passed the command result

runCommand

public <TResult> void runCommand(Bson command,
                                 java.lang.Class<TResult> resultClass,
                                 SingleResultCallback<TResult> callback)

Description copied from interface: MongoDatabase

Executes the given command in the context of the current database with a read preference of ReadPreference.primary().

Specified by:

runCommand in interface MongoDatabase

Type Parameters:

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

Parameters:

command - the command to be run

resultClass - the default class to cast any documents returned from the database into.

callback - the callback that is passed the command result

runCommand

public <TResult> void runCommand(Bson command,
                                 ReadPreference readPreference,
                                 java.lang.Class<TResult> resultClass,
                                 SingleResultCallback<TResult> callback)

Description copied from interface: MongoDatabase

Executes the given command in the context of the current database with the given read preference.

Specified by:

runCommand in interface MongoDatabase

Type Parameters:

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

Parameters:

command - the command to be run

readPreference - the ReadPreference to be used when executing the command

resultClass - the default class to cast any documents returned from the database into.

callback - the callback that is passed the command result

runCommand

public void runCommand(ClientSession clientSession,
                       Bson command,
                       SingleResultCallback<Document> callback)

Description copied from interface: MongoDatabase

Executes the given command in the context of the current database with a read preference of ReadPreference.primary().

Specified by:

runCommand in interface MongoDatabase

Parameters:

clientSession - the client session with which to associate this operation

command - the command to be run

callback - the callback that is passed the command result

runCommand

public void runCommand(ClientSession clientSession,
                       Bson command,
                       ReadPreference readPreference,
                       SingleResultCallback<Document> callback)

Description copied from interface: MongoDatabase

Executes the given command in the context of the current database with the given read preference.

Specified by:

runCommand in interface MongoDatabase

Parameters:

clientSession - the client session with which to associate this operation

command - the command to be run

readPreference - the ReadPreference to be used when executing the command

callback - the callback that is passed the command result

runCommand

public <TResult> void runCommand(ClientSession clientSession,
                                 Bson command,
                                 java.lang.Class<TResult> resultClass,
                                 SingleResultCallback<TResult> callback)

Description copied from interface: MongoDatabase

Executes the given command in the context of the current database with a read preference of ReadPreference.primary().

Specified by:

runCommand in interface MongoDatabase

Type Parameters:

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

Parameters:

clientSession - the client session with which to associate this operation

command - the command to be run

resultClass - the default class to cast any documents returned from the database into.

callback - the callback that is passed the command result

runCommand

public <TResult> void runCommand(ClientSession clientSession,
                                 Bson command,
                                 ReadPreference readPreference,
                                 java.lang.Class<TResult> resultClass,
                                 SingleResultCallback<TResult> callback)

Description copied from interface: MongoDatabase

Executes the given command in the context of the current database with the given read preference.

Specified by:

runCommand in interface MongoDatabase

Type Parameters:

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

Parameters:

clientSession - the client session with which to associate this operation

command - the command to be run

readPreference - the ReadPreference to be used when executing the command

resultClass - the default class to cast any documents returned from the database into.

callback - the callback that is passed the command result

executeCommand

private <TResult> void executeCommand(ClientSession clientSession,
                                      Bson command,
                                      ReadPreference readPreference,
                                      java.lang.Class<TResult> resultClass,
                                      SingleResultCallback<TResult> callback)

drop

public void drop(SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoDatabase

Drops this database.

Specified by:

drop in interface MongoDatabase

Parameters:

callback - the callback that is completed once the database has been dropped

drop

public void drop(ClientSession clientSession,
                 SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoDatabase

Drops this database.

Specified by:

drop in interface MongoDatabase

Parameters:

clientSession - the client session with which to associate this operation

callback - the callback that is completed once the database has been dropped

executeDrop

private void executeDrop(ClientSession clientSession,
                         SingleResultCallback<java.lang.Void> callback)

createCollection

public void createCollection(java.lang.String collectionName,
                             SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoDatabase

Create a new collection with the given name.

Specified by:

createCollection in interface MongoDatabase

Parameters:

collectionName - the name for the new collection to create

callback - the callback that is completed once the collection has been created

createCollection

public void createCollection(java.lang.String collectionName,
                             CreateCollectionOptions createCollectionOptions,
                             SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoDatabase

Create a new collection with the selected options

Specified by:

createCollection in interface MongoDatabase

Parameters:

collectionName - the name for the new collection to create

createCollectionOptions - various options for creating the collection

callback - the callback that is completed once the collection has been created

createCollection

public void createCollection(ClientSession clientSession,
                             java.lang.String collectionName,
                             SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoDatabase

Create a new collection with the given name.

Specified by:

createCollection in interface MongoDatabase

Parameters:

clientSession - the client session with which to associate this operation

collectionName - the name for the new collection to create

callback - the callback that is completed once the collection has been created

createCollection

public void createCollection(ClientSession clientSession,
                             java.lang.String collectionName,
                             CreateCollectionOptions options,
                             SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoDatabase

Create a new collection with the selected options

Specified by:

createCollection in interface MongoDatabase

Parameters:

clientSession - the client session with which to associate this operation

collectionName - the name for the new collection to create

options - various options for creating the collection

callback - the callback that is completed once the collection has been created

executeCreateCollection

private void executeCreateCollection(ClientSession clientSession,
                                     java.lang.String collectionName,
                                     CreateCollectionOptions options,
                                     SingleResultCallback<java.lang.Void> callback)

createView

public void createView(java.lang.String viewName,
                       java.lang.String viewOn,
                       java.util.List<? extends Bson> pipeline,
                       SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoDatabase

Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.

Specified by:

createView in interface MongoDatabase

Parameters:

viewName - the name of the view to create

viewOn - the backing collection/view for the view

pipeline - the pipeline that defines the view

callback - the callback that is completed once the collection has been created

createView

public void createView(java.lang.String viewName,
                       java.lang.String viewOn,
                       java.util.List<? extends Bson> pipeline,
                       CreateViewOptions createViewOptions,
                       SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoDatabase

Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.

Specified by:

createView in interface MongoDatabase

Parameters:

viewName - the name of the view to create

viewOn - the backing collection/view for the view

pipeline - the pipeline that defines the view

createViewOptions - various options for creating the view

callback - the callback that is completed once the collection has been created

createView

public void createView(ClientSession clientSession,
                       java.lang.String viewName,
                       java.lang.String viewOn,
                       java.util.List<? extends Bson> pipeline,
                       SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoDatabase

Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.

Specified by:

createView in interface MongoDatabase

Parameters:

clientSession - the client session with which to associate this operation

viewName - the name of the view to create

viewOn - the backing collection/view for the view

pipeline - the pipeline that defines the view

callback - the callback that is completed once the collection has been created

createView

public void createView(ClientSession clientSession,
                       java.lang.String viewName,
                       java.lang.String viewOn,
                       java.util.List<? extends Bson> pipeline,
                       CreateViewOptions createViewOptions,
                       SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoDatabase

Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.

Specified by:

createView in interface MongoDatabase

Parameters:

clientSession - the client session with which to associate this operation

viewName - the name of the view to create

viewOn - the backing collection/view for the view

pipeline - the pipeline that defines the view

createViewOptions - various options for creating the view

callback - the callback that is completed once the collection has been created

executeCreateView

private void executeCreateView(ClientSession clientSession,
                               java.lang.String viewName,
                               java.lang.String viewOn,
                               java.util.List<? extends Bson> pipeline,
                               CreateViewOptions createViewOptions,
                               SingleResultCallback<java.lang.Void> callback)

createBsonDocumentList

private java.util.List<BsonDocument> createBsonDocumentList(java.util.List<? extends Bson> pipeline)

toBsonDocument

private BsonDocument toBsonDocument(Bson document)