一、基础
1、增
# 创建库 ps:use的话需要插入数据才能显示的哟！
> use msg
# 查看当前使用的库
> db
# 创建集合
> use msg
> db.createCollection("user")
> show tables
# 插入数据
> db.user.insert({"name":"mongo"})
2、删
# 删除库
> use msg
> db.dropDatabase()
# 删除集合
> use msg
> db.user.drop()
# 删除整个集合中的所有数据
> db.test.remove()
# 删除集合中符合过滤条件的数据
> db.test.remove({name:/aws/})
# 删除符合条件的一条记录
> db.test.remove({name:/aws/},1)
3、查
# 查询数据库
> use msg
# 查看数据库数据详情
> db.stats()
# 查询集合
> show tables
# 重命名集合
> db.user.renameCollection("USER")
# 查看集合数据详情
> db.user.stats()
# 查看集合所有数据
> db.user.find()
# 格式化输出
> db.user.find().pretty()
# 查看一条数据
> db.user.findOne()
# 查看匹配数据
> db.user.find({"name":"mongo"})
# 查询大于某个数值数据
> db.user.find({salary:{$gt:7000}})
# 查看名称中包含‘a’的数据
> db.user.find({name:/a/})
# 查询name以W打头的数据
> db.user.find({name:/^W/})
# 多条件“与”
# 查询age小于30，salary大于6000的数据
> db.user.find({age:{$lt:30},salary:{$gt:6000}})
# 多条件“或”
# 查询age小于25，或者salary大于10000的记录
> db.user.find({$or:[{salary:{$gt:10000}},{age:{$lt:25}}]})
# 查询记录中的指定列
> db.user.find({},{name:1,age:1,salary:1,sex_orientation:true})
# 查询指定字段的数据，并去重
> db.user.distinct('gender')
# 指定结果集返回条目
> db.user.find().limit(2)
# 查询第一条以外的数据
> db.user.find().skip(1)
# 对结果集排序
# 升序
> db.user.find().sort({salary:1})
# 将序
> db.user.find().sort({salary:-1})
# 统计记录数量
> db.user.find().count()
4、改
# 修改数据
> db.user.update({"name":"mongo"},{$set:{"name":"mongos"}})
# 修改多条相同文档
> db.user.update({"name":"mongo"},{$set:{"name":"mongos"}},{multi:true})
# 只更新第一条记录：
> db.user.update( { "count" : { $gt : 1 } } , { $set : { "test2" : "OK"} } );
# 全部更新：
> db.user.update( { "count" : { $gt : 3 } } , { $set : { "test2" : "OK"} },false,true );
# 只添加第一条：
> db.user.update( { "count" : { $gt : 4 } } , { $set : { "test5" : "OK"} },true,false );
# 全部添加进去:
> db.user.update( { "count" : { $gt : 5 } } , { $set : { "test5" : "OK"} },true,true );
# 全部更新：
> db.user.update( { "count" : { $gt : 15 } } , { $inc : { "count" : 1} },false,true );
# 只更新第一条记录：
> db.user.update( { "count" : { $gt : 10 } } , { $inc : { "count" : 1} },false,false );
# 更新符合过滤条件的信息
> db.user.update({name:'Gal Gadot'},{$set:{age:23}},false,true)
# 添加新的字段
> db.user.update({name:'Mikie Hara'},{$set:{interest:"CBA"}},false,true)
# 使用函数 $inc
> db.user.update({gender:'female'},{$inc:{salary:50}},false,true)
# 原
{ "_id" : ObjectId("52453d8525e437dfea8fd4f5"), "name" : "Mikie Hara", "gender" : "female","interest" : "CBA", "age" : 26, "salary" : 7000 }
# 现
{ "_id" : ObjectId("52453d8525e437dfea8fd4f5"), "name" : "Mikie Hara", "gender" : "female","interest" : "CBA", "age" : 26, "salary" : 7050 }
二、集合操作
| 方法名 |
描述 |
| db.collection.aggregate() |
聚合，主要用于处理数据(诸如统计平均值,求和等)，并返回计算后的数据结果 |
| db.collection.bulkWrite() |
批量写入 |
| db.collection.createIndex() |
创建一个集合索引 |
| db.collection.count() |
返回集合总数或匹配查询的结果集总数 |
| db.collection.deleteOne() |
删除集合中的一个文档 |
| db.collection.deleteMany() |
删除集合中的多个文档 |
| db.collection.dataSize() |
返回集合的大小 |
| db.collection.distinct() |
返回具有指定字段不同值的文档（去除指定字段的重复数据） |
| db.collection.dropIndex() |
删除一个集合中的指定索引 |
| db.collection.dropIndexes() |
删除一个集合中的所有索引 |
| db.collection.drop() |
删除当前数据库中的collection集合 |
| db.collection.explain() |
返回各种方法的查询执行信息 |
| db.collection.findOne() |
查询单条数据 |
| db.collection.findOneAndReplace() |
查询单条数据并替换 |
| db.collection.findOneAndDelete() |
查询单条数据并删除 |
| db.collection.findOneAndUpdate() |
查询单条数据并更新 |
| db.collection.find() |
查询集合，无参数则查询所有，并返回一个游标对象 |
| db.collection.findAndModify() |
查询并修改 |
| db.collection.getIndexes() |
返回当前集合的所有索引数组 |
| db.collection.group() |
提供简单的数据聚合功能 |
| db.collection.isCapped() |
判断集合是否为定容量 |
| db.collection.insert() |
在当前集合插入一条或多条数据（或叫文档） |
| db.collection.insertMany() |
在当前集合插入多条数据 |
| db.collection.insertOne() |
在当前集合插入一条数据 |
| db.collection.reIndex() |
重建当前集合的所有索引 |
| db.collection.renameCollection() |
重命名集合名称 |
| db.collection.replaceOne() |
替换集合中的一个文档（一条数据） |
| db.collection.remove() |
从当前集合删除数据 |
| db.collection.save() |
已插入数据更新 |
| db.collection.stats() |
返回当前集合的状态 |
| db.collection.storageSize() |
返回当前集合已使用的空间大小 |
| db.collection.totalSize() |
返回当前集合的总占用空间，包括所有文件和所有索引 |
| db.collection.totalIndexSize() |
返回当前集合所有的索引所占用的空间大小 |
| db.collection.updateMany() |
修改集合中的多条数据 |
| db.collection.update() |
修改集合中的数据 |
| db.collection.updateOne() |
修改集合中的一条数据 |
| db.collection.validate() |
执行对集合验证操作 |
三、副本集操作
| 方法名 |
描述 |
| rs.initiate() |
|
| rs.addArb() |
添加仲裁 |
| rs.help() |
帮助 |
| rs.printReplicationInfo() |
查看到副本集操作日志 |
| rs.remove() |
减少副本集节点 |
| rs.freeze() |
“冻结”mongodb实例 |
| rs.status()/sh.status() |
查看副本集状态 |
| db.printSlaveReplicationInfo |
查看复制集的同步状态 |
| rs.add() |
增加副本集节点 |
| rs.stepDown() |
将当前主库“降级” |
| rs.slaveOk() |
|
| rs.conf() |
|
| rs.syncFrom() |
|
| rs.reconfig() |
|
四、用户管理
| 方法名 |
描述 |
| db.getUsers() |
获取所有用户 |
| db.dropAllUsers() |
删除所有用户 |
| db.updateUser() |
更新用户 |
| db.createUser() |
创建用户 |
| db.revokeRolesFromUser() |
取消授权 |
| db.removeUser() |
删除用户 |
| db.grantRolesToUser() |
授权 |
| db.getUser() |
获取用户 |
| db.changeUserPassword() |
更改用户密码 |
| db.auth() |
数据库认证、安全模式 |
五、索引
1、新增索引
# 单键索引
> db.集合.createIndex({"name":1})
# 倒序索引
> db.集合.createIndex({"name":-1})
# 唯一索引
> db.集合.createIndex({"name":1},{"unique":true})
# 后台建索引
> db.集合.createIndex({"name":1},{background:1})
# 复合索引
> db.集合.createIndex({"name":1,"age":1})
2、查看索引
# 查看数据库所有索引
> db.system.indexes.find()
# 查看集合索引
> db.集合.getIndexes()
> db.集合.getIndexKeys()
# 查看索引大小
> db.集合.totalIndexSize()
3、删除索引
# 删除单个索引
> db.集合.dropIndex("name_1")
# 删除所有索引
> db.集合.dropIndexes()
4、重建索引
> db.集合.reIndex({"name"：1})
六、副本集
1、基础操作
# 查看集群状态
> rs.status()
# 查看配置
> rs.config()
# 允许在从节点查询操作
> rs.slaveOK()
# 查询是否主节点
> rs.isMaster()
2、成员管理
# 添加成员
> rs.add("ip:port")
# 添加仲裁节点
> rs.addArb("ip:port")
# 删除成员
> rs.remove("ip:port")
# 重置配置
> rs.reconfig()
3、主从管理
# 降级
> rs.stepDown(time)
# 阻止选举
> rs.freeze(time)
# 主从延迟状态
# 主
> db.printReplicationInfo()
# 从
> db.printSlaveReplicationInfo()
七、分片
1、基础操作
# 查看集群状态
mongos> sh.status()
# 列出所有分片
mongos> db.runCommand({ listshards : 1 })
# 添加分片
mongos> sh.addShard("shard1/192.168.200.11:40000")
# 移除分片
mongos> db.runCommand({"removeShard":"shard1"})
# 如果是主分片，需要先把对应数据库移动到其他分片，再删除，执行多遍查看是否迁移完成。
mongos> db.runCommand( { movePrimary: "msg", to: "shard2" })
# 移除完需要刷新缓存
mongos> db.adminCommand({"flushRouterConfig":1})
2、平衡器
# 平衡器
# 开启平衡器
mongos> sh.startBalancer()
# 停止平衡器
mongos> sh.stopBalancer() # 停止平衡器
or
mongos> sh.setBalancerState(false)
# 获取平衡器状态
mongos> sh.getBalancerState()
# 验证禁用后有没有正在迁移的块
mongos> sh.isBalancerRunning()
3、开启分片
mongos> use admin
# 开启库分片
mongos> sh.enableSharding("dba")
或
mongos> db.runCommand({enablesharding:"dba"})
# 开启集合分片
mongos> sh.shardCollection("库.集合",{"name":1})
或
mongos> db.runCommand({shardcollection:"库.集合",key:{"name":1}})
mongos> sh.status()
# 查看集合分布情况
mongos> db.集合.stats()
4、数据块
# 查看块大小
mongos> use config
mongos> db.settings.find()
# 修改块大小
mongos> db.settings.save({"_id":"chunksize","value":32})
手动迁移块
# 需要先关闭平衡器哟
mongos> use config
查询块
mongos> db.chunks.find().pretty()
#手动拆分
mongos> sh.splitAt("库.集合",{"groupId":"500000001","_id":"6569514481477484544"})
#手动迁移分片
mongos> sh.moveChunk("库.集合",{"name" : "wPeFnJEvendSTbH"},"其他分片")
