注意：要加入mongodb相應的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代碼調用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ù)庫下面的某個集合，針對結合進行操作...

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

??????//

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

?

??????dbObject.put("title","奔放洋氣有深度，簡約時尚國際范");

??????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ù)庫下面的某個集合，針對結合進行操作...

??????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ù)庫下面的某個集合，針對結合進行操作...

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

??????// {}

??????//設置更新的條件

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

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

?

??????//設置更新的內容的對象...

??????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ù)庫下面的某個集合，針對結合進行操作...

??????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);

???}

}