MongoDB详解

复制代码
update() 方法用于更新已存在的文档。语法格式如下：
db.collection.update(
   <query>,
   <update>,
   {
     upsert: <boolean>,
     multi: <boolean>,
     writeConcern: <document>
   }
)
参数说明：对比update db1.t1 set name='EGON',sex='Male' where name='egon' and age=18;

query : 相当于where条件。
update : update的对象和一些更新的操作符（如$,$inc...等，相当于set后面的
upsert : 可选，默认为false，代表如果不存在update的记录不更新也不插入，设置为true代表插入。
multi : 可选，默认为false，代表只更新找到的第一条记录，设为true,代表更新找到的全部记录。
writeConcern :可选，抛出异常的级别。

更新操作是不可分割的：若两个更新同时发送，先到达服务器的先执行，然后执行另外一个，不会破坏文档。

#1、最简单的更新就是用一个新的文档完全替换匹配的文档。这适用于大规模式迁移的情况。例如对下面的用户文档做
一个比较大的调整
> db.user.find().pretty()
{
    "_id" : ObjectId("5a5b3a74c126b4b2cbb57e3f"),
    "name" : "ming",
    "girl_friends" : 20,
    "height" : 170
}


# 先找到要修改的对象
> var obj=db.user.findOne({'name':'ming'})
> obj
{
    "_id" : ObjectId("5a5b3a74c126b4b2cbb57e3f"),
    "name" : "ming",
    "girl_friends" : 20,
    "height" : 170
}
# 修改
> obj.detail={'girl_friends':20,'height':170}
{ "girl_friends" : 20, "height" : 170}
> obj.username=obj.name
egon

# 删掉不要的
> delete obj.girl_friends
true
> delete obj.height
true
> delete obj.name
true

# 完成更新
> db.user.update({'name':'ming'},obj)
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find()
{ "_id" : ObjectId("5a5b3a74c126b4b2cbb57e3f"), "detail" : { "girl_friends" : 20, "height" : 170}, "username" : "ming" }

2、一个常见的错误
db.user.insert({'name':'ming','age':10})
db.user.insert({'name':'ming','age':20})
db.user.insert({'name':'ming','age':30})
> db.user.find()
{ "_id" : ObjectId("5a5b3ecac126b4b2cbb57e43"), "name" : "ming", "age" : 10 }
{ "_id" : ObjectId("5a5b3ecbc126b4b2cbb57e44"), "name" : "ming", "age" : 20 }
{ "_id" : ObjectId("5a5b3ecdc126b4b2cbb57e45"), "name" : "ming", "age" : 30 }

# 找到的是第二个ming，他要过生日，于是长了一岁
> var obj=db.user.findOne({'name':'ming','age':20})
> obj.age++


# 我们的条件只定位到第二条记录这一条记录，所以更新是没问题的，
> db.user.update({'name':'ming','age':20},obj)
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })

# 我们的条件定位到了多条记录，而obj对象的_id是一定的，文档中的_id是唯一的，我们无法将三条改成同一个_id，所以报错
> db.user.update({'name':'ming'},obj) #报错

# 删掉后，更新成功，但默认改的是第一条
> delete obj._id
true
> obj
{ "name" : "ming", "age" : 21 }
> db.user.update({'name':'ming'},obj)
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find()
{ "_id" : ObjectId("5a5b40f6c126b4b2cbb57e46"), "name" : "ming", "age" : 21 }
{ "_id" : ObjectId("5a5b40f6c126b4b2cbb57e47"), "name" : "ming", "age" : 20 }
{ "_id" : ObjectId("5a5b40f6c126b4b2cbb57e48"), "name" : "ming", "age" : 30 }
> 

# 所以针对这种情况，我们还以_id作为条件保证只定位到我们想要修改的对象，并且比起随机字符串，_id的查找速度更快
> db.user.update({'_id':ObjectId("5a5b40f6c126b4b2cbb57e47")},obj)

# ps: 改多条
> db.user.update({'name':'ming'},obj,{'multi':true})
WriteResult({
    "nMatched" : 0,
    "nUpserted" : 0,
    "nModified" : 0,
    "writeError" : {
        "code" : 9,
        "errmsg" : "multi update only works with $ operators" #只能用修改器
    }
})
> db.user.update({'name':'ming'},{$set:obj},{'multi':true})
WriteResult({ "nMatched" : 3, "nUpserted" : 0, "nModified" : 1 })

通常文档只会有一部分需要更新。可以使用原子性的更新修改器，指定对文档中的某些字段进行更新。
更新修改器是种特殊的键，用来指定复杂的更新操作，比如修改、增加后者删除

#=======>1、"$set"修改器
> db.user.find()
{ "_id" : ObjectId("5a5b51a257147a04b81f2bb4"), "name" : "egon", "age" : 10 }
{ "_id" : ObjectId("5a5b51a257147a04b81f2bb5"), "name" : "egon", "age" : 20 }
{ "_id" : ObjectId("5a5b51a357147a04b81f2bb6"), "name" : "egon", "age" : 30 }
#完全覆盖原文档
> db.user.update({'_id':ObjectId("5a5b51a257147a04b81f2bb4")},{'age':111})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find()
{ "_id" : ObjectId("5a5b51a257147a04b81f2bb4"), "age" : 111 }
{ "_id" : ObjectId("5a5b51a257147a04b81f2bb5"), "name" : "egon", "age" : 20 }
{ "_id" : ObjectId("5a5b51a357147a04b81f2bb6"), "name" : "egon", "age" : 30 }
>

#$set只更新原文档的一部分
> db.user.update({'_id':ObjectId("5a5b51a257147a04b81f2bb5")},{'$set':{'age':222}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find()
{ "_id" : ObjectId("5a5b51a257147a04b81f2bb4"), "age" : 111 }
{ "_id" : ObjectId("5a5b51a257147a04b81f2bb5"), "name" : "egon", "age" : 222 }
{ "_id" : ObjectId("5a5b51a357147a04b81f2bb6"), "name" : "egon", "age" : 30 }

# 有则更新，无则新增
> db.user.update({'age':30},{'$set':{'addr':{'country':'China','city':'BJ'}}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find()
{ "_id" : ObjectId("5a5b51a257147a04b81f2bb4"), "age" : 111 }
{ "_id" : ObjectId("5a5b51a257147a04b81f2bb5"), "name" : "egon", "age" : 222 }
{ "_id" : ObjectId("5a5b51a357147a04b81f2bb6"), "name" : "egon", "age" : 30, "addr" : { "country" : "China", "city" : "BJ" } }


# 修改内嵌文档
db.user.update({'age':30},{'$set':{'addr.country':'CHINA'}})

# $unset 删除该键值对
db.user.update({'age':30},{'$unset':{'addr':'什么值都行'}})



#=======>2、增加和减少
"$inc"修改器用来增加已经有的键的值（负数则为减少），或者该键不存在那就创建一个。只能用于整型、长整型或双浮点
的值。
对于更新分析数据、因果关系、投票或者其他有变化数值的地方，使用这个都会非法方便


例如：
> db.analytics.find()
{ "_id" : ObjectId("5a5b4cb2126d610970c553ab"), "url" : "http://www.baidu.com", "pv" : 2 }
> db.analytics.update({'url':'http://www.baidu.com'},{'$inc':{'pv':1}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.analytics.find()
{ "_id" : ObjectId("5a5b4cb2126d610970c553ab"), "url" : "http://www.baidu.com", "pv" : 3 }
使用修改器时，_id的值不能改变。其他的键值，包括其他的唯一索引的键，都是可以更改的。
注意:整个文档替换时可以改变_id



#=======>3、往数组内添加元素
如果数组已经存在，"$push"会向已有的数组末尾加入一个元素，要是没有就创建一个新的数组。
例如提交博客的评论

db.blog.insert({'_id':1,'name':'alex意外死亡的真相'})

db.blog.update({'_id':1},{'$push':{'comments':{"name":"egon","content":'alex是谁？？？'}}})
db.blog.update({'_id':1},{'$push':{'comments':{"name":"wxx","content":'我去，真的假的'}}})
db.blog.update({'_id':1},{'$push':{'comments':{"name":"yxx","content":'吃喝嫖赌抽，欠下两个亿'}}})

> db.blog.find().pretty()
{
        "_id" : 1,
        "name" : "alex意外死亡的真相",
        "comments" : [
                {
                        "name" : "egon",
                        "content" : "alex是谁？？？"
                },
                {
                        "name" : "wxx",
                        "content" : "我去，真的假的"
                },
                {
                        "name" : "yxx",
                        "content" : "吃喝嫖赌抽，欠下两个亿"
                }
        ]
}

# 一次加多个"$push"
db.blog.update({'_id':1},{'$push':{'comments':{'$each':[{'name':'oldboy','content':'鼓掌'},{'name':'oldgirl','content':'一鞠躬'}]}}})

> db.blog.find().pretty()
{
        "_id" : 1,
        "name" : "alex意外死亡的真相",
        "comments" : [
                {
                        "name" : "egon",
                        "content" : "alex是谁？？？"
                },
                {
                        "name" : "wxx",
                        "content" : "我去，真的假的"
                },
                {
                        "name" : "yxx",
                        "content" : "吃喝嫖赌抽，欠下两个亿"
                },
                {
                        "name" : "oldboy",
                        "content" : "鼓掌"
                },
                {
                        "name" : "oldgirl",
                        "content" : "一鞠躬"
                }
        ]
}


# 限制大小"$slice",只留最后n个
db.blog.update({'_id':1},{'$push':{'comments':{'$each':[
    {'name':'xxx','content':'二鞠躬'},
    {'name':'yyy','content':'三鞠躬'},
    {'name':'yyy','content':'四鞠躬'},
    {'name':'zzz','content':'五鞠躬'},
    {'name':'mmm','content':'六鞠躬'},
    {'name':'nnn','content':'七鞠躬'},
    ],
    '$slice':-7
}}})

> db.blog.find().pretty()
{
        "_id" : 1,
        "name" : "alex意外死亡的真相",
        "comments" : [
                {
                        "name" : "oldgirl",
                        "content" : "一鞠躬"
                },
                {
                        "name" : "xxx",
                        "content" : "二鞠躬"
                },
                {
                        "name" : "yyy",
                        "content" : "三鞠躬"
                },
                {
                        "name" : "yyy",
                        "content" : "四鞠躬"
                },
                {
                        "name" : "zzz",
                        "content" : "五鞠躬"
                },
                {
                        "name" : "mmm",
                        "content" : "六鞠躬"
                },
                {
                        "name" : "nnn",
                        "content" : "七鞠躬"
                }
        ]
}




#=======>4、The $sort element value must be either 1 or -1"
# '$sort':{'name': 1}升序排
db.blog.update({'_id':1},{'$push':{'comments':{'$each':[
    {'name':'aaa','content':'礼毕'},
    ],
    '$slice':-3,
    '$sort':{'name': 1}
}}})

> db.blog.find().pretty()
{
        "_id" : 1,
        "name" : "alex意外死亡的真相",
        "comments" : [
                {
                        "name" : "yyy",
                        "content" : "三鞠躬"
                },
                {
                        "name" : "yyy",
                        "content" : "四鞠躬"
                },
                {
                        "name" : "zzz",
                        "content" : "五鞠躬"
                }
        ]
}

# '$sort':{'name': -1} 降序排
db.blog.update({'_id':1},{'$push':{'comments':{'$each':[
    {'name':'aaa','content':'礼毕'},
    ],
    '$slice':-2,
    '$sort':{'name': -1}
}}})

> db.blog.find().pretty()
{
        "_id" : 1,
        "name" : "alex意外死亡的真相",
        "comments" : [
                {
                        "name" : "yyy",
                        "content" : "四鞠躬"
                },
                {
                        "name" : "aaa",
                        "content" : "礼毕"
                }
        ]
}


#注意：不能只将"$slice"或者"$sort"与"$push"配合使用，且必须使用"$each"



#=======>5、避免添加重复 "$addToSet"
> db.urls.insert({'_id':1,'urls':[]})
WriteResult({ "nInserted" : 1 })
> db.urls.find()
{ "_id" : 1, "urls" : [ ] }

db.urls.update({'_id':1},{'$addToSet':{'urls':'http://www.baidu.com'}})
db.urls.update({'_id':1},{'$addToSet':{'urls':'http://www.baidu.com'}})
db.urls.update({'_id':1},{'$addToSet':{'urls':'http://www.baidu.com'}})
db.urls.update({'_id':1},{'$addToSet':{'urls':'http://www.python.org'}})
> db.urls.find()
{ "_id" : 1, "urls" : [ "http://www.baidu.com", "http://www.python.org" ] }


db.urls.update({'_id':1},{
    '$addToSet':{
        'urls':{
                '$each':['http://www.baidu.com','http://www.baidu.com','http://www.xxx.com']
            }
    }
})
> db.urls.find()
{ "_id" : 1, "urls" : [ "http://www.baidu.com", "http://www.python.org", "http://www.xxx.com" ] }


#=======>6、删除元素
如果把数组看成是队列或者栈，可以用"$pop",这个修改器可以从数组任何一端删除元素。
{"$pop":{"key":1}} 从数组末尾删除一个元素
{"$pop":{"key":-1}} 从头部删除


> db.queue.insert({'_id':1,'queue':[]})
WriteResult({ "nInserted" : 1 })
# 入队列
db.queue.update({'_id':1},{'$push':{'queue':'alex'}})
db.queue.update({'_id':1},{'$push':{'queue':'egon'}})
db.queue.update({'_id':1},{'$push':{'queue':'wxx'}})
db.queue.update({'_id':1},{'$push':{'queue':'yxx'}})

> db.queue.find()
{ "_id" : 1, "queue" : [ "alex", "egon", "wxx", "yxx" ] }

# 出队列
db.queue.update({'_id':1},{"$pop":{"queue":-1}})
db.queue.update({'_id':1},{"$pop":{"queue":-1}})
db.queue.update({'_id':1},{"$pop":{"queue":-1}})


# "$pull" 把符合条件的统统删掉，而$pop只能按照位置删除
db.queue.update({'_id':1},{"$pull":{"queue":'yxx'}})




#=======>7、基于位置的数组修改器
db.blog.insert({'_id':1,'name':'alex意外死亡的真相'})

db.blog.update({'_id':1},{'$push':{'comments':{"name":"egon","content":'alex是谁？？？','thumb':20}}})
db.blog.update({'_id':1},{'$push':{'comments':{"name":"wxx","content":'我去，真的假的','thumb':30}}})
db.blog.update({'_id':1},{'$push':{'comments':{"name":"yxx","content":'吃喝嫖赌抽，欠下两个亿','thumb':40}}})

> db.blog.find().pretty()
{
        "_id" : 1,
        "name" : "alex意外死亡的真相",
        "comments" : [
                {
                        "name" : "egon",
                        "content" : "alex是谁？？？",
                        "thumb" : 20
                },
                {
                        "name" : "wxx",
                        "content" : "我去，真的假的",
                        "thumb" : 30
                },
                {
                        "name" : "yxx",
                        "content" : "吃喝嫖赌抽，欠下两个亿",
                        "thumb" : 40
                }
        ]
}

根据下标修改
db.blog.update({'_id':1},{'$set':{'comments.0.thumb':200}})


必须查询才知道下表，所以提供了$,$ 代表根据条件匹配出的元素
db.blog.update({'comments.name':'wxx'},{'$set':{'comments.$.thumb':300}})



#=======>8、upsert与multi
db.col.update( { "count" : { $gt : 5 } } , { $set : { "test5" : "OK"} },true,true ) #全部添加加进去