com.mongodb

Class OutMessage

java.lang.Object

org.bson.BasicBSONEncoder

com.mongodb.OutMessage

All Implemented Interfaces:

BSONEncoder

class OutMessage
extends BasicBSONEncoder

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	OutMessage.OpCode

Field Summary

Fields

Modifier and Type	Field and Description
private PoolOutputBuffer	_buffer
private DBCollection	_collection
private DBEncoder	_encoder
private int	_id
private int	_maxBSONObjectSize
private Mongo	_mongo
private int	_numDocuments
private OutMessage.OpCode	_opCode
private DBObject	_query
private int	_queryOptions
(package private) static java.util.concurrent.atomic.AtomicInteger	REQUEST_ID

Fields inherited from class org.bson.BasicBSONEncoder

_buf

Constructor Summary

Constructors

Modifier	Constructor and Description
private	OutMessage(DBCollection collection, DBEncoder enc, DBObject query, int options, ReadPreference readPref, int maxBSONObjectSize)
private	OutMessage(DBCollection collection, Mongo m, OutMessage.OpCode opCode, DBEncoder enc)
private	OutMessage(DBCollection collection, Mongo m, OutMessage.OpCode opCode, DBEncoder enc, DBObject query, int options, ReadPreference readPref, int maxBSONObjectSize)
private	OutMessage(DBCollection collection, OutMessage.OpCode opCode)
private	OutMessage(DBCollection collection, OutMessage.OpCode opCode, DBEncoder enc)
private	OutMessage(DBCollection collection, OutMessage.OpCode opCode, DBEncoder enc, DBObject query)
private	OutMessage(Mongo m, OutMessage.OpCode opCode)

Method Summary

Modifier and Type	Method and Description
(package private) void	doneWithMessage()
(package private) int	getId()
(package private) static OutMessage	getMore(DBCollection collection, long cursorId, int batchSize)
(package private) java.lang.String	getNamespace()
(package private) int	getNumDocuments()
(package private) OutMessage.OpCode	getOpCode()
(package private) DBObject	getQuery()
(package private) boolean	hasOption(int option)
static OutMessage	insert(DBCollection collection, DBEncoder encoder, WriteConcern concern)
(package private) static OutMessage	killCursors(Mongo mongo, int numCursors)
(package private) void	pipe(java.io.OutputStream out)
(package private) void	prepare()
int	putObject(BSONObject o) Encodes a BSONObject.
(package private) static OutMessage	query(DBCollection collection, int options, int numToSkip, int batchSize, DBObject query, DBObject fields, int maxBSONObjectSize)
(package private) static OutMessage	query(DBCollection collection, int options, int numToSkip, int batchSize, DBObject query, DBObject fields, ReadPreference readPref, DBEncoder enc)
(package private) static OutMessage	query(DBCollection collection, int options, int numToSkip, int batchSize, DBObject query, DBObject fields, ReadPreference readPref, DBEncoder enc, int maxBSONObjectSize)
static OutMessage	remove(DBCollection collection, DBEncoder encoder, DBObject query, boolean multi)
(package private) int	size()
static OutMessage	update(DBCollection collection, DBEncoder encoder, boolean upsert, boolean multi, DBObject query, DBObject o)
private void	writeGetMore(long cursorId, int batchSize)
private void	writeInsertPrologue(WriteConcern concern)
private void	writeKillCursorsPrologue(int numCursors)
private void	writeMessagePrologue(OutMessage.OpCode opCode)
private void	writeQuery(DBObject fields, int numToSkip, int batchSize)
private void	writeRemove(boolean multi)
private void	writeUpdate(boolean upsert, boolean multi, DBObject query, DBObject o)

Methods inherited from class org.bson.BasicBSONEncoder

_put, _put, _putObjectField, _putValueString, done, encode, getOutputBuffer, handleSpecialObjects, putBinary, putBinary, putBoolean, putCode, putCodeWScope, putDate, putNull, putNumber, putObject, putObjectId, putSpecial, putString, putSymbol, putTimestamp, putUndefined, putUUID, set, writeCString, writeInt, writeLong

Methods inherited from class java.lang.Object

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

Field Detail

REQUEST_ID

static java.util.concurrent.atomic.AtomicInteger REQUEST_ID

_mongo

private final Mongo _mongo

_collection

private final DBCollection _collection

_buffer

private PoolOutputBuffer _buffer

_id

private final int _id

_opCode

private final OutMessage.OpCode _opCode

_queryOptions

private final int _queryOptions

_query

private final DBObject _query

_encoder

private final DBEncoder _encoder

_maxBSONObjectSize

private final int _maxBSONObjectSize

_numDocuments

private volatile int _numDocuments

Constructor Detail

OutMessage

private OutMessage(Mongo m,
                   OutMessage.OpCode opCode)

OutMessage

private OutMessage(DBCollection collection,
                   OutMessage.OpCode opCode)

OutMessage

private OutMessage(DBCollection collection,
                   OutMessage.OpCode opCode,
                   DBEncoder enc)

OutMessage

private OutMessage(DBCollection collection,
                   Mongo m,
                   OutMessage.OpCode opCode,
                   DBEncoder enc)

OutMessage

private OutMessage(DBCollection collection,
                   OutMessage.OpCode opCode,
                   DBEncoder enc,
                   DBObject query)

OutMessage

private OutMessage(DBCollection collection,
                   DBEncoder enc,
                   DBObject query,
                   int options,
                   ReadPreference readPref,
                   int maxBSONObjectSize)

OutMessage

private OutMessage(DBCollection collection,
                   Mongo m,
                   OutMessage.OpCode opCode,
                   DBEncoder enc,
                   DBObject query,
                   int options,
                   ReadPreference readPref,
                   int maxBSONObjectSize)

Method Detail

insert

public static OutMessage insert(DBCollection collection,
                                DBEncoder encoder,
                                WriteConcern concern)

update

public static OutMessage update(DBCollection collection,
                                DBEncoder encoder,
                                boolean upsert,
                                boolean multi,
                                DBObject query,
                                DBObject o)

remove

public static OutMessage remove(DBCollection collection,
                                DBEncoder encoder,
                                DBObject query,
                                boolean multi)

query

static OutMessage query(DBCollection collection,
                        int options,
                        int numToSkip,
                        int batchSize,
                        DBObject query,
                        DBObject fields,
                        int maxBSONObjectSize)

query

static OutMessage query(DBCollection collection,
                        int options,
                        int numToSkip,
                        int batchSize,
                        DBObject query,
                        DBObject fields,
                        ReadPreference readPref,
                        DBEncoder enc)

query

static OutMessage query(DBCollection collection,
                        int options,
                        int numToSkip,
                        int batchSize,
                        DBObject query,
                        DBObject fields,
                        ReadPreference readPref,
                        DBEncoder enc,
                        int maxBSONObjectSize)

getMore

static OutMessage getMore(DBCollection collection,
                          long cursorId,
                          int batchSize)

killCursors

static OutMessage killCursors(Mongo mongo,
                              int numCursors)

writeInsertPrologue

private void writeInsertPrologue(WriteConcern concern)

writeUpdate

private void writeUpdate(boolean upsert,
                         boolean multi,
                         DBObject query,
                         DBObject o)

writeRemove

private void writeRemove(boolean multi)

writeGetMore

private void writeGetMore(long cursorId,
                          int batchSize)

writeKillCursorsPrologue

private void writeKillCursorsPrologue(int numCursors)

writeQuery

private void writeQuery(DBObject fields,
                        int numToSkip,
                        int batchSize)

writeMessagePrologue

private void writeMessagePrologue(OutMessage.OpCode opCode)

prepare

void prepare()

pipe

void pipe(java.io.OutputStream out)
   throws java.io.IOException

Throws:

java.io.IOException

size

int size()

doneWithMessage

void doneWithMessage()

hasOption

boolean hasOption(int option)

getId

int getId()

getOpCode

OutMessage.OpCode getOpCode()

getQuery

DBObject getQuery()

getNamespace

java.lang.String getNamespace()

getNumDocuments

int getNumDocuments()

putObject

public int putObject(BSONObject o)

Description copied from class: BasicBSONEncoder

Encodes a BSONObject. This is for the higher level api calls.

Specified by:

putObject in interface BSONEncoder

Overrides:

putObject in class BasicBSONEncoder

Parameters:

o - the document to encode

Returns:

the number of characters in the encoding