MongoDb基础命令
一些基础忘记随时查看。。
#整备恢复
mongodump --port 20001 --authenticationDatabase=admin -u * -d lvlv -c lvlv -o /home
mongorestore --drop --host 172.16.201.74 --port 20001 --authenticationDatabase=admin -umgbackup -d test /tmp/liding/test/liding.bson
#基于时间备份oplog
mongodump --port 20001 --authenticationDatabase=admin -u* -d local -c oplog.rs -q 'ts:{$lt:Timestamp(1462830369,1),$gt: Timestamp(1462821613, 1)}}' -o /tmp/lidddd
#将oplog恢复到临时库
mongorestore -u* --authenticationDatabase=admin --host 172.16.201.73 --port 27017 -d local -c oplog.rs /data/backup/oplog1/local/oplog.rs.bson
#从临时库重放oplog
mongooplog --port 20001 -u* --authenticationDatabase=admin --from=172.16.201.73:27017
oplog查找
db.oplog.rs.find({ts:{$lt:Timestamp(1462917498, 1),$gt:Timestamp(1462918425, 1)}}).pretty()
use local
db.oplog.rs.find()
date -d @1361542596 +"%Y-%m-%d %H:%M:%S"
for (var i=0;i<1000;i++){db.lvlv.save({"xywy":i})}
sql="db.getReplicationInfo();"
echo "$sql"|/usr/local/xywy/mongodb-3.0.8/bin/mongo 127.0.0.1:20001/admin -u* -pC^8cE#1RvX5rBg0 --authenticationDatabase=admin --shell
添加管理用户:
use admin
db.createUser(
{
user: "*",
pwd: "*****",
roles: [ { role: "root", db: "admin" } ]
}
)
添加备份用户：
use admin
db.createUser(
{
user: "mgbackup",
pwd: "*********",
roles: [ { role: "backup", db: "admin" }, { role: "restore", db: "admin" } ]
}
)
添加日常操作用户：
use admin
db.createUser(
{
user: "mgadmin",
pwd: "*****",
roles: [ { role: "readWriteAnyDatabase", db:admin } ]
}
)
添加读写用户:
use admin
db.createUser(
{
user: "liuyunsong",
pwd: "*****",
roles: [
{ role: "rw", db: "123" }
]
}
)
修改用户权限:
use admin
db.runCommand(
{
updateUser:"liuyaxin",
pwd:"****",
roles: [
{ role: "read", db: "123" }
]
}
)
删除用户:
use 123
db.dropUser("123")
删除一个库下所有用户:
use 123
db. dropAllUsers ()
对用户添加角色：
use 123
db.runCommand( { grantRolesToUser: "*",
roles: [
{ role: "admin", db: "admin"}
]
} )
对用户移除角色：
use 123
db.runCommand( { revokeRolesFromUser: "liuyaxin",
roles: [
{ role: "read", db: "234"}
]
} )
创建角色：
use admin
db.runCommand({ createRole: "rw",
privileges: [
{ resource: { db: "123", collection: "" }, actions: [ "find", "update", "insert", "remove" ] }
],
roles: [
{ role: "read", db: "admin" }
]
})
修改角色权限：
use admin
db.runCommand(
{
updateRole: "rw",
privileges:
[
{
resource: { db: "123", collection: "" },
actions: [ "find" , "update", "insert", "remove" ]
}
],
roles:
[
{ role: "read", db: "admin" }
]
}
)
删除角色：
use admin
db.runCommand(
{
dropRole: "rw",
writeConcern: { w: "majority" }
}
)
删除所有角色：
Use 123
db.runCommand(
{
dropAllRolesFromDatabase: 1,
writeConcern: { w: "majority" }
}
)
为角色增加权限：
use 123
db.runCommand(
{
grantPrivilegesToRole: "rw",
privileges: [
{
resource: { db: "123", collection: "" }, actions: [ "find" ]
}
]
}
)
移除角色权限：
Use 123
db.runCommand(
{
revokePrivilegesFromRole: "rw",
privileges:
[
{
resource: { db: "123", collection: "" },
actions: [ "insert", "find" ]
}
]
}
)
刷新权限：
Use admin
db.runCommand( { invalidateUserCache: 1 } )
1、数据库中查询业务人员给的账号在数据库中是否存在
use database
show users
2、根据业务开发人员提出的需求授权
读写用户名：库名
先定义读写角色
use 库名
db.runCommand({ createRole: "rw",
privileges: [
{ resource: { db: "库名", collection: "" }, actions: [ "find", "update", "insert", "remove","listCollections"] }
],
roles: [
]
})
再加用户
use 库名
db.createUser(
{
user: "库名",
pwd: "*****",
roles: [
{ role: "rw", db: "库名" }
]
}
)
只读用户：库名_r
先定义只读角色
use 库名
db.runCommand({ createRole: "r",
privileges: [
{ resource: { db: "库名", collection: "" }, actions: [ "find","listCollections" ] }
],
roles: [
]
})
在添加用户
use 库名
db.createUser(
{
user: "库名_r",
pwd: "************",
roles: [
{ role: "r", db: "库名" }
]
}
)
3、检验授权有无生效
使用授权的用户登录数据库，查看该库权限是否正确
use 库名
db.auth("""")
4、将授权好的用户名密码发给该项目负责人同时发给dba组存档，格式如下
idc:xx 主库 ip:port 从库 ip：port
数据库： databases
读写用户： databases 读写密码： xxx
只读用户： databases_r 只读密码： xxx
管理用户： database_admin 管理密码： xxx
->use Admin (切换到创建用户)
->db.TestDb (创建数据库)
->db.addUser("userName","Pwd") 创建用户
->db.auth("userName","Pwd") 设置用户为允许连接的用户
->db.createCollection("TableName") 创建表
->showcollections 查看表是否创建成功
->db.TableName.Save({age:1}) 添加数据
->db.TableName.find() 查看添加的数据是否成功（如果没有查询到任何的结果，说明添加失败）
创建数据库
语法
MongoDB 创建数据库的语法格式如下：
use DATABASE_NAME
注：该命令只是在内存中临时创建数据库，创建后如果没有写入操作退出后会在内存中释放
删除数据库
语法
MongoDB 删除数据库的语法格式如下：
db.dropDatabase()
注：删除库之前一定要先use database
插入文档
MongoDB 使用 insert() 或 save() 方法向集合中插入文档，语法如下：
db.COLLECTION_NAME.insert({document})
MongoDB 更新文档
MongoDB 使用 update() 和 save() 方法来更新集合中的文档。接下来让我们详细来看下两个函数的应用及其区别。
update() 方法
update() 方法用于更新已存在的文档。语法格式如下：
db.collection.update(
参数说明：
query : update的查询条件，类似sql update查询内where后面的。
update : update的对象和一些更新的操作符（如$,$inc...）等，也可以理解为sql update查询内set后面的
upsert : 可选，这个参数的意思是，如果不存在update的记录，是否插入objNew,true为插入，默认是false，不插入。
multi : 可选，mongodb 默认是false,只更新找到的第一条记录，如果这个参数为true,就把按条件查出来多条记录全部更新。
writeConcern :可选，抛出异常的级别。
save() 方法
save() 方法通过传入的文档来替换已有文档。语法格式如下：
db.collection.save(
MongoDB 删除文档
MongoDB remove()函数是用来移除集合中的数据。
在执行remove()函数前先执行find()命令来判断执行的条件是否正确，这是一个比较好的习惯。
语法
remove() 方法的基本语法格式如下所示：
db.collection.remove(
参数说明：
query :（可选）删除的文档的条件。
justOne : （可选）如果设为 true 或 1，则只删除一个文档。
writeConcern :（可选）抛出异常的级别。
查询文档
语法
MongoDB 查询数据的语法格式如下：
>db.COLLECTION_NAME.find()
find() 方法以非结构化的方式来显示所有文档。
如果你需要以易读的方式来读取数据，可以使用 pretty() 方法，语法格式如下：
>db.col.find().pretty()
MongoDB 与 RDBMS Where 语句比较
如果你熟悉常规的 SQL 数据，通过下表可以更好的理解 MongoDB 的条件语句查询：
等于 {
小于 {
小于或等于 {
大于 {
大于或等于 {
不等于 {
操作
格式
范例
RDBMS中的类似语句
MongoDB AND 条件
MongoDB 的 find() 方法可以传入多个键(key)，每个键(key)以逗号隔开，及常规 SQL 的 AND 条件。
语法格式如下：
>db.col.find({key1:value1, key2:value2}).pretty()
MongoDB OR 条件
MongoDB OR 条件语句使用了关键字 $or,语法格式如下：
>db.col.find( { $or: [ {key1: value1}, {key2:value2} ] } ).pretty()
MongoDB Limit与Skip方法
MongoDB Limit() 方法
如果你需要在MongoDB中读取指定数量的数据记录，可以使用MongoDB的Limit方法，limit()方法接受一个数字参数，该参数指定从MongoDB中读取的记录条数。
语法
limit()方法基本语法如下所示：
>db.COLLECTION_NAME.find().limit(NUMBER)
MongoDB Skip() 方法
我们除了可以使用limit()方法来读取指定数量的数据外，还可以使用skip()方法来跳过指定数量的数据，skip方法同样接受一个数字参数作为跳过的记录条数。
语法
skip() 方法脚本语法格式如下：
>db.COLLECTION_NAME.find().limit(NUMBER).skip(NUMBER)
MongoDB 排序
MongoDB sort()方法
在MongoDB中使用使用sort()方法对数据进行排序，sort()方法可以通过参数指定排序的字段，并使用 1 和 -1 来指定排序的方式，其中 1 为升序排列，而-1是用于降序排列。
语法
sort()方法基本语法如下所示：
>db.COLLECTION_NAME.find().sort({KEY:1})
MongoDB 聚合
MongoDB中聚合(aggregate)主要用于处理数据(诸如统计平均值,求和等)，并返回计算后的数据结果。有点类似sql语句中的 count(*)。
aggregate() 方法
MongoDB中聚合的方法使用aggregate()。
语法
aggregate() 方法的基本语法格式如下所示：
>db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)
下表展示了一些聚合的表达式:
表达式
描述
实例
$sum 计算总和。 db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$sum : "$likes"}}}])
$avg 计算平均值 db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$avg : "$likes"}}}])
$min 获取集合中所有文档对应值得最小值。 db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$min : "$likes"}}}])
$max 获取集合中所有文档对应值得最大值。 db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$max : "$likes"}}}])
$push 在结果文档中插入值到一个数组中。 db.mycol.aggregate([{$group : {_id : "$by_user", url : {$push: "$url"}}}])
$addToSet 在结果文档中插入值到一个数组中，但不创建副本。 db.mycol.aggregate([{$group : {_id : "$by_user", url : {$addToSet : "$url"}}}])
$first 根据资源文档的排序获取第一个文档数据。 db.mycol.aggregate([{$group : {_id : "$by_user", first_url : {$first : "$url"}}}])
$last 根据资源文档的排序获取最后一个文档数据 db.mycol.aggregate([{$group : {_id : "$by_user", last_url : {$last : "$url"}}}])
管道的概念
管道在Unix和Linux中一般用于将当前命令的输出结果作为下一个命令的参数。
MongoDB的聚合管道将MongoDB文档在一个管道处理完毕后将结果传递给下一个管道处理。管道操作是可以重复的。
表达式：处理输入文档并输出。表达式是无状态的，只能用于计算当前聚合管道的文档，不能处理其它的文档。
这里我们介绍一下聚合框架中常用的几个操作：
$project：修改输入文档的结构。可以用来重命名、增加或删除域，也可以用于创建计算结果以及嵌套文档。
$match：用于过滤数据，只输出符合条件的文档。$match使用MongoDB的标准查询操作。
$limit：用来限制MongoDB聚合管道返回的文档数。
$skip：在聚合管道中跳过指定数量的文档，并返回余下的文档。
$unwind：将文档中的某一个数组类型字段拆分成多条，每条包含数组中的一个值。
$group：将集合中的文档分组，可用于统计结果。
$sort：将输入文档排序后输出。
$geoNear：输出接近某一地理位置的有序文档。
管道操作符实例
1.$project实例
db.article.aggregate( { $project : { title : 1 , author : 1 , }} );
2.$match实例
db.articles.aggregate( [ { $match : { score : { $gt : 70, $lte : 90 } } }, { $group: { _id: null, count: { $sum: 1 } } } ] );
3.$skip实例
db.article.aggregate( { $skip : 5 });
mongoDB常用命令
1、与Mql对照
MySQL
MongoDB
说明
mysqld
mongod
服务器守护进程
mysql
mongo
客户端工具
mysqldump
mongodump
逻辑备份工具
mysql
mongorestore
逻辑恢复工具
db.repairDatabase()
修复数据库
mysqldump
mongoexport
数据导出工具
source
mongoimport
数据导入工具
grant * privileges on *.* to …
Db.addUser()
Db.auth()
新建用户并权限
show databases
show dbs
显示库列表
Show tables
Show collections
显示表列表
Show slave status
Rs.status
查询主从状态
Create table users(a int, b int)
db.createCollection("mycoll", {capped:true,
size:100000}) 另：可隐式创建表。
创建表
Create INDEX idxname ON users(name)
db.users.ensureIndex({name:1})
创建索引
Create INDEX idxname ON users(name,ts DESC)
db.users.ensureIndex({name:1,ts:-1})
创建索引
Insert into users values(1, 1)
db.users.insert({a:1, b:1})
插入记录
Select a, b from users
db.users.find({},{a:1, b:1})
查询表
Select * from users
db.users.find()
查询表
Select * from users where age=33
db.users.find({age:33})
条件查询
Select a, b from users where age=33
db.users.find({age:33},{a:1, b:1})
条件查询
select * from users where age<33
db.users.find({'age':{$lt:33}})
条件查询
select * from users where age>33 and age<=40
db.users.find({'age':{$gt:33,$lte:40}})
条件查询
select * from users where a=1 and b='q'
db.users.find({a:1,b:'q'})
条件查询
select * from users where a=1 or b=2
db.users.find( { $or : [ { a : 1 } , { b : 2 } ] } )
条件查询
select * from users limit 1
db.users.findOne()
条件查询
select * from users where name like "%Joe%"
db.users.find({name:/Joe/})
模糊查询
select * from users where name like "Joe%"
db.users.find({name:/^Joe/})
模糊查询
select count(1) from users
Db.users.count()
获取表记录数
select count(1) from users where age>30
db.users.find({age: {'$gt': 30}}).count()
获取表记录数
select DISTINCT last_name from users
db.users.distinct('last_name')
去掉重复值
select * from users ORDER BY name
db.users.find().sort({name:-1})
排序
select * from users ORDER BY name DESC
db.users.find().sort({name:-1})
排序
EXPLAIN select * from users where z=3
db.users.find({z:3}).explain()
获取存储路径
update users set a=1 where b='q'
db.users.update({b:'q'}, {$set:{a:1}}, false, true)
更新记录
update users set a=a+2 where b='q'
db.users.update({b:'q'}, {$inc:{a:2}}, false, true)
更新记录
delete from users where z="abc"
db.users.remove({z:'abc'})
删除记录
db. users.remove()
删除所有的记录
drop database IF EXISTS test;
use test
db.dropDatabase()
删除数据库
drop table IF EXISTS test;
db.mytable.drop()
删除表/collection
db.addUser('test', 'test')
添加用户
readOnly-->false
db.addUser('test', 'test', true)
添加用户
readOnly-->true
db.addUser("test","test222")
更改密码
db.system.users.remove({user:"test"})
或者db.removeUser('test')
删除用户
db.system.users.find()
查看用户列表
show users
查看当前库所有用户
db.printCollectionStats()
查看各collection的状态
db.printReplicationInfo()
查看主从复制状态
show profile
查看profiling
db.copyDatabase('mail_addr','mail_addr_tmp')
拷贝数据库
db.users.dataSize()
查看collection数据的大小
db. users.totalIndexSize()
查询索引的大小
