7.MongoDB java CRUD，7.mongodbjavacrud

注意：要加入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);

      //根据连接获取到数据库

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

      //获取数据库下面的某个集合，针对结合进行操作...

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

      //根据连接获取到数据库

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

      //获取数据库下面的某个集合，针对结合进行操作...

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

      //根据连接获取到数据库

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

      //获取数据库下面的某个集合，针对结合进行操作...

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

      //根据连接获取到数据库

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

      //获取数据库下面的某个集合，针对结合进行操作...

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

   }

}