第7.1.2 mongodb常用操作

悠悠 2022-02-27 19:24 192阅读 0赞

**1 根据正则匹配**

db.invalid_data.find({error:"禁限用规则",name:{$regex:'^[.。]+'}})

**2 计数**

db.invalid_data.count({error:"禁限用规则",name:{$regex:'[()]+'}})

**3 更新数据**

db.nvalid_data.find({error:"新旧地址不一致",addresstel:{$regex:'&+'}}).forEach(
        function(item){
            var addresstel = String(item.addresstel)
            addresstel = addresstel.replace('“','“')
            addresstel = addresstel.replace('”','”')
            addresstel = addresstel.replace('·','·')
            addresstel = addresstel.replace('•','•')
            addresstel = addresstel.replace('—','—')
            addresstel = addresstel.replace('▪','▪')
            addresstel = addresstel.replace('▪','♯')
            addresstel = addresstel.replace(' ','')
            addresstel = addresstel.replace('•','•')
            addresstel = addresstel.replace('–','•')
            addresstel = addresstel.replace('½','½')
            addresstel = addresstel.replace('♯',' ')
            addresstel = addresstel.replace('‘','‘')
            addresstel = addresstel.replace('’','’')
            item.addresstel = addresstel
            db.nvalid_data.save(item)
        }    
    )

**4 聚合查询**  
单一条件的

db.invalid_data.aggregate([{$group:{_id:'$error',count:{$sum:1}}}])

多条件的分组查询，先通过match筛选，再分组

db.invalid_data.aggregate([
          {$match:{error:"禁限用规则",name:{$regex:'[(]{2,}.*[)]{2,}'}}},
          {$group:{_id:'$name',count:{$sum:1}}}
      ])

**5 删除**

db.invalid_data.remove({error:"禁限用规则",name:{$regex:'(--)+.*'}})

**6 聚合**  
聚合分组，保留名称最长的记录

db.repeat_data_15.aggregate([
        {$group:{_id:'$code',count:{$sum:1},len:{$max:{len:{$strLenCP :'$name'}}}}},
        {$match:{count:{$gte:2}}}
    ]).forEach(function(it){
            db.repeat_data_15.remove({code:it._id,$where:'this.name.length<'+it.len.len})
        }
    )

聚合后的查询，管道性质。先group，再过滤如下：

db.repeat_data_2.aggregate([
        {$group:{_id:'$code',count:{$sum:1}}},
        {$match:{count:{$gt:2}}}
    ])

根据时间匹配删除，保留最新的记录

db.repeat_data_14.aggregate([
        {$group:{_id:'$code',count:{$sum:1},max_date:{$max : "$date"}}},
        {$match:{count:{$gte:2}}}
    ]).forEach(
        function(it){
            db.repeat_data_14.remove({code:it._id,date:{$lt:it.max_date}})
        }    
    )

**7 查询不存在某字典**

db.repeat_en_14.find({es_index:{$exists:false}})

**8 sum**  
对某一个字段进行求和

db.sub_index.aggregate({$group:{_id:null,cn:{$sum:'$cn'}}})

根据某个条件，分组求和

db.sub_index.aggregate([{$group:{_id:'$end_time',cn:{$sum:'$cn'}}}])

**9 mongo建立索引**  
可以选择一个字段，或者多个字段创建索引

db.change_info.createIndex( { "name" : 1, "code" : 1 } );

**10 mongo根据条件导出数据**  
进入`mongodb/bin`目录下，执行下面的命令

./mongoexport -h 10.101.3.197 --db en_invalid --port 27017  --collection en_invalid_data --query '{error:"不符合规范"}' --out /application/bak/en_invalid_data_20190412.dat

全量备份

mongoexport -h 10.101.3.197 -p 27017 -d my_db -c my_col -o /appnew/mongobeifen20190215/detail_html20190215

还原数据，注意要到第二级目录

mongorestore -h 10.101.3.162:20000 -d en_invalid /tmp/en_invalid/en_invalid

除了这个命令，还有用dump

mongodump -h bwsc62:27017 -d your_db -o /appdata/bak

接着再通过`zip -r bak.zip your_db`进行压缩  
通过下面的命令进行还原

mongorestore -h bwsc148:20000 -d bxt -u=bxt -p=123456 /appdata/bak/your_db

**11 长度查询**  
通过这两种方式均可，正则的性能会好一些。

db.en_invalid_data_1.find({error:"不符合身份证规范",$where:'this.code.length<18'})

db.en_invalid_data_1.find({error:"不符合社会统一信用代码或身份证规范",creditcode:{$regex:/^.{0,17}$/}})