com.github.fakemongo

Class FongoConnection

java.lang.Object

com.github.fakemongo.FongoConnection

All Implemented Interfaces:

com.mongodb.binding.ReferenceCounted, com.mongodb.connection.Connection

public class FongoConnection
extends Object
implements com.mongodb.connection.Connection

Constructor Summary

Constructors

Constructor and Description
FongoConnection(Fongo fongo)

Method Summary

Modifier and Type	Method and Description
<T> T	command(String database, org.bson.BsonDocument command, boolean slaveOk, org.bson.FieldNameValidator fieldNameValidator, org.bson.codecs.Decoder<T> commandResultDecoder)
com.mongodb.WriteConcernResult	delete(com.mongodb.MongoNamespace namespace, boolean ordered, com.mongodb.WriteConcern writeConcern, List<com.mongodb.bulk.DeleteRequest> deletes)
com.mongodb.bulk.BulkWriteResult	deleteCommand(com.mongodb.MongoNamespace namespace, boolean ordered, com.mongodb.WriteConcern writeConcern, List<com.mongodb.bulk.DeleteRequest> deletes)
int	getCount()
com.mongodb.connection.ConnectionDescription	getDescription()
<T> com.mongodb.connection.QueryResult<T>	getMore(com.mongodb.MongoNamespace namespace, long cursorId, int numberToReturn, org.bson.codecs.Decoder<T> resultDecoder)
com.mongodb.WriteConcernResult	insert(com.mongodb.MongoNamespace namespace, boolean ordered, com.mongodb.WriteConcern writeConcern, List<com.mongodb.bulk.InsertRequest> inserts)
com.mongodb.bulk.BulkWriteResult	insertCommand(com.mongodb.MongoNamespace namespace, boolean ordered, com.mongodb.WriteConcern writeConcern, Boolean bypassDocumentValidation, List<com.mongodb.bulk.InsertRequest> inserts) Insert the documents using the insert command.
com.mongodb.bulk.BulkWriteResult	insertCommand(com.mongodb.MongoNamespace namespace, boolean ordered, com.mongodb.WriteConcern writeConcern, List<com.mongodb.bulk.InsertRequest> inserts)
void	killCursor(List<Long> cursors)
void	killCursor(com.mongodb.MongoNamespace namespace, List<Long> cursors)
<T> com.mongodb.connection.QueryResult<T>	query(com.mongodb.MongoNamespace namespace, org.bson.BsonDocument queryDocument, org.bson.BsonDocument fields, int numberToReturn, int skip, boolean slaveOk, boolean tailableCursor, boolean awaitData, boolean noCursorTimeout, boolean partial, boolean oplogReplay, org.bson.codecs.Decoder<T> resultDecoder)
<T> com.mongodb.connection.QueryResult<T>	query(com.mongodb.MongoNamespace namespace, org.bson.BsonDocument queryDocument, org.bson.BsonDocument fields, int skip, int limit, int batchSize, boolean slaveOk, boolean tailableCursor, boolean awaitData, boolean noCursorTimeout, boolean partial, boolean oplogReplay, org.bson.codecs.Decoder<T> resultDecoder)
void	release()
com.mongodb.connection.Connection	retain()
com.mongodb.WriteConcernResult	update(com.mongodb.MongoNamespace namespace, boolean ordered, com.mongodb.WriteConcern writeConcern, List<com.mongodb.bulk.UpdateRequest> updates)
com.mongodb.bulk.BulkWriteResult	updateCommand(com.mongodb.MongoNamespace namespace, boolean ordered, com.mongodb.WriteConcern writeConcern, Boolean bypassDocumentValidation, List<com.mongodb.bulk.UpdateRequest> updates) Update the documents using the update command.
com.mongodb.bulk.BulkWriteResult	updateCommand(com.mongodb.MongoNamespace namespace, boolean ordered, com.mongodb.WriteConcern writeConcern, List<com.mongodb.bulk.UpdateRequest> updates) Update the documents using the update command.

Methods inherited from class java.lang.Object

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

Constructor Detail

FongoConnection

public FongoConnection(Fongo fongo)

Method Detail

retain

public com.mongodb.connection.Connection retain()

Specified by:

retain in interface com.mongodb.binding.ReferenceCounted

Specified by:

retain in interface com.mongodb.connection.Connection

getDescription

public com.mongodb.connection.ConnectionDescription getDescription()

Specified by:

getDescription in interface com.mongodb.connection.Connection

insert

public com.mongodb.WriteConcernResult insert(com.mongodb.MongoNamespace namespace,
                                             boolean ordered,
                                             com.mongodb.WriteConcern writeConcern,
                                             List<com.mongodb.bulk.InsertRequest> inserts)

Specified by:

insert in interface com.mongodb.connection.Connection

update

public com.mongodb.WriteConcernResult update(com.mongodb.MongoNamespace namespace,
                                             boolean ordered,
                                             com.mongodb.WriteConcern writeConcern,
                                             List<com.mongodb.bulk.UpdateRequest> updates)

Specified by:

update in interface com.mongodb.connection.Connection

delete

public com.mongodb.WriteConcernResult delete(com.mongodb.MongoNamespace namespace,
                                             boolean ordered,
                                             com.mongodb.WriteConcern writeConcern,
                                             List<com.mongodb.bulk.DeleteRequest> deletes)

Specified by:

delete in interface com.mongodb.connection.Connection

insertCommand

public com.mongodb.bulk.BulkWriteResult insertCommand(com.mongodb.MongoNamespace namespace,
                                                      boolean ordered,
                                                      com.mongodb.WriteConcern writeConcern,
                                                      List<com.mongodb.bulk.InsertRequest> inserts)

Specified by:

insertCommand in interface com.mongodb.connection.Connection

insertCommand

public com.mongodb.bulk.BulkWriteResult insertCommand(com.mongodb.MongoNamespace namespace,
                                                      boolean ordered,
                                                      com.mongodb.WriteConcern writeConcern,
                                                      Boolean bypassDocumentValidation,
                                                      List<com.mongodb.bulk.InsertRequest> inserts)

Insert the documents using the insert command.

Specified by:

insertCommand in interface com.mongodb.connection.Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

bypassDocumentValidation - the bypassDocumentValidation flag

inserts - the inserts

Returns:

the bulk write result

Since:

3.2

updateCommand

public com.mongodb.bulk.BulkWriteResult updateCommand(com.mongodb.MongoNamespace namespace,
                                                      boolean ordered,
                                                      com.mongodb.WriteConcern writeConcern,
                                                      List<com.mongodb.bulk.UpdateRequest> updates)

Update the documents using the update command.

Specified by:

updateCommand in interface com.mongodb.connection.Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

updates - the updates

Returns:

the bulk write result

Since:

3.2

updateCommand

public com.mongodb.bulk.BulkWriteResult updateCommand(com.mongodb.MongoNamespace namespace,
                                                      boolean ordered,
                                                      com.mongodb.WriteConcern writeConcern,
                                                      Boolean bypassDocumentValidation,
                                                      List<com.mongodb.bulk.UpdateRequest> updates)

Update the documents using the update command.

Specified by:

updateCommand in interface com.mongodb.connection.Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

bypassDocumentValidation - the bypassDocumentValidation flag

updates - the updates

Returns:

the bulk write result

Since:

3.2

deleteCommand

public com.mongodb.bulk.BulkWriteResult deleteCommand(com.mongodb.MongoNamespace namespace,
                                                      boolean ordered,
                                                      com.mongodb.WriteConcern writeConcern,
                                                      List<com.mongodb.bulk.DeleteRequest> deletes)

Specified by:

deleteCommand in interface com.mongodb.connection.Connection

command

public <T> T command(String database,
                     org.bson.BsonDocument command,
                     boolean slaveOk,
                     org.bson.FieldNameValidator fieldNameValidator,
                     org.bson.codecs.Decoder<T> commandResultDecoder)

Specified by:

command in interface com.mongodb.connection.Connection

query

public <T> com.mongodb.connection.QueryResult<T> query(com.mongodb.MongoNamespace namespace,
                                                       org.bson.BsonDocument queryDocument,
                                                       org.bson.BsonDocument fields,
                                                       int numberToReturn,
                                                       int skip,
                                                       boolean slaveOk,
                                                       boolean tailableCursor,
                                                       boolean awaitData,
                                                       boolean noCursorTimeout,
                                                       boolean partial,
                                                       boolean oplogReplay,
                                                       org.bson.codecs.Decoder<T> resultDecoder)

Specified by:

query in interface com.mongodb.connection.Connection

query

public <T> com.mongodb.connection.QueryResult<T> query(com.mongodb.MongoNamespace namespace,
                                                       org.bson.BsonDocument queryDocument,
                                                       org.bson.BsonDocument fields,
                                                       int skip,
                                                       int limit,
                                                       int batchSize,
                                                       boolean slaveOk,
                                                       boolean tailableCursor,
                                                       boolean awaitData,
                                                       boolean noCursorTimeout,
                                                       boolean partial,
                                                       boolean oplogReplay,
                                                       org.bson.codecs.Decoder<T> resultDecoder)

Specified by:

query in interface com.mongodb.connection.Connection

getMore

public <T> com.mongodb.connection.QueryResult<T> getMore(com.mongodb.MongoNamespace namespace,
                                                         long cursorId,
                                                         int numberToReturn,
                                                         org.bson.codecs.Decoder<T> resultDecoder)

Specified by:

getMore in interface com.mongodb.connection.Connection

killCursor

public void killCursor(List<Long> cursors)

Specified by:

killCursor in interface com.mongodb.connection.Connection

killCursor

public void killCursor(com.mongodb.MongoNamespace namespace,
                       List<Long> cursors)

Specified by:

killCursor in interface com.mongodb.connection.Connection

getCount

public int getCount()

Specified by:

getCount in interface com.mongodb.binding.ReferenceCounted

release

public void release()

Specified by:

release in interface com.mongodb.binding.ReferenceCounted