Java实现对mongoDB的两表关联查询

Posted wgyang2016

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Java实现对mongoDB的两表关联查询相关的知识,希望对你有一定的参考价值。

Java实现对mongoDB的两表关联查询

记录一次学习java实现mongodb的两表关联查询的过程,方便日后需要用到的时候进行回顾。

场景:mongodb中有两张表,需要根据id进行关联查询。

表1数据如下:

表二数据如下:

实现两张表的关联查询,需要用到mongodb的lookup,在查询结果返回的时候,需要将没有结果集为空的数据过滤掉,此时要用到mongodb的match。

java实现需要用到mongo-java-driver包,这里使用mongo-java-driver-3.9.0.jar。阿里的maven镜像依赖如下

<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongo-java-driver</artifactId>
    <version>3.9.0</version>
</dependency>

Java代码实现如下:

MongoClient mongoClient = new MongoClient("localhost", 27017);

//“test”为连接的数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("test");

//test1是表1
MongoCollection<Document> mongoCollection = mongoDatabase.getCollection("test1");

List<Bson> aggregateList = new ArrayList<>(1);

//利用lookup进行关联查询
//test2是表2,两个表根据id进行关联,关联的结果定义一个新的字段

/**Aggregates.lookup函数的说明:
     * lookup(final String from, final String localField, final String foreignField, final String as)
     * Creates a $lookup pipeline stage, joining the current collection with the one specified in from
     * using equality match between the local field and the foreign field
     * @param from         the name of the collection in the same database to perform the join with.
     * @param localField   the field from the local collection to match values against.
     * @param foreignField the field in the from collection to match values against.
     * @param as           the name of the new array field to add to the input documents.
     */
aggregateList.add(Aggregates.lookup("test2", "id", "id", "result"));

//利用match将没有关联到的结果过滤掉
aggregateList.add(Aggregates.match(Filters.ne("result", new ArrayList<String>(0))));
AggregateIterable<Document> aggregateIterable = mongoCollection.aggregate(aggregateList);
for (Document document : aggregateIterable) {
    System.out.println(document.toJson());
}

返回结果如下:

{ "_id" : { "oid" : "5e92c58671f9147a73e03662" }, "id" : "aaa", "keys" : ["name", "mobile"], "values" : ["姓名", "手机"], "result" : [{ "_id" : { "oid" : "5e92c48571f9147a73e0365f" }, "id" : "aaa", "name" : "张三", "mobile" : "12345678987" }, { "_id" : { "oid" : "5e92d5e871f9147a73e03667" }, "id" : "aaa", "name" : "李四", "mobile" : "12345678987" }] }

{ "_id" : { "oid" : "5e92c64e71f9147a73e03664" }, "id" : "ccc", "keys" : ["imsi", "mobile"], "values" : ["IMSI", "手机"], "result" : [{ "_id" : { "oid" : "5e92c73f71f9147a73e03665" }, "id" : "ccc", "imsi" : "28834765932", "mobile" : "12345678987" }] }

整个实现过程需要对mongodb中“管道”的概念有一定的理解。比如在这个场景中,首先通过lookup将关联上的结果查询出来,再通过“管道”将结果集交给match进行过滤。

以上是关于Java实现对mongoDB的两表关联查询的主要内容,如果未能解决你的问题,请参考以下文章

金仓数据库KingbaseES 两表关联Update的两种写法与性能

mongodb关联查询

yii2单表内字段关联查询该怎么做

mybtis两表关联查询相同名字字段显示混乱

请教数据库高手,在access2003里,用sql语句查询实现两表关联查询用count更新其中一表?

qt 两个表关联