T |
OperationHelper.CallableWithConnection.call(Connection connection) |
T |
OperationHelper.CallableWithConnectionAndSource.call(ConnectionSource source,
Connection connection) |
(package private) static void |
OperationHelper.checkBypassDocumentValidationIsSupported(Connection connection,
java.lang.Boolean bypassDocumentValidation,
WriteConcern writeConcern) |
(package private) BulkWriteResult |
MixedBulkWriteOperation.Run.execute(Connection connection) |
protected abstract BulkWriteResult |
BaseWriteOperation.executeCommandProtocol(Connection connection)
Executes the write command protocol.
|
protected BulkWriteResult |
UpdateOperation.executeCommandProtocol(Connection connection) |
protected BulkWriteResult |
InsertOperation.executeCommandProtocol(Connection connection) |
protected BulkWriteResult |
DeleteOperation.executeCommandProtocol(Connection connection) |
protected abstract WriteConcernResult |
BaseWriteOperation.executeProtocol(Connection connection)
Executes the write protocol
|
protected WriteConcernResult |
UpdateOperation.executeProtocol(Connection connection) |
protected WriteConcernResult |
InsertOperation.executeProtocol(Connection connection) |
protected WriteConcernResult |
DeleteOperation.executeProtocol(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) |
private static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
Connection connection,
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) |
(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) |
(package private) MixedBulkWriteOperation.Run.RunExecutor |
MixedBulkWriteOperation.Run.getDeletesRunExecutor(java.util.List<DeleteRequest> deleteRequests,
Connection connection) |
(package private) MixedBulkWriteOperation.Run.RunExecutor |
MixedBulkWriteOperation.Run.getInsertsRunExecutor(java.util.List<InsertRequest> insertRequests,
java.lang.Boolean bypassDocumentValidation,
Connection connection) |
(package private) MixedBulkWriteOperation.Run.RunExecutor |
MixedBulkWriteOperation.Run.getUpdatesRunExecutor(java.util.List<UpdateRequest> updates,
java.lang.Boolean bypassDocumentValidation,
Connection connection) |
private void |
QueryBatchCursor.killCursor(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>> |
AggregateOperation.transformer(ConnectionSource source,
Connection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,MapReduceBatchCursor<T>> |
MapReduceWithInlineResultsOperation.transformer(ConnectionSource source,
Connection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,BatchCursor<T>> |
FindOperation.transformer(ConnectionSource source,
Connection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,BatchCursor<T>> |
GroupOperation.transformer(ConnectionSource source,
Connection connection) |
(package private) static void |
OperationHelper.validateCollation(Connection connection,
Collation collation) |
(package private) static void |
OperationHelper.validateCollationAndWriteConcern(Connection connection,
Collation collation,
WriteConcern writeConcern) |
(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) |
(package private) static void |
OperationHelper.validateWriteRequestCollations(Connection connection,
java.util.List<? extends WriteRequest> requests,
WriteConcern writeConcern) |
(package private) static void |
OperationHelper.validateWriteRequests(Connection connection,
java.lang.Boolean bypassDocumentValidation,
java.util.List<? extends WriteRequest> requests,
WriteConcern writeConcern) |