分享java操作mongodb的crud代码
2014-03-14 10:50
381 查看
代码中包括了mongodb的crud及其分页查询,排序功能
下载地址:分享java操作mongodb的crud代码
下载地址:分享java操作mongodb的crud代码
package com.zuidaima.mongodb.test; import java.net.UnknownHostException; import org.junit.After; import org.junit.Before; 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; import com.mongodb.MongoException; public class Main { private Mongo mongo = null; private DB db = null; private DBCollection test; @Before public void init() { try { mongo = new Mongo("localhost"); db = mongo.getDB("test"); test = db.getCollection("test"); } catch (UnknownHostException e) { e.printStackTrace(); } catch (MongoException e) { e.printStackTrace(); } } @Test public void create() { BasicDBObject data = new BasicDBObject().append("hosting", "hostA"); data.put("name", "中文"); data.put("name", "英文"); test.save(data); } @Test public void load() { BasicDBObject query = new BasicDBObject(); query.put("name", "中文"); DBCursor cursor = test.find(query); while (cursor.hasNext()) { DBObject object = cursor.next(); System.out.println(object); } } @Test public void page() { int count = 10; int page = 1; int skip = (page - 1) * count; DBCursor cursor = test.find().limit(count).skip(skip); while (cursor.hasNext()) { DBObject object = cursor.next(); System.out.println(object); } } @Test public void sort() { int count = 10; int page = 1; int skip = (page - 1) * count; DBCursor cursor = test.find().limit(count).skip(skip) .sort(new BasicDBObject("_id", -1)); while (cursor.hasNext()) { DBObject object = cursor.next(); System.out.println(object); } } @Test public void update() { BasicDBObject query = new BasicDBObject(); query.put("name", "中文"); DBCursor cursor = test.find(query); DBObject object = cursor.next(); BasicDBObject newObject = new BasicDBObject(); newObject.put("name", "中文"); newObject.put("value", "chinese"); test.update(object, newObject); cursor = test.find(); while (cursor.hasNext()) { System.out.println(cursor.next()); } } @Test public void delete() { BasicDBObject query = new BasicDBObject(); query.put("name", "中文"); DBCursor cursor = test.find(query); DBObject object = cursor.next(); test.remove(object); cursor = test.find(); while (cursor.hasNext()) { System.out.println(cursor.next()); } } @After public void destory() { if (mongo != null) mongo.close(); mongo = null; db = null; } }
相关文章推荐
- 使用Java代码操作MongoDB(CRUD)方法二
- 使用Java代码操作MongoDB(CRUD)方法一
- java操作MongoDB工具类分享
- java环境下:MongoDB的crud操作之Update (一)
- mongodb之java CRUD 简单操作
- mongodb之java CRUD 简单操作
- MongoDB学习日记 - java代码(三):数据库与集合操作
- java-jdbc操作详细代码分享
- MongoDB快速入门笔记(八)之MongoDB的java驱动操作代码讲解
- MongoDB的CRUD操作(java Util )
- mongoDB Java SDK CRUD操作例子
- [记录]MongoDB Java代码---入门操作
- Java操作MongoDB之CRUD(增删改查)
- MongoDBcrud操作,采集部分代码
- MongoDB 3.x java基本操作-CRUD
- mongodb3.0分片及java代码连接操作测试(开启用户验证)
- java操作mongodb示例分享
- MongoDB对图片进行CRUD操作——与JAVA结合
- Java操作MongoDB实现CRUD
- [MongoDB学习日志]Java对MongoDB的CRUD操作