search

eteplus / blog

🤠 Just a blog. Welcome to star. 🌟
https://eteplus.com
35 stars 6 forks source link

Mongodb 权威指南阅读笔记 #2

Open eteplus opened 7 years ago

eteplus commented 7 years ago

1、概念

  1. 文档是键值对的一个[有序]集
// 两个文档是不同的
{ x: 1, y: 2 }
{ y: 2, x: 1 }
  1. 集合是一组文档，一个集合相当于一张表
  2. 使用子集合组织数据
  3. 多个文档组成集合，多个集合组成数据库
  4. 数据库命名：UTF-8字符串
    • 不能是空字符串 ("")
    • 不能含有 /, \, ., ", *, <, >, :, |, $ (一个空格), \0 (空字符) 。基本上,只能使用ASCII中的字母和数字。
    • 数据库名区分大小写，建议数据库名应全部小写
    • 数据库名最多为64字节

2、基本操作

  1. 启动数据库服务
> mongodb
  1. 运行SHELL
> mongo
  1. 连接数据库
# 连接test数据库
mongo 127.0.0.1:27017/test
  1. 查看db当前指向的数据库
> db
test # 当前数据库为test
  1. 切换数据库
> use blog # 切换到数据库 blog
switched to db blog
> db
blog
  1. 插入单条：
> post = { "title": "My blog post", "date": new Date() }
> db.blog.insert(post)
WriteResult({ "nInserted" : 1 })
  1. 插入多条：

batchInsert 函数已被废弃，直接使用 insert， insetMany 插入多条数据 (参数为一个数组)

从数据Feed 或 MySQL 导入数据使用 mongoimport

# 导入json数组数据到blog数据库的link集合中
mongoimport -h "127.0.0.1:27017" -d "blog" -c "link" --file "/Users/eteplus/Downloads/link.json" --jsonArray

# 导入csv数据到blog数据库的article集合中
mongoimport -h "127.0.0.1:27017" -d "blog" -c "article" --fields "article_id,wechat_id,title,description,content,cover,type,published_at,created_at,updated_at,remark" --type csv --file "/Users/eteplus/Downloads/article.csv"
> db.blog.insert([{"_id": 0}, {"_id": 1}, {"_id": 2}])
> BulkWriteResult({
    "writeErrors" : [ ],
    "writeConcernErrors" : [ ],
    "nInserted" : 3,
    "nUpserted" : 0,
    "nMatched" : 0,
    "nModified" : 0,
    "nRemoved" : 0,
    "upserted" : [ ]
})

批量插入时，当集合中已存在_id相同的文档时，这个文档以及之后的所有的文档全部插入失败：

> db.blog.insert([{"_id": 3}, {"_id": 4}, {"_id": 5}, {"_id": 5}, {"_id": 6}, {"_id": 7}])
> BulkWriteResult({
    "writeErrors" : [
        {
        "index" : 3,
        "code" : 11000,
        "errmsg" : "E11000 duplicate key error index: test.blog.$_id_ dup key: { : 5.0 }",
        "op" : {
            "_id" : 5
        }
        }
    ],
    "writeConcernErrors" : [ ],
    "nInserted" : 3,
    "nUpserted" : 0,
    "nMatched" : 0,
    "nModified" : 0,
    "nRemoved" : 0,
    "upserted" : [ ]
})
> db.blog.find() // 5, 6, 7都没有出入成功
{ "_id" : 0 }
{ "_id" : 1 }
{ "_id" : 2 }
{ "_id" : 3 }
{ "_id" : 4 }
{ "_id" : 5 }

解决办法：使用continueOnError, (shell 不支持，驱动程序都支持)

> db.blog.find()
{
    "_id": ObjectId("58be4d4da36bb2b91a6cde5d"),
    "title": "My Blog Post",
    "date": ISODate("2017-03-07T06:03:44.225Z")
}
db.{table}.update(query, object[, upsert_bool, multi_bool])
> post.comments = []
[]
> db.blog.update({title: "My Blog Post"}, post)
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.blog.findOne()
{
    "_id": ObjectId("58be4d4da36bb2b91a6cde5d"),
    "title": "My Blog Post",
    "date": ISODate("2017-03-07T06:03:44.225Z"),
    "comments": []
}
db.{table}.remove(query)
# 删除创建的文章
> db.blog.remove({title: "My Blog Post"})

3、更新文档

更新文档时建议使用修改器来修改键/值对，文档替换操作有风险

> db.blog.insert({"name": "joe", "friends": 32, "enemies": 2})
> WriteResult({ "nInserted" : 1 })
> ete = db.blog.findOne({"name": "joe"})
{
    "_id" : ObjectId("58cb7877af6105891ec2a46d"),
    "name" : "joe",
    "friends" : 32,
    "enemies" : 2
}
> ete.relationships = {"friends": ete.friends, "enemies": ete.enemies}
{ "friends" : 32, "enemies" : 2 }
> delete ete.friends
true
> delete ete.enemies
true
> db.blog.update({"name": "joe"}, ete)
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
>db.blog.findOne({"name": "joe"})
{
    "_id" : ObjectId("58cb7877af6105891ec2a46d"),
    "name" : "joe",
    "relationships" : {
        "friends" : 32,
        "enemies" : 2
    }
}
$inc: 增加字段数值 (若字段不存在，则创建)
ps: $inc 只能用于整型、长整型或双精度浮点型的值
# 用 '$inc' 修改器增加 'score' 的值
eg: db.blog.update({ "_id" : ObjectId("58cb7877af6105891ec2a46d")},
{"$inc": {"score": 1}})

$set: 修改字段值 (若字段不存在，则创建)
# 用 '$set' 修改器修改 'name' 的值, 还可以修改内嵌文档的值
eg: db.blog.update({ "_id" : ObjectId("58cb7877af6105891ec2a46d")},
{"$set": {"name": "ete"}})

$unset: 删除字段
# 用 '$unset' 修改器删除 'nickname' 字段
eg: db.blog.update({ "_id" : ObjectId("58cb7877af6105891ec2a46d")},
{"$unset": {"nickname": 1}})

# 数组修改器
$push: 向已有的数组末尾加入一个元素 (若不存在，则创建新的数组)
# 用 '$push' 修改器向数组 'comments' 添加一条评论
eg: db.blog.update({ "_id" : ObjectId("58cb7877af6105891ec2a46d")},
{"$push": {"comments": {"name": "john", "email": "abc@gamil.com",
"contetn": "very good"}}})

# $push 子操作符
$each: 一次$push 操作添加多个值
eg: db.blog.update({ "_id" : ObjectId("58cb7877af6105891ec2a46d")},
{"$push": {"course": {"$each": ['music', 'art']}}})

$slice: 限制数组只包含最后加入的N个元素(值必须为负整数）
# 限制数组只包含最后加入的10个元素，若数组的元素数量小于10，那么所有的元素都会保留
eg: db.blog.update({ "_id" : ObjectId("58cb7877af6105891ec2a46d")},
{"$push": {"course": {
  "$each": ['music', 'art']
    "$slice": -10
  }}})

$addToSet 保证数组内的元素不重复, 可配合$each 添加多个值
# 保证course 数组不会重复添加'music'
eg: db.blog.update({ "_id" : ObjectId("58cb7877af6105891ec2a46d")},
{"$addToSet": {"course": "music"}})

$pop 从数组任何一端删除元素
# 从数组末尾删除一个元素
eg: db.blog.update({ "_id" : ObjectId("58cb7877af6105891ec2a46d")},
{"$pop": {"course": 1}})

# 从数组头部删除一个元素
eg: db.blog.update({ "_id" : ObjectId("58cb7877af6105891ec2a46d")},
{"$pop": {"course": -1}})

$pull: 删除数组特定元素,
# $pull会将所有匹配到email为'abc@gmail.com'的文档删除
eg: db.blog.update({ "_id" : ObjectId("58cb7877af6105891ec2a46d")},
{"$pull": {"emails": 'abc@gmail.com'}})
db.{table}.findAndModify({
    query: {},
    update: {},
    remove: true | false,
    new: true | false,
    fields: {},
    sort: {}
    upsert: true | false
})
> db.blog.findAndModify({
    query: {'name': 'joe'},
    remove: true,
    sort: { 'score': -1}
})