我爱编程

mongodb常用操作记录

2018-05-14  本文已影响42人  tenlee

修改字段名称

db.集合名称.update({}, {$rename:{"旧键名称":"新键名称"}}, false, true)

参数提示:
第一个false表示:可选,这个参数的意思是,如果不存在update的记录,true为插入新的记录,默认是false,不插入。
第二个true表示:可选,mongodb 默认是false,只更新找到的第一条记录,如果这个参数为true,就把按条件查出来多条记录全部更新。

distinct的实现:

db.consumerecords.distinct("userId"):键值去重 类似于mysql中的 select distinct userId from consumerecords

如果要计算去重后的数量,这个语句在大数据量的情况下不推荐使用,推荐使用如下语句

db.test.aggregate([{$group : {_id : "$userId", num_uerId: {$sum : 1}}}, {$count: "total_userId"}]);

db.consumerecords.distinct("userId",{act:"charge"}):过滤之后去重,类似于mysql中的select distinct userId from consumerecords where act="charge"

db.consumerecords.distinct("userId").length:去重之后求记录数,类似于mysql中的 select count(distinct userId) from consumerecords

count的实现

db.consumerecords.count():类似于 mysql中 select count(*) from consumerecords

db.consumerecords.count({act:"charge"}):类似于mysql中的 select count(*) from consumerecords where act="charge"

管道

db.items.aggregate([{$group:{_id:null,count:{$sum:1}}},{$project:{"_id":0,"count":1}}])  
 { "count" : 8 } 
db.items.aggregate([{$group:{_id:"$pnumber",total:{$sum:"$quantity"}}},{$match:{total:{$gt:8}}}]) 

一个复杂例子

db.getCollection('test').aggregate( [
                        {'$match': {'cardNum': {'$regex': '^310000'}}},
                        {'$project': {'cardNum':1, 'iname': 1}},
                        {'$group': { '_id': {'cardNum': '$cardNum', 'iname': '$iname'}, 'count': {'$sum': 1 }}},
                        {'$project': {'_id': 0, 'person': '$_id', 'count': 1}}, 
                        {'$sort': {'count': -1}},
                        {'$limit': 10}
                        ]);

$push的使用

插入单个

db.getCollection('test').update({source_id: '1'}, {$set: {'price': 4}, $push: 
     {
         "histroy":{"price": 3, "date": 3}
         }
     }, true);

插入多个

db.getCollection('test').update({source_id: '1'}, {$set: {'price': 4}, $push: 
     {
         "histroy": {"$each": [{"price": 3, "date": 3}, {"price": 2, "date": 2}]}
         }
     }, true);

字段的重命名,

mysqlas操作

db['test'].aggregate([
            {'$match': query},
            {'$project': {
                'arr1': {
                    '$map': {
                        "input": "$arr1",
                        'as': "sec",
                        'in': {
                            "col1_1": "$$sec.col1",
                            "re_name": "$name",
                        }
                    }
                },
                'update_time': '$updateTime'
            }}
        ])

计算array item的长度

db['test'].aggregate([
    {"$project":
        {
            "countArray1": {"$size": "$array1"},
           "countArray2": {"$size": {"$ifNull": ["$array2", []]}},
         }
    }
])

数据导出

mongodump -h localhost:27017  -d yourdatabase -u yourusername -p yourpassword -o /home/bak

数据导入

mongorestore -h 127.0.0.1:27017  -d yourdatabase -u yourusername -p yourpassword /home/bak/yourdatabase

参考文章
https://blog.csdn.net/congcong68/article/details/51620040

上一篇 下一篇

猜你喜欢

热点阅读