Package com.mongodb.internal.connection

Class DefaultServerConnection

java.lang.Object

com.mongodb.internal.connection.DefaultServerConnection

All Implemented Interfaces:

ReferenceCounted, AsyncConnection, Connection

public class DefaultServerConnection
extends java.lang.Object
implements Connection, AsyncConnection

Constructor Summary

Constructors

Constructor	Description
DefaultServerConnection(InternalConnection wrapped, ProtocolExecutor protocolExecutor, ClusterConnectionMode clusterConnectionMode)

Method Summary

Modifier and Type	Method	Description
<T> T	command(java.lang.String database, BsonDocument command, boolean slaveOk, FieldNameValidator fieldNameValidator, Decoder<T> commandResultDecoder)	Execute the command.
<T> T	command(java.lang.String database, BsonDocument command, FieldNameValidator fieldNameValidator, ReadPreference readPreference, Decoder<T> commandResultDecoder, SessionContext sessionContext)	Execute the command.
<T> T	command(java.lang.String database, BsonDocument command, FieldNameValidator commandFieldNameValidator, ReadPreference readPreference, Decoder<T> commandResultDecoder, SessionContext sessionContext, boolean responseExpected, SplittablePayload payload, FieldNameValidator payloadFieldNameValidator)	Executes the command, consuming as much of the SplittablePayload as possible.
<T> void	commandAsync(java.lang.String database, BsonDocument command, boolean slaveOk, FieldNameValidator fieldNameValidator, Decoder<T> commandResultDecoder, SingleResultCallback<T> callback)	Execute the command asynchronously.
<T> void	commandAsync(java.lang.String database, BsonDocument command, FieldNameValidator commandFieldNameValidator, ReadPreference readPreference, Decoder<T> commandResultDecoder, SessionContext sessionContext, boolean responseExpected, SplittablePayload payload, FieldNameValidator payloadFieldNameValidator, SingleResultCallback<T> callback)	Executes the command, consuming as much of the SplittablePayload as possible.
<T> void	commandAsync(java.lang.String database, BsonDocument command, FieldNameValidator fieldNameValidator, ReadPreference readPreference, Decoder<T> commandResultDecoder, SessionContext sessionContext, SingleResultCallback<T> callback)	Execute the command.
WriteConcernResult	delete(MongoNamespace namespace, boolean ordered, DeleteRequest deleteRequest)	Delete the documents using the delete wire protocol and apply the write concern.
void	deleteAsync(MongoNamespace namespace, boolean ordered, DeleteRequest deleteRequest, SingleResultCallback<WriteConcernResult> callback)	Delete the documents using the delete wire protocol and apply the write concern asynchronously.
int	getCount()	Gets the current reference count, which starts at 0.
ConnectionDescription	getDescription()	Gets the description of the connection.
<T> QueryResult<T>	getMore(MongoNamespace namespace, long cursorId, int numberToReturn, Decoder<T> resultDecoder)	Get more result documents from a cursor.
<T> void	getMoreAsync(MongoNamespace namespace, long cursorId, int numberToReturn, Decoder<T> resultDecoder, SingleResultCallback<QueryResult<T>> callback)	Get more result documents from a cursor asynchronously.
WriteConcernResult	insert(MongoNamespace namespace, boolean ordered, InsertRequest insertRequest)	Insert the documents using the insert wire protocol and apply the write concern.
void	insertAsync(MongoNamespace namespace, boolean ordered, InsertRequest insertRequest, SingleResultCallback<WriteConcernResult> callback)	Insert the documents using the insert wire protocol and apply the write concern asynchronously.
void	killCursor(MongoNamespace namespace, java.util.List<java.lang.Long> cursors)	Kills the given list of cursors.
void	killCursor(java.util.List<java.lang.Long> cursors)	Kills the given list of cursors.
void	killCursorAsync(MongoNamespace namespace, java.util.List<java.lang.Long> cursors, SingleResultCallback<java.lang.Void> callback)	Asynchronously Kills the given list of cursors.
void	killCursorAsync(java.util.List<java.lang.Long> cursors, SingleResultCallback<java.lang.Void> callback)	Asynchronously Kills the given list of cursors.
<T> QueryResult<T>	query(MongoNamespace namespace, BsonDocument queryDocument, BsonDocument fields, int numberToReturn, int skip, boolean slaveOk, boolean tailableCursor, boolean awaitData, boolean noCursorTimeout, boolean partial, boolean oplogReplay, Decoder<T> resultDecoder)	Execute the query.
<T> QueryResult<T>	query(MongoNamespace namespace, BsonDocument queryDocument, BsonDocument fields, int skip, int limit, int batchSize, boolean slaveOk, boolean tailableCursor, boolean awaitData, boolean noCursorTimeout, boolean partial, boolean oplogReplay, Decoder<T> resultDecoder)	Execute the query.
<T> void	queryAsync(MongoNamespace namespace, BsonDocument queryDocument, BsonDocument fields, int numberToReturn, int skip, boolean slaveOk, boolean tailableCursor, boolean awaitData, boolean noCursorTimeout, boolean partial, boolean oplogReplay, Decoder<T> resultDecoder, SingleResultCallback<QueryResult<T>> callback)	Execute the query asynchronously.
<T> void	queryAsync(MongoNamespace namespace, BsonDocument queryDocument, BsonDocument fields, int skip, int limit, int batchSize, boolean slaveOk, boolean tailableCursor, boolean awaitData, boolean noCursorTimeout, boolean partial, boolean oplogReplay, Decoder<T> resultDecoder, SingleResultCallback<QueryResult<T>> callback)	Execute the query asynchronously.
void	release()	Release a reference to this object.
DefaultServerConnection	retain()	Retain an additional reference to this object.
WriteConcernResult	update(MongoNamespace namespace, boolean ordered, UpdateRequest updateRequest)	Update the documents using the update wire protocol and apply the write concern.
void	updateAsync(MongoNamespace namespace, boolean ordered, UpdateRequest updateRequest, SingleResultCallback<WriteConcernResult> callback)	Update the documents using the update wire protocol and apply the write concern asynchronously.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.mongodb.binding.ReferenceCounted

getCount

Constructor Detail

DefaultServerConnection

public DefaultServerConnection(InternalConnection wrapped,
                               ProtocolExecutor protocolExecutor,
                               ClusterConnectionMode clusterConnectionMode)

Method Detail

retain

public DefaultServerConnection retain()

Description copied from interface: ReferenceCounted

Retain an additional reference to this object. All retained references must be released, or there will be a leak.

Specified by:

retain in interface AsyncConnection

Specified by:

retain in interface Connection

Specified by:

retain in interface ReferenceCounted

Returns:

this

release

public void release()

Description copied from interface: ReferenceCounted

Release a reference to this object.

Specified by:

release in interface ReferenceCounted

getDescription

public ConnectionDescription getDescription()

Description copied from interface: Connection

Gets the description of the connection.

Specified by:

getDescription in interface AsyncConnection

Specified by:

getDescription in interface Connection

Returns:

the connection description

insert

public WriteConcernResult insert(MongoNamespace namespace,
                                 boolean ordered,
                                 InsertRequest insertRequest)

Description copied from interface: Connection

Insert the documents using the insert wire protocol and apply the write concern.

Specified by:

insert in interface Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

insertRequest - the insert request

Returns:

the write concern result

insertAsync

public void insertAsync(MongoNamespace namespace,
                        boolean ordered,
                        InsertRequest insertRequest,
                        SingleResultCallback<WriteConcernResult> callback)

Description copied from interface: AsyncConnection

Insert the documents using the insert wire protocol and apply the write concern asynchronously.

Specified by:

insertAsync in interface AsyncConnection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

insertRequest - the insert request

callback - the callback to be passed the write result

update

public WriteConcernResult update(MongoNamespace namespace,
                                 boolean ordered,
                                 UpdateRequest updateRequest)

Description copied from interface: Connection

Update the documents using the update wire protocol and apply the write concern.

Specified by:

update in interface Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

updateRequest - the update request

Returns:

the write concern result

updateAsync

public void updateAsync(MongoNamespace namespace,
                        boolean ordered,
                        UpdateRequest updateRequest,
                        SingleResultCallback<WriteConcernResult> callback)

Description copied from interface: AsyncConnection

Update the documents using the update wire protocol and apply the write concern asynchronously.

Specified by:

updateAsync in interface AsyncConnection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

updateRequest - the update request

callback - the callback to be passed the write result

delete

public WriteConcernResult delete(MongoNamespace namespace,
                                 boolean ordered,
                                 DeleteRequest deleteRequest)

Description copied from interface: Connection

Delete the documents using the delete wire protocol and apply the write concern.

Specified by:

delete in interface Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

deleteRequest - the delete request

Returns:

the write concern result

deleteAsync

public void deleteAsync(MongoNamespace namespace,
                        boolean ordered,
                        DeleteRequest deleteRequest,
                        SingleResultCallback<WriteConcernResult> callback)

Description copied from interface: AsyncConnection

Delete the documents using the delete wire protocol and apply the write concern asynchronously.

Specified by:

deleteAsync in interface AsyncConnection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

deleteRequest - the delete request

callback - the callback to be passed the write result

command

public <T> T command(java.lang.String database,
                     BsonDocument command,
                     boolean slaveOk,
                     FieldNameValidator fieldNameValidator,
                     Decoder<T> commandResultDecoder)

Description copied from interface: Connection

Execute the command.

Specified by:

command in interface Connection

Type Parameters:

T - the type of the result

Parameters:

database - the database to execute the command in

command - the command document

slaveOk - whether the command can run on a secondary

fieldNameValidator - the field name validator for the command document

commandResultDecoder - the decoder for the result

Returns:

the command result

command

public <T> T command(java.lang.String database,
                     BsonDocument command,
                     FieldNameValidator fieldNameValidator,
                     ReadPreference readPreference,
                     Decoder<T> commandResultDecoder,
                     SessionContext sessionContext)

Description copied from interface: Connection

Execute the command.

Specified by:

command in interface Connection

Type Parameters:

T - the type of the result

Parameters:

database - the database to execute the command in

command - the command document

fieldNameValidator - the field name validator for the command document

readPreference - the read preference that was applied to get this connection, or null if this is a write operation

commandResultDecoder - the decoder for the result

sessionContext - the session context

Returns:

the command result

command

public <T> T command(java.lang.String database,
                     BsonDocument command,
                     FieldNameValidator commandFieldNameValidator,
                     ReadPreference readPreference,
                     Decoder<T> commandResultDecoder,
                     SessionContext sessionContext,
                     boolean responseExpected,
                     SplittablePayload payload,
                     FieldNameValidator payloadFieldNameValidator)

Description copied from interface: Connection

Executes the command, consuming as much of the SplittablePayload as possible.

Specified by:

command in interface Connection

Type Parameters:

T - the type of the result

Parameters:

database - the database to execute the command in

command - the command document

commandFieldNameValidator - the field name validator for the command document

readPreference - the read preference that was applied to get this connection, or null if this is a write operation

commandResultDecoder - the decoder for the result

sessionContext - the session context

responseExpected - true if a response from the server is expected

payload - the splittable payload to incorporate with the command

payloadFieldNameValidator - the field name validator for the payload documents

Returns:

the command result

commandAsync

public <T> void commandAsync(java.lang.String database,
                             BsonDocument command,
                             boolean slaveOk,
                             FieldNameValidator fieldNameValidator,
                             Decoder<T> commandResultDecoder,
                             SingleResultCallback<T> callback)

Description copied from interface: AsyncConnection

Execute the command asynchronously.

Specified by:

commandAsync in interface AsyncConnection

Type Parameters:

T - the type of the result

Parameters:

database - the database to execute the command in

command - the command document

slaveOk - whether the command can run on a secondary

fieldNameValidator - the field name validator for the command document

commandResultDecoder - the decoder for the result

callback - the callback to be passed the command result

commandAsync

public <T> void commandAsync(java.lang.String database,
                             BsonDocument command,
                             FieldNameValidator fieldNameValidator,
                             ReadPreference readPreference,
                             Decoder<T> commandResultDecoder,
                             SessionContext sessionContext,
                             SingleResultCallback<T> callback)

Description copied from interface: AsyncConnection

Execute the command.

Specified by:

commandAsync in interface AsyncConnection

Type Parameters:

T - the type of the result

Parameters:

database - the database to execute the command in

command - the command document

fieldNameValidator - the field name validator for the command document

readPreference - the read preference that was applied to get this connection, or null if this is a write operation

commandResultDecoder - the decoder for the result

sessionContext - the session context

callback - the callback to be passed the write result

commandAsync

public <T> void commandAsync(java.lang.String database,
                             BsonDocument command,
                             FieldNameValidator commandFieldNameValidator,
                             ReadPreference readPreference,
                             Decoder<T> commandResultDecoder,
                             SessionContext sessionContext,
                             boolean responseExpected,
                             SplittablePayload payload,
                             FieldNameValidator payloadFieldNameValidator,
                             SingleResultCallback<T> callback)

Description copied from interface: AsyncConnection

Executes the command, consuming as much of the SplittablePayload as possible.

Specified by:

commandAsync in interface AsyncConnection

Type Parameters:

T - the type of the result

Parameters:

database - the database to execute the command in

command - the command document

commandFieldNameValidator - the field name validator for the command document

readPreference - the read preference that was applied to get this connection, or null if this is a write operation

commandResultDecoder - the decoder for the result

sessionContext - the session context

responseExpected - true if a response from the server is expected

payload - the splittable payload to incorporate with the command

payloadFieldNameValidator - the field name validator for the payload documents

callback - the callback to be passed the write result

query

public <T> QueryResult<T> query(MongoNamespace namespace,
                                BsonDocument queryDocument,
                                BsonDocument fields,
                                int numberToReturn,
                                int skip,
                                boolean slaveOk,
                                boolean tailableCursor,
                                boolean awaitData,
                                boolean noCursorTimeout,
                                boolean partial,
                                boolean oplogReplay,
                                Decoder<T> resultDecoder)

Description copied from interface: Connection

Execute the query.

Specified by:

query in interface Connection

Type Parameters:

T - the query result document type

Parameters:

namespace - the namespace to query

queryDocument - the query document

fields - the field to include or exclude

numberToReturn - the number of documents to return

skip - the number of documents to skip

slaveOk - whether the query can run on a secondary

tailableCursor - whether to return a tailable cursor

awaitData - whether a tailable cursor should wait before returning if no documents are available

noCursorTimeout - whether the cursor should not timeout

partial - whether partial results from sharded clusters are acceptable

oplogReplay - whether to replay the oplog

resultDecoder - the decoder for the query result documents

Returns:

the query results

query

public <T> QueryResult<T> query(MongoNamespace namespace,
                                BsonDocument queryDocument,
                                BsonDocument fields,
                                int skip,
                                int limit,
                                int batchSize,
                                boolean slaveOk,
                                boolean tailableCursor,
                                boolean awaitData,
                                boolean noCursorTimeout,
                                boolean partial,
                                boolean oplogReplay,
                                Decoder<T> resultDecoder)

Description copied from interface: Connection

Execute the query.

Specified by:

query in interface Connection

Type Parameters:

T - the query result document type

Parameters:

namespace - the namespace to query

queryDocument - the query document

fields - the field to include or exclude

skip - the number of documents to skip

limit - the maximum number of documents to return in all batches

batchSize - the maximum number of documents to return in this batch

slaveOk - whether the query can run on a secondary

tailableCursor - whether to return a tailable cursor

awaitData - whether a tailable cursor should wait before returning if no documents are available

noCursorTimeout - whether the cursor should not timeout

partial - whether partial results from sharded clusters are acceptable

oplogReplay - whether to replay the oplog

resultDecoder - the decoder for the query result documents

Returns:

the query results

queryAsync

public <T> void queryAsync(MongoNamespace namespace,
                           BsonDocument queryDocument,
                           BsonDocument fields,
                           int numberToReturn,
                           int skip,
                           boolean slaveOk,
                           boolean tailableCursor,
                           boolean awaitData,
                           boolean noCursorTimeout,
                           boolean partial,
                           boolean oplogReplay,
                           Decoder<T> resultDecoder,
                           SingleResultCallback<QueryResult<T>> callback)

Description copied from interface: AsyncConnection

Execute the query asynchronously.

Specified by:

queryAsync in interface AsyncConnection

Type Parameters:

T - the query result document type

Parameters:

namespace - the namespace to query

queryDocument - the query document

fields - the field to include or exclude

numberToReturn - the number of documents to return

skip - the number of documents to skip

slaveOk - whether the query can run on a secondary

tailableCursor - whether to return a tailable cursor

awaitData - whether a tailable cursor should wait before returning if no documents are available

noCursorTimeout - whether the cursor should not timeout

partial - whether partial results from sharded clusters are acceptable

oplogReplay - whether to replay the oplog

resultDecoder - the decoder for the query result documents

callback - the callback to be passed the write result

queryAsync

public <T> void queryAsync(MongoNamespace namespace,
                           BsonDocument queryDocument,
                           BsonDocument fields,
                           int skip,
                           int limit,
                           int batchSize,
                           boolean slaveOk,
                           boolean tailableCursor,
                           boolean awaitData,
                           boolean noCursorTimeout,
                           boolean partial,
                           boolean oplogReplay,
                           Decoder<T> resultDecoder,
                           SingleResultCallback<QueryResult<T>> callback)

Description copied from interface: AsyncConnection

Execute the query asynchronously.

Specified by:

queryAsync in interface AsyncConnection

Type Parameters:

T - the query result document type

Parameters:

namespace - the namespace to query

queryDocument - the query document

fields - the field to include or exclude

skip - the number of documents to skip

limit - the maximum number of documents to return in all batches

batchSize - the maximum number of documents to return in this batch

slaveOk - whether the query can run on a secondary

tailableCursor - whether to return a tailable cursor

awaitData - whether a tailable cursor should wait before returning if no documents are available

noCursorTimeout - whether the cursor should not timeout

partial - whether partial results from sharded clusters are acceptable

oplogReplay - whether to replay the oplog

resultDecoder - the decoder for the query result documents

callback - the callback to be passed the write result

getMore

public <T> QueryResult<T> getMore(MongoNamespace namespace,
                                  long cursorId,
                                  int numberToReturn,
                                  Decoder<T> resultDecoder)

Description copied from interface: Connection

Get more result documents from a cursor.

Specified by:

getMore in interface Connection

Type Parameters:

T - the type of the query result documents

Parameters:

namespace - the namespace to get more documents from

cursorId - the cursor id

numberToReturn - the number of documents to return

resultDecoder - the decoder for the query results

Returns:

the query results

getMoreAsync

public <T> void getMoreAsync(MongoNamespace namespace,
                             long cursorId,
                             int numberToReturn,
                             Decoder<T> resultDecoder,
                             SingleResultCallback<QueryResult<T>> callback)

Description copied from interface: AsyncConnection

Get more result documents from a cursor asynchronously.

Specified by:

getMoreAsync in interface AsyncConnection

Type Parameters:

T - the type of the query result documents

Parameters:

namespace - the namespace to get more documents from

cursorId - the cursor id

numberToReturn - the number of documents to return

resultDecoder - the decoder for the query result documents

callback - the callback to be passed the query result

killCursor

public void killCursor(java.util.List<java.lang.Long> cursors)

Description copied from interface: Connection

Kills the given list of cursors.

Specified by:

killCursor in interface Connection

Parameters:

cursors - the cursors

killCursor

public void killCursor(MongoNamespace namespace,
                       java.util.List<java.lang.Long> cursors)

Description copied from interface: Connection

Kills the given list of cursors.

Specified by:

killCursor in interface Connection

Parameters:

namespace - the namespace to in which the cursors live

cursors - the cursors

killCursorAsync

public void killCursorAsync(java.util.List<java.lang.Long> cursors,
                            SingleResultCallback<java.lang.Void> callback)

Description copied from interface: AsyncConnection

Asynchronously Kills the given list of cursors.

Specified by:

killCursorAsync in interface AsyncConnection

Parameters:

cursors - the cursors

callback - the callback that is called once the cursors have been killed

killCursorAsync

public void killCursorAsync(MongoNamespace namespace,
                            java.util.List<java.lang.Long> cursors,
                            SingleResultCallback<java.lang.Void> callback)

Description copied from interface: AsyncConnection

Asynchronously Kills the given list of cursors.

Specified by:

killCursorAsync in interface AsyncConnection

Parameters:

namespace - the namespace in which the cursors live

cursors - the cursors

callback - the callback that is called once the cursors have been killed

getCount

public int getCount()

Description copied from interface: ReferenceCounted

Gets the current reference count, which starts at 0.

Specified by:

getCount in interface ReferenceCounted

Returns:

the current count, which must be greater than or equal to 0