Mongodb联合查询

在关系型数据库中，通过连接运算符可以实现多个表联合查询。而非关系型数据库的特点是表之间属于弱关联，Mongodb作为Nosql代表，其本身特性不建议对多Collection关联处理，不过对于有些需要对多表关联处理的需求，Mongodb也可以实现。主要分为两种方式：简单手工关联和DBRef方式关联

 

1.简单手工关联

下图表示帖子和用户两个Collection的ER图：

首先将authors集合中的用户对象查询出来，放在一个变量author中，代码如下：

> author=db.authors.findOne({name:"chenzhou"})
{
	"_id" : ObjectId("5030ba7621bdee44765b2147"),
	"name" : "chenzhou",
	"email" : "[e-mail]"
}

通过用户对象author来获取帖子列表，代码如下：

> for(var post=db.posts.find({"author_name":author.name}); post.hasNext();){
... printjson(post.next().title);
... }
"Hello Mongodb"
"Hello World"
"Hello My Friend"

2.DBRef方式关联

DBRef就是在两个Collection之间定义的一个关联关系，比如，把CollectionB "_id"列的值存在CollectionA的一个列中，然后通过CollectionA这个列中所存的值在CollectionB中找到相应的记录。

示例：模拟用户发帖的过程，看一看如何将帖子表和用户表建立关联。

步骤1：取得当前用户信息，代码如下：

> author=db.authors.find({name:"chenzhou"})[0]
{
	"_id" : ObjectId("5030ba7621bdee44765b2147"),
	"name" : "chenzhou",
	"email" : "[e-mail]"
}

步骤2：发帖子并做关联，代码如下： 

> db.posts.insert({"title":"Hello Mongodb DBRef1",
... authors:[new DBRef('authors',author._id)]})
> db.posts.insert({"title":"Hello Mongodb DBRef2",
... authors:[new DBRef('authors',author._id)]})
>

步骤3：通知帖子查找用户信息，代码如下：

>  db.posts.find({"title":"Hello Mongodb DBRef1"})[0].authors[0].fetch()
{
	"_id" : ObjectId("5030ba7621bdee44765b2147"),
	"name" : "chenzhou",
	"email" : "[e-mail]"
}

通过这个例子可以看出，DBRef就是从文档的一个属性指向另一个文档的指针。

关于DBRef详细信息，可以参见官网说明：http://docs.mongodb.org/manual/applications/database-references/  

 

评论

8 楼 whjpyyyy 2016-03-01  

                  

7 楼 iwlk 2015-07-16  

通过用户表的email 查询，符合条件的贴子
-------------------
select p._id,p.title

from posts p inner join authors a on a.name=a.author_name

where a.email like '[e-mail]%'


请问，这种查询mongodb 应该怎么写？


你举的例子，应该不叫联合查询吧~

6 楼 29120406 2014-09-04  

5 楼 jorwen_fang 2014-02-10  

咨询你一个关于mongodb DBRef的问题。

看一下我这个问题，帮忙解答一下，谢谢

http://www.iteye.com/problems/100017

4 楼 shen8wu 2013-11-22  

3 楼 junjun16818 2013-05-02  

一个一对多查询就要分2个语句来写那一张表关联了N张表就要写N条查询 如果是多对多那也太夸张了吧，还是说nosql就是应该尽量避免关联关系？

我遇到的问题是我再nodejs环境我查询到所有用户存在变量authors，遍历它。因为在nodejs中find语句是异步执行所以要写以下代码。

var len = authors.length;
authors.forEach(function(author)) {
    Posts.find({"author_name": author.name}, function(posts) {
        len--;
        if(len==0) {
             alert("查询完毕");
        }
    });
   
}

很麻烦。

2 楼 chenzhou123520 2013-04-28  

junjun16818 写道

通过用户查询贴子应该怎么查询呢？

上面已经提到了：
首先将authors集合中的用户对象查询出来，放在一个变量author中，代码如下：

> author=db.authors.findOne({name:"chenzhou"})
{
	"_id" : ObjectId("5030ba7621bdee44765b2147"),
	"name" : "chenzhou",
	"email" : "[e-mail]"
}

通过用户对象author来获取帖子列表，代码如下：

> for(var post=db.posts.find({"author_name":author.name}); post.hasNext();){
... printjson(post.next().title);
... }
"Hello Mongodb"
"Hello World"
"Hello My Friend"

1 楼 junjun16818 2013-04-27  

通过用户查询贴子应该怎么查询呢？