7.MongoDB java CRUD
2015-12-31 20:54
357 查看
注意:要增加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); } } |
相关文章推荐
- mongodb主从以及auth主从 配置详解
- MONGODB(三)——Java操作Mongo
- mongodb安装详解
- MongoDB学习笔记八:复制
- MongoDB学习笔记七:管理
- 使用MongoDB C#官方驱动操作MongoDB
- MONGODB(二)——索引操作
- MongoDB(一)
- Spark 连接mysql 及MongoDB
- MongoDB:Map-Reduce
- apache log4j将日志保存在mongodb数据库中
- mongodb的备份和还原
- Mongodb管理的几个常识
- MongoDB常用命令及例子详细介绍
- MongoDB GridFS
- mongoDB 入门指南、示例
- Java操作MongoDB
- Mongodb数据导出工具mongoexport和导入工具mongoimport介绍
- mongodb安装遇到的一个坑!!(mongodb 32位版本 win7 )
- 安装mongodb配置windows服务流程