package cn.test.db;

import java.io.File;

import java.io.IOException;

import java.net.UnknownHostException;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Set;

import com.mongodb.BasicDBObject;

import com.mongodb.BasicDBObjectBuilder;

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.gridfs.GridFS;

import com.mongodb.gridfs.GridFSDBFile;

import com.mongodb.gridfs.GridFSInputFile;

import com.mongodb.util.JSON;

/**

 * 需引入jar包 ：地址https://github.com/mongodb/mongo-java-driver/downloads

 * 根据服务器所安装版本下载对应即可>>>

 *

 *查看版本方式：[root@vmu010226-node1 ~]# mongo version

 */

public class App {

    /**

     * 连接库 test

     *

     * @return

     * @throws UnknownHostException

     * @throws MongoException

     */

    public static DB getDb() throws UnknownHostException, MongoException {

        // 实例化Mongo对象，连接27017端口

        Mongo mongo = new Mongo("10.1.207.110", 27017);

        // 连接名为test的数据库，假如数据库不存在的话，mongodb会自动建立

        DB db = mongo.getDB("test");

        return db;

    }

    /**

     * 获取所有的集合名

     *

     * @throws MongoException

     * @throws UnknownHostException

     */

    public void getCollectionName() throws MongoException, UnknownHostException {

        Set<String> collections = getDb().getCollectionNames();

        for (String collectionName : collections) {

            System.out.println("collectionName=" + collectionName);

        }

    }

    /**

     * 与集合名为game的取得连接

     *

     * @return

     * @throws UnknownHostException

     * @throws MongoException

     */

    public static DBCollection getCollection() throws UnknownHostException,

            MongoException {

        DBCollection collection = getDb().getCollection("game");

        return collection;

    }

    /**

     * insert 第一种方法，是使用BasicDBObjec

     *

     * @throws MongoException

     * @throws UnknownHostException

     */

    public static void insertByBasicDBObject() throws MongoException,

            UnknownHostException {

        BasicDBObject document = new BasicDBObject();

        document.put("id", 1);

        document.put("name", "测试数据no1");

        document.put("content", "评价no1");

        document.put("score", 5000);

        BasicDBObject documentDetail = new BasicDBObject();

        documentDetail.put("records", "99");

        documentDetail.put("index", "vps_index1");

        documentDetail.put("active", "true");

        document.put("detail", documentDetail);

        getCollection().insert(document);

        /***

         * 输出结果 ：{ "_id" : ObjectId("547536e291812694b70f5059"), "id" : 1,

         * "name" : "测试数据no1", "content" : "评价no1", "score" : 5000, "detail" : {

         * "records" : "99", "index" : "vps_index1", "active" : "true" } }

         */

    }

    /**

     * insert 第二种方法，是使用BasicDBObjectBuilder

     *

     * @throws MongoException

     * @throws UnknownHostException

     */

    public static void insertByBasicDBObjectBuilder() throws MongoException,

            UnknownHostException {

        BasicDBObjectBuilder documentBuilder = BasicDBObjectBuilder.start()

                .add("id", 2).add("name", "测试数据no2").add("content", "评价no2")

                .add("score", 5000);

        BasicDBObjectBuilder documentBuilderDetail = BasicDBObjectBuilder

                .start().add("records", "100").add("index", "vps_index2").add(

                        "active", "true");

        documentBuilder.add("detail", documentBuilderDetail.get());

        getCollection().insert(documentBuilder.get());

        /***

         * 输出结果 ：{ "_id" : ObjectId("547539009181903d3a37ddeb"), "id" : 2,

         * "name" : "测试数据no2", "content" : "评价no2", "score" : 5000, "detail" : {

         * "records" : "100", "index" : "vps_index2", "active" : "true" } }

         */

    }

    /**

     * insert 第三种方法，是使用Map

     *

     * @throws MongoException

     * @throws UnknownHostException

     */

    @SuppressWarnings("unchecked")

    public static void insertByMap() throws MongoException,

            UnknownHostException {

        Map documentMap = new HashMap();

        documentMap.put("id", 3);

        documentMap.put("name", "测试数据no3");

        documentMap.put("content", "评价no3");

        documentMap.put("score", 5000);

        Map documentMapDetail = new HashMap();

        documentMapDetail.put("records", "99");

        documentMapDetail.put("index", "vps_index3");

        documentMapDetail.put("active", "true");

        documentMap.put("detail", documentMapDetail);

        getCollection().insert(new BasicDBObject(documentMap));

        /**

         * 输出结果：{ "_id" : ObjectId("547539ff9181629953cc678c"), "content" :

         * "评价no3", "id" : 3, "detail" : { "index" : "vps_index3", "active" :

         * "true", "records" : "99" }, "name" : "测试数据no3", "score" : 5000 }

         */

    }

    /**

     * insert 第四种方法，直接使用json格式

     *

     * @throws MongoException

     * @throws UnknownHostException

     */

    public static void insertByJson() throws MongoException,

            UnknownHostException {

        String json = "{'database' : 'mkyongDB','table' : 'hosting',"

                + "'detail' : {'records' : 99, 'index' : 'vps_index1', 'active' : 'true'}}}";

        DBObject dbObject = (DBObject) JSON.parse(json);

        getCollection().insert(dbObject);

        /**

         * 输出结果：{ "_id" : ObjectId("54753abd91810ba1daa7ff0f"), "database" :

         * "mkyongDB", "table" : "hosting", "detail" : { "records" : 99, "index"

         * : "vps_index1", "active" : "true" } }

         */

    }

    /****

     *

     * game集合里面现在的数据为 > db.game.find() { "_id" :

     * ObjectId("547443c4c9158f23e626927f"), "name" : "my hero", "content" :

     * "are you sure?", "score" : 20000 } { "_id" :

     * ObjectId("54752f5f9181f945548b2375"), "id" : 1001, "name" : "啦啦啦啦啦啦啦",

     * "content" : "hello world mongoDB in Java", "score" : 1 } { "_id" :

     * ObjectId("547530ac9181d6f709a151f0"), "id" : 1001, "name" : "啦啦啦啦啦啦啦",

     * "content" : "hello world mongoDB in Java", "score" : 1 } { "_id" :

     * ObjectId("547536e291812694b70f5059"), "id" : 1, "name" : "测试数据no1",

     * "content" : "评价no1", "score" : 5000, "detail" : { "records" : "99",

     * "index" : "vps_index1", "active" : "true" } } { "_id" :

     * ObjectId("547539009181903d3a37ddeb"), "id" : 2, "name" : "测试数据no2",

     * "content" : "评价no2", "score" : 5000, "detail" : { "records" : "100",

     * "index" : "vps_index2", "active" : "true" } } { "_id" :

     * ObjectId("547539ff9181629953cc678c"), "content" : "评价no3", "id" : 3,

     * "detail" : { "index" : "vps_index3", "active" : "true", "records" : "99"

     * }, "name" : "测试数据no3", "score" : 5000 } { "_id" :

     * ObjectId("54753abd91810ba1daa7ff0f"), "database" : "mkyongDB", "table" :

     * "hosting", "detail" : { "records" : 99, "index" : "vps_index1", "active"

     * : "true" } }

     *

     */

    // 更新 .............

    /**

     * update

     *

     * @param args

     * @throws UnknownHostException

     * @throws MongoException

     *             　使用BasicDBObject对象，并为其赋值了新的值后，然后使用collection的update方法，即可更新该对象

     */

    public static void update_1() throws MongoException, UnknownHostException {

        // ** 将这条数据更新 { "_id" : ObjectId("547443c4c9158f23e626927f"), "name" :

        // "my hero", "content" : "are you sure?", "score" : 20000 }

        BasicDBObject newDocument = new BasicDBObject();

        newDocument.put("name", "my new hero");

        newDocument.put("content", "这是我的新英雄!");

        newDocument.put("score", 15400);

        getCollection().update(new BasicDBObject().append("name", "my hero"),

                newDocument);

        /**

         * 输出结果 ：{ "_id" : ObjectId("547443c4c9158f23e626927f"), "name" :

         * "my new hero", "content" : "这是我的新英雄!", "score" : 15400 }

         */

    }

    /***

     *

     * 还可以使用mongodb中的$inc修饰符号去对某个值进行更新，比如，要将name值为my new

     * hero的document的score的值得更新为16000(即15400+4600=16000)

     *

     * @param args

     * @about "$inc"更新修改器 可作为计数器

     */

    public static void update_inc() throws MongoException, UnknownHostException {

        /**

         * 初始{ "_id" : ObjectId("547443c4c9158f23e626927f"), "name" :

         * "my new hero", "content" : "这是我的新英雄!", "score" : 15400 }

         */

        BasicDBObject newDocument = new BasicDBObject().append("$inc",

                new BasicDBObject().append("score", 4600));

        getCollection().update(

                new BasicDBObject().append("name", "my new hero"), newDocument);

        /**

         * 输出结果 ：{ "_id" : ObjectId("547443c4c9158f23e626927f"), "name" :

         * "my new hero", "content" : "这是我的新英雄!", "score" : 20000 }

         */

    }

    /**

     * "$set" 可添加字段内容

     *

     * @throws MongoException

     * @throws UnknownHostException

     */

    public static void update_set() throws MongoException, UnknownHostException {

        BasicDBObject newDocument = new BasicDBObject().append("$set",

                new BasicDBObject().append("useset", "使用$set"));

        getCollection().update(

                new BasicDBObject().append("name", "my new hero"), newDocument);

        /**

         * 输出结果 ：{ "_id" : ObjectId("547443c4c9158f23e626927f"), "name" :

         * "my new hero", "content" : "这是我的新英雄!", "score" : 20000, "useset" :

         * "使用$set" }

         */

    }

    /**

     * "$unset" 可删除字段内容

     *

     * @throws MongoException

     * @throws UnknownHostException

     */

    public static void update_unset() throws MongoException,

            UnknownHostException {

        BasicDBObject newDocument = new BasicDBObject().append("$unset",

                new BasicDBObject().append("useset", "使用$set"));

        getCollection().update(

                new BasicDBObject().append("name", "my new hero"), newDocument);

        /**

         * 输出结果 ：{ "_id" : ObjectId("547443c4c9158f23e626927f"), "name" :

         * "my new hero", "content" : "这是我的新英雄!", "score" : 20000 }

         */

    }

    /**

     * 批量更新

     *

     * @throws MongoException

     * @throws UnknownHostException

     */

    public static void update_multi() throws MongoException,

            UnknownHostException {

        // 将id为1001的数据的score更新为999999

        /**

         * 初始值：{ "_id" : ObjectId("54752f5f9181f945548b2375"), "id" : 1001,

         * "name" : "啦啦啦啦啦啦啦", "content" : "hello world mongoDB in Java",

         * "score" : 1 } { "_id" : ObjectId("547530ac9181d6f709a151f0"), "id" :

         * 1001, "name" : "啦啦啦啦啦啦啦", "content" : "hello world mongoDB in Java",

         * "score" : 1 }

         */

        BasicDBObject updateQuery = new BasicDBObject().append("$set",

                new BasicDBObject().append("score", 999999));

        getCollection().update(new BasicDBObject().append("id", 1001),

                updateQuery, false, true);

        /**

         * 输出结果 { "_id" : ObjectId("54752f5f9181f945548b2375"), "id" : 1001,

         * "name" : "啦啦啦啦啦啦啦", "content" : "hello world mongoDB in Java",

         * "score" : 999999 } { "_id" : ObjectId("547530ac9181d6f709a151f0"),

         * "id" : 1001, "name" : "啦啦啦啦啦啦啦", "content" :

         * "hello world mongoDB in Java", "score" : 999999 }

         */

    }

    // 查询

    /**

     * 查询Document

     *

     * 先用下面的代码往数据库中插入1-10数字：

     */

    public static void init() throws MongoException, UnknownHostException {

        for (int i = 1; i <= 10; i++) {

            getCollection().insert(new BasicDBObject().append("number", i));

        }

        /**

         * 结果为： { "_id" : ObjectId("547562c991818dbe4d036486"), "number" : 1 } {

         * "_id" : ObjectId("547562c991818dbe4d036487"), "number" : 2 } { "_id"

         * : ObjectId("547562c991818dbe4d036488"), "number" : 3 } { "_id" :

         * ObjectId("547562c991818dbe4d036489"), "number" : 4 } { "_id" :

         * ObjectId("547562c991818dbe4d03648a"), "number" : 5 } { "_id" :

         * ObjectId("547562c991818dbe4d03648b"), "number" : 6 } { "_id" :

         * ObjectId("547562c991818dbe4d03648c"), "number" : 7 } { "_id" :

         * ObjectId("547562c991818dbe4d03648d"), "number" : 8 } { "_id" :

         * ObjectId("547562c991818dbe4d03648e"), "number" : 9 } { "_id" :

         * ObjectId("547562c991818dbe4d03648f"), "number" : 10 }

         */

    }

    /**

     * 查询第一个数据

     *

     * @throws MongoException

     * @throws UnknownHostException

     */

    public static void findOne() throws MongoException, UnknownHostException {

        DBObject dbObject = getCollection().findOne(); // 等同于mongo 执行

        // db.game.findOne()

        System.out.println(dbObject);

        /**

         * 输出结果 ：{ "_id" : ObjectId("547562c991818dbe4d036486"), "number" : 1 }

         */

    }

    /**

     * 获得document的集合

     *

     * @param

     * @throws MongoException

     * @throws UnknownHostException

     */

    public static void getDocCollections() throws UnknownHostException,

            MongoException {

        DBCursor cursor = getCollection().find();

        while (cursor.hasNext()) {

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

        }

        /***

         * 输出结果为：{ "_id" : { "$oid" : "547562c991818dbe4d036486"} , "number" :

         * 1} { "_id" : { "$oid" : "547562c991818dbe4d036487"} , "number" : 2} {

         * "_id" : { "$oid" : "547562c991818dbe4d036488"} , "number" : 3} {

         * "_id" : { "$oid" : "547562c991818dbe4d036489"} , "number" : 4} {

         * "_id" : { "$oid" : "547562c991818dbe4d03648a"} , "number" : 5} {

         * "_id" : { "$oid" : "547562c991818dbe4d03648b"} , "number" : 6} {

         * "_id" : { "$oid" : "547562c991818dbe4d03648c"} , "number" : 7} {

         * "_id" : { "$oid" : "547562c991818dbe4d03648d"} , "number" : 8} {

         * "_id" : { "$oid" : "547562c991818dbe4d03648e"} , "number" : 9} {

         * "_id" : { "$oid" : "547562c991818dbe4d03648f"} , "number" : 10}

         */

    }

    /**

     * 获得document集合的总数

     *

     * @throws UnknownHostException

     * @throws MongoException

     */

    public static void getDocCount() throws UnknownHostException,

            MongoException {

        DBCursor cursor = getCollection().find();

        System.out.println(cursor.count());

    }

    /**

     * 根据条件取document

     *

     * @throws UnknownHostException

     * @throws MongoException

     */

    @SuppressWarnings("unchecked")

    public static void getDocCollectionsByCondition()

            throws UnknownHostException, MongoException {

        BasicDBObject query = new BasicDBObject();

        query.put("number", 5); // 取number 为5的document

        DBCursor cursor = getCollection().find(query);

        while (cursor.hasNext()) {

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

        }// 输出结果：{ "_id" : { "$oid" : "547562c991818dbe4d03648a"} , "number" :

        // 5}

        /**

         * 使用 "$in"

         */

        BasicDBObject query_in = new BasicDBObject();

        List list_in = new ArrayList();

        list_in.add(9);

        list_in.add(10);

        query_in.put("number", new BasicDBObject("$in", list_in)); // 取number等于9和10的数据

        DBCursor cursor_in = getCollection().find(query_in);

        while (cursor_in.hasNext()) {

            System.out.println(cursor_in.next());// 输出结果：{ "_id" : { "$oid" :

            // "547562c991818dbe4d03648e"}

            // , "number" : 9}

            // { "_id" : { "$oid" : "547562c991818dbe4d03648f"} , "number" : 10}

        }

        /*

         * 使用>,<等比较符号 "$lt" "$lte" "$gt" "$gte" "$ne" //小于 小于等于 大于 大于等于 不等于

         */

        BasicDBObject query_gt = new BasicDBObject();

        query_gt.put("number", new BasicDBObject("$gt", 5).append("$lte", 8)); // 大于5小于8

        DBCursor cursor_gt = getCollection().find(query_gt);

        while (cursor_gt.hasNext()) {

            System.out.println(cursor_gt.next());// 输出结果：{ "_id" : { "$oid" :

            // "547562c991818dbe4d03648b"}

            // , "number" : 6}

            // { "_id" : { "$oid" : "547562c991818dbe4d03648c"} , "number" : 7}

            // { "_id" : { "$oid" : "547562c991818dbe4d03648d"} , "number" : 8}

        }

    }

    /**

     * 删除操作

     */

    @SuppressWarnings("unchecked")

    public static void removeFirstOne() throws MongoException,

            UnknownHostException {

        // 删除第一个document

        DBObject dbObject = getCollection().findOne();

        getCollection().remove(dbObject);

        // 删除指定的document

        BasicDBObject document = new BasicDBObject();

        document.put("number", 2);

        getCollection().remove(document);

        // 使用$in 删除多个document

        BasicDBObject query_in = new BasicDBObject();

        List list_in = new ArrayList();

        list_in.add(9);

        list_in.add(10);

        query_in.put("number", new BasicDBObject("$in", list_in)); // 先取number等于9和10的数据

        getCollection().remove(query_in);

        // 删除所有的document

        DBCursor cursor = getCollection().find();

        while (cursor.hasNext()) {

            getCollection().remove(cursor.next());

        }

    }

    /**

     * 保存图片

     *

     * @throws IOException

     */

    public static void savePhoto() throws IOException {

        String newFileName = "test-mongo-image";

        File imageFile = new File("C:\\Users\\xiao\\Desktop\\pda\\logo.gif");

        GridFS gfsPhoto = new GridFS(getDb(), "photo");

        GridFSInputFile gfsFile = gfsPhoto.createFile(imageFile);

        gfsFile.setFilename(newFileName);

        gfsFile.save();

    }

    /**

     * 读取图片

     *

     * @throws UnknownHostException

     * @throws MongoException

     */

    public static void readPhoto() throws UnknownHostException, MongoException {

        String newFileName = "test-mongo-image";

        GridFS gfsPhoto = new GridFS(getDb(), "photo");

        GridFSDBFile imageForOutput = gfsPhoto.findOne(newFileName);

        System.out.println(imageForOutput);

        /**

         *

         *

         *输出结果：{ "_id" : { "$oid" : "54756e479181e6adf838e1f0"} , "chunkSize" :

         * 262144 , "length" : 5238 , "md5" : "a47baf8201db57a790c91c88329aaa69"

         * , "filename" : "test-mongo-image" , "contentType" : null ,

         * "uploadDate" : { "$date" : "2014-11-26T06:08:07.047Z"} , "aliases" :

         * null }

         *

         *

         */

    }

    /**

     * 读取所有的图片

     *

     * @throws UnknownHostException

     * @throws MongoException

     */

    public static void readAllPhoto() throws UnknownHostException,

            MongoException {

        GridFS gfsPhoto = new GridFS(getDb(), "photo");

        DBCursor cursor = gfsPhoto.getFileList();

        while (cursor.hasNext()) {

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

        }

    }

    /**

     * 从数据库读取后写入到磁盘上

     *

     * @throws IOException

     */

    public static void readToWrite() throws IOException {

        String newFileName = "test-mongo-image";

        GridFS gfsPhoto = new GridFS(getDb(), "photo");

        GridFSDBFile imageForOutput = gfsPhoto.findOne(newFileName);

        imageForOutput.writeTo("c:\\JavaWebHostingNew.png");

    }

    /**

     * 删除图片

     *

     * @throws UnknownHostException

     * @throws MongoException

     */

    public static void removePhotos() throws UnknownHostException,

            MongoException {

        String newFileName = "test-mongo-image";

        GridFS gfsPhoto = new GridFS(getDb(), "photo");

        gfsPhoto.remove(gfsPhoto.findOne(newFileName));

    }

    public static void main(String[] args) throws Exception {

        /**

         * 插入 4种方式

         */

        // insertByBasicDBObject();

        // insertByBasicDBObjectBuilder();

        // insertByMap();

        // insertByJson();

        /**

         * 更新

         * */

        // update_1();

        // update_inc();

        // update_set();

        // update_unset();

        // update_multi();

        /**

         * 初始化需要查询的数据

         */

        // init();

        // findOne();

        // getDocCollections();

        // getDocCount();

        // getDocCollectionsByCondition();

        // removeFirstOne();

        /**

         * 图片操作

         */

        // savePhoto();

        // readPhoto();

        // readAllPhoto();

        // readToWrite();

        // removePhotos();

        System.out.println("done....");

    }

}

源码地址：http://download.csdn.net/detail/u010497606/8200295

最新文章

  1. cron表达式详解[转]
  2. Python魔法 - MetaClass
  3. [MCSM]伪随机数和伪随机数生成器
  4. 通过IL分析C#中的委托、事件、Func、Action、Predicate之间的区别与联系
  5. Android 多国语言
  6. socket.io发送给指定的客户端
  7. Java中的继承与组合
  8. Wii硬盘游戏管理
  9. 测试框架mochajs详解
  10. 如何优雅的设计Redux中的Store
  11. thinkphp pdo 重写问题
  12. 商城项目实战 | 2.1 Android 仿京东商城——自定义 Toolbar (一)
  13. 实现 node_modules 共享
  14. 【Arduino】2017年电子设计大赛B题 滚球控制系统|板球系统
  15. Spring Boot 2.x基础教程：工程结构推荐
  16. cf455C Civilization (并查集)
  17. vim 多行添加注释，取消注释
  18. TXLSReadWriteII5 单元格读写
  19. How to use Nissan consult 3 plus to check, make key and program?
  20. HTTP小幺鸡接口管理工具安装与配置说明

热门文章

  1. RedHat升级内核成功
  2. Qt双缓冲机制：实现一个简单的绘图工具（纯代码实现）
  3. 使用Fiddler解析WCF RIA Service传输的数据
  4. Oracle 11g RAC features
  5. 网页在Safari快速滚动和回弹的原理： -webkit-overflow-scrolling : touch;的实现
  6. sublime编辑器怎样高速输入PHP头部版本号声明
  7. BootStrap 智能表单系列 十 自动完成组件的支持
  8. Lucene站内搜索的设计思路
  9. C++变量
  10. Ubuntu 14.10 编译 qt4.8.6