Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.async.client |
This packages contains classes for the new async client
|
com.mongodb.binding |
This package contains classes that manage binding to MongoDB servers for various operations.
|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
com.mongodb.internal.connection | |
com.mongodb.internal.session | |
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
Modifier and Type | Method and Description |
---|---|
SessionContext |
ClientSessionBinding.getSessionContext() |
SessionContext |
ClientSessionBinding.SessionBindingConnectionSource.getSessionContext() |
Modifier and Type | Method and Description |
---|---|
SessionContext |
ClientSessionBinding.getSessionContext() |
SessionContext |
ClientSessionBinding.SessionBindingAsyncConnectionSource.getSessionContext() |
Modifier and Type | Method and Description |
---|---|
SessionContext |
WriteBinding.getSessionContext()
Gets the session context for this binding.
|
SessionContext |
SingleServerBinding.getSessionContext() |
SessionContext |
SingleServerBinding.SingleServerBindingConnectionSource.getSessionContext() |
SessionContext |
SingleConnectionReadBinding.getSessionContext() |
SessionContext |
SingleConnectionReadBinding.SingleConnectionSource.getSessionContext() |
SessionContext |
ReadBinding.getSessionContext()
Gets the session context for this binding.
|
SessionContext |
ConnectionSource.getSessionContext()
Gets the session context for this source
|
SessionContext |
ClusterBinding.getSessionContext() |
SessionContext |
ClusterBinding.ClusterBindingConnectionSource.getSessionContext() |
SessionContext |
AsyncWriteBinding.getSessionContext()
Gets the session context for this binding.
|
SessionContext |
AsyncSingleConnectionReadBinding.getSessionContext() |
SessionContext |
AsyncSingleConnectionReadBinding.AsyncSingleConnectionSource.getSessionContext() |
SessionContext |
AsyncReadBinding.getSessionContext()
Gets the session context for this binding.
|
SessionContext |
AsyncConnectionSource.getSessionContext()
Gets the session context for this source
|
SessionContext |
AsyncClusterBinding.getSessionContext() |
SessionContext |
AsyncClusterBinding.AsyncClusterBindingConnectionSource.getSessionContext() |
Modifier and Type | Class and Description |
---|---|
(package private) class |
ClusterClockAdvancingSessionContext |
Modifier and Type | Field and Description |
---|---|
private SessionContext |
CommandProtocolImpl.sessionContext |
private SessionContext |
ClusterClockAdvancingSessionContext.wrapped |
Modifier and Type | Method and Description |
---|---|
<T> T |
DefaultServerConnection.command(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder,
SessionContext sessionContext) |
<T> T |
Connection.command(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder,
SessionContext sessionContext)
Execute the command.
|
<T> T |
DefaultServerConnection.command(java.lang.String database,
BsonDocument command,
FieldNameValidator commandFieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder,
SessionContext sessionContext,
boolean responseExpected,
SplittablePayload payload,
FieldNameValidator payloadFieldNameValidator) |
<T> T |
Connection.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 |
DefaultServerConnection.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) |
<T> void |
AsyncConnection.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 |
DefaultServerConnection.commandAsync(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
<T> void |
AsyncConnection.commandAsync(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder,
SessionContext sessionContext,
SingleResultCallback<T> callback)
Execute the command.
|
void |
RequestMessage.encode(BsonOutput bsonOutput,
SessionContext sessionContext)
Encoded the message to the given output.
|
protected abstract RequestMessage.EncodingMetadata |
RequestMessage.encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
SessionContext sessionContext)
Encode the message body to the given output.
|
protected RequestMessage.EncodingMetadata |
LegacyMessage.encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
SessionContext sessionContext) |
protected RequestMessage.EncodingMetadata |
CompressedMessage.encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
SessionContext sessionContext) |
protected RequestMessage.EncodingMetadata |
CommandMessage.encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
SessionContext sessionContext) |
<T> T |
ProtocolExecutor.execute(CommandProtocol<T> protocol,
InternalConnection connection,
SessionContext sessionContext) |
<T> T |
DefaultServer.DefaultServerProtocolExecutor.execute(CommandProtocol<T> protocol,
InternalConnection connection,
SessionContext sessionContext) |
<T> void |
ProtocolExecutor.executeAsync(CommandProtocol<T> protocol,
InternalConnection connection,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
<T> void |
DefaultServer.DefaultServerProtocolExecutor.executeAsync(CommandProtocol<T> protocol,
InternalConnection connection,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
private <T> T |
DefaultServerConnection.executeProtocol(CommandProtocol<T> protocol,
SessionContext sessionContext) |
private <T> void |
DefaultServerConnection.executeProtocolAsync(CommandProtocol<T> protocol,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
private java.util.List<BsonElement> |
CommandMessage.getExtraElements(SessionContext sessionContext) |
private <T> T |
InternalStreamConnection.receiveCommandMessageResponse(CommandMessage message,
Decoder<T> decoder,
InternalStreamConnection.CommandEventSender commandEventSender,
SessionContext sessionContext) |
<T> T |
UsageTrackingInternalConnection.sendAndReceive(CommandMessage message,
Decoder<T> decoder,
SessionContext sessionContext) |
<T> T |
InternalStreamConnection.sendAndReceive(CommandMessage message,
Decoder<T> decoder,
SessionContext sessionContext) |
<T> T |
InternalConnection.sendAndReceive(CommandMessage message,
Decoder<T> decoder,
SessionContext sessionContext)
Send a command message to the server.
|
<T> T |
DefaultConnectionPool.PooledConnection.sendAndReceive(CommandMessage message,
Decoder<T> decoder,
SessionContext sessionContext) |
<T> void |
UsageTrackingInternalConnection.sendAndReceiveAsync(CommandMessage message,
Decoder<T> decoder,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
<T> void |
InternalStreamConnection.sendAndReceiveAsync(CommandMessage message,
Decoder<T> decoder,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
<T> void |
InternalConnection.sendAndReceiveAsync(CommandMessage message,
Decoder<T> decoder,
SessionContext sessionContext,
SingleResultCallback<T> callback)
Send a command message to the server.
|
<T> void |
DefaultConnectionPool.PooledConnection.sendAndReceiveAsync(CommandMessage message,
Decoder<T> decoder,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
private void |
InternalStreamConnection.sendCommandMessage(CommandMessage message,
InternalStreamConnection.LazyCommandDocument lazyCommandDocument,
ByteBufferBsonOutput bsonOutput,
SessionContext sessionContext) |
private <T> void |
InternalStreamConnection.sendCommandMessageAsync(int messageId,
Decoder<T> decoder,
SessionContext sessionContext,
SingleResultCallback<T> callback,
ByteBufferBsonOutput bsonOutput,
InternalStreamConnection.CommandEventSender commandEventSender,
boolean responseExpected) |
CommandProtocolImpl<T> |
CommandProtocolImpl.sessionContext(SessionContext sessionContext) |
CommandProtocol<T> |
CommandProtocol.sessionContext(SessionContext sessionContext) |
private void |
InternalStreamConnection.updateSessionContext(SessionContext sessionContext,
ResponseBuffers responseBuffers) |
Constructor and Description |
---|
ClusterClockAdvancingSessionContext(SessionContext wrapped,
ClusterClock clusterClock) |
Modifier and Type | Class and Description |
---|---|
class |
NoOpSessionContext
A SessionContext implementation that does nothing and reports that it has no session.
|
Modifier and Type | Class and Description |
---|---|
class |
ClientSessionContext |
Modifier and Type | Field and Description |
---|---|
private SessionContext |
CommandOperationHelper.CommandProtocolExecutingCallback.sessionContext |
private SessionContext |
BulkWriteBatch.sessionContext |
Modifier and Type | Method and Description |
---|---|
(package private) static void |
ReadConcernHelper.appendReadConcernToCommand(ReadConcern readConcern,
SessionContext sessionContext,
BsonDocument commandDocument) |
static BulkWriteBatch |
BulkWriteBatch.createBulkWriteBatch(MongoNamespace namespace,
ServerDescription serverDescription,
ConnectionDescription connectionDescription,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
boolean retryWrites,
java.util.List<? extends WriteRequest> writeRequests,
SessionContext sessionContext) |
private static <D,T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
Connection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SessionContext sessionContext) |
private static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
Connection connection,
ReadPreference readPreference,
SessionContext sessionContext) |
private static <D,T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
Connection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SessionContext sessionContext) |
private static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
AsyncConnection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
private static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
AsyncConnection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
private BsonDocument |
AggregateOperation.getCommand(ConnectionDescription description,
SessionContext sessionContext) |
private BsonDocument |
ParallelCollectionScanOperation.getCommand(SessionContext sessionContext) |
private BsonDocument |
MapReduceWithInlineResultsOperation.getCommand(SessionContext sessionContext) |
private BsonDocument |
FindOperation.getCommand(SessionContext sessionContext) |
private BsonDocument |
DistinctOperation.getCommand(SessionContext sessionContext) |
private BsonDocument |
CountOperation.getCommand(SessionContext sessionContext) |
protected CommandOperationHelper.CommandCreator |
FindAndUpdateOperation.getCommandCreator(SessionContext sessionContext) |
protected CommandOperationHelper.CommandCreator |
FindAndReplaceOperation.getCommandCreator(SessionContext sessionContext) |
protected CommandOperationHelper.CommandCreator |
FindAndDeleteOperation.getCommandCreator(SessionContext sessionContext) |
protected abstract CommandOperationHelper.CommandCreator |
BaseFindAndModifyOperation.getCommandCreator(SessionContext sessionContext) |
private static ReadConcernLevel |
ReadConcernHelper.getReadConcernLevel(ReadConcern readConcern,
SessionContext sessionContext) |
private static boolean |
ReadConcernHelper.shouldAddAfterClusterTime(SessionContext sessionContext) |
Constructor and Description |
---|
BulkWriteBatch(MongoNamespace namespace,
ConnectionDescription connectionDescription,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
boolean retryWrites,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
IndexMap indexMap,
WriteRequest.Type batchType,
BsonDocument command,
SplittablePayload payload,
java.util.List<BulkWriteBatch.WriteRequestWithIndex> unprocessed,
SessionContext sessionContext) |
BulkWriteBatch(MongoNamespace namespace,
ConnectionDescription connectionDescription,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
boolean retryWrites,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
java.util.List<BulkWriteBatch.WriteRequestWithIndex> writeRequestsWithIndices,
SessionContext sessionContext) |
CommandProtocolExecutingCallback(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,R> transformer,
SessionContext sessionContext,
SingleResultCallback<R> callback) |