T |
OperationHelper.CallableWithConnection.call(Connection connection) |
T |
OperationHelper.CallableWithConnectionAndSource.call(ConnectionSource source,
Connection connection) |
private BulkWriteResult |
MixedBulkWriteOperation.executeBulkWriteBatch(WriteBinding binding,
Connection connection,
BulkWriteBatch originalBatch) |
private BsonDocument |
MixedBulkWriteOperation.executeCommand(Connection connection,
BulkWriteBatch batch,
WriteBinding binding) |
private BulkWriteResult |
MixedBulkWriteOperation.executeLegacyBatches(Connection connection) |
(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) |
private static <D,T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
Connection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SessionContext sessionContext) |
private static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
Connection connection,
ReadPreference readPreference,
SessionContext sessionContext) |
private static <D,T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
Connection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SessionContext sessionContext) |
(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 <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<BsonDocument> decoder,
Connection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
private void |
QueryBatchCursor.killCursor(Connection connection) |
private BsonDocument |
FsyncUnlockOperation.queryUnlock(Connection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,BatchCursor<T>> |
ListDatabasesOperation.transformer(ConnectionSource source,
Connection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,BatchCursor<T>> |
DistinctOperation.transformer(ConnectionSource source,
Connection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,BatchCursor<T>> |
GroupOperation.transformer(ConnectionSource source,
Connection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,BatchCursor<T>> |
AggregateOperation.transformer(ConnectionSource source,
Connection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,BatchCursor<T>> |
FindOperation.transformer(ConnectionSource source,
Connection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,MapReduceBatchCursor<T>> |
MapReduceWithInlineResultsOperation.transformer(ConnectionSource source,
Connection connection) |
(package private) static void |
OperationHelper.validateCollation(Connection connection,
Collation collation) |
(package private) static void |
OperationHelper.validateIndexRequestCollations(Connection connection,
java.util.List<IndexRequest> requests) |
(package private) static void |
OperationHelper.validateReadConcern(Connection connection,
ReadConcern readConcern) |
(package private) static void |
OperationHelper.validateReadConcernAndCollation(Connection connection,
ReadConcern readConcern,
Collation collation) |
private void |
MixedBulkWriteOperation.validateWriteRequestsAndReleaseConnectionIfError(Connection connection) |