mongodb 循环处理表数据 时间转换


var d=db.Statistical_2016_1.find()

d.forEach(function(item){
 var id = item._id;
 var dateNew=item.executionDate;
 var flowSizeNew = item.flowSize*1024;
 db.Statistical_2016_1.update({_id:id},{$set:{executionDate1:new Date(dateNew)}})
db.Statistical_2016_1.update({_id:id},{$set:{flowSizeNew:flowSizeNew}})

});


关联表更新数据

var mccEntity = db.MccTest.find({})
var isoArray = {};
mccEntity.forEach(function(item){
 var mccNew=item.mcc;
 var county = item.iso2;
 isoArray[mccNew]=county;
});


var d=db.Test_2016_12.find({visit:null,createDate:{$gte:1481500800000}})
d.forEach(function(item){
 var id = item._id;
 var mccNew=item.mcc;
 var county = isoArray[mccNew];
 db.Test_2016_12.update({_id:id},{$set:{visit:county}})
});



mongoexport --authenticationDatabase admin -u root -p 123456 -d test -c cyltest -q '{id:"5711bc85e643cb11e94f4e20",createDate:{$lt:1465344000000,$gte:1465257600000}}' --type csv --fields flowId,customerId,userName,startTime --out test.txt

猜你喜欢

转载自blog.csdn.net/changyuan101/article/details/53488119