其他分享
首页 > 其他分享> > mongDB进阶

mongDB进阶

作者：互联网

Mongo进阶

聚合

聚合操作将来自多个文档的值组合在一起，并且可以对分组数据执行各种操作以返回单个结果。

文档进入多阶段管道，将文档转换为聚合结果

聚合管道

例子：

第一阶段：过滤，$match

第二阶段：分组，$group

db.collectionName.aggregate([ { $match: { status: "A" } }, { $group: { _id: "$field1", total: { $sum: "$field2" } } } # 引号中$+字段表示字段路径，说明是对该字段下的值进行操作 ])

聚合管道由多个阶段组成

聚合方法

db.collectionName.aggregate()：提供聚合管道的访问

db.collectionName.mapReduce()：对大型数据集执行map-reduce聚合

变量

用户变量

要访问变量的 value，请使用带有前缀为 ($$)的变量名的 string。

如果变量 references 一个 object，要访问 object 中的特定字段，使用$$<variable>.<field>

系统变量

Map-reudce

MongoDB 中的所有 map-reduce 函数都是JavaScript，在mongod进程中运行

map-reduce 操作可以将结果写入集合或内联返回结果

db.collection.mapReduce( function() {emit(key,value);}, //map 函数 function(key,values) {return reduceFunction}, //reduce 函数 { out: collection, query: document, sort: document, limit: number } )

参考

关联

DBRef

{ $ref : <value>, $id : <value>, $db : <value> }

例子

> db.posts.insert({"title":"Hello Mongodb DBRef1",authors:[new DBRef('authors',author._id)]})
# posts集合插入一个文档，该文档中的authors记录的是集合author中的id
# 相当于posts集合给authors字段设置外键

$lookup

db.product.aggregate([ { $lookup: { from: "orders", # 需要关联的集合 localField: "_id", # 本集合需要关联的字段 foreignField: "pid", # 外键字段 as: "inventory_docs"：对应外键集合的数据，即orders的数据 } } ])

原子操作

常用命令描述例子
$set 用来指定一个键并更新键值，若键不存在并创建 { $set : { field : value } }
$unset 删除一个键 { $unset : { field : 1} }
$inc 增减的操作 { $inc : { field : value } }
$push 把value追加到field里面去，field一定要是数组类型才行，如果field不存在，会新增一个数组类型加进去 { $push : { field : value } }
$pushAll 同$push,只是一次可以追加多个值到一个数组字段内 { $pushAll : { field : value_array } }
$pull 从数组field内删除一个等于value值 { $pull : { field : _value } }
$addToSet 增加一个值到数组内，而且只有当这个值不在数组内才增加  
$pop 删除数组的第一个或最后一个元素 { $pop : { field : 1 } }
$rename 修改字段名称 { $rename : { old_field_name : new_field_name } }
$bit 位操作 {$bit : { field : {and : 5}}}

索引

索引可以提高读操作的效率

创建索引

db.collectionName.createIndex( <key and index type specification>, <options> )

选项

ParameterTypeDescription
background Boolean 建索引过程会阻塞其它数据库操作，background可指定以后台方式创建索引，即增加 "background" 可选参数。 "background" 默认值为false。
unique Boolean 建立的索引是否唯一。指定为true创建唯一索引。默认值为false.
name string 索引的名称。如果未指定，MongoDB的通过连接索引的字段名和排序顺序生成一个索引名称。
sparse Boolean 对文档中不存在的字段数据不启用索引；这个参数需要特别注意，如果设置为true的话，在索引字段中不会查询出不包含对应字段的文档.。默认值为 false.
expireAfterSeconds integer 指定一个以秒为单位的数值，完成 TTL设定，设定集合的生存时间。
v index version 索引的版本号。默认的索引版本取决于mongod创建索引时运行的版本。
weights document 索引权重值，数值在 1 到 99,999 之间，表示该索引相对于其他索引字段的得分权重。
default_language string 对于文本索引，该参数决定了停用词及词干和词器的规则的列表。 默认为英语
language_override string 对于文本索引，该参数指定了包含在文档中的字段名，语言覆盖默认的language，默认值为 language.

例子：db.values.createIndex({open: 1, close: 1}, {background: true,name: myindex})

复制

副本集（replica set）特征：

副本集设置

开启服务并为其命名

mongod --port "PORT" --dbpath "YOUR_DB_DATA_PATH" --replSet "REPLICA_SET_INSTANCE_NAME"

参考

分片（shard）

一种将数据分配到多个机器上的方法，实现水平扩展

为什么使用分片

实例

分片结构如下（需要启动三种服务）

Shard Server 1：27020
Shard Server 2：27021
Shard Server 3：27022
Shard Server 4：27023
--------------------
Config Server ：27100 
--------------------
Route Process：40000

此例是为方便展示使用不同端口来区分切片服务，实际应用中可以通过不同的host，在不同的机器中创建和启动

Shard Server

# 创建切片服务的数据存储文件夹
[root@100 /]# mkdir -p /www/mongoDB/shard/s{1,2,3,4}
​
# 创建切片服务的日志文件夹
[root@100 /]# mkdir -p /www/mongoDB/shard/log
​

在指定的一个路径下分别创建服务启动的配置文件，比如

vim /usr/mongoDB/shard/s1.conf
​
port=27020  #指定服务端口
dbpath=/www/mongoDB/shard/s1    #数据存储目录
logpath=/www/mongoDB/shard/log/s1.log   #日志文件
logappend=true  #使用追加方式写日志
fork=true   #后台运行
maxConns=5000   #设定最大同时连接数，默认为2000
storageEngine=mmapv1    #指定存储引擎为内存映射文件
shardsvr=true   # 分片服务

启动服务

# 启动shard服务
[root@100 /]# /usr/local/mongoDB/bin/mongod -f /usr/mongoDB/shard/s1.conf
....
[root@100 /]# /usr/local/mongoDB/bin/mongod -f /usr/mongoDB/shard/s4.conf

Config Server

[root@100 /]# mkdir -p /www/mongoDB/shard/config
[root@100 /]# /usr/local/mongoDB/bin/mongod --port 27100 --dbpath=/www/mongoDB/shard/config --logpath=/www/mongoDB/shard/log/config.log --logappend --fork
--------------------------
vim /usr/mongoDB/shard/config.conf
​
port=27100      
dbpath=/www/mongoDB/shard/config    
logpath=/www/mongoDB/shard/log/config.log        
logappend=true           
fork=true                       
maxConns=5000               
storageEngine=mmapv1        
configsvr=true        #配置服务
--------------------------
# 启动config服务
[root@100 /]# /usr/local/mongoDB/bin/mongod -f /usr/mongoDB/shard/config.conf

Route Progress

# 启动路由服务
[root@100 /]#/usr/local/mongoDB/bin/mongos --port 40000 --configdb localhost:27100 --fork --logpath=/www/mongoDB/shard/log/route.log --chunkSize 19

chunkSize这一项是用来指定chunk的大小的，单位是MB，默认大小为200MB

在Route Progress服务处登陆
[root@100 shard]# /usr/local/mongoDB/bin/mongo admin --port 40000
添加分片节点
mongos> sh.addshard("localhost:27020")
mongos> sh.addshard("localhost:27021")
mongos> sh.addshard("localhost:27022")
mongos> sh.addshard("localhost:27023")
使库有分片能力
mongos> sh.enablesharding("dbName")
使集合分片
#指定文档中数据库对应的表通过什么分片．使表根据field1和field2分片
mongos>sh.shardcollection("dbName.collectionName",{"field1":1,"field2":1}})
添加标签
sh.addShardTag("shard0000","Master")
sh.addShardTag("shard0001","s1")
sh.addShardTag("shard0002","s2")
sh.addShardTag("shard0003","s3")
sh.addShardTag("shard0004","s4")
测试
mongos> sh.status() # 查看分片状态信息
mongos> user dbName
mongos> for (var i=1;i<=50000;i++)dbName.collectionName.insert({"id":i,"name":"tom"+i})     # 写入数据查看结果
删除分片
mongos> db.runCommand("removeShard":"localhost:27023")

备份与恢复

备份

mongodump -h dbhost -d dbname -o dbdirectory

恢复

mongorestore -h <hostname><:port> -d dbname <path>

不需要登陆mongo

标签：mongDB,field,--,mongoDB,shard,索引,sh,进阶
来源： https://www.cnblogs.com/totopian/p/15635083.html