Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.async.client |
This packages contains classes for the new async client
|
com.mongodb.bulk |
Contains classes for representing the result of a bulk write operation.
|
com.mongodb.client.gridfs.codecs |
This package contains codecs for use with GridFS
|
com.mongodb.client.model |
This package contains models and options that help describe MongoCollection operations
|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
com.mongodb.event |
This package contains cluster and connection event related classes
|
com.mongodb.internal.authentication | |
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.conversions |
This package contains the Bson interface
|
Modifier and Type | Field and Description |
---|---|
private BsonDocument |
WriteError.details |
private BsonDocument |
CommandResult.response |
private BsonDocument |
MongoCommandException.response |
private BsonDocument |
WriteConcernException.response |
Modifier and Type | Method and Description |
---|---|
BsonDocument |
WriteConcern.asDocument()
Gets this write concern as a document.
|
BsonDocument |
ReadConcern.asDocument()
Gets this read concern as a document.
|
private BsonDocument |
MongoCollectionImpl.documentToBsonDocument(TDocument document) |
BsonDocument |
WriteError.getDetails()
Gets the details associated with this error.
|
BsonDocument |
MongoCommandException.getResponse()
For internal use only.
|
BsonDocument |
WriteConcernException.getResponse()
Gets the response to the write operation.
|
private BsonDocument |
MapReduceIterableImpl.toBsonDocument(Bson document) |
private BsonDocument |
FindIterableImpl.toBsonDocument(Bson document) |
private BsonDocument |
MongoCollectionImpl.toBsonDocument(Bson bson) |
private BsonDocument |
MongoDatabaseImpl.toBsonDocument(Bson document) |
private BsonDocument |
ListCollectionsIterableImpl.toBsonDocument(Bson document) |
<TDocument> |
BasicDBObject.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
abstract BsonDocument |
ReadPreference.toDocument()
Gets a document representing this read preference in the wire protocol.
|
BsonDocument |
ReadPreference.PrimaryReadPreference.toDocument() |
BsonDocument |
TaggableReadPreference.toDocument() |
private BsonDocument |
TaggableReadPreference.toDocument(TagSet tagSet) |
(package private) BsonDocument |
DBCollection.wrap(DBObject document) |
private BsonDocument |
DB.wrap(DBObject document) |
(package private) BsonDocument |
DBCollection.wrap(DBObject document,
DBEncoder encoder) |
private BsonDocument |
DB.wrap(DBObject document,
DBEncoder encoder) |
(package private) BsonDocument |
DBCollection.wrap(DBObject document,
Encoder<DBObject> encoder) |
(package private) BsonDocument |
DBCollection.wrapAllowNull(DBObject document) |
Modifier and Type | Method and Description |
---|---|
private java.util.List<BsonDocument> |
MongoDatabaseImpl.createBsonDocumentList(java.util.List<? extends Bson> pipeline) |
private java.util.List<BsonDocument> |
AggregateIterableImpl.createBsonDocumentList(java.util.List<? extends Bson> pipeline) |
(package private) java.util.List<BsonDocument> |
DBCollection.preparePipeline(java.util.List<? extends DBObject> pipeline) |
Modifier and Type | Method and Description |
---|---|
private void |
WriteConcern.addFSync(BsonDocument document) |
private void |
WriteConcern.addJ(BsonDocument document) |
private void |
WriteConcern.addW(BsonDocument document) |
private void |
WriteConcern.addWTimeout(BsonDocument document) |
(package private) CommandResult |
DB.executeCommand(BsonDocument commandDocument) |
(package private) CommandResult |
DB.executeCommand(BsonDocument commandDocument,
ReadPreference readPreference) |
private static int |
MongoCommandException.extractErrorCode(BsonDocument response) |
static int |
WriteConcernException.extractErrorCode(BsonDocument response)
For internal use only: extract the error code from the response to a write command.
|
private static java.lang.String |
MongoCommandException.extractErrorMessage(BsonDocument response) |
static java.lang.String |
WriteConcernException.extractErrorMessage(BsonDocument response)
For internal use only: extract the error message from the response to a write command.
|
private static java.lang.String |
MongoCommandException.getResponseAsJson(BsonDocument commandResponse) |
static DBObject |
DBObjects.toDBObject(BsonDocument document) |
Modifier and Type | Method and Description |
---|---|
private AggregateToCollectionOperation |
AggregateIterableImpl.createAggregateToCollectionOperation(java.util.List<BsonDocument> aggregateList) |
private BsonValue |
AggregateIterableImpl.getOutCollection(java.util.List<BsonDocument> aggregateList) |
Constructor and Description |
---|
CommandResult(BsonDocument response) |
CommandResult(BsonDocument response,
ServerAddress address) |
DuplicateKeyException(BsonDocument response,
ServerAddress address,
WriteConcernResult writeConcernResult)
Construct an instance.
|
MongoCommandException(BsonDocument response,
ServerAddress address)
Construct a new instance with the CommandResult from a failed command
|
WriteConcernException(BsonDocument response,
ServerAddress address,
WriteConcernResult writeConcernResult)
Construct a new instance.
|
WriteError(int code,
java.lang.String message,
BsonDocument details)
Constructs a new instance.
|
Modifier and Type | Method and Description |
---|---|
private BsonDocument |
MongoCollectionImpl.documentToBsonDocument(TDocument document) |
private BsonDocument |
MapReduceIterableImpl.toBsonDocument(Bson document) |
private BsonDocument |
FindIterableImpl.toBsonDocument(Bson document) |
private BsonDocument |
MongoCollectionImpl.toBsonDocument(Bson document) |
private BsonDocument |
MongoDatabaseImpl.toBsonDocument(Bson document) |
private BsonDocument |
ListCollectionsIterableImpl.toBsonDocument(Bson document) |
Modifier and Type | Method and Description |
---|---|
private java.util.List<BsonDocument> |
AggregateIterableImpl.createBsonDocumentList() |
private java.util.List<BsonDocument> |
MongoDatabaseImpl.createBsonDocumentList(java.util.List<? extends Bson> pipeline) |
Modifier and Type | Method and Description |
---|---|
private BsonValue |
AggregateIterableImpl.getAggregateOutCollection(java.util.List<BsonDocument> aggregateList) |
Modifier and Type | Field and Description |
---|---|
private BsonDocument |
WriteConcernError.details |
private BsonDocument |
InsertRequest.document |
private BsonDocument |
UpdateRequest.filter |
private BsonDocument |
DeleteRequest.filter |
private BsonDocument |
IndexRequest.keys |
private BsonDocument |
IndexRequest.partialFilterExpression |
private BsonDocument |
IndexRequest.storageEngine |
private BsonDocument |
UpdateRequest.update |
private BsonDocument |
IndexRequest.weights |
Modifier and Type | Method and Description |
---|---|
BsonDocument |
WriteConcernError.getDetails()
Gets the details associated with this error.
|
BsonDocument |
InsertRequest.getDocument()
Gets the document to insert.
|
BsonDocument |
UpdateRequest.getFilter()
Gets the query filter for the update.
|
BsonDocument |
DeleteRequest.getFilter()
Gets the query Object filter.
|
BsonDocument |
IndexRequest.getKeys()
Gets the index keys
|
BsonDocument |
IndexRequest.getPartialFilterExpression()
Get the filter expression for the documents to be included in the index or null if not set
|
BsonDocument |
IndexRequest.getStorageEngine()
Gets the storage engine options document for this index.
|
BsonDocument |
UpdateRequest.getUpdate()
Gets the update.
|
BsonDocument |
IndexRequest.getWeights()
Gets the weighting object for use with a text index
|
Modifier and Type | Method and Description |
---|---|
IndexRequest |
IndexRequest.partialFilterExpression(BsonDocument partialFilterExpression)
Sets the filter expression for the documents to be included in the index
|
IndexRequest |
IndexRequest.storageEngine(BsonDocument storageEngineOptions)
Sets the storage engine options document for this index.
|
IndexRequest |
IndexRequest.weights(BsonDocument weights)
Sets the weighting object for use with a text index.
|
Constructor and Description |
---|
BulkWriteError(int code,
java.lang.String message,
BsonDocument details,
int index)
Constructs a new instance.
|
DeleteRequest(BsonDocument filter)
Construct a new instance.
|
IndexRequest(BsonDocument keys)
Construct a new instance with the given keys
|
InsertRequest(BsonDocument document)
Construct an instance with the given document.
|
UpdateRequest(BsonDocument filter,
BsonDocument update,
WriteRequest.Type updateType)
Construct a new instance.
|
WriteConcernError(int code,
java.lang.String message,
BsonDocument details)
Constructs a new instance.
|
Modifier and Type | Field and Description |
---|---|
private Codec<BsonDocument> |
GridFSFileCodec.bsonDocumentCodec |
Modifier and Type | Method and Description |
---|---|
private Document |
GridFSFileCodec.asDocumentOrNull(BsonDocument bsonDocument) |
Modifier and Type | Method and Description |
---|---|
BsonDocument |
Collation.asDocument()
Gets this collation options as a document.
|
private BsonDocument |
Filters.NotFilter.createFilter(java.lang.String fieldName,
BsonValue value) |
<TDocument> |
Aggregates.SimplePipelineStage.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Aggregates.BucketStage.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Aggregates.BucketAutoStage.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Aggregates.GraphLookupStage.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Aggregates.GroupStage.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Aggregates.SortByCountStage.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Aggregates.FacetStage.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Aggregates.AddFieldsStage.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Aggregates.ReplaceRootStage.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Projections.FieldsProjection.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Projections.ElemMatchFilterProjection.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Filters.SimpleFilter.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Filters.OperatorFilter.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Filters.AndFilter.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Filters.OrNorFilter.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Filters.IterableOperatorFilter.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Filters.SimpleEncodingFilter.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Filters.NotFilter.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Filters.GeometryOperatorFilter.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Filters.TextFilter.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Sorts.CompoundSort.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
SimpleExpression.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Updates.SimpleUpdate.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Updates.WithEachUpdate.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Updates.PullAllUpdate.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
<TDocument> |
Updates.CompositeUpdate.toBsonDocument(java.lang.Class<TDocument> tDocumentClass,
CodecRegistry codecRegistry) |
Modifier and Type | Method and Description |
---|---|
private void |
Filters.AndFilter.addClause(BsonDocument document,
java.util.Map.Entry<java.lang.String,BsonValue> clause) |
private boolean |
Filters.AndFilter.keysIntersect(BsonDocument first,
BsonDocument second) |
private void |
Filters.AndFilter.promoteRenderableToDollarForm(BsonDocument document,
java.util.Map.Entry<java.lang.String,BsonValue> clause) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
ByteBufBsonDocument |
Modifier and Type | Field and Description |
---|---|
static BsonDocument |
ClientMetadataHelper.CLIENT_METADATA_DOCUMENT |
private BsonDocument |
InternalStreamConnectionFactory.clientMetadataDocument |
private BsonDocument |
InternalStreamConnectionInitializer.clientMetadataDocument |
private BsonDocument |
CommandProtocol.command |
private BsonDocument |
CommandMessage.command |
private BsonDocument |
QueryMessage.fields |
private BsonDocument |
QueryProtocol.fields |
private BsonDocument |
QueryMessage.queryDocument |
private BsonDocument |
QueryProtocol.queryDocument |
private BsonDocument |
SaslAuthenticator.Continuator.saslStartDocument |
Modifier and Type | Method and Description |
---|---|
private static BsonDocument |
ClientMetadataHelper.addDriverInformation(MongoDriverInformation mongoDriverInformation,
BsonDocument document) |
BsonDocument |
ByteBufBsonDocument.append(java.lang.String key,
BsonValue value) |
private BsonDocument |
KillCursorProtocol.asCommandDocument() |
private BsonDocument |
KillCursorProtocol.asCommandResponseDocument() |
private BsonDocument |
QueryProtocol.asFindCommandDocument(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
private BsonDocument |
QueryProtocol.asFindCommandResponseDocument(ResponseBuffers responseBuffers,
QueryResult<T> queryResult,
boolean isExplain) |
private BsonDocument |
GetMoreProtocol.asGetMoreCommandDocument() |
private BsonDocument |
GetMoreProtocol.asGetMoreCommandResponseDocument(QueryResult<T> queryResult,
ResponseBuffers responseBuffers) |
BsonDocument |
ByteBufBsonDocument.clone() |
(package private) static BsonDocument |
ClientMetadataHelper.createClientMetadataDocument(java.lang.String applicationName) |
(package private) static BsonDocument |
ClientMetadataHelper.createClientMetadataDocument(java.lang.String applicationName,
MongoDriverInformation mongoDriverInformation) |
(package private) static BsonDocument |
ClientMetadataHelper.createClientMetadataDocument(java.lang.String applicationName,
MongoDriverInformation mongoDriverInformation,
BsonDocument templateDocument) |
private BsonDocument |
WriteProtocol.createGetLastErrorCommandDocument() |
private BsonDocument |
InternalStreamConnectionInitializer.createIsMasterCommand() |
private BsonDocument |
SaslAuthenticator.createSaslContinueDocument(BsonInt32 conversationId,
byte[] outToken) |
private BsonDocument |
SaslAuthenticator.createSaslStartCommandDocument(byte[] outToken) |
(package private) static BsonDocument |
CommandHelper.executeCommand(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
(package private) static BsonDocument |
CommandHelper.executeCommandWithoutCheckingForFailure(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
protected BsonDocument |
DeleteProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
protected BsonDocument |
UpdateProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
protected BsonDocument |
InsertProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
protected abstract BsonDocument |
WriteProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
private BsonDocument |
X509Authenticator.getAuthCommand(java.lang.String userName) |
protected BsonDocument |
WriteProtocol.getBaseCommandDocument(java.lang.String commandName) |
private BsonDocument |
WriteProtocol.getResponseDocument(RequestMessage curMessage,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
WriteConcernException writeConcernException) |
private static BsonDocument |
CommandHelper.receiveCommandDocument(InternalConnection internalConnection,
CommandMessage message) |
private static BsonDocument |
CommandHelper.receiveCommandResult(InternalConnection internalConnection,
CommandMessage message) |
private BsonDocument |
WriteCommandProtocol.receiveMessage(InternalConnection connection,
RequestMessage message) |
private BsonDocument |
SaslAuthenticator.sendSaslContinue(BsonInt32 conversationId,
byte[] outToken,
InternalConnection connection) |
private BsonDocument |
SaslAuthenticator.sendSaslStart(byte[] outToken,
InternalConnection connection) |
private BsonDocument |
ByteBufBsonDocument.toBsonDocument() |
Modifier and Type | Method and Description |
---|---|
(package private) Codec<BsonDocument> |
RequestMessage.getCodec(BsonDocument document) |
private static ReplyMessage<BsonDocument> |
CommandHelper.receiveReply(InternalConnection internalConnection,
CommandMessage message) |
Modifier and Type | Method and Description |
---|---|
protected void |
RequestMessage.addCollectibleDocument(BsonDocument document,
BsonOutput bsonOutput,
FieldNameValidator validator)
Appends a document to the message that is intended for storage in a collection.
|
protected <T> void |
RequestMessage.addDocument(BsonDocument document,
BsonOutput bsonOutput,
FieldNameValidator validator)
Appends a document to the message.
|
private static BsonDocument |
ClientMetadataHelper.addDriverInformation(MongoDriverInformation mongoDriverInformation,
BsonDocument document) |
protected void |
DeleteProtocol.appendToWriteCommandResponseDocument(RequestMessage curMessage,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
BsonDocument response) |
protected void |
UpdateProtocol.appendToWriteCommandResponseDocument(RequestMessage curMessage,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
BsonDocument response) |
protected void |
InsertProtocol.appendToWriteCommandResponseDocument(RequestMessage curMessage,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
BsonDocument response) |
protected abstract void |
WriteProtocol.appendToWriteCommandResponseDocument(RequestMessage curMessage,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
BsonDocument response) |
private ConnectionDescription |
InternalStreamConnectionInitializer.applyGetLastErrorResult(BsonDocument getLastErrorResult,
ConnectionDescription connectionDescription) |
protected void |
CommandResultCallback.callCallback(BsonDocument response,
java.lang.Throwable t) |
protected void |
WriteProtocol.WriteResultCallback.callCallback(BsonDocument result,
java.lang.Throwable throwableFromCallback) |
(package private) static boolean |
ClientMetadataHelper.clientMetadataDocumentTooLarge(BsonDocument document) |
<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,
boolean slaveOk,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder)
Execute the command.
|
<T> void |
AsyncConnection.commandAsync(java.lang.String database,
BsonDocument command,
boolean slaveOk,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
SingleResultCallback<T> callback)
Execute the command asynchronously.
|
<T> void |
DefaultServerConnection.commandAsync(java.lang.String database,
BsonDocument command,
boolean slaveOk,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
SingleResultCallback<T> callback) |
private void |
SaslAuthenticator.Continuator.continueConversation(BsonDocument result) |
(package private) static BsonDocument |
ClientMetadataHelper.createClientMetadataDocument(java.lang.String applicationName,
MongoDriverInformation mongoDriverInformation,
BsonDocument templateDocument) |
private static MongoCommandException |
CommandHelper.createCommandFailureException(BsonDocument reply,
InternalConnection internalConnection) |
(package private) static ConnectionDescription |
DescriptionHelper.createConnectionDescription(ConnectionId connectionId,
BsonDocument isMasterResult,
BsonDocument buildInfoResult) |
(package private) static ServerDescription |
DescriptionHelper.createServerDescription(ServerAddress serverAddress,
BsonDocument isMasterResult,
ServerVersion serverVersion,
long roundTripTime) |
private static MongoException |
ProtocolHelper.createSpecialException(BsonDocument response,
ServerAddress serverAddress,
java.lang.String errorMessageFieldName) |
private static WriteConcernResult |
ProtocolHelper.createWriteResult(BsonDocument result) |
(package private) static BsonDocument |
CommandHelper.executeCommand(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
(package private) static void |
CommandHelper.executeCommandAsync(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection,
SingleResultCallback<BsonDocument> callback) |
(package private) static BsonDocument |
CommandHelper.executeCommandWithoutCheckingForFailure(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
(package private) static MongoBulkWriteException |
WriteCommandResultHelper.getBulkWriteException(WriteRequest.Type type,
BsonDocument result,
ServerAddress serverAddress) |
(package private) static BulkWriteResult |
WriteCommandResultHelper.getBulkWriteResult(WriteRequest.Type type,
BsonDocument result) |
(package private) Codec<BsonDocument> |
RequestMessage.getCodec(BsonDocument document) |
(package private) static MongoException |
ProtocolHelper.getCommandFailureException(BsonDocument response,
ServerAddress serverAddress) |
private static int |
WriteCommandResultHelper.getCount(BsonDocument result) |
private static ObjectId |
DescriptionHelper.getElectionId(BsonDocument isMasterResult) |
(package private) static int |
ProtocolHelper.getErrorCode(BsonDocument response) |
(package private) static java.lang.String |
ProtocolHelper.getErrorMessage(BsonDocument response,
java.lang.String errorMessageFieldName) |
private static java.util.Date |
DescriptionHelper.getLastWriteDate(BsonDocument isMasterResult) |
private static int |
DescriptionHelper.getMaxBsonObjectSize(BsonDocument isMasterResult) |
private static int |
DescriptionHelper.getMaxMessageSizeBytes(BsonDocument isMasterResult) |
private static int |
DescriptionHelper.getMaxWriteBatchSize(BsonDocument isMasterResult) |
private static java.lang.Integer |
WriteCommandResultHelper.getModifiedCount(WriteRequest.Type type,
BsonDocument result) |
(package private) static MongoException |
ProtocolHelper.getQueryFailureException(BsonDocument errorDocument,
ServerAddress serverAddress) |
private static ServerType |
DescriptionHelper.getServerType(BsonDocument isMasterResult) |
private static java.lang.Integer |
DescriptionHelper.getSetVersion(BsonDocument isMasterResult) |
private static java.lang.String |
DescriptionHelper.getString(BsonDocument response,
java.lang.String key) |
private static TagSet |
DescriptionHelper.getTagSetFromDocument(BsonDocument tagsDocuments) |
private static java.util.List<BulkWriteUpsert> |
WriteCommandResultHelper.getUpsertedItems(BsonDocument result) |
(package private) static ServerVersion |
DescriptionHelper.getVersion(BsonDocument buildInfoResult) |
private static WriteConcernError |
WriteCommandResultHelper.getWriteConcernError(BsonDocument result) |
private static java.util.List<BulkWriteError> |
WriteCommandResultHelper.getWriteErrors(BsonDocument result) |
(package private) static WriteConcernResult |
ProtocolHelper.getWriteResult(BsonDocument result,
ServerAddress serverAddress) |
(package private) static boolean |
WriteCommandResultHelper.hasError(BsonDocument result) |
private static boolean |
ProtocolHelper.hasWriteError(BsonDocument response) |
(package private) static boolean |
ProtocolHelper.isCommandOk(BsonDocument response) |
(package private) static boolean |
CommandHelper.isCommandOk(BsonDocument response) |
private static boolean |
DescriptionHelper.isReplicaSetMember(BsonDocument isMasterResult) |
void |
SaslAuthenticator.Continuator.onResult(BsonDocument result,
java.lang.Throwable t) |
<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 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 skip,
int limit,
int batchSize,
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> 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) |
(package private) static void |
ProtocolHelper.sendCommandStartedEvent(RequestMessage message,
java.lang.String databaseName,
java.lang.String commandName,
BsonDocument command,
ConnectionDescription connectionDescription,
CommandListener commandListener) |
(package private) static void |
ProtocolHelper.sendCommandSucceededEvent(RequestMessage message,
java.lang.String commandName,
BsonDocument response,
ConnectionDescription connectionDescription,
long startTimeNanos,
CommandListener commandListener) |
private static CommandMessage |
CommandHelper.sendMessage(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
private static void |
CommandHelper.sendMessageAsync(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection,
SingleResultCallback<CommandMessage> callback) |
private void |
CommandProtocol.sendSucceededEvent(ConnectionDescription connectionDescription,
long startTimeNanos,
CommandMessage commandMessage,
BsonDocument response) |
private void |
WriteCommandProtocol.sendSucceededEvent(InternalConnection connection,
BaseWriteCommandMessage message,
long startTimeNanos,
BsonDocument result) |
private void |
WriteProtocol.sendSucceededEvent(InternalConnection connection,
RequestMessage message,
BsonDocument responseDocument,
long startTimeNanos) |
private static void |
ProtocolHelper.throwWriteException(BsonDocument result,
ServerAddress serverAddress) |
Modifier and Type | Method and Description |
---|---|
(package private) static void |
CommandHelper.executeCommandAsync(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection,
SingleResultCallback<BsonDocument> callback) |
private static void |
CommandHelper.receiveReplyAsync(InternalConnection internalConnection,
CommandMessage message,
SingleResultCallback<ReplyMessage<BsonDocument>> callback) |
private void |
WriteCommandProtocol.sendMessageAsync(InternalConnection connection,
ByteBufferBsonOutput buffer,
BaseWriteCommandMessage message,
long startTimeNanos,
SingleResultCallback<BulkWriteResult> clientCallback,
SingleResultCallback<BsonDocument> callback) |
private void |
SaslAuthenticator.sendSaslContinueAsync(BsonInt32 conversationId,
byte[] outToken,
InternalConnection connection,
SingleResultCallback<BsonDocument> callback) |
private void |
SaslAuthenticator.sendSaslStartAsync(byte[] outToken,
InternalConnection connection,
SingleResultCallback<BsonDocument> callback) |
Constructor and Description |
---|
CommandMessage(java.lang.String collectionName,
BsonDocument command,
boolean slaveOk,
FieldNameValidator validator,
MessageSettings settings) |
CommandMessage(java.lang.String collectionName,
BsonDocument command,
boolean slaveOk,
MessageSettings settings) |
CommandProtocol(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder) |
Continuator(javax.security.sasl.SaslClient saslClient,
BsonDocument saslStartDocument,
InternalConnection connection,
SingleResultCallback<java.lang.Void> callback) |
InternalStreamConnectionInitializer(java.util.List<Authenticator> authenticators,
BsonDocument clientMetadataDocument) |
QueryMessage(java.lang.String collectionName,
int skip,
int numberToReturn,
BsonDocument queryDocument,
BsonDocument fields,
MessageSettings settings) |
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) |
Constructor and Description |
---|
WriteResultCallback(SingleResultCallback<WriteConcernResult> callback,
Decoder<BsonDocument> decoder,
RequestMessage message,
RequestMessage nextMessage,
long requestId,
InternalConnection connection,
long startTimeNanos) |
Modifier and Type | Field and Description |
---|---|
private BsonDocument |
CommandStartedEvent.command |
private BsonDocument |
ServerHeartbeatSucceededEvent.reply |
private BsonDocument |
CommandSucceededEvent.response |
Modifier and Type | Method and Description |
---|---|
BsonDocument |
CommandStartedEvent.getCommand()
Gets the command document.
|
BsonDocument |
ServerHeartbeatSucceededEvent.getReply()
Gets the reply to the isMaster command executed for this heartbeat.
|
BsonDocument |
CommandSucceededEvent.getResponse()
Gets the response document.
|
Constructor and Description |
---|
CommandStartedEvent(int requestId,
ConnectionDescription connectionDescription,
java.lang.String databaseName,
java.lang.String commandName,
BsonDocument command)
Construct an instance.
|
CommandSucceededEvent(int requestId,
ConnectionDescription connectionDescription,
java.lang.String commandName,
BsonDocument response,
long elapsedTimeNanos)
Construct an instance.
|
ServerHeartbeatSucceededEvent(ConnectionId connectionId,
BsonDocument reply,
long elapsedTimeNanos)
Construct an instance.
|
Modifier and Type | Method and Description |
---|---|
static BsonDocument |
NativeAuthenticationHelper.getAuthCommand(java.lang.String userName,
char[] password,
java.lang.String nonce) |
static BsonDocument |
NativeAuthenticationHelper.getAuthCommand(java.lang.String userName,
java.lang.String authHash,
java.lang.String nonce) |
static BsonDocument |
NativeAuthenticationHelper.getNonceCommand() |
Modifier and Type | Field and Description |
---|---|
private BsonDocument |
CommandWriteOperation.command |
private BsonDocument |
CommandReadOperation.command |
private BsonDocument |
CommandOperationHelper.CommandProtocolExecutingCallback.command |
private static BsonDocument |
DropDatabaseOperation.DROP_DATABASE |
private BsonDocument |
FindAndUpdateOperation.filter |
private BsonDocument |
MapReduceWithInlineResultsOperation.filter |
private BsonDocument |
FindAndReplaceOperation.filter |
private BsonDocument |
FindOperation.filter |
private BsonDocument |
MapReduceToCollectionOperation.filter |
private BsonDocument |
DistinctOperation.filter |
private BsonDocument |
ListCollectionsOperation.filter |
private BsonDocument |
GroupOperation.filter |
private BsonDocument |
FindAndDeleteOperation.filter |
private BsonDocument |
CountOperation.filter |
private static BsonDocument |
FsyncUnlockOperation.FSYNC_UNLOCK_COMMAND |
private BsonDocument |
FindOperation.hint |
private BsonDocument |
CreateCollectionOperation.indexOptionDefaults |
private BsonDocument |
GroupOperation.initial |
private BsonDocument |
GroupOperation.key |
private BsonDocument |
FindOperation.max |
private BsonDocument |
FindOperation.min |
private BsonDocument |
FindOperation.modifiers |
private BsonDocument |
FindAndUpdateOperation.projection |
private BsonDocument |
FindAndReplaceOperation.projection |
private BsonDocument |
FindOperation.projection |
private BsonDocument |
FindAndDeleteOperation.projection |
private BsonDocument |
FindAndReplaceOperation.replacement |
private BsonDocument |
MapReduceWithInlineResultsOperation.scope |
private BsonDocument |
MapReduceToCollectionOperation.scope |
private BsonDocument |
FindAndUpdateOperation.sort |
private BsonDocument |
MapReduceWithInlineResultsOperation.sort |
private BsonDocument |
FindAndReplaceOperation.sort |
private BsonDocument |
FindOperation.sort |
private BsonDocument |
MapReduceToCollectionOperation.sort |
private BsonDocument |
FindAndDeleteOperation.sort |
private BsonDocument |
CreateCollectionOperation.storageEngineOptions |
private BsonDocument |
FindAndUpdateOperation.update |
private BsonDocument |
CreateCollectionOperation.validator |
Modifier and Type | Field and Description |
---|---|
private SingleResultCallback<BsonDocument> |
FindOperation.ExplainResultCallback.callback |
private BatchCursor<BsonDocument> |
ListCollectionsOperation.ProjectingBatchCursor.delegate |
private AsyncBatchCursor<BsonDocument> |
ListCollectionsOperation.ProjectingAsyncBatchCursor.delegate |
private java.util.List<BsonDocument> |
AggregateOperation.pipeline |
private java.util.List<BsonDocument> |
AggregateToCollectionOperation.pipeline |
private java.util.List<BsonDocument> |
CreateViewOperation.pipeline |
private java.util.List<BsonDocument> |
AggregateExplainOperation.pipeline |
Modifier and Type | Method and Description |
---|---|
(package private) static BsonDocument |
UserOperationHelper.asCollectionInsertDocument(MongoCredential credential,
boolean readOnly) |
(package private) static BsonDocument |
UserOperationHelper.asCollectionQueryDocument(MongoCredential credential) |
(package private) static BsonDocument |
UserOperationHelper.asCollectionUpdateDocument(MongoCredential credential,
boolean readOnly) |
(package private) static BsonDocument |
UserOperationHelper.asCommandDocument(MongoCredential credential,
boolean readOnly,
java.lang.String commandName) |
private BsonDocument |
FindOperation.asDocument(ConnectionDescription connectionDescription,
ReadPreference readPreference) |
(package private) static BsonDocument |
ExplainHelper.asExplainCommand(BsonDocument command,
ExplainVerbosity explainVerbosity) |
private BsonDocument |
QueryBatchCursor.asGetMoreCommandDocument() |
private BsonDocument |
AsyncQueryBatchCursor.asGetMoreCommandDocument(long cursorId) |
private BsonDocument |
QueryBatchCursor.asKillCursorsCommandDocument() |
private BsonDocument |
AsyncQueryBatchCursor.asKillCursorsCommandDocument(ServerCursor localCursor) |
private BsonDocument |
ListIndexesOperation.asQueryDocument(ConnectionDescription connectionDescription,
ReadPreference readPreference) |
private BsonDocument |
ListCollectionsOperation.asQueryDocument(ConnectionDescription connectionDescription,
ReadPreference readPreference) |
BsonDocument |
FsyncUnlockOperation.execute(ReadBinding binding) |
BsonDocument |
CurrentOpOperation.execute(ReadBinding binding) |
BsonDocument |
AggregateExplainOperation.execute(ReadBinding binding) |
BsonDocument |
FsyncUnlockOperation.execute(WriteBinding binding)
Deprecated.
use
FsyncUnlockOperation.execute(ReadBinding) instead. |
(package private) static BsonDocument |
CommandOperationHelper.executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command) |
(package private) static BsonDocument |
CommandOperationHelper.executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection) |
(package private) static BsonDocument |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command) |
(package private) static BsonDocument |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection) |
private BsonDocument |
MapReduceWithInlineResultsOperation.getCommand() |
private BsonDocument |
ListDatabasesOperation.getCommand() |
private BsonDocument |
ParallelCollectionScanOperation.getCommand() |
private BsonDocument |
ListIndexesOperation.getCommand() |
private BsonDocument |
FindOperation.getCommand() |
private BsonDocument |
UserExistsOperation.getCommand() |
private BsonDocument |
DistinctOperation.getCommand() |
private BsonDocument |
ListCollectionsOperation.getCommand() |
private BsonDocument |
AggregateExplainOperation.getCommand() |
private BsonDocument |
GroupOperation.getCommand() |
private BsonDocument |
CountOperation.getCommand() |
private BsonDocument |
AggregateOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
FindAndUpdateOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
AggregateToCollectionOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
DropDatabaseOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
DropIndexOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
FindAndReplaceOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
DropCollectionOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
CreateIndexesOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
CreateViewOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
UpdateUserOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
CreateCollectionOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
CreateUserOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
MapReduceToCollectionOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
FindAndDeleteOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
DropUserOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
RenameCollectionOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
ParallelCollectionScanOperation.getCursorDocument(BsonDocument cursorDocument) |
(package private) static BsonDocument |
CursorHelper.getCursorDocumentFromBatchSize(java.lang.Integer batchSize) |
BsonDocument |
FindAndUpdateOperation.getFilter()
Gets the query filter.
|
BsonDocument |
MapReduceWithInlineResultsOperation.getFilter()
Gets the query filter.
|
BsonDocument |
FindAndReplaceOperation.getFilter()
Gets the query filter.
|
BsonDocument |
FindOperation.getFilter()
Gets the query filter.
|
BsonDocument |
MapReduceToCollectionOperation.getFilter()
Gets the query filter.
|
BsonDocument |
DistinctOperation.getFilter()
Gets the query filter.
|
BsonDocument |
ListCollectionsOperation.getFilter()
Gets the query filter.
|
BsonDocument |
GroupOperation.getFilter()
Gets the query filter to determine which documents in the collection to process.
|
BsonDocument |
FindAndDeleteOperation.getFilter()
Gets the query filter.
|
BsonDocument |
CountOperation.getFilter()
Gets the query filter.
|
BsonDocument |
FindOperation.getHint()
Returns the hint for which index to use.
|
private BsonDocument |
CreateIndexesOperation.getIndex(IndexRequest request) |
BsonDocument |
CreateCollectionOperation.getIndexOptionDefaults()
Gets the index option defaults for the collection.
|
BsonDocument |
GroupOperation.getInitial()
Gets the initial the aggregation result document.
|
BsonDocument |
GroupOperation.getKey()
Gets the document containing the field or fields to group.
|
BsonDocument |
FindOperation.getMax()
Returns the exclusive upper bound for a specific index.
|
BsonDocument |
FindOperation.getMin()
Returns the minimum inclusive lower bound for a specific index.
|
BsonDocument |
FindOperation.getModifiers()
Gets the query modifiers to apply to this operation.
|
BsonDocument |
FindAndUpdateOperation.getProjection()
Gets a document describing the fields to return for all matching documents.
|
BsonDocument |
FindAndReplaceOperation.getProjection()
Gets a document describing the fields to return for all matching documents.
|
BsonDocument |
FindOperation.getProjection()
Gets a document describing the fields to return for all matching documents.
|
BsonDocument |
FindAndDeleteOperation.getProjection()
Gets a document describing the fields to return for all matching documents.
|
BsonDocument |
FindAndReplaceOperation.getReplacement()
Gets the document which will replace the document matching the query filter.
|
BsonDocument |
MapReduceWithInlineResultsOperation.getScope()
Gets the global variables that are accessible in the map, reduce and finalize functions.
|
BsonDocument |
MapReduceToCollectionOperation.getScope()
Gets the global variables that are accessible in the map, reduce and finalize functions.
|
BsonDocument |
FindAndUpdateOperation.getSort()
Gets the sort criteria to apply to the query.
|
BsonDocument |
MapReduceWithInlineResultsOperation.getSort()
Gets the sort criteria to apply to the query.
|
BsonDocument |
FindAndReplaceOperation.getSort()
Gets the sort criteria to apply to the query.
|
BsonDocument |
FindOperation.getSort()
Gets the sort criteria to apply to the query.
|
BsonDocument |
MapReduceToCollectionOperation.getSort()
Gets the sort criteria to apply to the query.
|
BsonDocument |
FindAndDeleteOperation.getSort()
Gets the sort criteria to apply to the query.
|
BsonDocument |
CreateCollectionOperation.getStorageEngineOptions()
Gets the storage engine options document for this collection.
|
BsonDocument |
FindAndUpdateOperation.getUpdate()
Gets the document containing update operators
|
BsonDocument |
CreateCollectionOperation.getValidator()
Gets the validation rules for inserting or updating documents
|
private BsonDocument |
BaseWriteOperation.manufactureGetLastErrorResponse(MongoBulkWriteException e) |
private BsonDocument |
FsyncUnlockOperation.queryUnlock(Connection connection) |
private BsonDocument |
MixedBulkWriteOperation.Run.BaseRunExecutor.translateGetLastErrorResponseToErrInfo(BsonDocument response) |
(package private) static BsonDocument |
CommandOperationHelper.wrapCommand(BsonDocument command,
ReadPreference readPreference,
ConnectionDescription connectionDescription) |
private BsonDocument |
FindOperation.wrapInExplainIfNecessary(BsonDocument commandDocument) |
Modifier and Type | Method and Description |
---|---|
private void |
BaseWriteOperation.addBulkWriteResultToResponse(BulkWriteResult bulkWriteResult,
BsonDocument response) |
(package private) static void |
WriteConcernHelper.appendWriteConcernToCommand(WriteConcern writeConcern,
BsonDocument commandDocument,
ConnectionDescription description) |
(package private) static BsonDocument |
ExplainHelper.asExplainCommand(BsonDocument command,
ExplainVerbosity explainVerbosity) |
private QueryResult<T> |
AggregateOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
MapReduceWithInlineResultsOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
ListDatabasesOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
DistinctOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
GroupOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
ParallelCollectionScanOperation.createQueryResult(BsonDocument cursorDocument,
ServerAddress serverAddress) |
(package private) static MapReduceStatistics |
MapReduceHelper.createStatistics(BsonDocument result) |
(package private) static WriteConcernError |
WriteConcernHelper.createWriteConcernError(BsonDocument writeConcernErrorDocument) |
private static WriteConcernError |
FindAndModifyHelper.createWriteConcernError(BsonDocument writeConcernErrorDocument) |
(package private) static MongoWriteConcernException |
WriteConcernHelper.createWriteConcernError(BsonDocument result,
ServerAddress serverAddress) |
private static WriteConcernResult |
FindAndModifyHelper.createWriteConcernResult(BsonDocument result) |
(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> QueryResult<T> |
OperationHelper.cursorDocumentToQueryResult(BsonDocument cursorDocument,
ServerAddress serverAddress) |
private static <T> QueryResult<T> |
OperationHelper.cursorDocumentToQueryResult(BsonDocument cursorDocument,
ServerAddress serverAddress,
java.lang.String fieldNameContainingBatch) |
private QueryResult<T> |
FindOperation.documentToQueryResult(BsonDocument result,
ServerAddress serverAddress) |
(package private) static BsonDocument |
CommandOperationHelper.executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(package private) static BsonDocument |
CommandOperationHelper.executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> 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) |
private static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
Connection connection,
ReadPreference readPreference) |
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) |
private static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<T> decoder,
ConnectionSource source,
ReadPreference readPreference) |
(package private) static BsonDocument |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(package private) static BsonDocument |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(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,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(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 void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
SingleResultCallback<BsonDocument> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
SingleResultCallback<BsonDocument> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
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) |
(package private) static void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
SingleResultCallback<BsonDocument> 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,
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,
SingleResultCallback<T> callback) |
FindAndUpdateOperation<T> |
FindAndUpdateOperation.filter(BsonDocument filter)
Sets the filter to apply to the query.
|
MapReduceWithInlineResultsOperation<T> |
MapReduceWithInlineResultsOperation.filter(BsonDocument filter)
Sets the filter to apply to the query.
|
FindAndReplaceOperation<T> |
FindAndReplaceOperation.filter(BsonDocument filter)
Sets the query filter to apply to the query.
|
FindOperation<T> |
FindOperation.filter(BsonDocument filter)
Sets the query filter to apply to the query.
|
MapReduceToCollectionOperation |
MapReduceToCollectionOperation.filter(BsonDocument filter)
Sets the filter to apply to the query.
|
DistinctOperation<T> |
DistinctOperation.filter(BsonDocument filter)
Sets the query filter to apply to the query.
|
ListCollectionsOperation<T> |
ListCollectionsOperation.filter(BsonDocument filter)
Sets the query filter to apply to the query.
|
GroupOperation<T> |
GroupOperation.filter(BsonDocument filter)
Sets the optional query filter to determine which documents in the collection to process.
|
FindAndDeleteOperation<T> |
FindAndDeleteOperation.filter(BsonDocument filter)
Sets the filter to apply to the query.
|
CountOperation |
CountOperation.filter(BsonDocument filter)
Sets the filter to apply to the query.
|
(package private) static java.lang.String |
IndexHelper.generateIndexName(BsonDocument index)
Convenience method to generate an index name from the set of fields it is over.
|
private BsonDocument |
ParallelCollectionScanOperation.getCursorDocument(BsonDocument cursorDocument) |
private BsonArray |
ParallelCollectionScanOperation.getCursorDocuments(BsonDocument result) |
private static int |
MapReduceHelper.getDuration(BsonDocument result) |
private static int |
MapReduceHelper.getEmitCount(BsonDocument result) |
private static int |
MapReduceHelper.getInputCount(BsonDocument result) |
(package private) static <T> QueryResult<T> |
OperationHelper.getMoreCursorDocumentToQueryResult(BsonDocument cursorDocument,
ServerAddress serverAddress) |
private static int |
MapReduceHelper.getOutputCount(BsonDocument result) |
(package private) static boolean |
WriteConcernHelper.hasWriteConcernError(BsonDocument result) |
FindOperation<T> |
FindOperation.hint(BsonDocument hint)
Sets the hint for which index to use.
|
CreateCollectionOperation |
CreateCollectionOperation.indexOptionDefaults(BsonDocument indexOptionDefaults)
Sets the index option defaults document for the collection.
|
private void |
QueryBatchCursor.initFromCommandResult(BsonDocument getMoreCommandResultDocument) |
GroupOperation<T> |
GroupOperation.key(BsonDocument key)
Sets the document containing the field or fields to group.
|
FindOperation<T> |
FindOperation.max(BsonDocument max)
Sets the exclusive upper bound for a specific index.
|
FindOperation<T> |
FindOperation.min(BsonDocument min)
Sets the minimum inclusive lower bound for a specific index.
|
FindOperation<T> |
FindOperation.modifiers(BsonDocument modifiers)
Deprecated.
use the individual setters instead
|
void |
AsyncQueryBatchCursor.CommandResultSingleResultCallback.onResult(BsonDocument result,
java.lang.Throwable t) |
FindAndUpdateOperation<T> |
FindAndUpdateOperation.projection(BsonDocument projection)
Sets a document describing the fields to return for all matching documents.
|
FindAndReplaceOperation<T> |
FindAndReplaceOperation.projection(BsonDocument projection)
Sets a document describing the fields to return for all matching documents.
|
FindOperation<T> |
FindOperation.projection(BsonDocument projection)
Sets a document describing the fields to return for all matching documents.
|
FindAndDeleteOperation<T> |
FindAndDeleteOperation.projection(BsonDocument projection)
Sets a document describing the fields to return for all matching documents.
|
(package private) static void |
DocumentHelper.putIfNotNull(BsonDocument command,
java.lang.String key,
BsonValue value) |
(package private) static void |
DocumentHelper.putIfNotZero(BsonDocument command,
java.lang.String key,
int value) |
(package private) static void |
DocumentHelper.putIfNotZero(BsonDocument command,
java.lang.String key,
long value) |
(package private) static void |
DocumentHelper.putIfTrue(BsonDocument command,
java.lang.String key,
boolean condition) |
MapReduceWithInlineResultsOperation<T> |
MapReduceWithInlineResultsOperation.scope(BsonDocument scope)
Sets the global variables that are accessible in the map, reduce and finalize functions.
|
MapReduceToCollectionOperation |
MapReduceToCollectionOperation.scope(BsonDocument scope)
Sets the global variables that are accessible in the map, reduce and finalize functions.
|
FindAndUpdateOperation<T> |
FindAndUpdateOperation.sort(BsonDocument sort)
Sets the sort criteria to apply to the query.
|
MapReduceWithInlineResultsOperation<T> |
MapReduceWithInlineResultsOperation.sort(BsonDocument sort)
Sets the sort criteria to apply to the query.
|
FindAndReplaceOperation<T> |
FindAndReplaceOperation.sort(BsonDocument sort)
Sets the sort criteria to apply to the query.
|
FindOperation<T> |
FindOperation.sort(BsonDocument sort)
Sets the sort criteria to apply to the query.
|
MapReduceToCollectionOperation |
MapReduceToCollectionOperation.sort(BsonDocument sort)
Sets the sort criteria to apply to the query.
|
FindAndDeleteOperation<T> |
FindAndDeleteOperation.sort(BsonDocument sort)
Sets the sort criteria to apply to the query.
|
CreateCollectionOperation |
CreateCollectionOperation.storageEngineOptions(BsonDocument storageEngineOptions)
Sets the storage engine options document for this collection.
|
(package private) static void |
WriteConcernHelper.throwOnWriteConcernError(BsonDocument result,
ServerAddress serverAddress) |
(package private) static <T> T |
BsonDocumentWrapperHelper.toDocument(BsonDocument document) |
(package private) static <T> java.util.List<T> |
BsonDocumentWrapperHelper.toList(BsonDocument result,
java.lang.String fieldContainingWrappedArray) |
private BsonDocument |
MixedBulkWriteOperation.Run.BaseRunExecutor.translateGetLastErrorResponseToErrInfo(BsonDocument response) |
CreateCollectionOperation |
CreateCollectionOperation.validator(BsonDocument validator)
Sets the validation rules for inserting or updating documents
|
(package private) static BsonDocument |
CommandOperationHelper.wrapCommand(BsonDocument command,
ReadPreference readPreference,
ConnectionDescription connectionDescription) |
private BsonDocument |
FindOperation.wrapInExplainIfNecessary(BsonDocument commandDocument) |
Modifier and Type | Method and Description |
---|---|
void |
AggregateExplainOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<BsonDocument> callback) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> 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 <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 <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(package private) static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(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 <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 <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 <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 <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(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 <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 void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
SingleResultCallback<BsonDocument> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
SingleResultCallback<BsonDocument> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
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 <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 <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 <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 void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
SingleResultCallback<BsonDocument> callback) |
void |
FindOperation.ExplainResultCallback.onResult(AsyncBatchCursor<BsonDocument> cursor,
java.lang.Throwable t) |
private java.util.List<T> |
ListCollectionsOperation.projectFromFullNamespaceToCollectionName(java.util.List<BsonDocument> unstripped) |
Constructor and Description |
---|
CommandProtocolExecutingCallback(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,R> transformer,
SingleResultCallback<R> callback) |
CommandReadOperation(java.lang.String databaseName,
BsonDocument command,
Decoder<T> decoder)
Construct a new instance.
|
CommandWriteOperation(java.lang.String databaseName,
BsonDocument command,
Decoder<T> decoder)
Construct a new instance.
|
DropIndexOperation(MongoNamespace namespace,
BsonDocument keys)
|
DropIndexOperation(MongoNamespace namespace,
BsonDocument keys,
WriteConcern writeConcern)
Construct a new instance.
|
FindAndReplaceOperation(MongoNamespace namespace,
Decoder<T> decoder,
BsonDocument replacement)
|
FindAndReplaceOperation(MongoNamespace namespace,
WriteConcern writeConcern,
Decoder<T> decoder,
BsonDocument replacement)
Construct a new instance.
|
FindAndUpdateOperation(MongoNamespace namespace,
Decoder<T> decoder,
BsonDocument update)
|
FindAndUpdateOperation(MongoNamespace namespace,
WriteConcern writeConcern,
Decoder<T> decoder,
BsonDocument update)
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.
|
Constructor and Description |
---|
AggregateExplainOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline) |
AggregateOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline,
Decoder<T> decoder)
Construct a new instance.
|
AggregateToCollectionOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline)
|
AggregateToCollectionOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline,
WriteConcern writeConcern)
Construct a new instance.
|
CreateViewOperation(java.lang.String databaseName,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<BsonDocument> pipeline,
WriteConcern writeConcern)
Construct a new instance.
|
ExplainResultCallback(SingleResultCallback<BsonDocument> callback) |
ProjectingAsyncBatchCursor(AsyncBatchCursor<BsonDocument> delegate) |
ProjectingBatchCursor(BatchCursor<BsonDocument> delegate) |
Modifier and Type | Class and Description |
---|---|
class |
BsonDocumentWrapper<T>
A
BsonDocument that begins its life as a document of any type and an Encoder for that document, which lets an instance of
any class with an Encoder be treated as a BsonDocument. |
class |
RawBsonDocument
An immutable BSON document that is represented using only the raw bytes.
|
Modifier and Type | Field and Description |
---|---|
private BsonDocument |
BsonDocumentWriter.document |
private BsonDocument |
BsonJavaScriptWithScope.scope |
private BsonDocument |
BsonDocumentWrapper.unwrapped |
Modifier and Type | Method and Description |
---|---|
BsonDocument |
BsonDocument.append(java.lang.String key,
BsonValue value)
Put the given key and value into this document, and return the document.
|
BsonDocument |
RawBsonDocument.append(java.lang.String key,
BsonValue value) |
static BsonDocument |
BsonDocumentWrapper.asBsonDocument(java.lang.Object document,
CodecRegistry codecRegistry)
A helper to convert an document of type Object to a BsonDocument
|
BsonDocument |
BsonValue.asDocument()
Gets this value as a BsonDocument if it is one, otherwise throws exception
|
BsonDocument |
BsonDocument.clone() |
BsonDocument |
RawBsonDocument.clone() |
BsonDocument |
BsonDocumentWrapper.clone() |
BsonDocument |
BsonDocumentWriter.getDocument()
Gets the document that the writer is writing to.
|
BsonDocument |
BsonDocument.getDocument(java.lang.Object key)
Gets the value of the key if it is a BsonDocument, or throws if not.
|
BsonDocument |
BsonDocument.getDocument(java.lang.Object key,
BsonDocument defaultValue)
If the document does not contain the given key, return the given default value.
|
BsonDocument |
BsonJavaScriptWithScope.getScope()
Get the scope.
|
private BsonDocument |
BsonDocumentWrapper.getUnwrapped() |
static BsonDocument |
BsonDocument.parse(java.lang.String json)
Parses a string in MongoDB Extended JSON format to a
BsonDocument |
private BsonDocument |
RawBsonDocument.toBsonDocument() |
<C> BsonDocument |
BsonDocument.toBsonDocument(java.lang.Class<C> documentClass,
CodecRegistry codecRegistry) |
<C> BsonDocument |
Document.toBsonDocument(java.lang.Class<C> documentClass,
CodecRegistry codecRegistry) |
Modifier and Type | Method and Description |
---|---|
BsonDocument |
BsonDocument.getDocument(java.lang.Object key,
BsonDocument defaultValue)
If the document does not contain the given key, return the given default value.
|
Constructor and Description |
---|
BsonDocumentReader(BsonDocument document)
Construct a new instance.
|
BsonDocumentWriter(BsonDocument document)
Construct a new instance.
|
BsonJavaScriptWithScope(java.lang.String code,
BsonDocument scope)
Construct a new instance with the given code and scope.
|
Context(BsonDocumentReader.Context parentContext,
BsonContextType contextType,
BsonDocument document) |
SerializationProxy(BsonDocument document) |
Modifier and Type | Field and Description |
---|---|
private Codec<BsonDocument> |
BsonDocumentWrapperCodec.bsonDocumentCodec |
private Codec<BsonDocument> |
BsonJavaScriptWithScopeCodec.documentCodec |
Modifier and Type | Method and Description |
---|---|
BsonDocument |
BsonDocumentCodec.decode(BsonReader reader,
DecoderContext decoderContext) |
BsonDocument |
BsonDocumentCodec.generateIdIfAbsentFromDocument(BsonDocument document) |
Modifier and Type | Method and Description |
---|---|
java.lang.Class<BsonDocument> |
BsonDocumentCodec.getEncoderClass() |
Modifier and Type | Method and Description |
---|---|
private void |
BsonDocumentCodec.beforeFields(BsonWriter bsonWriter,
EncoderContext encoderContext,
BsonDocument value) |
boolean |
BsonDocumentCodec.documentHasId(BsonDocument document) |
void |
BsonDocumentCodec.encode(BsonWriter writer,
BsonDocument value,
EncoderContext encoderContext) |
BsonDocument |
BsonDocumentCodec.generateIdIfAbsentFromDocument(BsonDocument document) |
BsonValue |
BsonDocumentCodec.getDocumentId(BsonDocument document) |
Constructor and Description |
---|
BsonDocumentWrapperCodec(Codec<BsonDocument> bsonDocumentCodec)
Construct a new instance,
|
BsonJavaScriptWithScopeCodec(Codec<BsonDocument> documentCodec)
Construct a new instance with the given codec to use for the nested document
|
Modifier and Type | Method and Description |
---|---|
<TDocument> |
Bson.toBsonDocument(java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry)
Render the filter into a BsonDocument.
|