com.mongodb

Class DBCollectionImpl.Run.RunExecutor

java.lang.Object

com.mongodb.DBCollectionImpl.Run.RunExecutor

Enclosing class:

DBCollectionImpl.Run

private abstract class DBCollectionImpl.Run.RunExecutor
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private DBPort	port

Constructor Summary

Constructors

Constructor and Description
RunExecutor(DBPort port)

Method Summary

Modifier and Type	Method and Description
(package private) WriteResult	addMissingUpserted(ModifyRequest update, WriteResult writeResult)
(package private) BulkWriteResult	execute()
(package private) abstract BulkWriteResult	executeWriteCommandProtocol()
private BulkWriteResult	executeWriteProtocol()
(package private) abstract WriteResult	executeWriteProtocol(int i)
private BulkWriteError	getBulkWriteError(WriteConcernException writeException)
private int	getCount(WriteResult writeResult)
private DBObject	getErrorResponseDetails(DBObject response)
(package private) BulkWriteResult	getResult(WriteResult writeResult)
(package private) abstract WriteRequest.Type	getType()
(package private) java.util.List<BulkWriteUpsert>	getUpsertedItems(WriteResult writeResult)
private WriteConcernError	getWriteConcernError(CommandResult commandResult)
private java.lang.String	getWriteConcernErrorMessage(CommandResult commandResult)
private boolean	isWriteConcernError(CommandResult commandResult)

Methods inherited from class java.lang.Object

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

Field Detail

port

private final DBPort port

Constructor Detail

RunExecutor

RunExecutor(DBPort port)

Method Detail

executeWriteCommandProtocol

abstract BulkWriteResult executeWriteCommandProtocol()

executeWriteProtocol

abstract WriteResult executeWriteProtocol(int i)

getType

abstract WriteRequest.Type getType()

getResult

BulkWriteResult getResult(WriteResult writeResult)

execute

BulkWriteResult execute()

executeWriteProtocol

private BulkWriteResult executeWriteProtocol()

getCount

private int getCount(WriteResult writeResult)

getUpsertedItems

java.util.List<BulkWriteUpsert> getUpsertedItems(WriteResult writeResult)

getBulkWriteError

private BulkWriteError getBulkWriteError(WriteConcernException writeException)

isWriteConcernError

private boolean isWriteConcernError(CommandResult commandResult)

getWriteConcernError

private WriteConcernError getWriteConcernError(CommandResult commandResult)

getWriteConcernErrorMessage

private java.lang.String getWriteConcernErrorMessage(CommandResult commandResult)

getErrorResponseDetails

private DBObject getErrorResponseDetails(DBObject response)

addMissingUpserted

WriteResult addMissingUpserted(ModifyRequest update,
                               WriteResult writeResult)