首页 / JAVA / 【MongoDB for Java】Java操作MongoDB

【MongoDB for Java】Java操作MongoDB

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了【MongoDB for Java】Java操作MongoDB，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含8388字，纯文字阅读大概需要12分钟。

内容图文

开发环境：

System：Windows

IDE：eclipse、MyEclipse 8

Database：mongoDB

开发依赖库：

JavaEE5、mongo-2.5.3.jar、junit-4.8.2.jar

 

一、准备工作

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，目录如下：

技术分享

 

 

二、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，它相当于我们数据库的“表”。

查询所有数据

DBCursor cur = users.find();

　　while (cur.hasNext()) {

　　System.out.println(cur.next());

}

 

java代码：

             1
            package com.hoo.test;

             2
             3
            import java.net.UnknownHostException;

             4
            import com.mongodb.DB;

             5
            import com.mongodb.DBCollection;

             6
            import com.mongodb.DBCursor;

             7
            import com.mongodb.Mongo;

             8
            import com.mongodb.MongoException;

             9
            import com.mongodb.util.JSON;

            10
            11
            /*
            *

            12
             * MongoDB 简单示例

            13
            */
            14
            public
            class
             SimpleTest {

            15
            16
            public
            static
            void
             main(String[] args) throws UnknownHostException, MongoException {

            17         Mongo mg = new Mongo();
18//查询所有的Database19for (String name : mg.getDatabaseNames()) {
20             System.out.println("dbName: " + name);
21        }
2223         DB db = mg.getDB("test");
24//查询所有的聚集集合25for (String name : db.getCollectionNames()) {
26             System.out.println("collectionName: " + name);
27        }
2829         DBCollection users = db.getCollection("users");
3031//查询所有的数据32         DBCursor cur = users.find();
33while (cur.hasNext()) {
34             System.out.println(cur.next());
35        }
36         System.out.println(cur.count());
37         System.out.println(cur.getCursorId());
38         System.out.println(JSON.serialize(cur));
39    }
40 }

 

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

             1
            package com.hoo.test;

             2
             3
            import java.net.UnknownHostException;

             4
            import java.util.ArrayList;

             5
            import java.util.List;

             6
            import org.bson.types.ObjectId;

             7
            import org.junit.After;

             8
            import org.junit.Before;

             9
            import org.junit.Test;

            10
            import com.mongodb.BasicDBObject;

            11
            import com.mongodb.Bytes;

            12
            import com.mongodb.DB;

            13
            import com.mongodb.DBCollection;

            14
            import com.mongodb.DBCursor;

            15
            import com.mongodb.DBObject;

            16
            import com.mongodb.Mongo;

            17
            import com.mongodb.MongoException;

            18
            import com.mongodb.QueryOperators;

            19
            import com.mongodb.util.JSON;

            20
            21
            /*
            *

            22
             * 实现MongoDB的CRUD操作

            23
            */
            24
            public
            class
             MongoDB4CRUDTest {

            25
            26
            private Mongo mg = null;
27private DB db;
28private DBCollection users;
2930    @Before
31publicvoid init() {
32try {
33             mg = new Mongo();
34//mg = new Mongo("localhost", 27017);35         } catch (UnknownHostException e) {
36            e.printStackTrace();
37         } catch (MongoException e) {
38            e.printStackTrace();
39        }
40//获取temp DB；如果默认没有创建，mongodb会自动创建41         db = mg.getDB("temp");
42//获取users DBCollection；如果默认没有创建，mongodb会自动创建43         users = db.getCollection("users");
44    }
4546    @After
47publicvoid destory() {
48if (mg != null)
49            mg.close();
50         mg = null;
51         db = null;
52         users = null;
53        System.gc();
54    }
5556publicvoid print(Object o) {
57         System.out.println(o);
58    }
59 }

 

3、 添加操作

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

             1
            /*
            *

             2
             * 查询所有数据

             3
            */
             4
            private
            void
             queryAll() {

             5     print("查询users的所有数据：");
 6//db游标 7     DBCursor cur = users.find();
 8while (cur.hasNext()) {
 9        print(cur.next());
10    }
11}
1213@Test
14publicvoid add() {
15//先查询所有数据16    queryAll();
17     print("count: " + users.count());
1819     DBObject user = new BasicDBObject();
20     user.put("name", "hoojo");
21     user.put("age", 24);
22//users.save(user)保存，getN()获取影响行数
23//print(users.save(user).getN());
2425//扩展字段，随意添加字段，不影响现有数据26     user.put("sex", "男");
27    print(users.save(user).getN());
2829//添加多条数据，传递Array对象30     print(users.insert(user, new BasicDBObject("name", "tom")).getN());
3132//添加List集合33     List<DBObject> list = new ArrayList<DBObject>();
34    list.add(user);
35     DBObject user2 = new BasicDBObject("name", "lucy");
36     user.put("age", 22);
37    list.add(user2);
38//添加List集合39    print(users.insert(list).getN());
4041//查询下数据，看看是否添加成功42     print("count: " + users.count());
43    queryAll();
44 }

 

4、 删除数据

            1
            @Test

            2
            public
            void
             remove() {

            3
                queryAll();

            4     print("删除id = 4de73f7acd812d61b4626a77：" + users.remove(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).getN());
5     print("remove age >= 24: " + users.remove(new BasicDBObject("age", new BasicDBObject("$gte", 24))).getN());
6 }

5、 修改数据

             1
            @Test

             2
            public
            void
             modify() {

             3     print("修改：" + users.update(new BasicDBObject("_id", new ObjectId("4dde25d06be7c53ffbd70906")), new BasicDBObject("age", 99)).getN());
 4     print("修改：" + users.update(
 5new BasicDBObject("_id", new ObjectId("4dde2b06feb038463ff09042")), 
 6new BasicDBObject("age", 121),
 7true,//如果数据库不存在，是否添加 8false//多条修改 9            ).getN());
10     print("修改：" + users.update(
11new BasicDBObject("name", "haha"), 
12new BasicDBObject("name", "dingding"),
13true,//如果数据库不存在，是否添加14true//false只修改第一天，true如果有多条就不修改15            ).getN());
1617//当数据库不存在就不修改、不添加数据，当多条数据就不修改
18//print("修改多条：" + coll.updateMulti(new BasicDBObject("_id", new ObjectId("4dde23616be7c19df07db42c")), new BasicDBObject("name", "199")));19 }

6、 查询数据：

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

             1
            @Test

             2
            public
            void
             query() {

             3
            //
            查询所有

             4
            //
            queryAll();

             5
             6
            //
            查询id = 4de73f7acd812d61b4626a77
             7     print("find id = 4de73f7acd812d61b4626a77: " + users.find(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).toArray());
 8 9//查询age = 2410     print("find age = 24: " + users.find(new BasicDBObject("age", 24)).toArray());
1112//查询age >= 2413     print("find age >= 24: " + users.find(new BasicDBObject("age", new BasicDBObject("$gte", 24))).toArray());
14     print("find age <= 24: " + users.find(new BasicDBObject("age", new BasicDBObject("$lte", 24))).toArray());
1516     print("查询age!=25：" + users.find(new BasicDBObject("age", new BasicDBObject("$ne", 25))).toArray());
17     print("查询age in 25/26/27：" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.IN, newint[] { 25, 26, 27 }))).toArray());
18     print("查询age not in 25/26/27：" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.NIN, newint[] { 25, 26, 27 }))).toArray());
19     print("查询age exists 排序：" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.EXISTS, true))).toArray());
2021     print("只查询age属性：" + users.find(null, new BasicDBObject("age", true)).toArray());
22     print("只查属性：" + users.find(null, new BasicDBObject("age", true), 0, 2).toArray());
23     print("只查属性：" + users.find(null, new BasicDBObject("age", true), 0, 2, Bytes.QUERYOPTION_NOTIMEOUT).toArray());
2425//只查询一条数据，多条去第一条26     print("findOne: " + users.findOne());
27     print("findOne: " + users.findOne(new BasicDBObject("age", 26)));
28     print("findOne: " + users.findOne(new BasicDBObject("age", 26), new BasicDBObject("name", true)));
2930//查询修改、删除31     print("findAndRemove 查询age=25的数据，并且删除: " + users.findAndRemove(new BasicDBObject("age", 25)));
3233//查询age=26的数据，并且修改name的值为Abc34     print("findAndModify: " + users.findAndModify(new BasicDBObject("age", 26), new BasicDBObject("name", "Abc")));
35     print("findAndModify: " + users.findAndModify(
36new BasicDBObject("age", 28), //查询age=28的数据37new BasicDBObject("name", true), //查询name属性38new BasicDBObject("age", true), //按照age排序39false, //是否删除，true表示删除40new BasicDBObject("name", "Abc"), //修改的值，将name修改成Abc41true, 
42true));
4344    queryAll();
45 }

7、 其他操作

             1
            public
            void
             testOthers() {

             2     DBObject user = new BasicDBObject();
 3     user.put("name", "hoojo");
 4     user.put("age", 24);
 5 6//JSON 对象转换         7     print("serialize: " + JSON.serialize(user));
 8//反序列化 9     print("parse: " + JSON.parse("{ \"name\" : \"hoojo\" , \"age\" : 24}"));
1011     print("判断temp Collection是否存在: " + db.collectionExists("temp"));
1213//如果不存在就创建14if (!db.collectionExists("temp")) {
15         DBObject options = new BasicDBObject();
16         options.put("size", 20);
17         options.put("capped", 20);
18         options.put("max", 20);
19         print(db.createCollection("account", options));
20    }
2122//设置db为只读23     db.setReadOnly(true);
2425//只读不能写入数据26     db.getCollection("test").save(user);
27 }

 

原文：http://www.cnblogs.com/link1988/p/5415621.html

内容总结

以上是互联网集市为您收集整理的【MongoDB for Java】Java操作MongoDB全部内容，希望文章能够帮你解决【MongoDB for Java】Java操作MongoDB所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1201937.html

来源：【匿名】