MongoDB 分片操作

时间:2023-03-08 21:20:30

添加分片

use admin

//添加分片节点,每个分片都是一个副本集【allowLocal:true仅仅开发时才将分片配置到本地,生产时不能这样】

db.runCommand({addshard:"localhost:9335",allowLocal:true})

db.runCommand({addshard:"localhost:9336",allowLocal:true})

db.runCommand({addshard:"localhost:9337",allowLocal:true,”maxSize”:20000})   注意:还可以为不同分片设置大小”maxSize”:20000(20gb)

//要分片的数据库

db.runCommand({enablesharding:"mydb"})

//设置要分片的集合:users集合,name字段为key来分片

db.runCommand({shardcollection:"mydb.users",key:{name:1}})

db.runCommand({shardcollection:"mydb.users",key:{_id:1,name:1,name:1}})      【如果出现"errmsg" : "please create an index that starts with the shard key before sharding.",请创建索引】

查看分片结果

//查看分区情况

use mydb

db.users.getShardDistribution()

db.users.stats();

向已经分片的数据中,再次添加分片

db.runCommand({addshard:"localhost:9337",allowLocal:true})     会自动平衡数据

删除分片

db.runCommand({removeshard:"localhost:9335"})

db.runCommand({removeshard:"localhost:9336"})

db.runCommand({removeshard:"localhost:9337"})

//【如果删除的是主节点,还需要】

db.runCommand({"moveprimary" : "mydb","to" : "localhost:9336"})

//【删除完后还需要在执行一次db.runCommand({removeshard:"localhost:xxxx"})   才能完整删除】

//【观察删除情况:】

use admin

db.printShardingStatus()

//【这种方式不能删除所有分片,最后一个分片是不能删除的】