com.eightkdata.mongowp.client.wrapper

Class MongoConnectionWrapper

java.lang.Object

com.eightkdata.mongowp.client.wrapper.MongoConnectionWrapper

All Implemented Interfaces:

MongoConnection, Closeable, AutoCloseable

public class MongoConnectionWrapper
extends Object
implements MongoConnection

Nested Class Summary

Nested classes/interfaces inherited from interface com.eightkdata.mongowp.client.core.MongoConnection

MongoConnection.CorrectRemoteCommandResponse<R>, MongoConnection.ErroneousRemoteCommandResponse<R>, MongoConnection.FromExceptionRemoteCommandRequest<R>, MongoConnection.RemoteCommandResponse<R>

Constructor Summary

Constructors

Constructor and Description
MongoConnectionWrapper(org.bson.codecs.configuration.CodecRegistry codecRegistry, MongoClientWrapper owner)

Method Summary

Modifier and Type	Method and Description
void	asyncDelete(String database, String collection, boolean singleRemove, com.eightkdata.mongowp.bson.BsonDocument selector)
void	asyncInsert(String database, String collection, boolean continueOnError, List<? extends com.eightkdata.mongowp.bson.BsonDocument> docsToInsert)
void	asyncKillCursors(Iterable<Long> cursors)
void	asyncKillCursors(long[] cursors)
void	asyncUpdate(String database, String collection, com.eightkdata.mongowp.bson.BsonDocument selector, com.eightkdata.mongowp.bson.BsonDocument update, boolean upsert, boolean multiUpdate)
void	close()
<A,R> MongoConnection.RemoteCommandResponse<R>	execute(com.eightkdata.mongowp.server.api.Command<? super A,R> command, String database, boolean isSlaveOk, A arg)
<A,R> MongoConnection.RemoteCommandResponse<R>	execute(com.eightkdata.mongowp.server.api.Command<? super A,R> command, String database, boolean isSlaveOk, A arg, Duration timeout)
MongoClient	getClientOwner()
boolean	isClosed()
boolean	isRemote()
com.eightkdata.mongowp.server.api.pojos.MongoCursor<com.eightkdata.mongowp.bson.BsonDocument>	query(String database, String collection, com.eightkdata.mongowp.bson.BsonDocument query, int numberToSkip, int numberToReturn, com.eightkdata.mongowp.messages.request.QueryMessage.QueryOptions queryOptions, com.eightkdata.mongowp.bson.BsonDocument sortBy, com.eightkdata.mongowp.bson.BsonDocument projection)

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoConnectionWrapper

public MongoConnectionWrapper(org.bson.codecs.configuration.CodecRegistry codecRegistry,
                              MongoClientWrapper owner)

Method Detail

getClientOwner

public MongoClient getClientOwner()

Specified by:

getClientOwner in interface MongoConnection

query

public com.eightkdata.mongowp.server.api.pojos.MongoCursor<com.eightkdata.mongowp.bson.BsonDocument> query(String database,
                                                                                                           String collection,
                                                                                                           com.eightkdata.mongowp.bson.BsonDocument query,
                                                                                                           int numberToSkip,
                                                                                                           int numberToReturn,
                                                                                                           com.eightkdata.mongowp.messages.request.QueryMessage.QueryOptions queryOptions,
                                                                                                           com.eightkdata.mongowp.bson.BsonDocument sortBy,
                                                                                                           com.eightkdata.mongowp.bson.BsonDocument projection)
                                                                                                    throws com.eightkdata.mongowp.exceptions.MongoException

Specified by:

query in interface MongoConnection

Throws:

com.eightkdata.mongowp.exceptions.MongoException

asyncKillCursors

public void asyncKillCursors(Iterable<Long> cursors)
                      throws com.eightkdata.mongowp.exceptions.MongoException

Specified by:

asyncKillCursors in interface MongoConnection

Throws:

com.eightkdata.mongowp.exceptions.MongoException

asyncKillCursors

public void asyncKillCursors(long[] cursors)
                      throws com.eightkdata.mongowp.exceptions.MongoException

Specified by:

asyncKillCursors in interface MongoConnection

Throws:

com.eightkdata.mongowp.exceptions.MongoException

asyncInsert

public void asyncInsert(String database,
                        String collection,
                        boolean continueOnError,
                        List<? extends com.eightkdata.mongowp.bson.BsonDocument> docsToInsert)
                 throws com.eightkdata.mongowp.exceptions.MongoException

Specified by:

asyncInsert in interface MongoConnection

Throws:

com.eightkdata.mongowp.exceptions.MongoException

asyncUpdate

public void asyncUpdate(String database,
                        String collection,
                        com.eightkdata.mongowp.bson.BsonDocument selector,
                        com.eightkdata.mongowp.bson.BsonDocument update,
                        boolean upsert,
                        boolean multiUpdate)
                 throws com.eightkdata.mongowp.exceptions.MongoException

Specified by:

asyncUpdate in interface MongoConnection

Throws:

com.eightkdata.mongowp.exceptions.MongoException

asyncDelete

public void asyncDelete(String database,
                        String collection,
                        boolean singleRemove,
                        com.eightkdata.mongowp.bson.BsonDocument selector)
                 throws com.eightkdata.mongowp.exceptions.MongoException

Specified by:

asyncDelete in interface MongoConnection

Throws:

com.eightkdata.mongowp.exceptions.MongoException

execute

public <A,R> MongoConnection.RemoteCommandResponse<R> execute(com.eightkdata.mongowp.server.api.Command<? super A,R> command,
                                                              String database,
                                                              boolean isSlaveOk,
                                                              A arg)

Specified by:

execute in interface MongoConnection

execute

public <A,R> MongoConnection.RemoteCommandResponse<R> execute(com.eightkdata.mongowp.server.api.Command<? super A,R> command,
                                                              String database,
                                                              boolean isSlaveOk,
                                                              A arg,
                                                              Duration timeout)

Specified by:

execute in interface MongoConnection

isClosed

public boolean isClosed()

Specified by:

isClosed in interface MongoConnection

isRemote

public boolean isRemote()

Specified by:

isRemote in interface MongoConnection

close

public void close()

Specified by:

close in interface MongoConnection

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable