MONGO常用操作指令

配置：

// 结果50行为1批展示
DBQuery.shellBatchSize = 50

创建：

// 创建表
db.createCollection('table_name')
// 创建索引（unique可选 是否唯一索引）
db.getCollection("table_name").createIndex({column1: 1, column2: 1},{unique: true});

查询：

基础查询

find语法

db.collection.find(query, projection)
query 为可选项，设置查询操作符指定查询条件；
projection 也为可选项，表示使用投影操作符指定返回的字段，如果忽略此选项则返回所有字段。

示例

// 单条件查询
db.getCollection("table_name").find({"_id" : ObjectId("626003cb3eecaa000aac4a22")}).limit(1000).skip(0).pretty()
// 多条件查询
db.getCollection("table_name").find({"_id" : ObjectId("626003cb3eecaa000aac4a22"), "column" : "value"}).limit(1000).skip(0).pretty()
// 指定返回查询
db.getCollection("table_name").find({"column" : "value"}, { _id: 1, column: 1}).limit(1000).skip(0).pretty()
// 条件操作符查询
// 常用操作符: $gt,$lt,$gte,$lte,$ne,$in,$regex,$or,$size
db.getCollection("table_name").find({_id: {$in: [ObjectId("61adde77c1b7d15c5b2ca823"), ObjectId("61add448c1b7d15c5b2ca7f5")]}})
// 查询结果排序(1 是升序，-1 是降序)
db.getCollection("table_name").find({}, {create_time: 1}).sort({"create_time":1}).limit(1000).skip(0).pretty()

聚合查询

aggregate语法

db.aggregate( [ <pipeline> ], { <options> } )

管道操作符

// 会丢失[],null,以及无指定字段 的数据
db.getCollection('table_name').aggregate([
    {
        $unwind: '$list'
    }
])
 
// 不会丢失[],null,以及无指定字段 的数据
db.getCollection('table_name').aggregate([
    {
        $unwind: {
            path: '$list', // path是指定字段
            preserveNullAndEmptyArrays: true //该属性为true即保留
        }
    }
])

表达式操作符

 示例

// group
db.getCollection("table_name").aggregate([{"$group": {_id:"$create_name"}}])
 
// where + group
db.getCollection("table_name").aggregate([{"$match": {create_name: "zhangsan"}}, {"$group": {_id:"$create_name"}}])
 
// where + group + having
db.getCollection("table_name").aggregate([{"$match": {create_name: "zhangsan"}}, {"$group": {_id:"$create_name", count:{$sum:1}}}, {"$match": {count:{$gt:1}}}])
 
// 多个字段group
db.getCollection("table_name").aggregate([{"$match": {create_time:{$gte:ISODate("2023-09-14T16:00:00.000Z")}}}, {"$group": {_id:{create_name: "$create_name", create_time: "$create_time"}, count:{$sum:1}}}])
 
// sum字段
db.getCollection("table_name").aggregate([{"$match": {create_time:{$gte:ISODate("2023-09-14T16:00:00.000Z")}}}, {"$group": {_id:{create_name: "$create_name", create_time: "$create_time"}, count:{$sum:"$price"}}}])
 
// Date字段拆分
db.getCollection("table_name").aggregate([{"$match": {create_time:{$gte:ISODate("2023-08-10T16:00:00.000Z")}}}, {"$group": {_id: {
          create_time: {
               month: { $month: "$create_time" },
               day: { $dayOfMonth: "$create_time" },
               year: { $year: "$create_time"}
           }
        }, count:{$sum: 1}}}])
 
// push
db.getCollection("table_name").aggregate([
  {
    $group: {
      _id: '$price',
      title: { $push: '$title' }
    }
  }
])
 
// unwind + project + toLower + toUpper + concat + substr + substrCP + 加减乘除模
db.getCollection("table_name").aggregate([
  { $unwind: '$数组列名' },
  { 
    $project: {
      _id: 0,
      Title: '$title',
      tags: '$tags',
      New_Title: { $toLower: '$title'},
      New_Tags: { $toUpper: '$tags'},
      Title_Tags: { $concat: ['$title','-','$tags']},
      Title_Prefix: { $substr: ['$title',0,3]},
      Title_Prefix_CN: { $substrCP: ['$title',0,6]},
      Add_Price: { $add: ['$price',1]},
      Sub_Price: { $subtract: ['$price',1]},
      Mul_Price: { $multiply: ['$price',2]},
      Div_Price: { $divide: ['$price',2]},
      Mod_Price: { $mod: ['$price',2]}
   }
  }
])
 
// lookup
db.getCollection("source_table_name").aggregate([
    {
      $lookup:
        {
          from: "dest_table_name",
          localField: "source_table_name key",
          foreignField: "dest_table_name key",
          as: "new column name"
        }
   }
])

options

collation: {
   locale: ,
   caseLevel: ,
   caseFirst: ,
   strength: ,
   numericOrdering: ,
   alternate: ,
   maxVariable: ,
   backwards: 
}

db.getCollection('table_name').aggregate([{$group: {_id: "$ds",count: { $sum: 1 }}}],{explain: "executionStats"} )
db.getCollection('table_name').explain("executionStats").aggregate([{$group: {_id: "$ds",count: { $sum: 1 }}}])

修改：

更新语法

// 已不推荐使用
db.collection.update(filter, update, options)
// 是对update的封装,不支持{multi:true}属性,加了也没用
db.collection.updateOne(filter，update，options)  // Added in MongoDB 4.2
// 是对update的封装,自动加入了 {multi:true}属性,设为false也不行
db.collection.updateMany(filter，update，options)  // Added in MongoDB 4.2

更新方法模板

db.collection.update(
   <filter>,
   <update>,
   {
     upsert: <boolean>,  // 默认false
     multi: <boolean>,   // 默认false
     writeConcern: <document>,
     collation: <document>,
     arrayFilters: [ <filterdocument1>, ... ],
     hint:  <document|string>, // Added in MongoDB 4.2
     let: <document> // Added in MongoDB 5.0
   }
)
 
writeConcern：可选，MongoDB写入安全机制，用于控制写入安全的级别。它指定了在写操作完成之前，MongoDB需要接收到的确认数。writeConcern级别越高，写操作的确认就越安全，但也会影响写的性能。writeConcern有三种级别，分别是：
- 1：表示写操作需要写入主节点的内存中，但不需要确认写操作是否成功。这是默认级别。
- majority：表示写操作需要写入大多数节点的内存中，并且需要确认写操作是否成功。
- <number>：表示写操作需要写入指定数量的节点的内存中，并且需要确认写操作是否成功。
如果有需求可以查看文档：https://www.mongodb.com/docs/v5.0/reference/write-concern/

字段更新操作符:

数组字段更新操作符:

更新操作符修饰符

update示例：MongoDB update 彻底聊明白（案例篇） - 知乎

执行返回：WriteResult

执行完update命令之后我们应该明白MongoDB返回的信息，告诉我们成功与否以及更新了多少条等信息；db.collection.update () 方法返回一个WriteResult()对象，其中包含操作的状态。

执行成功

如果执行成功，WriteResult()对象将包含：

• nMatched：匹配查询条件的文档数量
• nUpserted：更新插入的文档数量
• nModified：修改的文档数量

WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })

执行失败

如果执行失败，WriteResult对象除了成功哪些字段之外，还包含writeConcernError，比较重要的信息有错误信息(errmsg).如下显示写入复制节点超时：

WriteResult({
   "nMatched" : 1,
   "nUpserted" : 0,
   "nModified" : 1,
   "writeConcernError": {
     "code" : 64,
     "errmsg" : "waiting for replication timed out",
     "errInfo" : {
       "wtimeout" : true,
       "writeConcern" : {
         "w" : "majority",
         "wtimeout" : 100,
         "provenance" : "getLastErrorDefaults"
       }
   }
})

示例：
// set更新数据
db.getCollection("table_name").update({"_id" : ObjectId("628cbae13b7750c6711d09f4")}, {$set:{"column":"value"}}, false, true)
// unset去除数据
db.getCollection("table_name").update({"_id" : ObjectId("628cbae13b7750c6711d09f4")}, {$unset:{"column":"value"}}, {upsert:true, multi:true})
// push添加数据
db.getCollection("table_name").update({"_id" : ObjectId("628cbae13b7750c6711d09f4")}, {"$push":{"actions" : "appeal-rule-link"}}, {"$push":{"consumers" : {
      "source" : "zp_serv13_appeal_audit",
      "timeOut" : NumberInt("1000")
    }}})
// pull移除数据
db.getCollection("table_name").update({"_id" : ObjectId("628cbae13b7750c6711d09f4")}, {"$pull":{"actions" : ["appeal_check_dispose"]}})

删除：

// 指定query删除
db.getCollection("table_name").remove({create_time:{$gte:ISODate("2023-08-29T01:55:38.000Z"),$lte:ISODate("2023-08-29T01:56:37.999Z")}})

批量操作

// String转Int
db.getCollection('table_name').find({column:{$type:"string"}}).forEach(
   function(item){   
     item.column=NumberInt(item.column);
     db.getCollection('table_name').save(item);
   }
)
 
// ..._...转...-...
db.getCollection('table_name').find({column:{$regex:"-"}}).forEach(
   function(item){                
     item.column = item.column.replace('_', '-');
     db.getCollection('table_name').update({"_id":item._id},{"$set":{"column":item.column}});
   }
)
 
// ...aaa...转...bb...
db.getCollection('table_name').find({'column':{'$regex': /aaa/ }}).forEach(
    function(item) {
    var tmp = String(item.column)
    tmp = tmp.replace('aaa','bb')
    if (tmp == null){
        print(item.column)  
    }
    item.column = tmp ;
    db.table_name.save(item);
});
db.getCollection('table_name').updateMany(
  {'column':{'$regex': "aaa"}},
  {
    $set: {column: {
      $replaceOne: { input:"$column", find:"aaa", replacement:"bb" }
    }}
  }
);

其他：

// 计数
db.getCollection("table_name").count()
 
// mongo数据导入导出
1.导出 ./bin/mongoexport -h 'host' -p 'port' --username 'username' --password 'password' -d 'database_name' -c 'collection_name' --authenticationDatabase 'auth' -o dump.txt
2.压缩 tar -zcf dump.tar.gz dump.txt
3.下载 downloadfile dump.tar.gz
4.导入 ./bin/mongoimport -h 'host' -p 'port' --username 'username' --password 'password' -d 'database_name' -c 'collection_name' --authenticationDatabase 'auth'  /../dump.txt