0

我想findOne在地图减少中使用。我的代码有什么问题？我的错误是：

命令'mapreduce'失败：异常：映射调用失败：JS错误：TypeError：用户没有属性nofile_b：3（响应：{“errmsg”：“异常：映射调用失败：JS错误：TypeError：用户没有属性nofile_b： 3”，“代码”：9014，“确定”：0.0}）

string map = @"
function() {
    var movie = this;
    var user = db.users.findOne({UserId : parseInt(movie.UserId)});
    emit( movie.UserId, {Name:user.Name});
}";


string reduce = @"        
function(key, values) {
    var result =values;
    return result;
}";

string finalize = @"
function(key, value){           
  return value;

}";

c#代码下

var collection = database.GetCollection("movies");
var options = new MapReduceOptionsBuilder();
options.SetFinalize(finalize);
options.SetOutput(MapReduceOutput.Inline);
var results = collection.MapReduce(map, reduce, options);
lbResultList.Items.Clear();
foreach (var result in results.GetResults())
{
     lbResultList.Items.Add(result.ToJson());
}

我解决了我的问题地图功能更改

function () {

var user = db.users.find({UserId:this.UserId});
var userName ='';
var userSurName ='';
user.forEach(function(u) { 
    userName = u.Name;
    userSurName = u.SurName;
});
emit(
    this._id,                   
    {title: this.Title,category:this.Category,UserName: userName,UserSurName: userSurName}  
);

}

我认为这不合逻辑，就像子查询这样解决。这种情况我能做什么？

4

1 回答 1

0

看起来您正在尝试执行 SQL JOIN。MapReduce 是错误的工具。您实际上只想将其分解为聚合操作以获取 UserID 数组和查询操作以获取用户名：

在 mongo shell 中是这样的：

var UserIDArray = [];
movieCollection.aggregate({$group: {_id: "$UserId"}}).forEach(function (v) {
    UserIDArray.push(v._id);
});

UserIDNamePairs = userCollection.find({_id : {$in: UserIdArray}}, {_id: "$name"}).toArray();
于 2013-01-09T23:18:14.420 回答