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" } ]

  }

)

添加備份使用者：

    user: "mgbackup",

    pwd: "*********",

    roles: [ { role: "backup", db: "admin" }, { role: "restore", db: "admin" } ]

添加日常操作使用者：

    user: "mgadmin",

    roles: [ { role: "readWriteAnyDatabase", db:admin } ]

添加讀寫使用者:

 {

   user: "liuyunsong",

   pwd: "*****",

   roles: [

      { role: "rw", db: "123" }

   ]

 }

修改使用者權限:

db.runCommand(

    updateUser:"liuyaxin",

    pwd:"****",

         roles: [

    { role: "read", db: "123" }

         ]

删除使用者:

use 123

db.dropUser("123")

删除一個庫下所有使用者:

db. dropAllUsers ()

對使用者添加角色：

db.runCommand( { grantRolesToUser: "*",

                 roles: [

                    { role: "admin", db: "admin"}

                 ]

             } )

對使用者移除角色：

db.runCommand( { revokeRolesFromUser: "liuyaxin",

                    { role: "read", db: "234"}

建立角色：

db.runCommand({ createRole: "rw",

  privileges: [

    { resource: { db: "123", collection: "" }, actions: [ "find", "update", "insert", "remove" ] }

  ],

  roles: [

    { role: "read", db: "admin" }

  ]

})

修改角色權限：

   {

     updateRole: "rw",

     privileges:

         [

           {

             resource: { db: "123", collection: "" },

             actions: [ "find" , "update", "insert", "remove" ]

           }

         ],

     roles:

           { role: "read", db: "admin" }

   }

删除角色：

     dropRole: "rw",

     writeConcern: { w: "majority" }

删除所有角色：

Use 123

     dropAllRolesFromDatabase: 1,

為角色增權重限：

     grantPrivilegesToRole: "rw",

     privileges: [

         {

           resource: { db: "123", collection: "" }, actions: [ "find" ]

         }

     ]

移除角色權限：

     revokePrivilegesFromRole: "rw",

      [

        {

          resource: { db: "123", collection: "" },

          actions: [ "insert", "find" ]

        }

      ]

重新整理權限：

Use admin

db.runCommand( { invalidateUserCache: 1 } )

1、資料庫中查詢業務人員給的賬号在資料庫中是否存在

use database

show users

2、根據業務開發人員提出的需求授權

讀寫使用者名：庫名

先定義讀寫角色

use 庫名

privileges: [

{ resource: { db: "庫名", collection: "" }, actions: [ "find", "update", "insert", "remove","listCollections"] }

],

roles: [

]

再加使用者

{

user: "庫名",

pwd: "*****",

{ role: "rw", db: "庫名" }

}

隻讀使用者：庫名_r

先定義隻讀角色

db.runCommand({ createRole: "r",

{ resource: { db: "庫名", collection: "" }, actions: [ "find","listCollections" ] }

在添加使用者

user: "庫名_r",

pwd: "************",

{ role: "r", db: "庫名" }

3、檢驗授權有無生效 

使用授權的使用者登入資料庫，檢視該庫權限是否正确

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

邏輯備份工具

mongorestore

邏輯恢複工具

db.repairDatabase()

修複資料庫

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

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

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

檢視使用者清單

檢視目前庫所有使用者

db.printCollectionStats()

檢視各collection的狀态

db.printReplicationInfo()

檢視主從複制狀态

show profile

檢視profiling

db.copyDatabase('mail_addr','mail_addr_tmp')

拷貝資料庫

db.users.dataSize()

檢視collection資料的大小

db. users.totalIndexSize()

查詢索引的大小