com.mongodb

Class DBCollectionImpl.Run

java.lang.Object

com.mongodb.DBCollectionImpl.Run

Enclosing class:

DBCollectionImpl

private class DBCollectionImpl.Run
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	DBCollectionImpl.Run.RunExecutor

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.Boolean	bypassDocumentValidation
private DBEncoder	encoder
private IndexMap	indexMap
private WriteRequest.Type	type
private WriteConcern	writeConcern
private java.util.List<WriteRequest>	writeRequests

Constructor Summary

Constructors

Constructor and Description
Run(WriteRequest.Type type, java.lang.Boolean bypassDocumentValidation, WriteConcern writeConcern, DBEncoder encoder)

Method Summary

Modifier and Type	Method and Description
(package private) void	add(WriteRequest writeRequest, int originalIndex)
(package private) BulkWriteResult	execute(DBPort port)
(package private) BulkWriteResult	executeInserts(java.util.List<InsertRequest> insertRequests, DBPort port)
(package private) BulkWriteResult	executeRemoves(java.util.List<RemoveRequest> removeRequests, DBPort port)
(package private) BulkWriteResult	executeReplaces(java.util.List<ModifyRequest> replaceRequests, DBPort port)
(package private) BulkWriteResult	executeUpdates(java.util.List<ModifyRequest> updateRequests, DBPort port)
private java.util.List<InsertRequest>	getWriteRequestsAsInsertRequests()
private java.util.List<ModifyRequest>	getWriteRequestsAsModifyRequests()
private java.util.List	getWriteRequestsAsRaw()
private java.util.List<RemoveRequest>	getWriteRequestsAsRemoveRequests()
int	size()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

writeRequests

private final java.util.List<WriteRequest> writeRequests

type

private final WriteRequest.Type type

bypassDocumentValidation

private final java.lang.Boolean bypassDocumentValidation

writeConcern

private final WriteConcern writeConcern

encoder

private final DBEncoder encoder

indexMap

private IndexMap indexMap

Constructor Detail

Run

Run(WriteRequest.Type type,
    java.lang.Boolean bypassDocumentValidation,
    WriteConcern writeConcern,
    DBEncoder encoder)

Method Detail

add

void add(WriteRequest writeRequest,
         int originalIndex)

size

public int size()

execute

BulkWriteResult execute(DBPort port)

getWriteRequestsAsRaw

private java.util.List getWriteRequestsAsRaw()

getWriteRequestsAsRemoveRequests

private java.util.List<RemoveRequest> getWriteRequestsAsRemoveRequests()

getWriteRequestsAsInsertRequests

private java.util.List<InsertRequest> getWriteRequestsAsInsertRequests()

getWriteRequestsAsModifyRequests

private java.util.List<ModifyRequest> getWriteRequestsAsModifyRequests()

executeUpdates

BulkWriteResult executeUpdates(java.util.List<ModifyRequest> updateRequests,
                               DBPort port)

executeReplaces

BulkWriteResult executeReplaces(java.util.List<ModifyRequest> replaceRequests,
                                DBPort port)

executeRemoves

BulkWriteResult executeRemoves(java.util.List<RemoveRequest> removeRequests,
                               DBPort port)

executeInserts

BulkWriteResult executeInserts(java.util.List<InsertRequest> insertRequests,
                               DBPort port)