title: mongodb-2 mongodb-java-driver做基本的CRUD–基本查询
date: 2017-01-11 16:25:59
tags:
categories: mongodb

本文demo代码地址：https://github.com/lazyguy21/mongoDemo

如何连接mongodb？
http://mongodb.github.io/mongo-java-driver/3.4/driver/tutorials/connect-to-mongodb/
其中MongoClient类比jdbc时的连接池，全局唯一。MongoCollection类似于Connection
不同的是，使用完MongoCollection后并不需要像JDBC，redis的jedis客户端一样手动返回，很方便。

利用Document构建查询语句

mongodb-java-driver为我们提供了2种方式。一种是用Document（类似Map）来构建一个JSON式的对象。怎么个搞法呢？

@Test
public void testQuery() throws Exception {
    Document document = new Document("price", new Document("$gte", 1)
            .append("$lt", 500))
            .append("name", "shirt");
    System.out.println(document.toJson());
    MongoCollection<Document> clothCollection = mongoClient.getDatabase("test").getCollection("Cloth");
    FindIterable<Document> results = clothCollection.find(document);
    results.forEach((Consumer<? super Document>) System.out::println);
}

说实话用json(或者说BSON)的样式作为交互语言，给习惯了sql的我来说本来就十分别扭了，翻译成这个样子之后，不管你怎么看，我觉得简直是崩溃。研究了很久之后，我发现Document提供了2个便利方法。

一个是Document.parse将一个JSON字符串反序列化为Document,

一个是toJson可以把Document序列化为json字符串。

这样tojson方法可以作为一种查看你最后写的BSON语句正确与否的手段。如果记录在日志里面，就可以像打印sql一样留下记录了！

/**
 * 使用mongodb时怎么去判断自己最后写出的语句对不对呢？
 *
 * @throws Exception
 */
@Test
public void testToJson() throws Exception {
    Document document = new Document("price", new Document("$gte", 1)
            .append("$lt", 5))
            .append("name", "shirt");
    String string = document.toJson();
    String s = document.toString();
    System.out.println( s);
    System.out.println(string);

}

输出:

Document{{price=Document{{$gte=1, $lt=5}}, name=shirt}}
{ "price" : { "$gte" : 1, "$lt" : 5 }, "name" : "shirt" }

前者是toString，后者是toJson的结果。可以看见tojson可以直接复制到GUI里面调试。

使用Filters工具类简写

 @Test
    public void testQuery2() throws Exception {
        MongoCollection<Document> clothCollection = mongoClient.getDatabase("test").getCollection("Cloth");
//        此Document等于下面的简写
//        new Document("stars", new Document("$gte", 2)
//                .append("$lt", 5))
//                .append("categories", "Bakery")
        clothCollection.find(and(gte("stars", 2), lt("stars", 5), eq("categories", "Bakery")))
                .forEach((Consumer<? super Document>) System.out::println);

    }

很容易理解的工具类，不过这样写无法利用toJson方法，因为生成的不是Document。

限制Document返回的Field

@Test
public void testKey() throws Exception {
    FindIterable<Document> results = clothCollection.find().projection(Projections.include("name"));
    results.forEach((Consumer<? super Document>) System.out::println);
}

输出：

Document{{_id=586f4c462148d00ffe8d9787, name=shirt}}

如上，返回的仅仅只有_id 和name。

这段实际在shell中就是:db.Cloth.find(null,{“name”:1}); 1表示include，0表示exclude，其中_id在没有指明的时候默认回传。

通过主键查询ID

@Test
    public void queryDate() throws Exception {
//        FindIterable<Document> results = clothCollection.find(Filters.eq("_id", "58759260bc497244060ba7c0"));
        FindIterable<Document> results = clothCollection.find(new Document("_id", new ObjectId("58759260bc497244060ba7c0")));
        
        results.forEach((Consumer<? super Document>) document -> {
            System.out.println(document);
        });

    }

注意Mongodb的主键类型是ObjectID,需要自己去构造。

分页

@Test
public void testPagination() throws Exception {
    int pageNum=1;
    int pageSize=3;
    FindIterable<Document> results = clothCollection.find().skip((pageNum-1)*pageSize).limit(pageSize);
    long count = clothCollection.count();
    System.out.println("count :"+count);
    results.forEach((Consumer<? super Document>) document -> {
        System.out.println(document);
    });

}

mongodb的分skip和count都是非常耗时的操作，数据量达到几百万的时候，最好别进行count。

分页最好只显示前面几十页即可。

或者使用上一页的id作为条件,排序查询代替分页(这样做的弊端是翻页的时候不能跳页，好处是可以一直翻下去，而且不会变慢，其实感觉这样的需求并不强)。

所以一般常见的做法就是别count，分页只拿前面部分。

OR 或查询

@Test
    public void testOR() throws Exception {
//        Document document = new Document("$or", new Object[]{new Document("label", "adfad"), new Document("name", "T")});
//        Document[] documentsParam = new Document[]{new Document("label", "adfad"), new Document("name", "T")};
        ArrayList<Document> documentsParam = Lists.newArrayList(new Document("label", "adfad"), new Document("name", "T"));
        Document document = new Document("$or", documentsParam);
        FindIterable<Document> documents = clothCollection.find(document);
        documents.forEach((Consumer<? super Document>) document1 -> {
            System.out.println(document1);
        });

    }

上面的代码查询的是name=T或者label=adfad的文档。

shell就是:find({ “$or” : [{ “label” : “adfad” }, { “name” : “T” }] })

值得一提的是驱动能认识ArrayList，却没有Array的解析器……

IN查询

@Test
public void testIN() throws Exception {
    Bson queryParam = Filters.in("name", "T", "shirt");
    FindIterable<Document> documents = clothCollection.find(queryParam);
    documents.forEach((Consumer<? super Document>) document1 -> System.out.println(document1));
}

in也可以在单filed的时候或
shell ：find{“name”,{“$in” : [ “shirt”,”T” ]}}

上面代码用的Filters辅助类，参数既可以接受可变参数，也可以是List

NULL查询

@Test
public void testNULL() throws Exception {
    FindIterable<Document> results = clothCollection.find(new Document("name", null));
    results.forEach((Consumer<? super Document>) document1 -> System.out.println(document1));
}

输出:

Document{{_id=58735ed5bc49722dd7b74f91, name=null}}
Document{{_id=58759260bc497244060ba7c0, date=Wed Jan 11 10:03:12 CST 2017}}

可以看到单纯的传 name:null这样的条件，将会匹配到name的值本身为null的Document，也会匹配到根本就没有name这个field的Document！！

匹配有name字段并且name字段值为null的Document

@Test
public void testNULL2() throws Exception {
    ArrayList<Object> objects = Lists.newArrayList();
    objects.add(null);
    FindIterable<Document> documents = clothCollection.find(Filters.and(Filters.in("name",objects), Filters.exists("name")));
    documents.forEach((Consumer<? super Document>) document1 -> System.out.println(document1));
}

shell即为：{name:{“$in”:[null],”$exits”:true}}

没有$eq 这种操作符……只能用$in来代替

比较尴尬的是，null对于java来说也是很特殊的字段，注意上面代码中，我是怎么传null到list里面的……