Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.client.gridfs.codecs |
This package contains codecs for use with GridFS
|
com.mongodb.client.model.changestream |
This package contains classes for the change stream api
|
com.mongodb.client.model.geojson.codecs |
This package contains classes that encode and decode GeoJSON objects.
|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
org.bson |
Contains the base BSON classes.
|
org.bson.codecs |
This package contains all the default BSON codecs.
|
org.bson.codecs.configuration |
This package contains codec configurations and the codec registry helper
|
org.bson.codecs.pojo |
This package contains classes specific to mapping user POJOs.
|
Modifier and Type | Class and Description |
---|---|
class |
BSONTimestampCodec
Knows how to encode and decode BSON timestamps.
|
(package private) class |
CompoundDBObjectCodec |
(package private) class |
DBDecoderAdapter |
class |
DBObjectCodec
A collectible codec for a DBObject.
|
class |
DBRefCodec
A Codec for DBRef instances.
|
Modifier and Type | Field and Description |
---|---|
private Decoder<DBObject> |
CompoundDBObjectCodec.decoder |
private Decoder<DBObject> |
DBCursor.decoder |
Modifier and Type | Method and Description |
---|---|
Decoder<DBObject> |
CompoundDBObjectCodec.getDecoder() |
Modifier and Type | Method and Description |
---|---|
private FindOperation<DBObject> |
DBCursor.getQueryOperation(Decoder<DBObject> decoder) |
private static java.lang.Object |
BulkWriteHelper.getUpsertedId(BulkWriteUpsert cur,
Decoder<DBObject> decoder) |
static BasicDBObject |
BasicDBObject.parse(java.lang.String json,
Decoder<BasicDBObject> decoder)
Parses a string in MongoDB Extended JSON format to a
BasicDBObject . |
(package private) static BulkWriteException |
BulkWriteHelper.translateBulkWriteException(MongoBulkWriteException e,
Decoder<DBObject> decoder) |
(package private) static BulkWriteResult |
BulkWriteHelper.translateBulkWriteResult(BulkWriteResult bulkWriteResult,
Decoder<DBObject> decoder) |
(package private) static java.util.List<BulkWriteUpsert> |
BulkWriteHelper.translateBulkWriteUpserts(java.util.List<BulkWriteUpsert> upserts,
Decoder<DBObject> decoder) |
Constructor and Description |
---|
CompoundDBObjectCodec(Encoder<DBObject> encoder,
Decoder<DBObject> decoder) |
DBCursor(DBCollection collection,
DBObject filter,
DBCollectionFindOptions findOptions,
OperationExecutor executor,
DBDecoderFactory decoderFactory,
Decoder<DBObject> decoder) |
Modifier and Type | Class and Description |
---|---|
class |
GridFSFileCodec
A codec for GridFS Files
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
ChangeStreamDocumentCodec<TResult> |
(package private) class |
OperationTypeCodec |
Modifier and Type | Class and Description |
---|---|
(package private) class |
AbstractGeometryCodec<T extends Geometry> |
class |
GeometryCodec
A Codec for a GeoJSON Geometry.
|
class |
GeometryCollectionCodec
A Codec for a GeoJSON GeometryCollection.
|
class |
LineStringCodec
A Codec for a GeoJSON LineString.
|
class |
MultiLineStringCodec
A Codec for a GeoJSON MultiLineString.
|
class |
MultiPointCodec
A Codec for a GeoJSON MultiPoint.
|
class |
MultiPolygonCodec
A Codec for a GeoJSON MultiPolygon.
|
class |
NamedCoordinateReferenceSystemCodec
Codec for a GeoJson Coordinate Reference System of type name.
|
class |
PointCodec
A Codec for a GeoJSON point.
|
class |
PolygonCodec
A Codec for a GeoJSON polygon.
|
Modifier and Type | Field and Description |
---|---|
private Decoder<T> |
CommandProtocolImpl.commandResultDecoder |
private Decoder<T> |
CommandResultCallback.decoder |
private Decoder<T> |
CommandResultBaseCallback.decoder |
private Decoder<T> |
QueryProtocol.resultDecoder |
private Decoder<T> |
GetMoreProtocol.resultDecoder |
Modifier and Type | Method and Description |
---|---|
<T> T |
Connection.command(java.lang.String database,
BsonDocument command,
boolean slaveOk,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder)
|
<T> T |
DefaultServerConnection.command(java.lang.String database,
BsonDocument command,
boolean slaveOk,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder) |
<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 fieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder,
SessionContext sessionContext) |
<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> 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> void |
AsyncConnection.commandAsync(java.lang.String database,
BsonDocument command,
boolean slaveOk,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
SingleResultCallback<T> callback)
|
<T> void |
DefaultServerConnection.commandAsync(java.lang.String database,
BsonDocument command,
boolean slaveOk,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
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 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 fieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder,
SessionContext sessionContext,
SingleResultCallback<T> callback)
Execute the command.
|
<T> void |
DefaultServerConnection.commandAsync(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
<T> QueryResult<T> |
Connection.getMore(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder)
Get more result documents from a cursor.
|
<T> QueryResult<T> |
DefaultServerConnection.getMore(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder) |
<T> void |
AsyncConnection.getMoreAsync(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback)
Get more result documents from a cursor asynchronously.
|
<T> void |
DefaultServerConnection.getMoreAsync(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback) |
private static <T extends BsonDocument> |
InternalStreamConnection.getResponseDocument(ResponseBuffers responseBuffers,
int messageId,
Decoder<T> decoder) |
<T> QueryResult<T> |
Connection.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)
|
<T> QueryResult<T> |
DefaultServerConnection.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) |
<T> QueryResult<T> |
Connection.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> QueryResult<T> |
DefaultServerConnection.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) |
<T> void |
AsyncConnection.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)
|
<T> void |
DefaultServerConnection.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) |
<T> void |
AsyncConnection.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.
|
<T> void |
DefaultServerConnection.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) |
private <T> T |
InternalStreamConnection.receiveCommandMessageResponse(CommandMessage message,
Decoder<T> decoder,
InternalStreamConnection.CommandEventSender commandEventSender,
SessionContext sessionContext) |
<T> T |
InternalStreamConnection.sendAndReceive(CommandMessage message,
Decoder<T> decoder,
SessionContext sessionContext) |
<T> T |
UsageTrackingInternalConnection.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 |
InternalStreamConnection.sendAndReceiveAsync(CommandMessage message,
Decoder<T> decoder,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
<T> void |
UsageTrackingInternalConnection.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 <T> void |
InternalStreamConnection.sendCommandMessageAsync(int messageId,
Decoder<T> decoder,
SessionContext sessionContext,
SingleResultCallback<T> callback,
ByteBufferBsonOutput bsonOutput,
InternalStreamConnection.CommandEventSender commandEventSender,
boolean responseExpected) |
Constructor and Description |
---|
CommandProtocolImpl(java.lang.String database,
BsonDocument command,
FieldNameValidator commandFieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder) |
CommandProtocolImpl(java.lang.String database,
BsonDocument command,
FieldNameValidator commandFieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder,
boolean responseExpected,
SplittablePayload payload,
FieldNameValidator payloadFieldNameValidator,
ClusterConnectionMode clusterConnectionMode) |
CommandResultBaseCallback(Decoder<T> decoder,
long requestId,
ServerAddress serverAddress) |
CommandResultCallback(SingleResultCallback<T> callback,
Decoder<T> decoder,
long requestId,
ServerAddress serverAddress) |
GetMoreProtocol(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder) |
QueryProtocol(MongoNamespace namespace,
int skip,
int numberToReturn,
BsonDocument queryDocument,
BsonDocument fields,
Decoder<T> resultDecoder) |
QueryProtocol(MongoNamespace namespace,
int skip,
int limit,
int batchSize,
BsonDocument queryDocument,
BsonDocument fields,
Decoder<T> resultDecoder) |
ReplyMessage(ResponseBuffers responseBuffers,
Decoder<T> decoder,
long requestId) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
CommandResultArrayCodec<T> |
(package private) class |
CommandResultDocumentCodec<T> |
Modifier and Type | Field and Description |
---|---|
private Decoder<T> |
QueryBatchCursor.decoder |
private Decoder<D> |
CommandOperationHelper.CommandProtocolExecutingCallback.decoder |
private Decoder<T> |
ListCollectionsOperation.decoder |
private Decoder<T> |
FindAndReplaceOperation.decoder |
private Decoder<T> |
FindAndDeleteOperation.decoder |
private Decoder<T> |
CommandWriteOperation.decoder |
private Decoder<T> |
CommandReadOperation.decoder |
private Decoder<T> |
ParallelCollectionScanOperation.decoder |
private Decoder<T> |
ListDatabasesOperation.decoder |
private Decoder<T> |
CommandResultArrayCodec.decoder |
private Decoder<T> |
DistinctOperation.decoder |
private Decoder<T> |
GroupOperation.decoder |
private Decoder<T> |
AggregateOperation.decoder |
private Decoder<T> |
FindOperation.decoder |
private Decoder<T> |
ChangeStreamOperation.decoder |
private Decoder<T> |
ListIndexesOperation.decoder |
private Decoder<T> |
FindAndUpdateOperation.decoder |
private Decoder<T> |
AsyncQueryBatchCursor.decoder |
private Decoder<T> |
MapReduceWithInlineResultsOperation.decoder |
private static Decoder<BsonDocument> |
BulkWriteBatch.DECODER |
private Decoder<T> |
CommandResultDocumentCodec.payloadDecoder |
private Decoder<P> |
CommandResultCodecProvider.payloadDecoder |
Modifier and Type | Method and Description |
---|---|
Decoder<T> |
FindAndReplaceOperation.getDecoder()
Gets the decoder used to decode the result documents.
|
Decoder<T> |
FindAndDeleteOperation.getDecoder()
Gets the decoder used to decode the result documents.
|
protected abstract Decoder<T> |
BaseFindAndModifyOperation.getDecoder() |
Decoder<T> |
GroupOperation.getDecoder()
Gets the decoder used to decode the result documents.
|
Decoder<BsonDocument> |
BulkWriteBatch.getDecoder() |
Decoder<T> |
FindOperation.getDecoder()
Gets the decoder used to decode the result documents.
|
Decoder<T> |
ChangeStreamOperation.getDecoder() |
Decoder<T> |
FindAndUpdateOperation.getDecoder()
Gets the decoder used to decode the result documents.
|
Decoder<T> |
MapReduceWithInlineResultsOperation.getDecoder()
Gets the decoder used to decode the result documents.
|
Modifier and Type | Method and Description |
---|---|
(package private) static <P> Codec<BsonDocument> |
CommandResultDocumentCodec.create(Decoder<P> decoder,
java.util.List<java.lang.String> fieldsContainingPayload) |
(package private) static <P> Codec<BsonDocument> |
CommandResultDocumentCodec.create(Decoder<P> decoder,
java.lang.String fieldContainingPayload) |
private static <T,R> SingleResultCallback<T> |
CommandOperationHelper.createCommandCallback(AsyncWriteBinding binding,
AsyncConnectionSource oldSource,
AsyncConnection oldConnection,
java.lang.String database,
ReadPreference readPreference,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
CommandOperationHelper.CommandTransformer<T,R> transformer,
SingleResultCallback<R> callback) |
(package private) static <T> QueryBatchCursor<T> |
OperationHelper.createEmptyBatchCursor(MongoNamespace namespace,
Decoder<T> decoder,
ServerAddress serverAddress,
int batchSize) |
(package private) static <T> AsyncBatchCursor<T> |
OperationHelper.cursorDocumentToAsyncBatchCursor(BsonDocument cursorDocument,
Decoder<T> decoder,
AsyncConnectionSource source,
AsyncConnection connection,
int batchSize) |
(package private) static <T> BatchCursor<T> |
OperationHelper.cursorDocumentToBatchCursor(BsonDocument cursorDocument,
Decoder<T> decoder,
ConnectionSource source,
int batchSize) |
(package private) static <T,R> void |
CommandOperationHelper.executeRetryableCommand(AsyncWriteBinding binding,
java.lang.String database,
ReadPreference readPreference,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
CommandOperationHelper.CommandCreator commandCreator,
CommandOperationHelper.CommandTransformer<T,R> transformer,
SingleResultCallback<R> originalCallback) |
(package private) static <T,R> R |
CommandOperationHelper.executeRetryableCommand(WriteBinding binding,
java.lang.String database,
ReadPreference readPreference,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
CommandOperationHelper.CommandCreator commandCreator,
CommandOperationHelper.CommandTransformer<T,R> transformer) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<BsonDocument> decoder,
Connection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(package private) static <D,T> T |
CommandOperationHelper.executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<T> decoder) |
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 <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
ConnectionSource source,
ReadPreference readPreference) |
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 <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<T> decoder,
ConnectionSource source,
ReadPreference readPreference) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<BsonDocument> decoder,
Connection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(package private) static <D,T> T |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<T> decoder) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<BsonDocument> decoder,
Connection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(package private) static <D,T> T |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<BsonDocument> decoder,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<BsonDocument> decoder,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<BsonDocument> decoder,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
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) |
Constructor and Description |
---|
AggregateOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline,
Decoder<T> decoder)
Construct a new instance.
|
AsyncQueryBatchCursor(QueryResult<T> firstBatch,
int limit,
int batchSize,
long maxTimeMS,
Decoder<T> decoder,
AsyncConnectionSource connectionSource,
AsyncConnection connection) |
ChangeStreamOperation(MongoNamespace namespace,
FullDocument fullDocument,
java.util.List<BsonDocument> pipeline,
Decoder<T> decoder)
Construct a new instance.
|
CommandProtocolExecutingCallback(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,R> transformer,
SessionContext sessionContext,
SingleResultCallback<R> callback) |
CommandReadOperation(java.lang.String databaseName,
BsonDocument command,
Decoder<T> decoder)
Construct a new instance.
|
CommandResultArrayCodec(CodecRegistry registry,
Decoder<T> decoder) |
CommandResultCodecProvider(Decoder<P> payloadDecoder,
java.util.List<java.lang.String> fieldContainingPayload) |
CommandResultDocumentCodec(CodecRegistry registry,
Decoder<T> payloadDecoder,
java.util.List<java.lang.String> fieldsContainingPayload) |
CommandWriteOperation(java.lang.String databaseName,
BsonDocument command,
Decoder<T> decoder)
Construct a new instance.
|
DistinctOperation(MongoNamespace namespace,
java.lang.String fieldName,
Decoder<T> decoder)
Construct an instance.
|
FindAndDeleteOperation(MongoNamespace namespace,
Decoder<T> decoder)
Deprecated.
|
FindAndDeleteOperation(MongoNamespace namespace,
WriteConcern writeConcern,
boolean retryWrites,
Decoder<T> decoder)
Construct a new instance.
|
FindAndDeleteOperation(MongoNamespace namespace,
WriteConcern writeConcern,
Decoder<T> decoder)
Deprecated.
|
FindAndReplaceOperation(MongoNamespace namespace,
Decoder<T> decoder,
BsonDocument replacement)
|
FindAndReplaceOperation(MongoNamespace namespace,
WriteConcern writeConcern,
boolean retryWrites,
Decoder<T> decoder,
BsonDocument replacement)
Construct a new instance.
|
FindAndReplaceOperation(MongoNamespace namespace,
WriteConcern writeConcern,
Decoder<T> decoder,
BsonDocument replacement)
|
FindAndUpdateOperation(MongoNamespace namespace,
Decoder<T> decoder,
BsonDocument update)
|
FindAndUpdateOperation(MongoNamespace namespace,
WriteConcern writeConcern,
boolean retryWrites,
Decoder<T> decoder,
BsonDocument update)
Construct a new instance.
|
FindAndUpdateOperation(MongoNamespace namespace,
WriteConcern writeConcern,
Decoder<T> decoder,
BsonDocument update)
|
FindOperation(MongoNamespace namespace,
Decoder<T> decoder)
Construct a new instance.
|
GroupOperation(MongoNamespace namespace,
BsonJavaScript reduceFunction,
BsonDocument initial,
Decoder<T> decoder)
Create an operation that will perform a Group on a given collection.
|
ListCollectionsOperation(java.lang.String databaseName,
Decoder<T> decoder)
Construct a new instance.
|
ListDatabasesOperation(Decoder<T> decoder)
Construct a new instance.
|
ListIndexesOperation(MongoNamespace namespace,
Decoder<T> decoder)
Construct a new instance.
|
MapReduceInlineResultsCursor(QueryResult<T> queryResult,
Decoder<T> decoder,
ConnectionSource connectionSource,
MapReduceStatistics statistics) |
MapReduceWithInlineResultsOperation(MongoNamespace namespace,
BsonJavaScript mapFunction,
BsonJavaScript reduceFunction,
Decoder<T> decoder)
Construct a MapReduceOperation with all the criteria it needs to execute.
|
ParallelCollectionScanOperation(MongoNamespace namespace,
int numCursors,
Decoder<T> decoder)
Construct a new instance.
|
QueryBatchCursor(QueryResult<T> firstQueryResult,
int limit,
int batchSize,
Decoder<T> decoder) |
QueryBatchCursor(QueryResult<T> firstQueryResult,
int limit,
int batchSize,
Decoder<T> decoder,
ConnectionSource connectionSource) |
QueryBatchCursor(QueryResult<T> firstQueryResult,
int limit,
int batchSize,
long maxTimeMS,
Decoder<T> decoder,
ConnectionSource connectionSource,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
<T> T |
RawBsonDocument.decode(Decoder<T> decoder)
Decode this into a document.
|
static Document |
Document.parse(java.lang.String json,
Decoder<Document> decoder)
Parses a string in MongoDB Extended JSON format to a
Document |
Modifier and Type | Interface and Description |
---|---|
interface |
Codec<T>
Implementations of this interface can both encode and decode values of type
T . |
interface |
CollectibleCodec<T>
A Codec that generates complete BSON documents for storage in a MongoDB collection.
|
Modifier and Type | Class and Description |
---|---|
class |
AtomicBooleanCodec
Encodes and decodes
AtomicBoolean objects. |
class |
AtomicIntegerCodec
Encodes and decodes
AtomicInteger objects. |
class |
AtomicLongCodec
Encodes and decodes
AtomicLong objects. |
class |
BigDecimalCodec
Encodes and decodes
BigDecimal objects. |
class |
BinaryCodec
A Codec for the BSON Binary type.
|
class |
BooleanCodec
Encodes and decodes
Boolean objects. |
class |
BsonArrayCodec
A codec for BsonArray instances.
|
class |
BsonBinaryCodec
A Codec for the BSON Binary type.
|
class |
BsonBooleanCodec
A Codec for BsonBoolean instances.
|
class |
BsonDateTimeCodec
A Codec for BsonDateTime instances.
|
class |
BsonDBPointerCodec
Converts BSON type DBPointer(0x0c) to database references as DBPointer is deprecated.
|
class |
BsonDecimal128Codec
A Codec for BsonDecimal128 instances.
|
class |
BsonDocumentCodec
A codec for BsonDocument instances.
|
class |
BsonDocumentWrapperCodec
A Codec
|
class |
BsonDoubleCodec
A Codec for BsonDouble instances.
|
class |
BsonInt32Codec
A Codec for BsonInt32 instances.
|
class |
BsonInt64Codec
A Codec for BsonInt64 instances.
|
class |
BsonJavaScriptCodec
A Codec for the
BsonJavaScript type. |
class |
BsonJavaScriptWithScopeCodec
A Codec for
BsonJavaScriptWithScope instances. |
class |
BsonMaxKeyCodec
A codec for
BsonMaxKey instances. |
class |
BsonMinKeyCodec
A codec for
BsonMinKey instances. |
class |
BsonNullCodec
A Codec for BsonNull instances.
|
class |
BsonObjectIdCodec
A Codec for
BsonObjectId instances. |
class |
BsonRegularExpressionCodec
A codec for BSON regular expressions.
|
class |
BsonStringCodec
A Codec for BsonString instances.
|
class |
BsonSymbolCodec
A codec for BSON symbol type.
|
class |
BsonTimestampCodec
A Codec for BSON Timestamp instances.
|
class |
BsonUndefinedCodec
Allows reading and writing of the BSON Undefined type.
|
class |
BsonValueCodec
A codec for unknown BsonValues.
|
class |
ByteArrayCodec
Encodes and decodes byte arrays.
|
class |
ByteCodec
Encodes and decodes
Byte objects. |
class |
CharacterCodec
Encodes and decodes
Character objects. |
class |
CodeCodec
Encodes and decodes instances of type
Code . |
class |
CodeWithScopeCodec
Encodes and decodes
CodeWithScope instances. |
class |
DateCodec
Encodes and decodes
java.util.Date objects. |
class |
Decimal128Codec
Encodes and decodes
Decimal128 objects. |
class |
DocumentCodec
A Codec for Document instances.
|
class |
DoubleCodec
Encodes and decodes
Double objects. |
class |
FloatCodec
Encodes and decodes
Float objects. |
class |
IntegerCodec
Encodes and decodes
Integer objects. |
class |
IterableCodec
Encodes and decodes
Iterable objects. |
class |
LongCodec
Encodes and decodes
Long objects. |
class |
MapCodec
A Codec for Map instances.
|
class |
MaxKeyCodec
Encodes and decodes instances of type
MaxKey . |
class |
MinKeyCodec
Encodes and decodes instances of type
MinKey . |
class |
ObjectIdCodec
A Codec for ObjectId instances.
|
class |
PatternCodec
A codec for
Pattern instances. |
class |
RawBsonDocumentCodec
A simple BSONDocumentBuffer codec.
|
class |
ShortCodec
Encodes and decodes
Short objects. |
class |
StringCodec
Encodes and decodes
String objects. |
class |
SymbolCodec
A codec for BSON symbol type.
|
class |
UuidCodec
Encodes and decodes
UUID objects. |
Modifier and Type | Method and Description |
---|---|
<T> T |
DecoderContext.decodeWithChildContext(Decoder<T> decoder,
BsonReader reader)
Creates a child context and then deserializes using the reader.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
LazyCodec<T> |
Modifier and Type | Class and Description |
---|---|
(package private) class |
AutomaticPojoCodec<T> |
private static class |
CollectionPropertyCodecProvider.CollectionCodec<T> |
private static class |
EnumPropertyCodecProvider.EnumCodec<T extends java.lang.Enum<T>> |
(package private) class |
LazyPojoCodec<T> |
private static class |
MapPropertyCodecProvider.MapCodec<T> |
(package private) class |
PojoCodec<T> |
(package private) class |
PojoCodecImpl<T> |