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