欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  数据库

7.MongoDBjavaCRUD

程序员文章站 2024-02-10 18:05:34
...

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

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

}

}



推荐阅读