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>, { upsert: <boolean>, multi: <boolean>, writeConcern: <document> } )

参数说明：

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( <document>, { writeConcern: <document> } )

MongoDB 删除文档

MongoDB remove()函数是用来移除集合中的数据。

在执行remove()函数前先执行find()命令来判断执行的条件是否正确，这是一个比较好的习惯。

语法

remove() 方法的基本语法格式如下所示：

db.collection.remove( <query>, { justOne: <boolean>, writeConcern: <document> } )

参数说明：

query :（可选）删除的文档的条件。

justOne : （可选）如果设为 true 或 1，则只删除一个文档。

writeConcern :（可选）抛出异常的级别。

查询文档

语法

MongoDB 查询数据的语法格式如下：

>db.COLLECTION_NAME.find()

find() 方法以非结构化的方式来显示所有文档。

如果你需要以易读的方式来读取数据，可以使用 pretty() 方法，语法格式如下：

>db.col.find().pretty()

MongoDB 与 RDBMS Where 语句比较

如果你熟悉常规的 SQL 数据，通过下表可以更好的理解 MongoDB 的条件语句查询：

等于 {<key>:<value>} db.col.find({"by":"xywydba"}).pretty() where by = 'xywydba'

小于 {<key>:{$lt:<value>}} db.col.find({"likes":{$lt:50}}).pretty() where likes < 50

小于或等于 {<key>:{$lte:<value>}} db.col.find({"likes":{$lte:50}}).pretty() where likes <= 50

大于 {<key>:{$gt:<value>}} db.col.find({"likes":{$gt:50}}).pretty() where likes > 50

大于或等于 {<key>:{$gte:<value>}} db.col.find({"likes":{$gte:50}}).pretty() where likes >= 50

不等于 {<key>:{$ne:<value>}} db.col.find({"likes":{$ne:50}}).pretty() where likes != 50

操作

格式

范例

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()

查询索引的大小