怎么用Java操作MongoDB【转】

2012-10-06

如何用Java操作MongoDB【转】上一篇文章介绍到了在MongoDB的控制台完成MongoDB的数据操作，通过前一篇文章我

如何用Java操作MongoDB【转】

上一篇文章介绍到了在MongoDB的控制台完成MongoDB的数据操作，通过前一篇文章我们对MongoDB有了全面的认识和理解。现在我们就用Java来操作MongoDB的数据。

开发环境：

System：WindowsIDE：eclipse、MyEclipse 8Database：mongoDB

开发依赖库：

JavaEE5、mongo-2.5.3.jar、junit-4.8.2.jarEmail：hoojo_@126.comBlog：http://blog.csdn.net/IBM_hoojo

一、准备工作

1、首先，下载mongoDB对Java支持的驱动包

驱动包下载地址：https://github.com/mongodb/mongo-java-driver/downloads

mongoDB对Java的相关支持、技术：http://www.mongodb.org/display/DOCS/Java+Language+Center

驱动源码下载：https://download.github.com/mongodb-mongo-java-driver-r2.6.1-7-g6037357.zip

在线查看源码：https://github.com/mongodb/mongo-java-driver

2、下面建立一个JavaProject工程，导入下载下来的驱动包。即可在Java中使用mongoDB，目录如下：

#FormatImgID_0#

二、Java操作MongoDB示例

在本示例之前你需要启动mongod.exe的服务，启动后，下面的程序才能顺利执行;

1、建立SimpleTest.java，完成简单的mongoDB数据库操作

Mongo mongo = new Mongo();

这样就创建了一个MongoDB的数据库连接对象，它默认连接到当前机器的localhost地址，端口是27017。

DB db = mongo.getDB(“test”);

这样就获得了一个test的数据库，如果mongoDB中没有创建这个数据库也是可以正常运行的。如果你读过上一篇文章就知道，mongoDB可以在没有创建这个数据库的情况下，完成数据的添加操作。当添加的时候，没有这个库，mongoDB会自动创建当前数据库。

得到了db，下一步我们要获取一个“聚集集合DBCollection”，通过db对象的getCollection方法来完成。

DBCollection users = db.getCollection("users");

这样就获得了一个DBCollection，它相当于我们数据库的“表”。

查询所有数据

package?com.hoo.test; ?? ?
import?java.net.UnknownHostException; ?import?com.mongodb.DB; ?
import?com.mongodb.DBCollection; ?import?com.mongodb.DBCursor; ?
import?com.mongodb.Mongo; ?import?com.mongodb.MongoException; ?
import?com.mongodb.util.JSON; ?? ?
/** ??*?function:MongoDB?简单示例 ?
?*?@author?hoojo ??*?@createDate?2011-5-24?下午02:42:29 ?
?*?@file?SimpleTest.java ??*?@package?com.hoo.test ?
?*?@project?MongoDB ??*?@blog?http://blog.csdn.net/IBM_hoojo ?
?*?@email?hoojo_@126.com ??*?@version?1.0 ?
?*/?public?class?SimpleTest?{ ?
? ?????public?static?void?main(String[]?args)?throws?UnknownHostException,?MongoException?{ ?
????????Mongo?mg?=?new?Mongo(); ?????????//查询所有的Database ?
????????for?(String?name?:?mg.getDatabaseNames())?{ ?????????????System.out.println("dbName:?"?+?name); ?
????????} ????????? ?
????????DB?db?=?mg.getDB("test"); ?????????//查询所有的聚集集合 ?
????????for?(String?name?:?db.getCollectionNames())?{ ?????????????System.out.println("collectionName:?"?+?name); ?
????????} ????????? ?
????????DBCollection?users?=?db.getCollection("users"); ????????? ?
????????//查询所有的数据 ?????????DBCursor?cur?=?users.find(); ?
????????while?(cur.hasNext())?{ ?????????????System.out.println(cur.next()); ?
????????} ?????????System.out.println(cur.count()); ?
????????System.out.println(cur.getCursorId()); ?????????System.out.println(JSON.serialize(cur)); ?
????} ?} ?

2、?完成CRUD操作，首先建立一个MongoDB4CRUDTest.java，基本测试代码如下：?

package?com.hoo.test;?? ???? ?
?import?java.net.UnknownHostException;?? ?
import?java.util.ArrayList;?? ?import?java.util.List;?? ?
import?org.bson.types.ObjectId;?? ?import?org.junit.After;?? ?
import?org.junit.Before;?? ?import?org.junit.Test;?? ?
import?com.mongodb.BasicDBObject;?? ?import?com.mongodb.Bytes;?? ?
import?com.mongodb.DB;?? ?import?com.mongodb.DBCollection;?? ?
import?com.mongodb.DBCursor;?? ?import?com.mongodb.DBObject;?? ?
import?com.mongodb.Mongo;?? ?import?com.mongodb.MongoException;?? ?
import?com.mongodb.QueryOperators;?? ?import?com.mongodb.util.JSON;?? ?
??? ?/**?? ?
?*?function:实现MongoDB的CRUD操作?? ??*?@author?hoojo?? ?
?*?@createDate?2011-6-2?下午03:21:23?? ??*?@file?MongoDB4CRUDTest.java?? ?
?*?@package?com.hoo.test?? ??*?@project?MongoDB?? ?
?*?@blog?http://blog.csdn.net/IBM_hoojo?? ??*?@email?hoojo_@126.com?? ?
?*?@version?1.0?? ??*/? ?
public?class?MongoDB4CRUDTest?{?? ??????? ?
????private?Mongo?mg?=?null;?? ?????private?DB?db;?? ?
????private?DBCollection?users;?? ??????? ?
????@Before? ?????public?void?init()?{?? ?
????????try?{?? ?????????????mg?=?new?Mongo();?? ?
????????????//mg?=?new?Mongo("localhost",?27017);?? ?????????}?catch?(UnknownHostException?e)?{?? ?
????????????e.printStackTrace();?? ?????????}?catch?(MongoException?e)?{?? ?
????????????e.printStackTrace();?? ?????????}?? ?
????????//获取temp?DB；如果默认没有创建，mongodb会自动创建?? ?????????db?=?mg.getDB("temp");?? ?
????????//获取users?DBCollection；如果默认没有创建，mongodb会自动创建?? ?????????users?=?db.getCollection("users");?? ?
????}?? ??????? ?
?????@After? ?
????public?void?destory()?{?? ?????????if?(mg?!=?null)?? ?
????????????mg.close();?? ?????????mg?=?null;?? ?
????????db?=?null;?? ?????????users?=?null;?? ?
????????System.gc();?? ?????}?? ?
????public?void?print(Object?o)?{?? ?????????System.out.println(o);?? ?
????}?? ?}??

3、添加操作

在添加操作之前，我们需要写个查询方法，来查询所有的数据。代码如下：

/** ??*?function:?查询所有数据 ?
?*?@author?hoojo ??*?@createDate?2011-6-2?下午03:22:40 ?
?*/?private?void?queryAll()?{ ?
????print("查询users的所有数据："); ?????//db游标 ?
????DBCursor?cur?=?users.find(); ?????while?(cur.hasNext())?{ ?
????????print(cur.next()); ?????} ?
} ?? ?
@Test?public?void?add()?{ ?
????//先查询所有数据 ?????queryAll(); ?
????print("count:?"?+?users.count()); ????? ?
????DBObject?user?=?new?BasicDBObject(); ?????user.put("name",?"hoojo"); ?
????user.put("age",?24); ?????//users.save(user)保存，getN()获取影响行数 ?
????//print(users.save(user).getN()); ????? ?
????//扩展字段，随意添加字段，不影响现有数据 ?????user.put("sex",?"男"); ?
????print(users.save(user).getN()); ????? ?
????//添加多条数据，传递Array对象 ?????print(users.insert(user,?new?BasicDBObject("name",?"tom")).getN()); ?
???? ?????//添加List集合 ?
????List?list?=?new?ArrayList(); ?????list.add(user); ?
????DBObject?user2?=?new?BasicDBObject("name",?"lucy"); ?????user.put("age",?22); ?
????list.add(user2); ?????//添加List集合 ?
????print(users.insert(list).getN()); ????? ?
????//查询下数据，看看是否添加成功 ?????print("count:?"?+?users.count()); ?
????queryAll(); ?}?

4、删除数据

@Test?public?void?remove()?{ ?
????queryAll(); ?????print("删除id?=?4de73f7acd812d61b4626a77："?+?users.remove(new?BasicDBObject("_id",?new?ObjectId("4de73f7acd812d61b4626a77"))).getN()); ?
????print("remove?age?>=?24:?"?+?users.remove(new?BasicDBObject("age",?new?BasicDBObject("$gte",?24))).getN()); ?}?

5、修改数据

@Test?public?void?modify()?{ ?
????print("修改："?+?users.update(new?BasicDBObject("_id",?new?ObjectId("4dde25d06be7c53ffbd70906")),?new?BasicDBObject("age",?99)).getN()); ?????print("修改："?+?users.update( ?
????????????new?BasicDBObject("_id",?new?ObjectId("4dde2b06feb038463ff09042")),? ?????????????new?BasicDBObject("age",?121), ?
????????????true,//如果数据库不存在，是否添加 ?????????????false//多条修改 ?
????????????).getN()); ?????print("修改："?+?users.update( ?
????????????new?BasicDBObject("name",?"haha"),? ?????????????new?BasicDBObject("name",?"dingding"), ?
????????????true,//如果数据库不存在，是否添加 ?????????????true//false只修改第一天，true如果有多条就不修改 ?
????????????).getN()); ????? ?
????//当数据库不存在就不修改、不添加数据，当多条数据就不修改 ?????//print("修改多条："?+?coll.updateMulti(new?BasicDBObject("_id",?new?ObjectId("4dde23616be7c19df07db42c")),?new?BasicDBObject("name",?"199"))); ?
}?

6、查询数据

@Test?public?void?query()?{ ?
????//查询所有 ?????//queryAll(); ?
???? ?????//查询id?=?4de73f7acd812d61b4626a77 ?
????print("find?id?=?4de73f7acd812d61b4626a77:?"?+?users.find(new?BasicDBObject("_id",?new?ObjectId("4de73f7acd812d61b4626a77"))).toArray()); ????? ?
????//查询age?=?24 ?????print("find?age?=?24:?"?+?users.find(new?BasicDBObject("age",?24)).toArray()); ?
???? ?????//查询age?>=?24 ?
????print("find?age?>=?24:?"?+?users.find(new?BasicDBObject("age",?new?BasicDBObject("$gte",?24))).toArray()); ?????print("find?age?<=?24:?"?+?users.find(new?BasicDBObject("age",?new?BasicDBObject("$lte",?24))).toArray()); ?
???? ?????print("查询age!=25："?+?users.find(new?BasicDBObject("age",?new?BasicDBObject("$ne",?25))).toArray()); ?
????print("查询age?in?25/26/27："?+?users.find(new?BasicDBObject("age",?new?BasicDBObject(QueryOperators.IN,?new?int[]?{?25,?26,?27?}))).toArray()); ?????print("查询age?not?in?25/26/27："?+?users.find(new?BasicDBObject("age",?new?BasicDBObject(QueryOperators.NIN,?new?int[]?{?25,?26,?27?}))).toArray()); ?
????print("查询age?exists?排序："?+?users.find(new?BasicDBObject("age",?new?BasicDBObject(QueryOperators.EXISTS,?true))).toArray()); ????? ?
????print("只查询age属性："?+?users.find(null,?new?BasicDBObject("age",?true)).toArray()); ?????print("只查属性："?+?users.find(null,?new?BasicDBObject("age",?true),?0,?2).toArray()); ?
????print("只查属性："?+?users.find(null,?new?BasicDBObject("age",?true),?0,?2,?Bytes.QUERYOPTION_NOTIMEOUT).toArray()); ????? ?
????//只查询一条数据，多条去第一条 ?????print("findOne:?"?+?users.findOne()); ?
????print("findOne:?"?+?users.findOne(new?BasicDBObject("age",?26))); ?????print("findOne:?"?+?users.findOne(new?BasicDBObject("age",?26),?new?BasicDBObject("name",?true))); ?
???? ?????//查询修改、删除 ?
????print("findAndRemove?查询age=25的数据，并且删除:?"?+?users.findAndRemove(new?BasicDBObject("age",?25))); ????? ?
????//查询age=26的数据，并且修改name的值为Abc ?????print("findAndModify:?"?+?users.findAndModify(new?BasicDBObject("age",?26),?new?BasicDBObject("name",?"Abc"))); ?
????print("findAndModify:?"?+?users.findAndModify( ?????????new?BasicDBObject("age",?28),?//查询age=28的数据 ?
????????new?BasicDBObject("name",?true),?//查询name属性 ?????????new?BasicDBObject("age",?true),?//按照age排序 ?
????????false,?//是否删除，true表示删除 ?????????new?BasicDBObject("name",?"Abc"),?//修改的值，将name修改成Abc ?
????????true,? ?????????true)); ?
???? ?????queryAll(); ?
}?

mongoDB不支持联合查询、子查询，这需要我们自己在程序中完成。将查询的结果集在Java查询中进行需要的过滤即可。

7、其他操作

public?void?testOthers()?{ ?????DBObject?user?=?new?BasicDBObject(); ?
????user.put("name",?"hoojo"); ?????user.put("age",?24); ?
???? ?????//JSON?对象转换???????? ?
????print("serialize:?"?+?JSON.serialize(user)); ?????//反序列化 ?
????print("parse:?"?+?JSON.parse("{?"name"?:?"hoojo"?,?"age"?:?24}")); ????? ?
????print("判断temp?Collection是否存在:?"?+?db.collectionExists("temp")); ????? ?
????//如果不存在就创建 ?????if?(!db.collectionExists("temp"))?{ ?
????????DBObject?options?=?new?BasicDBObject(); ?????????options.put("size",?20); ?
????????options.put("capped",?20); ?????????options.put("max",?20); ?
????????print(db.createCollection("account",?options)); ?????} ?
???? ?????//设置db为只读 ?
????db.setReadOnly(true); ????? ?
????//只读不能写入数据 ?????db.getCollection("test").save(user); ?
}?

好了，这里基本上就介绍这么多Java操作MongoDB的方法。其他的东西还需要你自己多多研究。上面操作MongoDB的方法都是一些常用的方法，比较简单。

原文链接：http://www.cnblogs.com/hoojo/archive/2011/06/02/2068665.html

热点排行

其他数据库

怎么用Java操作MongoDB【转】