final class CommandOperationHelper
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
private static class |
CommandOperationHelper.CommandProtocolExecutingCallback<D,R> |
(package private) static interface |
CommandOperationHelper.CommandTransformer<T,R> |
(package private) static class |
CommandOperationHelper.IdentityTransformer<T> |
(package private) static class |
CommandOperationHelper.VoidTransformer<T> |
Modifier | Constructor and Description |
---|---|
private |
CommandOperationHelper() |
Modifier and Type | Method and Description |
---|---|
(package private) static BsonDocument |
executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command) |
(package private) static <T> T |
executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(package private) static BsonDocument |
executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection) |
(package private) static <T> T |
executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(package private) static <T> T |
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 |
executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer) |
(package private) static <T> T |
executeWrappedCommandProtocol(ReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<T> decoder) |
private static <D,T> T |
executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
Connection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer) |
private static <T> T |
executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
Connection connection,
ReadPreference readPreference) |
private static <T> T |
executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
ConnectionSource source,
ReadPreference readPreference) |
private static <D,T> T |
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 |
executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<T> decoder,
ConnectionSource source,
ReadPreference readPreference) |
(package private) static BsonDocument |
executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command) |
(package private) static <T> T |
executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(package private) static BsonDocument |
executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection) |
(package private) static <T> T |
executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
Connection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer) |
(package private) static <T> T |
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 |
executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer) |
(package private) static <T> T |
executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<T> decoder) |
(package private) static <T> T |
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 |
executeWrappedCommandProtocol(WriteBinding binding,
java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer) |
(package private) static <T> void |
executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
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 |
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 |
executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
SingleResultCallback<T> callback) |
(package private) static void |
executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
SingleResultCallback<BsonDocument> callback) |
(package private) static <T> void |
executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static void |
executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
SingleResultCallback<BsonDocument> callback) |
(package private) static <T> void |
executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
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 |
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 |
executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
SingleResultCallback<T> callback) |
(package private) static <T> void |
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 |
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 |
executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
SingleResultCallback<BsonDocument> callback) |
private static <D,T> void |
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 |
executeWrappedCommandProtocolAsync(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
AsyncConnection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
(package private) static boolean |
isNamespaceError(java.lang.Throwable t) |
(package private) static void |
rethrowIfNotNamespaceError(MongoCommandException e) |
(package private) static <T> T |
rethrowIfNotNamespaceError(MongoCommandException e,
T defaultValue) |
(package private) static BsonDocument |
wrapCommand(BsonDocument command,
ReadPreference readPreference,
ConnectionDescription connectionDescription) |
static BsonDocument executeWrappedCommandProtocol(ReadBinding binding, java.lang.String database, BsonDocument command)
static <T> T executeWrappedCommandProtocol(ReadBinding binding, java.lang.String database, BsonDocument command, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer)
static <T> T executeWrappedCommandProtocol(ReadBinding binding, java.lang.String database, BsonDocument command, Decoder<T> decoder)
static <D,T> T executeWrappedCommandProtocol(ReadBinding binding, java.lang.String database, BsonDocument command, Decoder<D> decoder, CommandOperationHelper.CommandTransformer<D,T> transformer)
static BsonDocument executeWrappedCommandProtocol(ReadBinding binding, java.lang.String database, BsonDocument command, Connection connection)
static <T> T executeWrappedCommandProtocol(ReadBinding binding, java.lang.String database, BsonDocument command, Connection connection, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer)
static <T> T executeWrappedCommandProtocol(ReadBinding binding, java.lang.String database, BsonDocument command, Decoder<BsonDocument> decoder, Connection connection, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer)
static BsonDocument executeWrappedCommandProtocol(WriteBinding binding, java.lang.String database, BsonDocument command)
static <T> T executeWrappedCommandProtocol(WriteBinding binding, java.lang.String database, BsonDocument command, Decoder<T> decoder)
static <T> T executeWrappedCommandProtocol(WriteBinding binding, java.lang.String database, BsonDocument command, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer)
static <D,T> T executeWrappedCommandProtocol(WriteBinding binding, java.lang.String database, BsonDocument command, Decoder<D> decoder, CommandOperationHelper.CommandTransformer<D,T> transformer)
static <T> T executeWrappedCommandProtocol(WriteBinding binding, java.lang.String database, BsonDocument command, Connection connection, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer)
static <T> T executeWrappedCommandProtocol(WriteBinding binding, java.lang.String database, BsonDocument command, Decoder<BsonDocument> decoder, Connection connection, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer)
static <T> T executeWrappedCommandProtocol(WriteBinding binding, java.lang.String database, BsonDocument command, FieldNameValidator fieldNameValidator, Decoder<BsonDocument> decoder, Connection connection, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer)
static <D,T> T executeWrappedCommandProtocol(WriteBinding binding, java.lang.String database, BsonDocument command, FieldNameValidator fieldNameValidator, Decoder<D> decoder, CommandOperationHelper.CommandTransformer<D,T> transformer)
static BsonDocument executeWrappedCommandProtocol(WriteBinding binding, java.lang.String database, BsonDocument command, Connection connection)
private static <T> T executeWrappedCommandProtocol(java.lang.String database, BsonDocument command, Decoder<T> decoder, ConnectionSource source, ReadPreference readPreference)
private static <T> T executeWrappedCommandProtocol(java.lang.String database, BsonDocument command, FieldNameValidator fieldNameValidator, Decoder<T> decoder, ConnectionSource source, ReadPreference readPreference)
private static <T> T executeWrappedCommandProtocol(java.lang.String database, BsonDocument command, Decoder<T> decoder, Connection connection, ReadPreference readPreference)
private static <D,T> T executeWrappedCommandProtocol(java.lang.String database, BsonDocument command, Decoder<D> decoder, Connection connection, ReadPreference readPreference, CommandOperationHelper.CommandTransformer<D,T> transformer)
private static <D,T> T executeWrappedCommandProtocol(java.lang.String database, BsonDocument command, FieldNameValidator fieldNameValidator, Decoder<D> decoder, Connection connection, ReadPreference readPreference, CommandOperationHelper.CommandTransformer<D,T> transformer)
static void executeWrappedCommandProtocolAsync(AsyncReadBinding binding, java.lang.String database, BsonDocument command, SingleResultCallback<BsonDocument> callback)
static <T> void executeWrappedCommandProtocolAsync(AsyncReadBinding binding, java.lang.String database, BsonDocument command, Decoder<T> decoder, SingleResultCallback<T> callback)
static <T> void executeWrappedCommandProtocolAsync(AsyncReadBinding binding, java.lang.String database, BsonDocument command, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer, SingleResultCallback<T> callback)
static <D,T> void executeWrappedCommandProtocolAsync(AsyncReadBinding binding, java.lang.String database, BsonDocument command, Decoder<D> decoder, CommandOperationHelper.CommandTransformer<D,T> transformer, SingleResultCallback<T> callback)
static <T> void executeWrappedCommandProtocolAsync(AsyncReadBinding binding, java.lang.String database, BsonDocument command, AsyncConnection connection, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer, SingleResultCallback<T> callback)
static <T> void executeWrappedCommandProtocolAsync(AsyncReadBinding binding, java.lang.String database, BsonDocument command, Decoder<BsonDocument> decoder, AsyncConnection connection, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer, SingleResultCallback<T> callback)
static void executeWrappedCommandProtocolAsync(AsyncWriteBinding binding, java.lang.String database, BsonDocument command, SingleResultCallback<BsonDocument> callback)
static <T> void executeWrappedCommandProtocolAsync(AsyncWriteBinding binding, java.lang.String database, BsonDocument command, Decoder<T> decoder, SingleResultCallback<T> callback)
static <T> void executeWrappedCommandProtocolAsync(AsyncWriteBinding binding, java.lang.String database, BsonDocument command, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer, SingleResultCallback<T> callback)
static <D,T> void executeWrappedCommandProtocolAsync(AsyncWriteBinding binding, java.lang.String database, BsonDocument command, Decoder<D> decoder, CommandOperationHelper.CommandTransformer<D,T> transformer, SingleResultCallback<T> callback)
static <T> void executeWrappedCommandProtocolAsync(AsyncWriteBinding binding, java.lang.String database, BsonDocument command, Decoder<BsonDocument> decoder, AsyncConnection connection, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer, SingleResultCallback<T> callback)
static <T> void executeWrappedCommandProtocolAsync(AsyncWriteBinding binding, java.lang.String database, BsonDocument command, FieldNameValidator fieldNameValidator, Decoder<BsonDocument> decoder, AsyncConnection connection, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer, SingleResultCallback<T> callback)
static <D,T> void executeWrappedCommandProtocolAsync(AsyncWriteBinding binding, java.lang.String database, BsonDocument command, FieldNameValidator fieldNameValidator, Decoder<D> decoder, CommandOperationHelper.CommandTransformer<D,T> transformer, SingleResultCallback<T> callback)
static void executeWrappedCommandProtocolAsync(AsyncWriteBinding binding, java.lang.String database, BsonDocument command, AsyncConnection connection, SingleResultCallback<BsonDocument> callback)
static <T> void executeWrappedCommandProtocolAsync(AsyncWriteBinding binding, java.lang.String database, BsonDocument command, AsyncConnection connection, CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer, SingleResultCallback<T> callback)
private static <D,T> void 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 executeWrappedCommandProtocolAsync(java.lang.String database, BsonDocument command, FieldNameValidator fieldNameValidator, Decoder<D> decoder, AsyncConnection connection, ReadPreference readPreference, CommandOperationHelper.CommandTransformer<D,T> transformer, SingleResultCallback<T> callback)
static void rethrowIfNotNamespaceError(MongoCommandException e)
static <T> T rethrowIfNotNamespaceError(MongoCommandException e, T defaultValue)
static boolean isNamespaceError(java.lang.Throwable t)
static BsonDocument wrapCommand(BsonDocument command, ReadPreference readPreference, ConnectionDescription connectionDescription)