Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.binding |
This package contains classes that manage binding to MongoDB servers for various operations.
|
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
ClientSessionBinding |
Modifier and Type | Method and Description |
---|---|
BatchCursor<TResult> |
MapReduceIterableImpl.WrappedMapReduceReadOperation.execute(ReadBinding binding) |
Modifier and Type | Interface and Description |
---|---|
interface |
ReadWriteBinding
A factory of connection sources to servers that can be read from or written to.
|
Modifier and Type | Class and Description |
---|---|
class |
ClusterBinding
A simple ReadWriteBinding implementation that supplies write connection sources bound to a possibly different primary each time, and a
read connection source bound to a possible different server each time.
|
class |
SingleConnectionReadBinding
A read binding that is bound to a single connection.
|
class |
SingleServerBinding
A simple binding where all connection sources are bound to the server specified in the constructor.
|
Modifier and Type | Method and Description |
---|---|
ReadBinding |
ReadBinding.retain() |
ReadBinding |
SingleConnectionReadBinding.retain() |
Modifier and Type | Field and Description |
---|---|
private ReadBinding |
ChangeStreamBatchCursor.binding |
Modifier and Type | Method and Description |
---|---|
java.util.List<BatchCursor<T>> |
ParallelCollectionScanOperation.execute(ReadBinding binding) |
BatchCursor<T> |
FindOperation.execute(ReadBinding binding) |
BatchCursor<T> |
DistinctOperation.execute(ReadBinding binding) |
BsonDocument |
AggregateExplainOperation.execute(ReadBinding binding) |
BatchCursor<T> |
GroupOperation.execute(ReadBinding binding)
Will return a cursor of Documents containing the results of the group operation.
|
java.lang.Long |
CountOperation.execute(ReadBinding binding) |
java.lang.Boolean |
UserExistsOperation.execute(ReadBinding binding) |
T |
CommandReadOperation.execute(ReadBinding binding) |
BatchCursor<T> |
ListCollectionsOperation.execute(ReadBinding binding) |
BatchCursor<T> |
ChangeStreamOperation.execute(ReadBinding binding) |
BsonDocument |
FsyncUnlockOperation.execute(ReadBinding binding) |
BatchCursor<T> |
ListDatabasesOperation.execute(ReadBinding binding)
Executing this will return a list of all the databases names in the MongoDB instance.
|
BatchCursor<T> |
AggregateOperation.execute(ReadBinding binding) |
MapReduceBatchCursor<T> |
MapReduceWithInlineResultsOperation.execute(ReadBinding binding)
Executing this will return a cursor with your results and the statistics in.
|
T |
ReadOperation.execute(ReadBinding binding)
General execute which can return anything of type T
|
BatchCursor<T> |
ListIndexesOperation.execute(ReadBinding binding) |
BsonDocument |
CurrentOpOperation.execute(ReadBinding binding) |
(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) |
(package private) static <T> T |
OperationHelper.withConnection(ReadBinding binding,
OperationHelper.CallableWithConnection<T> callable) |
(package private) static <T> T |
OperationHelper.withConnection(ReadBinding binding,
OperationHelper.CallableWithConnectionAndSource<T> callable) |
Constructor and Description |
---|
ChangeStreamBatchCursor(ChangeStreamOperation<T> changeStreamOperation,
BatchCursor<RawBsonDocument> wrapped,
ReadBinding binding) |