org.qbroker.net

Class MongoDBConnector

java.lang.Object

org.qbroker.net.MongoDBConnector

All Implemented Interfaces:

Connector

Direct Known Subclasses:

MongoDBMessenger

public class MongoDBConnector
extends java.lang.Object
implements Connector

MongoDBConnector connects to a MongoDB and provides some basic DB operation methods: list(), count(), find(), findone(), insert(), update() and remove().

This is NOT MT-Safe. Therefore, you need to use multiple instances to achieve your MT-Safty goal.

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
static int	ACTION_COUNT
static int	ACTION_FIND
static int	ACTION_FINDANDMODIFY
static int	ACTION_FINDANDREMOVE
static int	ACTION_FINDONE
static int	ACTION_GROUP
static int	ACTION_INSERT
static int	ACTION_LIST
static int	ACTION_MAPREDUCE
static int	ACTION_REMOVE
static int	ACTION_UPDATE
static int	ACTION_UPDATEMULTI
protected java.lang.String	dbName
protected java.lang.String	hostname
protected boolean	isConnected
protected boolean	isSlaveOK
protected java.lang.String	password
protected int	port
protected int	timeout
protected java.lang.String	uri
protected java.lang.String	username

Constructor Summary

Constructors

Constructor and Description
MongoDBConnector(java.util.Map props) Creates new MongoDBConnector

Method Summary

Modifier and Type	Method and Description
void	close() closes the MongoDB connections
long	count(java.lang.String collName, java.lang.String query) returns the count of the query for the collection or -1 on failure
com.mongodb.DBCursor	find(java.lang.String collName, java.lang.String query) returns DBCursor for all the found docs or null on failure
com.mongodb.DBCursor	find(java.lang.String collName, java.lang.String query, java.lang.String projection) It returns DBCursor for all the found docs with the query and the projection or null on failure.
com.mongodb.DBObject	findOne(java.lang.String collName, java.lang.String query) returns DBObject for the found docs with the query or null on failure
com.mongodb.DBObject	findOne(java.lang.String collName, java.lang.String query, java.lang.String projection) It returns DBObject for the found doc with the query and the projection or null on failure.
com.mongodb.DBCollection	getCollection(java.lang.String collName) returns the collection or null if name is not well defined
static int	getCommandID(java.lang.String cmd) returns the id for the command or -1 if the cmd is not supported
java.lang.String	getURI()
java.lang.String	insert(java.lang.String collName, java.lang.String data) returns id of the inserted doc or null on failure
boolean	isConnected()
java.lang.String[]	list() returns an array of collection names for the DB
static void	main(java.lang.String[] args) tests MongoDB basic operations
static com.mongodb.DBObject	parse(java.lang.String jsonText) parses a JSON text into a DBObject
java.lang.String	reconnect() It reconnects and returns null or error message upon failure
int	remove(java.lang.String collName, java.lang.String query) returns number of removed docs for the query or -1 on failure
int	update(java.lang.String collName, java.lang.String query, java.lang.String data) returns number of the updated doc for the query or -1 on failure
int	updateMulti(java.lang.String collName, java.lang.String query, java.lang.String data) returns number of updated docs for the query or -1 on failure

Methods inherited from class java.lang.Object

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

Field Detail

hostname

protected java.lang.String hostname

username

protected java.lang.String username

password

protected java.lang.String password

dbName

protected java.lang.String dbName

uri

protected java.lang.String uri

port

protected int port

timeout

protected int timeout

isConnected

protected boolean isConnected

isSlaveOK

protected boolean isSlaveOK

ACTION_LIST

public static final int ACTION_LIST

See Also:

Constant Field Values

ACTION_COUNT

public static final int ACTION_COUNT

See Also:

Constant Field Values

ACTION_FIND

public static final int ACTION_FIND

See Also:

Constant Field Values

ACTION_FINDONE

public static final int ACTION_FINDONE

See Also:

Constant Field Values

ACTION_FINDANDMODIFY

public static final int ACTION_FINDANDMODIFY

See Also:

Constant Field Values

ACTION_FINDANDREMOVE

public static final int ACTION_FINDANDREMOVE

See Also:

Constant Field Values

ACTION_INSERT

public static final int ACTION_INSERT

See Also:

Constant Field Values

ACTION_REMOVE

public static final int ACTION_REMOVE

See Also:

Constant Field Values

ACTION_UPDATE

public static final int ACTION_UPDATE

See Also:

Constant Field Values

ACTION_UPDATEMULTI

public static final int ACTION_UPDATEMULTI

See Also:

Constant Field Values

ACTION_GROUP

public static final int ACTION_GROUP

See Also:

Constant Field Values

ACTION_MAPREDUCE

public static final int ACTION_MAPREDUCE

See Also:

Constant Field Values

Constructor Detail

MongoDBConnector

public MongoDBConnector(java.util.Map props)

Creates new MongoDBConnector

Method Detail

getURI

public java.lang.String getURI()

Specified by:

getURI in interface Connector

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Connector

reconnect

public java.lang.String reconnect()

It reconnects and returns null or error message upon failure

Specified by:

reconnect in interface Connector

parse

public static com.mongodb.DBObject parse(java.lang.String jsonText)

parses a JSON text into a DBObject

getCollection

public com.mongodb.DBCollection getCollection(java.lang.String collName)

returns the collection or null if name is not well defined

find

public com.mongodb.DBCursor find(java.lang.String collName,
                                 java.lang.String query,
                                 java.lang.String projection)
                          throws com.mongodb.MongoException

It returns DBCursor for all the found docs with the query and the projection or null on failure.

Throws:

com.mongodb.MongoException

find

public com.mongodb.DBCursor find(java.lang.String collName,
                                 java.lang.String query)
                          throws com.mongodb.MongoException

returns DBCursor for all the found docs or null on failure

Throws:

com.mongodb.MongoException

findOne

public com.mongodb.DBObject findOne(java.lang.String collName,
                                    java.lang.String query,
                                    java.lang.String projection)
                             throws com.mongodb.MongoException

It returns DBObject for the found doc with the query and the projection or null on failure.

Throws:

com.mongodb.MongoException

findOne

public com.mongodb.DBObject findOne(java.lang.String collName,
                                    java.lang.String query)
                             throws com.mongodb.MongoException

returns DBObject for the found docs with the query or null on failure

Throws:

com.mongodb.MongoException

insert

public java.lang.String insert(java.lang.String collName,
                               java.lang.String data)
                        throws com.mongodb.MongoException

returns id of the inserted doc or null on failure

Throws:

com.mongodb.MongoException

update

public int update(java.lang.String collName,
                  java.lang.String query,
                  java.lang.String data)
           throws com.mongodb.MongoException

returns number of the updated doc for the query or -1 on failure

Throws:

com.mongodb.MongoException

updateMulti

public int updateMulti(java.lang.String collName,
                       java.lang.String query,
                       java.lang.String data)
                throws com.mongodb.MongoException

returns number of updated docs for the query or -1 on failure

Throws:

com.mongodb.MongoException

remove

public int remove(java.lang.String collName,
                  java.lang.String query)
           throws com.mongodb.MongoException

returns number of removed docs for the query or -1 on failure

Throws:

com.mongodb.MongoException

count

public long count(java.lang.String collName,
                  java.lang.String query)
           throws com.mongodb.MongoException

returns the count of the query for the collection or -1 on failure

Throws:

com.mongodb.MongoException

list

public java.lang.String[] list()
                        throws com.mongodb.MongoException

returns an array of collection names for the DB

Throws:

com.mongodb.MongoException

close

public void close()

closes the MongoDB connections

Specified by:

close in interface Connector

getCommandID

public static final int getCommandID(java.lang.String cmd)

returns the id for the command or -1 if the cmd is not supported

main

public static void main(java.lang.String[] args)

tests MongoDB basic operations