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

Methods

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, List<com.mongodb.bulk.InsertRequest> inserts)
void	killCursor(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)
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, List<com.mongodb.bulk.UpdateRequest> updates)

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

updateCommand

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

Specified by:

updateCommand in interface com.mongodb.connection.Connection

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

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

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