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