com.github.fakemongo.async

Class FongoAsync

java.lang.Object

com.github.fakemongo.async.FongoAsync

All Implemented Interfaces:

com.mongodb.operation.AsyncOperationExecutor

public class FongoAsync
extends Object
implements com.mongodb.operation.AsyncOperationExecutor

Faked out version of com.mongodb.client.async.Mongo

This class doesn't implement Mongo, but does provide the same basic interface

Usage:

 
 FongoAsync fongo = new FongoAsync("test server");
 // if you need an instance of com.mongodb.async.MongoClient
 com.mongodb.async.MongoClient mongo = fongo.getMongoClient();
 
 

Author:

twillouer

Field Summary

Fields

Modifier and Type	Field and Description
static com.mongodb.connection.ServerVersion	DEFAULT_SERVER_VERSION

Constructor Summary

Constructors

Constructor and Description
FongoAsync(String name)
FongoAsync(String name, com.mongodb.connection.ServerVersion serverVersion)
FongoAsync(String name, com.mongodb.connection.ServerVersion serverVersion, org.bson.codecs.configuration.CodecRegistry codecRegistry)

Method Summary

Modifier and Type	Method and Description
void	dropDatabase(String dbName) Drop db and all data from memory
<T> void	execute(com.mongodb.operation.AsyncReadOperation<T> operation, com.mongodb.ReadPreference readPreference, com.mongodb.session.ClientSession session, com.mongodb.async.SingleResultCallback<T> callback)
<T> void	execute(com.mongodb.operation.AsyncReadOperation<T> operation, com.mongodb.ReadPreference readPreference, com.mongodb.async.SingleResultCallback<T> callback) Execute the read operation with the given read preference.
<T> void	execute(com.mongodb.operation.AsyncWriteOperation<T> operation, com.mongodb.session.ClientSession session, com.mongodb.async.SingleResultCallback<T> callback)
<T> void	execute(com.mongodb.operation.AsyncWriteOperation<T> operation, com.mongodb.async.SingleResultCallback<T> callback) Execute the write operation.
com.mongodb.async.client.FongoAsyncMongoDatabase	getDatabase(String databaseName) equivalent to getDatabase in driver multiple calls to this method return the same MongoDatabase instance
List<String>	getDatabaseNames() Get database names that have been used
Fongo	getFongo()
com.mongodb.async.client.MongoClient	getMongo() A mocked out instance of com.mongodb.Mongo All methods calls are intercepted and execute associated Fongo method
com.mongodb.ServerAddress	getServerAddress() This will always be localhost:27017
com.mongodb.connection.ServerVersion	getServerVersion()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SERVER_VERSION

public static final com.mongodb.connection.ServerVersion DEFAULT_SERVER_VERSION

Constructor Detail

FongoAsync

public FongoAsync(String name)

Parameters:

name - Used only for a nice toString in case you have multiple instances

FongoAsync

public FongoAsync(String name,
                  com.mongodb.connection.ServerVersion serverVersion)

Parameters:

name - Used only for a nice toString in case you have multiple instances

serverVersion - version of the server to use for fongo.

FongoAsync

public FongoAsync(String name,
                  com.mongodb.connection.ServerVersion serverVersion,
                  org.bson.codecs.configuration.CodecRegistry codecRegistry)

Parameters:

name - Used only for a nice toString in case you have multiple instances

serverVersion - version of the server to use for fongo.

codecRegistry - the codec registry used by fongo.

Method Detail

getDatabase

public com.mongodb.async.client.FongoAsyncMongoDatabase getDatabase(String databaseName)

equivalent to getDatabase in driver multiple calls to this method return the same MongoDatabase instance

Parameters:

databaseName - name of the db.

Returns:

the MongoDatabase associated to this name.

getDatabaseNames

public List<String> getDatabaseNames()

Get database names that have been used

Returns:

database names.

dropDatabase

public void dropDatabase(String dbName)

Drop db and all data from memory

Parameters:

dbName - name of the database.

getServerAddress

public com.mongodb.ServerAddress getServerAddress()

This will always be localhost:27017

Returns:

the server address.

getMongo

public com.mongodb.async.client.MongoClient getMongo()

A mocked out instance of com.mongodb.Mongo All methods calls are intercepted and execute associated Fongo method

Returns:

the mongo client

toString

public String toString()

Overrides:

toString in class Object

execute

public <T> void execute(com.mongodb.operation.AsyncReadOperation<T> operation,
                        com.mongodb.ReadPreference readPreference,
                        com.mongodb.async.SingleResultCallback<T> callback)

Execute the read operation with the given read preference.

Specified by:

execute in interface com.mongodb.operation.AsyncOperationExecutor

Parameters:

operation - the read operation.

readPreference - the read preference.

callback - the callback to be called when the operation has been executed

execute

public <T> void execute(com.mongodb.operation.AsyncReadOperation<T> operation,
                        com.mongodb.ReadPreference readPreference,
                        com.mongodb.session.ClientSession session,
                        com.mongodb.async.SingleResultCallback<T> callback)

Specified by:

execute in interface com.mongodb.operation.AsyncOperationExecutor

execute

public <T> void execute(com.mongodb.operation.AsyncWriteOperation<T> operation,
                        com.mongodb.async.SingleResultCallback<T> callback)

Execute the write operation.

Specified by:

execute in interface com.mongodb.operation.AsyncOperationExecutor

Parameters:

operation - the write operation.

callback - the callback to be called when the operation has been executed

execute

public <T> void execute(com.mongodb.operation.AsyncWriteOperation<T> operation,
                        com.mongodb.session.ClientSession session,
                        com.mongodb.async.SingleResultCallback<T> callback)

Specified by:

execute in interface com.mongodb.operation.AsyncOperationExecutor

getServerVersion

public com.mongodb.connection.ServerVersion getServerVersion()

getFongo

public Fongo getFongo()