Package com.mongodb.connection

Interface AsyncConnection

  • All Superinterfaces:
    ReferenceCounted
    @ThreadSafe
@Deprecated
public interface AsyncConnection
extends ReferenceCounted
    Deprecated.
    An asynchronous connection to a MongoDB server with non-blocking operations.

    Implementations of this class are thread safe.

    This interface is not stable. While methods will not be removed, new ones may be added.

    Since:
    3.0

    • Method Detail

      • retain

        AsyncConnection retain()
        Deprecated.
        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 ReferenceCounted
        Returns:
        this

      • getDescription

        ConnectionDescription getDescription()
        Deprecated.
        Gets the description of the connection.
        Returns:
        the connection description

      • insertAsync

        void insertAsync(MongoNamespace namespace,
                 boolean ordered,
                 InsertRequest insertRequest,
                 SingleResultCallback<WriteConcernResult> callback)
        Deprecated.
        Insert the documents using the insert wire protocol and apply the write concern asynchronously.
        Parameters:
        namespace - the namespace
        ordered - whether the writes are ordered
        insertRequest - the insert request
        callback - the callback to be passed the write result

      • updateAsync

        void updateAsync(MongoNamespace namespace,
                 boolean ordered,
                 UpdateRequest updateRequest,
                 SingleResultCallback<WriteConcernResult> callback)
        Deprecated.
        Update the documents using the update wire protocol and apply the write concern asynchronously.
        Parameters:
        namespace - the namespace
        ordered - whether the writes are ordered
        updateRequest - the update request
        callback - the callback to be passed the write result

      • deleteAsync

        void deleteAsync(MongoNamespace namespace,
                 boolean ordered,
                 DeleteRequest deleteRequest,
                 SingleResultCallback<WriteConcernResult> callback)
        Deprecated.
        Delete the documents using the delete wire protocol and apply the write concern asynchronously.
        Parameters:
        namespace - the namespace
        ordered - whether the writes are ordered
        deleteRequest - the delete request
        callback - the callback to be passed the write result

      • commandAsync

        <T> void commandAsync(String database,
                      BsonDocument command,
                      FieldNameValidator fieldNameValidator,
                      ReadPreference readPreference,
                      Decoder<T> commandResultDecoder,
                      SessionContext sessionContext,
                      SingleResultCallback<T> callback)
        Deprecated.
        Execute the command.
        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
        Since:
        3.6

      • commandAsync

        <T> void commandAsync(String database,
                      BsonDocument command,
                      FieldNameValidator commandFieldNameValidator,
                      ReadPreference readPreference,
                      Decoder<T> commandResultDecoder,
                      SessionContext sessionContext,
                      boolean responseExpected,
                      SplittablePayload payload,
                      FieldNameValidator payloadFieldNameValidator,
                      SingleResultCallback<T> callback)
        Deprecated.
        Executes the command, consuming as much of the SplittablePayload as possible.
        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
        Since:
        3.6

      • queryAsync

        @Deprecated
<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)
        Deprecated.
        Replaced by queryAsync(MongoNamespace, BsonDocument, BsonDocument, int, int, int, boolean, boolean, boolean, boolean, boolean, boolean, Decoder, SingleResultCallback)
        Execute the query asynchronously.
        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

        <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)
        Deprecated.
        Execute the query asynchronously.
        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
        Since:
        3.1

      • getMoreAsync

        <T> void getMoreAsync(MongoNamespace namespace,
                      long cursorId,
                      int numberToReturn,
                      Decoder<T> resultDecoder,
                      SingleResultCallback<QueryResult<T>> callback)
        Deprecated.
        Get more result documents from a cursor asynchronously.
        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

      • killCursorAsync

        void killCursorAsync(MongoNamespace namespace,
                     List<Long> cursors,
                     SingleResultCallback<Void> callback)
        Deprecated.
        Asynchronously Kills the given list of cursors.
        Parameters:
        namespace - the namespace in which the cursors live
        cursors - the cursors
        callback - the callback that is called once the cursors have been killed