注意：要加入mongodb相應(yīng)的jar包

package cn.toto.mongodb;

import java.net.UnknownHostException;

import org.bson.types.ObjectId;

import org.junit.Test;

import com.mongodb.BasicDBObject;

import com.mongodb.DB;

import com.mongodb.DBCollection;

import com.mongodb.DBCursor;

import com.mongodb.DBObject;

import com.mongodb.Mongo;

?

/**

?*使用java代碼調(diào)用mongodb

?*

?*@author to-to

?*/

publicclass MongoDBDao {

???@Test

???publicvoid add()throws UnknownHostException {

??????//建立起連接

??????Mongo mongo =new Mongo("192.168.1.100", 27017);

??????//根據(jù)連接獲取到數(shù)據(jù)庫

??????DB db = mongo.getDB("test");

??????//獲取數(shù)據(jù)庫下面的某個(gè)集合，針對(duì)結(jié)合進(jìn)行操作...

??????DBCollection dbCollection = db.getCollection("person");

??????//

??????BasicDBObject dbObject =new BasicDBObject();

?

??????dbObject.put("title","奔放洋氣有深度，簡(jiǎn)約時(shí)尚國(guó)際范");

??????dbObject.put("content","高大上");

??????// {key:value,keyvalue}

??????dbCollection.insert(dbObject);

??????mongo.close();

???}

?

???@Test

???publicvoid del()throws UnknownHostException {

??????Mongo mongo =new Mongo("192.168.1.100", 27017);

??????//根據(jù)連接獲取到數(shù)據(jù)庫

??????DB db = mongo.getDB("test");

??????//獲取數(shù)據(jù)庫下面的某個(gè)集合，針對(duì)結(jié)合進(jìn)行操作...

??????DBCollection dbCollection = db.getCollection("person");

??????// {}

??????DBObject dbObject =new BasicDBObject();

?

??????dbCollection.remove(dbObject);

???}

?

???/**

????*更新

????*

????*@throws UnknownHostException

????*/

???@Test

???publicvoid update()throws UnknownHostException {

??????Mongo mongo =new Mongo("192.168.1.100", 27017);

??????//根據(jù)連接獲取到數(shù)據(jù)庫

??????DB db = mongo.getDB("test");

??????//獲取數(shù)據(jù)庫下面的某個(gè)集合，針對(duì)結(jié)合進(jìn)行操作...

??????DBCollection dbCollection = db.getCollection("person");

??????// {}

??????//設(shè)置更新的條件

??????BasicDBObject query =new BasicDBObject("_id",new ObjectId(

?????????????"53db556a5bcbcfc947854027"));

?

??????//設(shè)置更新的內(nèi)容的對(duì)象...

??????BasicDBObject object = (BasicDBObject) dbCollection.findOne(query);

??????object.put("title","高端大氣上檔次");

?

??????dbCollection.update(query, object);

???}

?

???@Test

???publicvoid find()throws UnknownHostException {

??????Mongo mongo =new Mongo("192.168.1.100", 27017);

??????//根據(jù)連接獲取到數(shù)據(jù)庫

??????DB db = mongo.getDB("test");

??????//獲取數(shù)據(jù)庫下面的某個(gè)集合，針對(duì)結(jié)合進(jìn)行操作...

??????DBCollection dbCollection = db.getCollection("person");

?

??????// BasicDBObject dbObject=new BasicDBObject();

?

??????// dbObject.put("content", "高大上");

??????DBCursor cursor = dbCollection.find();

?

??????while (cursor.hasNext()) {

??????????DBObject dbObject2 = cursor.next();

??????????System.out.println(dbObject2.toString());

??????}

??????// {$lt:{age:20}}

??????// db.collection.find()

??????// {}

??????BasicDBObject basicDBObject =new BasicDBObject();

?

??????BasicDBObject basicDBObject2 =new BasicDBObject();

?

??????basicDBObject2.put("age", 20);

??????basicDBObject.put("$lt", basicDBObject2);

???}

}