使用 junit 4 测试 Mongodb3 增、删、改、查
数据库: Mongodb 3.0.2
jar包 : mongo-java-driver-3.0.2.jar
junit-4.10.jar
数据库客户端工具: Robomongo
3.0.2 版本中,使用 MongoCollection<Document> 代替了原来的 DBCollection,
使用 MongoDatabase 代替了原来的 DB
java代码如下:
import org.bson.Document; import org.bson.types.ObjectId; import org.junit.Before; import org.junit.Test; import com.mongodb.BasicDBObject; import com.mongodb.MongoClient; import com.mongodb.client.FindIterable; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoCursor; import com.mongodb.client.MongoDatabase; /** * @ClassName: TestMongodb * @deprecated: Mongodb3.0.2方法测试(junit4) * @author * @company * @date 2015-6-1 * @version V1.0 */ public class TestMongodb { private MongoCollection<Document> coll = null; @Before public void setUp() throws Exception { try { MongoClient mongoClient = new MongoClient("10.0.0.117", 27017); // 连接数据库,若没有,则新建 MongoDatabase db = mongoClient.getDatabase("test"); // 连接集合(类似于RDBMS)中的表,若没有,则新建 coll = db.getCollection("testCollection"); } catch (Exception e) { e.printStackTrace(); throw e; } } @Test public void insert() { try { // 老版本 // BasicDBObject doc = new BasicDBObject("name", "MongoDB") // .append("type", "database").append("count", 1) // .append("info", new BasicDBObject("x", 203).append("y", 102)); // coll.insert(doc); /* 3.0.2版本 */ Document doc = new Document(); doc.put("cust_id", "A111"); doc.put("amount", 210); doc.put("status", "C"); coll.insertOne(doc); System.out.println("Insert Success!"); } catch (Exception e) { e.printStackTrace(); } } @Test public void query() { MongoCursor<Document> cursor = null; try { BasicDBObject query = new BasicDBObject("cust_id", "A111"); FindIterable<Document> iter = coll.find(query); cursor = iter.iterator(); System.out.println(cursor.hasNext()); Document doc = null; while (cursor.hasNext()) { doc = cursor.next(); System.out.println(doc.get("cust_id")); System.out.println(doc.toString()); } } catch (Exception e) { e.printStackTrace(); } finally { if (null != cursor) { cursor.close(); } } } @Test public void delete() { // BasicDBObject query = new BasicDBObject("status", "C"); // // coll.deleteMany(query); // 根据主键(_id)删除 BasicDBObject query = new BasicDBObject("_id", new ObjectId( "556d7121d49c6f19e0c76c8e")); coll.deleteOne(query); // 查找集合(表)中所有的文档(行) FindIterable<Document> iterable = coll.find(); MongoCursor<Document> cursor = iterable.iterator(); Document doc = null; while (cursor.hasNext()) { doc = cursor.next(); System.out.println(doc.toString()); } } @Test public void update() { try { // 查找_id=556d7121d49c6f19e0c76c8e的文档(行) BasicDBObject searchQuery = new BasicDBObject().append("_id", new ObjectId("556d7121d49c6f19e0c76c8e")); System.out.println(searchQuery); BasicDBObject newDocument = new BasicDBObject(); // 将其中的Key为cust_id的值改为ABC123 newDocument.append("$set", new BasicDBObject().append("cust_id", "ABC123")); coll.updateOne(searchQuery, newDocument); System.out.println("Update Success!"); } catch (Exception e) { e.printStackTrace(); } } }
相关推荐
JAVA连接MongoDB,并进行简单的增删改查操作小例子源码,相关博文: http://blog.csdn.net/dream_broken/article/details/36014733
java连接Mongodb进行增删改查,包括查询、删除、增加等功能
本Demo简单演示了如何使用Express 4.x 与MongoDb实现增删改查等Web网站最基本的功能
演示了JAVA怎样操作mongodb数据库进行增删改查操作。
nodejs+express+mongodb 博客系统增删改查完整版,包括用户注册,博客发表,博客修改,博客删除,权限控制。后台连接mongodb:blog
mongoDB增删改查+前端页面实现+idea+themlesf+mybatis
使用Java对MongoDB进行一些基础操作,包括增删改查基础搓澡。给刚接触mongodb或者想使用Java操作Mongodb的童鞋们一些引导性的帮助。
c#基于接口泛型书写的可扩展性强的操作mongodb增删改查功能源代码,经过测试通过,在MongodbGetData.aspx.cs中Page_Load方法中,注释掉的代码为相关测试语句
C# mongodb 增删改查 入门示例源码下载.rar
MongoDB java API实现增删改查,包含批量操作
java mongodb增删改查示例
mongodb基本增删改查代码,包含了常见的最近本的操作
MongoDB增删改查操作案例-用户信息增删改查.zip
java 操作mongodb代码,可直接运行成功,作为初学者非常实用。其中数据库是包含用户名和密码,用户名root ,密码root。
本源码提供了一个基于Html的crud-express-mongodb增删改查设计。项目包含1586个文件,其中...这个项目是一个基于crud-express-mongodb的增删改查系统,可能包括数据的增删改查等功能,适合用于需要进行数据操作的场景。
使用nodejs操作mongodb来实现增删改查,适合初学者 文章链接:http://blog.csdn.net/wang_situ/article/details/39959643
java操作mongodb增删改查mongodb查询 in like 修改自增
本例用Java代码实现键值数据库mongodb的增删改查操作,并结合junit进行简单增删改查测试,希望能帮助刚接触hadoop以及mongodb的学习者。
基于ER模型,Flask封装对MongoDB的增删改查
MongoDb增删改查的网站范例,Using the spring-data project and the mongodb adapter specifically.