美文网首页
MongoDB

MongoDB

作者: 极速魔法 | 来源:发表于2022-06-30 07:26 被阅读0次

    MongoDB

    NoSQL

    Not only SQL 性能高，不使用 SQL意味着没有结构化存储要求，没有约束之后架构更加灵活

    • 列存储，Hbase
    • 键值存储，redis
    • 图像存储 Neo4j
    • 文档存储，MongoDB

    MongoDB体系结构

    存储在集合中的数据都是BSON格式，BSON格式是一种类似JSON的二进制存储格式

    MongoDB 和 RDBMS(关系型数据库) 对比

    • Collection 对应 table 表
    • Document 对应 row 行
    • Field 对应 column 列
    • embedded Document 嵌套文档 对应 join（主外键关联）

    MongoDB基本操作

    # 查看数据库
show dbs

# 切换数据库
use 数据库名

# 删除当前数据库
db.dropDatabase();

# 创建集合
db.createCollection("order")

show collections

# 删除集合
db.集合.drop();

    集合增删改查

    查询

    use lagou;
db.createCollection("order")
db.oder.insert({name:"joe",birth:new ISODate("2020-01-01)})

# 批量插入
db.oder.insert([{name:"joe",birth:new ISODate("2020-01-01)},
    {name:"lee",birth:new ISODate("2021-02-02)}
])

    _id ObjectId类型，12字节 BSON类型数据。

    • 前4个字节表示时间戳
    • 接下来3个字节 机器码
    • 紧接着2个字节 进程id
    • 最后3个字节 随机数

    查询

    db.order.find({salary:{$gt:1800}})
db.order.find({salary:{$gte:1800}})
db.order.find({salary:{$lt:1800}})

// 逻辑条件 and
db.order.find({salary:{$lt:1800},city:'beijing'})
// or
db.order.find({$or:[{{salary:1800},{city:'beijing'}]})

// not
db.order.find({salary:{$not:{$eq:1800}}})

// 1 升序，-1 降序
db.order.find({salary:1000}).sort({salary:1})

db.order.find({salary:1000}).sort({salary:1})
    .skip(1).limit(2)

    更新 删除

    // 更新salary 2000到2300，只更新一条，不存在时不插入
db.order.update({salary:2000},{$set:{salary:2300}},
{multi:false,upsert: false})

 // 删除joe Document 的salary字段
db.order.update({name:"joe"},{$unset:{salary:2300}},
{multi:false,upsert: false})

// 删除
db.order.remove({name:"joe"})

    聚合

    // 按照 city分组，city 出现的次数
db.order.aggregate([{$group:{_id:"$city",city_count:{$sum:1}}}])
// 按照 city分组，salary 平均值
db.order.aggregate([{$group:{_id:"$city",avg_salary:{$avg:"$salary"}}}])

// 管道 match相当于 having，对分组后的数据过滤
db.order.aggregate([{$group:{_id:"$city",avg_salary:{$avg:"$salary"}}},{$match:{avg_salary:{$gt:2000}}}])

// MapReduce, Document转为 key-value结构，对city分组salary求平均
db.order.mapReduce(function(){emit(this.city,this.salary)},
    function(key,value){return Array.avg(value)},
    {out:"avgSalary"})

    索引

    索引分类

    • 过期索引
    • 复合索引
    • 多键索引，针对数组字段创建的索引
    • 地理空间索引
    • 全文索引
    // 全文索引
db.order.createIndex({description:"text"})
db.order.find({"$text":{"$search":"two"}})
    • 哈希索引
      db.order.createIndex({"age":"hashed"})

    执行计划分析

    executionStats返回逐层分析

    • executionTimeMillis ，语句的执⾏时间
    • executionStages.executionTimeMillisEstimate，检索document获得数据的时间。
    • executionStages.inputStage.executionTimeMillisEstimate，查询扫描⽂档 index所⽤时间

    stage类型

    • COLLSCAN：全表扫描
    • IXSCAN：索引扫描
    • FETCH：根据索引去检索指定document
    • SHARD_MERGE：将各个分⽚返回数据
    • PROJECTION：限定返回字段时候stage的返回
    • IDHACK：针对_id进⾏查询

    索引原理

    B-树，所有节点都有Data域，只要找到指定索引就可以访问数据

    MongoDB 数据模型

    • 内嵌，把相关联的数据保存在同一个文档结构中
    • 引用

    复制集

    复制集是由⼀组拥有相同数据集的mongod实例做组成的集群。
    复制集是⼀个集群，它是2台及2台以上的服务器组成，以及复制集成员包括Primary主节点,secondary从节点 和投票节点。

    分片集群搭建

    use admin;
var cfg = {
    "_id": "configsvr",
    "members": [
        { "_id": 1, "host": "192.168.184.3:17011" },
        { "_id": 2, "host": "192.168.184.3:17013" },
        { "_id": 3, "host": "192.168.184.3:17015" }]
};

rs.initiate(cfg)

// shard1
var cfg = {
    "_id": "shard1",
    "protocolVersion": 1,
    "members": [
        { "_id": 1, "host": "192.168.184.5:37011", "priority": 10 },
        { "_id": 2, "host": "192.168.184.5:37013" },
        { "_id": 3, "host": "192.168.184.5:37015" },
        { "_id": 4, "host": "192.168.184.5:37017", "arbiterOnly": true }
    ]
};
rs.initiate(cfg)
rs.reconfig(cfg)
rs.status()

// shard2
var cfg = {
    "_id": "shard2",
    "protocolVersion": 1,
    "members": [
        { "_id": 1, "host": "192.168.184.4:47011", "priority": 10 },
        { "_id": 2, "host": "192.168.184.4:47013" },
        { "_id": 3, "host": "192.168.184.4:47015" },
        { "_id": 4, "host": "192.168.184.4:47017", "arbiterOnly": true }
    ]
};
rs.initiate(cfg)
rs.reconfig(cfg)
rs.status()

// shard3
var cfg = {
    "_id": "shard3",
    "protocolVersion": 1,
    "members": [
        { "_id": 1, "host": "192.168.184.8:57011", "priority": 10 },
        { "_id": 2, "host": "192.168.184.8:57013" },
        { "_id": 3, "host": "192.168.184.8:57015" },
        { "_id": 4, "host": "192.168.184.8:57017", "arbiterOnly": true }
    ]
};
rs.initiate(cfg)
rs.reconfig(cfg)
rs.status()

// shard4
var cfg = {
    "_id": "shard4",
    "protocolVersion": 1,
    "members": [
        { "_id": 1, "host": "192.168.184.9:58011", "priority": 10 },
        { "_id": 2, "host": "192.168.184.9:58013" },
        { "_id": 3, "host": "192.168.184.9:58015" },
        { "_id": 4, "host": "192.168.184.9:58017", "arbiterOnly": true }
    ]
};
rs.initiate(cfg)
rs.reconfig(cfg)
rs.status()

// config
use admin
var cfg = {
    "_id": "configsvr",
    "members": [
        { "_id": 1, "host": "192.168.184.3:17011" },
        { "_id": 2, "host": "192.168.184.3:17013" },
        { "_id": 3, "host": "192.168.184.3:17015" }]
};
rs.initiate(cfg)

// 添加分片节点
sh.status()
sh.addShard("shard1/192.168.184.5:37011,192.168.184.5:37013,192.168.184.5:37015,192.168.184.5:37017");
sh.addShard("shard2/192.168.184.4:47011,192.168.184.4:47013,192.168.184.4:47015,192.168.184.4:47017");
sh.addShard("shard3/192.168.184.8:57011,192.168.184.8:57013,192.168.184.8:57015,192.168.184.8:57017");
sh.addShard("shard4/192.168.184.9:58011,192.168.184.9:58013,192.168.184.9:58015,192.168.184.9:58017");

sh.enableSharding("lagou_resume")

sh.shardCollection("lagou_resume.lagou_resume_datas", { "name": "hashed" })

// 认证
db.createUser(
    {
        user: "lagou_gx",
        pwd: "abc321",
        roles: [{ role: "readWrite", db: "lg_resume" }]
    }
)


auth = true
keyFile = /home/scott / Mongodb / config / testKeyFile.file

    分片

    分片集群

    • 路由节点，请求通过路由节点协调
    • 配置节点
    • 分片节点

    Neo4j

    NoSql 图形数据库，图数据结构的形式来存储和查询书籍的数据库

    Neo4j基础

    Neo4j 是开源的无Schema 基于java开发的图形数据库，结构化数据存储在图中。

    CQL

    Cypher查询语言

    -- 创建标签 Person,节点person
create(person:Person)

-- 创建person带有属性
create(person:Person {cid:1,name:"joe"})

-- match
match(p:Person) return
match(p:Person {cid:1}) return p.name,ID(p)

-- 现有节点创建 没有属性的关系
match(p1:Person {cid:1}),(p2:Person{cid:2}) create(p1)-[r:Couple]->(p2)


-- 查询关系
match (p1:Person {cid:1})-[r:Couple]->(p2:Person) return p1,p2

-- 使用现有节点创建 有属性的关系
match (p1:Person {cid:1})-[r:Couple {price:1000}]->(p2:Person) return p1,p2 return r;

-- 新节点创建 没有属性的关系
create(p1:Person {cid:3})-[r:Couple]->(p2:Person {cid:4})
-- 新节点创建 有属性的关系
create(p1:Person {cid:3})-[r:Couple {price:2000}]->(p2:Person {cid:4})

    WHERE和删除

    match(p:Person) where p.price > 1000 return p

match p=(:Person {name:"joe"})-[r:Couple]-(:Person) return p;

-- 删节点
match(p:Person) where p.cid=2 delete p

-- 删关系
match p = (:Person {name:"林婉儿"})-[r:Couple]-(:Person) delete r

-- 删属性
match(p:Person) where p.cid=2 remove p.name

-- 深度运算,查询深度最小1，最大2
match data=(na:Person {name:"joe"}-[*1..2]-(nb:Person) return data

    相关文章

      网友评论

          本文标题：MongoDB

          本文链接：https://www.haomeiwen.com/subject/rdqfbrtx.html

          延伸阅读

          深度阅读

          • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

          栏目导航

          热点阅读

          关于我们|服务条款|联系我们|MongoDB|投稿指南|网站地图|RSS订阅|排版工具|手机版

          提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

          Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

          备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

          本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

          所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！