com.kdata.mongowp.client.wrapper

Class MongoConnectionWrapper

java.lang.Object

com.kdata.mongowp.client.wrapper.MongoConnectionWrapper

All Implemented Interfaces:

MongoConnection, Closeable, AutoCloseable

public class MongoConnectionWrapper
extends Object
implements MongoConnection

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	asyncDelete(String database, String collection, EnumSet<com.eightkdata.mongowp.messages.request.DeleteMessage.Flag> flags, org.bson.BsonDocument selector)
void	asyncInsert(String database, String collection, boolean continueOnError, List<? extends org.bson.BsonDocument> docsToInsert)
void	asyncKillCursors(Iterable<Long> cursors)
void	asyncKillCursors(long[] cursors)
void	asyncUpdate(String database, String collection, EnumSet<com.eightkdata.mongowp.messages.request.UpdateMessage.Flag> flags, org.bson.BsonDocument selector, org.bson.BsonDocument update)
void	close()
<Arg,Result> Result	execute(com.eightkdata.mongowp.mongoserver.api.safe.Command<? super Arg,Result> command, String database, boolean isSlaveOk, Arg arg)
MongoClient	getClientOwner()
boolean	isRemote()
com.eightkdata.mongowp.mongoserver.api.safe.pojos.MongoCursor<org.bson.BsonDocument>	query(String database, String collection, EnumSet<com.eightkdata.mongowp.messages.request.QueryMessage.Flag> flags, org.bson.BsonDocument query, int numberToSkip, int numberToReturn, org.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.mongoserver.api.safe.pojos.MongoCursor<org.bson.BsonDocument> query(String database,
                                                                                         String collection,
                                                                                         EnumSet<com.eightkdata.mongowp.messages.request.QueryMessage.Flag> flags,
                                                                                         org.bson.BsonDocument query,
                                                                                         int numberToSkip,
                                                                                         int numberToReturn,
                                                                                         org.bson.BsonDocument projection)
                                                                                           throws com.eightkdata.mongowp.mongoserver.protocol.exceptions.MongoException

Specified by:

query in interface MongoConnection

Throws:

com.eightkdata.mongowp.mongoserver.protocol.exceptions.MongoException

asyncKillCursors

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

Specified by:

asyncKillCursors in interface MongoConnection

Throws:

com.eightkdata.mongowp.mongoserver.protocol.exceptions.MongoException

asyncKillCursors

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

Specified by:

asyncKillCursors in interface MongoConnection

Throws:

com.eightkdata.mongowp.mongoserver.protocol.exceptions.MongoException

asyncInsert

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

Specified by:

asyncInsert in interface MongoConnection

Throws:

com.eightkdata.mongowp.mongoserver.protocol.exceptions.MongoException

asyncUpdate

public void asyncUpdate(String database,
               String collection,
               EnumSet<com.eightkdata.mongowp.messages.request.UpdateMessage.Flag> flags,
               org.bson.BsonDocument selector,
               org.bson.BsonDocument update)
                 throws com.eightkdata.mongowp.mongoserver.protocol.exceptions.MongoException

Specified by:

asyncUpdate in interface MongoConnection

Throws:

com.eightkdata.mongowp.mongoserver.protocol.exceptions.MongoException

asyncDelete

public void asyncDelete(String database,
               String collection,
               EnumSet<com.eightkdata.mongowp.messages.request.DeleteMessage.Flag> flags,
               org.bson.BsonDocument selector)
                 throws com.eightkdata.mongowp.mongoserver.protocol.exceptions.MongoException

Specified by:

asyncDelete in interface MongoConnection

Throws:

com.eightkdata.mongowp.mongoserver.protocol.exceptions.MongoException

execute

public <Arg,Result> Result execute(com.eightkdata.mongowp.mongoserver.api.safe.Command<? super Arg,Result> command,
                          String database,
                          boolean isSlaveOk,
                          Arg arg)
               throws com.eightkdata.mongowp.mongoserver.protocol.exceptions.MongoException

Specified by:

execute in interface MongoConnection

Throws:

com.eightkdata.mongowp.mongoserver.protocol.exceptions.MongoException

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