mongo 的垮库与批量操作

批量更新

db.getCollection('JRCP_XYK_WAK_ALL').find({}).forEach(   function(item){                       db.getCollection('JRCP_XYK_WAK_ALL').update({"_id":item._id},{$set:{"STATUS_": "1"}})   } )

垮库批量操作

var count = 0; var items = {}; db.getSiblingDB("spider_data").JRCP_BX.find({"ENTITY_CODE_":"JRCP_LCCP_ZGJSYH_GW_ALL"}).forEach(function(_item) {   // items 当做 map 使用， key 商品条码（barcode）   items[_item.URL_] = _item; }); ​ db.getCollection('JRCP_LCCP_ZGJSYH_GW_ALL').find({}).forEach(function(_order){   var item = items[_order.URL_];   if(item){       // db.JRCP_BX_ZGJSY_GW_ALL.update({_id:_order._id});       count++;   }else{       print("商品不存在， 条码：" + _order.URL_);   } }); print("更新条数：" + count);

 

var count = 0; var inexistence_count = 0; // 不存在计数 var items = {}; var items_old = {}; var items_temp = {}; db.getSiblingDB("spider_data").JRCP_JJ.find({"ENTITY_CODE_":"JRCP_JJ_ZGMSYH_GW_ALL"}).forEach(function(_item) {   // items 当做 map 使用， key 商品条码（barcode）   items[_item.URL_] = _item; }); db.getSiblingDB("spider_data_old").JRCP_JJ.find({"ENTITY_CODE_":"JRCP_JJ_ZGMSYH_GW_ALL"}).forEach(function(_item) {   // items_old 当做 map 使用， key 商品条码（barcode）   items_old[_item.URL_] = _item; }); db.getSiblingDB("spider_url_temp").JRCP_JJ_ZGMSYH_GW_ALL.find({}).forEach(function(_item) {   // items_fixed 当做 map 使用， key 商品条码（barcode）   items_temp[_item.URL_] = _item; }); ​ ​ db.getSiblingDB("spider_url_fixed").JRCP_JJ_ZGMSYH_GW_ALL.find({}).forEach(function(_order){   var item = items[_order.URL_];   var item_old = items_old[_order.URL_];   var item_temp = items_temp[_order.URL_];   if(item || item_old || item_temp){ //     print(_order.URL_);       count++;   }else{       inexistence_count++; print(_order.URL_);   } }); print("更新条数：" + count); print("不存在条数：" + inexistence_count);