Mongo管理基本命令

1、MongoDB是一個NoSQL數(shù)據(jù)庫系統(tǒng)：一個數(shù)據(jù)庫可以包含多個集合（Collection），每個集合對應(yīng)于關(guān)系數(shù)據(jù)庫中的表；而每個集合中可以存儲一組由列標(biāo)識的記錄，列是可以自由定義的，非常靈活，由一組列標(biāo)識的實體的集合對應(yīng)于關(guān)系數(shù)據(jù)庫表中的行。下面通過熟悉MongoDB的基本管理命令，來了解MongoDB提供的DBMS的基本功能和行為。MongoDB命令幫助系統(tǒng)在安裝MongoDB后，啟動服務(wù)器進(jìn)程（mongod），可以通過在客戶端命令mongo實現(xiàn)對MongoDB的管理和監(jiān)控。看一下MongoDB的命令幫助系統(tǒng)：rootdev2:# mongoMongoDB shell version:

2、1.8.3connecting to: test help db.help() help on db methods db.mycoll.help() help on collection methods rs.help() help on replica set methods help connect connecting to a db help help admin administrative help help misc misc things to know help mr mapreduce help show dbs show database names show coll

3、ections show collections in current database show users show users in current database show profile show most recent file entries with time = 1ms use set current database db.foo.find() list objects in collection foo db.foo.find( a : 1 ) list objects in foo where a = 1 it result of the last

4、 line evaluated; use to further iterate DBQuery.shellBatchSize = x set default number of items to display on shell exit quit the mongo shell這是MongoDB最頂層的命令列表，主要告訴我們管理數(shù)據(jù)庫相關(guān)的一些抽象的范疇：數(shù)據(jù)庫操作幫助、集合操作幫助、管理幫助。如果你想了解數(shù)據(jù)庫操作更詳細(xì)的幫助命令，可以直接使用db.help()，如下所示： db.help()DB methods: db.addUser(username, password, readOn

5、ly=false) db.auth(username, password) db.cloneDatabase(fromhost) mandHelp(name) returns the help for the command db.copyDatabase(fromdb, todb, fromhost) db.createCollection(name, size : ., capped : ., max : . ) db.currentOp() displays the current operation in the db db.dropDatabase() db.eval(func, a

6、rgs) run code server-side db.getCollection(cname) same as dbcname or ame db.getCollectionNames() db.getLastError() - just returns the err msg string db.getLastErrorObj() - return full status object db.getMongo() get the server connection object db.getMongo().setSlaveOk() allow this connection to rea

7、d from the nonmaster member of a replica pair db.getName() db.getPrevError() db.getProfilingLevel() - deprecated db.getProfilingStatus() - returns if profiling is on and slow threshold db.getReplicationInfo() db.getSiblingDB(name) get the db at the same server as this one db.isMaster() check replica

8、 primary status db.killOp(opid) kills the current operation in the db db.listCommands() lists all the db commands db.printCollectionStats() db.printReplicationInfo() db.printSlaveReplicationInfo() db.printShardingStatus() db.removeUser(username) db.repairDatabase() db.resetError() db.runCommand(cmdO

9、bj) run a database command. if cmdObj is a string, turns it into cmdObj : 1 db.serverStatus() db.setProfilingLevel(level,) 0=off 1=slow 2=all db.shutdownServer() db.stats() db.version() current version of the server db.getMongo().setSlaveOk() allow queries on a replication slave server對數(shù)據(jù)庫進(jìn)行管理和操作的基本

10、命令，可以從上面獲取到。如果想要得到更多，而且每個命令的詳細(xì)用法，可以使用上面列出的db.listCommands()查詢。另一個比較基礎(chǔ)的是對指定數(shù)據(jù)庫的集合進(jìn)行操作、管理和監(jiān)控，可以通過查詢db.mycoll.help()獲取到： db.mycoll.help()DBCollection help db.mycoll.find().help() - show DBCursor help db.mycoll.count() db.mycoll.dataSize() db.mycoll.distinct( key ) - eg. db.mycoll.distinct( x ) db.mycol

11、l.drop() drop the collection db.mycoll.dropIndex(name) db.mycoll.dropIndexes() db.mycoll.ensureIndex(keypattern,options) - options is an object with these possible fields: name, unique, dropDups db.mycoll.reIndex() db.mycoll.find(query,fields) - query is an optional query filter. fields is optional

12、set of fields to return. e.g. db.mycoll.find( x:77 , name:1, x:1 ) db.mycoll.find(.).count() db.mycoll.find(.).limit(n) db.mycoll.find(.).skip(n) db.mycoll.find(.).sort(.) db.mycoll.findOne(query) db.mycoll.findAndModify( update : . , remove : bool , query: , sort: , new: false ) db.mycoll.getDB() g

13、et DB object associated with collection db.mycoll.getIndexes() db.mycoll.group( key : ., initial: ., reduce : ., cond: . ) db.mycoll.mapReduce( mapFunction , reduceFunction , ) db.mycoll.remove(query) db.mycoll.renameCollection( newName , ) renames the collection. db.mycoll.runCommand( name , ) runs

14、 a db command with the given name where the first param is the collection name db.mycoll.save(obj) db.mycoll.stats() db.mycoll.storageSize() - includes free space allocated to this collection db.mycoll.totalIndexSize() - size in bytes of all the indexes db.mycoll.totalSize() - storage allocated for

15、all data and indexes db.mycoll.update(query, object, upsert_bool, multi_bool) db.mycoll.validate() - SLOW db.mycoll.getShardVersion() - only for use with sharding有關(guān)數(shù)據(jù)庫和集合管理的相關(guān)命令，是最基礎(chǔ)和最常用的，如集合查詢、索引操作等?；久罴皩嵗旅嫱ㄟ^實際的例子來演示一些常見的命令：（一）基本命令1、show dbs顯示當(dāng)前數(shù)據(jù)庫服務(wù)器上的數(shù)據(jù)庫2、use pagedb切換到指定數(shù)據(jù)庫pagedb的上下文，可以在此上下文中管理

16、pagedb數(shù)據(jù)庫以及其中的集合等3、show collections顯示數(shù)據(jù)庫中所有的集合（collection）4、db.serverStatus() 查看數(shù)據(jù)庫服務(wù)器的狀態(tài)。示例如下所示： host : dev2, version : 1.8.3, process : mongod, uptime : 845446, uptimeEstimate : 839192, localTime : ISODate(2011-12-27T04:03:12.512Z), globalLock : totalTime : 845445636925, lockTime : ra

17、tio : 0.016122827283818857, currentQueue : total : 0, readers : 0, writers : 0 , activeClients : total : 0, readers : 0, writers : 0 , mem : bits : 64, resident : 12208, virtual : 466785, supported : true, mapped : 466139 , connections : current : 27, available : 792 , extra_info : note : fields var

18、y by platform, heap_usage_bytes : 70895216, page_faults : 17213898 , indexCounters : btree : accesses : 4466653, hits : 4465526, misses : 1127, resets : 0, missRatio : 0.00025231420484197006 , backgroundFlushing : flushes : 14090, total_ms : 15204393, average_ms : 1079.0910574875797, last_ms : 669,

19、last_finished : ISODate(2011-12-27T04:02:28.713Z) , cursors : totalOpen : 3, clientCursors_size : 3, timedOut : 53 , network : bytesIn : 63460818650, bytesOut : 763926196104, numRequests : 67055921 , opcounters : insert : 7947057, query : 35720451, update : 16263239, delete : 154, getmore : 91707, c

20、ommand : 68520 , asserts : regular : 0, warning : 1, msg : 0, user : 7063866, rollovers : 0 , writeBacksQueued : false, ok : 1有時，通過查看數(shù)據(jù)庫服務(wù)器的狀態(tài)，可以判斷數(shù)據(jù)庫是否存在問題，如果有問題，如數(shù)據(jù)損壞，可以及時執(zhí)行修復(fù)。5、查詢指定數(shù)據(jù)庫統(tǒng)計信息use fragmentdb.stats()查詢結(jié)果示例如下所示： db.stats() db : fragment, collections : 12, objects : 384553, avgObjSize :

21、3028.40198360174, dataSize : 1164581068, storageSize : 1328351744, numExtents : 109, indexes : 10, indexSize : 16072704, fileSize : 4226809856, ok : 1顯示fragment數(shù)據(jù)庫的統(tǒng)計信息。6、查詢指定數(shù)據(jù)庫包含的集合名稱列表db.getCollectionNames()結(jié)果如下所示： db.getCollectionNames() 17u, baseSe, bytravel, daodao, go2eu, lotour, lvping, mafe

22、ngwo, sina, sohu, system.indexes（二）基本DDL和DML1、創(chuàng)建數(shù)據(jù)庫如果你習(xí)慣了關(guān)系型數(shù)據(jù)庫，你可能會尋找相關(guān)的創(chuàng)建數(shù)據(jù)庫的命令。在MongoDB中，你可以直接通過use dbname來切換到這個數(shù)據(jù)庫上下文下面，系統(tǒng)會自動延遲創(chuàng)建該數(shù)據(jù)庫，例如： show dbsadmin 0.03125GBlocal (empty)pagedb 0.03125GBtest 0.03125GB use LuceneIndexDBswitched to db LuceneIndexDB show dbsadmin 0.03125GBlocal (empty)pagedb 0.

23、03125GBtest 0.03125GB dbLuceneIndexDB db.storeCollection.save(version:3.5, segment:e3ol6) show dbsLuceneIndexDB 0.03125GBadmin 0.03125GBlocal (empty)pagedb 0.03125GBtest 0.03125GB可見，在use指定數(shù)據(jù)庫后，并且向指定其中的一個集合并插入數(shù)據(jù)后，數(shù)據(jù)庫和集合都被創(chuàng)建了。2、刪除數(shù)據(jù)庫直接使用db.dropDatabase()即可刪除數(shù)據(jù)庫。3、創(chuàng)建集合可以使用命令db.createCollection(name, si

24、ze : ., capped : ., max : . )創(chuàng)建集合，示例如下所示： db.createCollection(replicationColletion, capped:true, size:10240, max:17855200) ok : 1 show collectionsreplicationColletionstoreCollectionsystem.indexes4、刪除集合刪除集合，可以執(zhí)行db.mycoll.drop()。5、插入更新記錄直接使用集合的save方法，如下所示： db.storeCollection.save(version:3.5, segment:

25、e3ol6)更新記錄，使用save會將原來的記錄值進(jìn)行覆蓋實現(xiàn)記錄更新。6、查詢一條記錄使用findOne()函數(shù)，參數(shù)為查詢條件，可選，系統(tǒng)會隨機查詢獲取到滿足條件的一條記錄（如果存在查詢結(jié)果數(shù)量大于等于1）示例如下所示： db.storeCollection.findOne(version:3.5) _id : ObjectId(4ef970f23c1fc4613425accc), version : 3.5, segment : e3ol67、查詢多條記錄使用find()函數(shù)，參數(shù)指定查詢條件，不指定條件則查詢?nèi)坑涗洝?、刪除記錄使用集合的remove()方法，參數(shù)指定為查詢條件，示例

26、如下所示： db.storeCollection.remove(version:3.5) db.storeCollection.findOne()null9、創(chuàng)建索引可以使用集合的ensureIndex(keypattern,options)方法，示例如下所示： use pagedbswitched to db pagedb db.page.ensureIndex(title:1, url:-1) db.system.indexes.find() name : _id_, ns : pagedb.page, key : _id : 1 , v : 0 name : _id_, ns : pag

27、edb.system.users, key : _id : 1 , v : 0 _id : ObjectId(4ef977633c1fc4613425accd), ns : pagedb.page, key : title : 1, url : -1 , name : title_1_url_-1, v : 0 上述，ensureIndex方法參數(shù)中，數(shù)字1表示升序，-1表示降序。使用db.system.indexes.find()可以查詢?nèi)克饕?0、查詢索引我們?yōu)榧辖⒌乃饕?，那么可以通過集合的getIndexes()方法實現(xiàn)查詢，示例如下所示： db.page.getIndexes(

28、) name : _id_, ns : pagedb.page, key : _id : 1 , v : 0 , _id : ObjectId(4ef977633c1fc4613425accd), ns : pagedb.page, key : title : 1, url : -1 , name : title_1_url_-1, v : 0 當(dāng)然，如果需要查詢系統(tǒng)中全部的索引，可以使用db.system.indexes.find()函數(shù)。11、刪除索引刪除索引給出了兩個方法： db.mycoll.dropIndex(name) db.mycoll.dropIndexes()第一個通過指定索

29、引名稱，第二個刪除指定集合的全部索引。12、索引重建可以通過集合的reIndex()方法進(jìn)行索引的重建，示例如下所示： db.page.reIndex() nIndexesWas : 2, msg : indexes dropped for collection, ok : 1, nIndexes : 2, indexes : name : _id_, ns : pagedb.page, key : _id : 1 , v : 0 , _id : ObjectId(4ef977633c1fc4613425accd), ns : pagedb.page, key : title : 1, url

30、 : -1 , name : title_1_url_-1, v : 0 , ok : 113、統(tǒng)計集合記錄數(shù)use fragmentdb.baseSe.count()統(tǒng)計結(jié)果，如下所示： use fragmentswitched to db fragment db.baseSe.count()36749上述統(tǒng)計了數(shù)據(jù)庫fragment的baseSe集合中記錄數(shù)。14、查詢并統(tǒng)計結(jié)果記錄數(shù)use fragmentdb.baseSe.find().count()find()可以提供查詢參數(shù)，然后查詢并統(tǒng)計結(jié)果，如下所示： use fragmentswitched to db fragment d

31、b.baseSe.find().count()36749上述執(zhí)行先根據(jù)查詢條件查詢結(jié)果，然后統(tǒng)計了查詢數(shù)據(jù)庫fragment的baseSe結(jié)果記錄集合中記錄數(shù)。15、查詢指定數(shù)據(jù)庫的集合當(dāng)前可用的存儲空間use fragment db.baseSe.storageSize(查詢指定數(shù)據(jù)庫的集合分配的存儲空間 db.baseSe.totalSize()144096000上述查詢結(jié)果中，包括為集合（數(shù)據(jù)及其索引存儲）分配的存儲空間。（三）啟動與終止1、正常啟動mongod -dbpath /usr/mongo/data -logfile /var/mongo.log說明：

32、指定數(shù)據(jù)存儲目錄和日志目錄，如果采用安全認(rèn)證模式，需要加上-auth選項，如：mongod -auth -dbpath /usr/mongo/data -logfile /var/mongo.log2、以修復(fù)模式啟動mongod-repair以修復(fù)模式啟動數(shù)據(jù)庫。實際很可能數(shù)據(jù)庫數(shù)據(jù)損壞或數(shù)據(jù)狀態(tài)不一致，導(dǎo)致無法正常啟動MongoDB服務(wù)器，根據(jù)啟動信息可以看到需要進(jìn)行修復(fù)?；蛘邎?zhí)行：mongod -f /etc/mongodb.conf -repair3、終止服務(wù)器進(jìn)程db.shutdownServer()終止數(shù)據(jù)庫服務(wù)器進(jìn)程?；蛘?，可以直接kill掉mongod進(jìn)程即可。（四）安全管理1、

33、以安全認(rèn)證模式啟動mongod -auth -dbpath /usr/mongo/data -logfile /var/mongo.log使用-auth選項啟動mongod進(jìn)程即可啟用認(rèn)證模式?；蛘?，也可以修改/etc/mongodb.conf，設(shè)置auth=true，重啟mongod進(jìn)程。2、添加用戶db.addUser(admin, ,%F23_kj00Opoo0+/)添加數(shù)據(jù)庫用戶，添加成功，則顯示結(jié)果如下所示： user : admin, readOnly : false, pwd : 995d2143e0bf79cba24b58b3e41852cd3、安全認(rèn)證db.auth(admi

34、n, ,%F23_kj00Opoo0+/)數(shù)據(jù)庫安全認(rèn)證。認(rèn)證成功顯示結(jié)果： user : admin, readOnly : false, pwd : 995d2143e0bf79cba24b58b3e41852cd如果是認(rèn)證用戶，執(zhí)行某些命令，可以看到正確執(zhí)行結(jié)果，如下所示：db.system.users.find() _id : ObjectId(4ef940a13c1fc4613425acc8), user : admin, readOnly : false, pwd : 995d2143e0bf79cba24b58b3e41852cd 否則，認(rèn)證失敗，則執(zhí)行相關(guān)命令會提示錯誤：db.

35、system.users.find()error: $err : unauthorized db:admin lock type:-1 client:, code : 100574、為數(shù)據(jù)庫寫數(shù)據(jù)（同步到磁盤）加鎖db.runCommand(fsync:1,lock:1)說明：該操作已經(jīng)對數(shù)據(jù)庫上鎖，不允許執(zhí)行寫數(shù)據(jù)操作，一般在執(zhí)行數(shù)據(jù)庫備份時有用。執(zhí)行命令，結(jié)果示例如下： info : now locked against writes, use db.$cmd.sys.unlock.findOne() to unlock, ok : 15、查看當(dāng)前鎖狀態(tài)db.curren

36、tOp()說明：查詢結(jié)果如下所示： inprog : , fsyncLock : 1, info : use db.$cmd.sys.unlock.findOne() to terminate the fsync write/snapshot lock其中，fsyncLock為1表示MongoDB的fsync進(jìn)程（負(fù)責(zé)將寫入改變同步到磁盤）不允許其他進(jìn)程執(zhí)行寫數(shù)據(jù)操作6、解鎖use admindb.$cmd.sys.unlock.findOne()說明：執(zhí)行解鎖，結(jié)果如下所示： ok : 1, info : unlock requested 可以執(zhí)行命令查看鎖狀態(tài)：db.currentOp()

37、狀態(tài)信息如下： inprog : 說明當(dāng)前沒有鎖，可以執(zhí)行寫數(shù)據(jù)操作。（五）數(shù)據(jù)備份、恢復(fù)與遷移管理1、備份全部數(shù)據(jù)庫mkdir testbakcd testbakmongodump說明：默認(rèn)備份目錄及數(shù)據(jù)文件格式為./dump/databasename/collectionname.bson2、備份指定數(shù)據(jù)庫mongodump -d pagedb說明：備份數(shù)據(jù)庫pagedb中的數(shù)據(jù)。3、備份一個數(shù)據(jù)庫中的某個集合mongodump -d pagedb -c page說明：備份數(shù)據(jù)庫pagedb的page集合。4、恢復(fù)全部數(shù)據(jù)庫cd testbakmongorestore -drop說明：將備

38、份的所有數(shù)據(jù)庫恢復(fù)到數(shù)據(jù)庫，-drop指定恢復(fù)數(shù)據(jù)之前刪除原來數(shù)據(jù)庫數(shù)據(jù)，否則會造成回復(fù)后的數(shù)據(jù)中數(shù)據(jù)重復(fù)。5、恢復(fù)某個數(shù)據(jù)庫的數(shù)據(jù)cd testbakmongorestore -d pagedb -drop說明：將備份的pagedb的數(shù)據(jù)恢復(fù)到數(shù)據(jù)庫。6、恢復(fù)某個數(shù)據(jù)庫的某個集合的數(shù)據(jù)cd testbakmongorestore -d pagedb -c page -drop說明：將備份的pagedb的的page集合的數(shù)據(jù)恢復(fù)到數(shù)據(jù)庫。7、向MongoDB導(dǎo)入數(shù)據(jù)mongoimport -d pagedb -c page -type csv -headerline -drop csvORts

39、vFile.csv說明：將文件csvORtsvFile.csv的數(shù)據(jù)導(dǎo)入到pagedb數(shù)據(jù)庫的page集合中，使用cvs或tsv文件的列名作為集合的列名。需要注意的是，使用-headerline選項時，只支持csv和tsv文件。-type支持的類型有三個：csv、tsv、json其他各個選項的使用，可以查看幫助：mongoimport -helpoptions: -help produce help message -v -verbose be more verbose (include multiple times for more verbosity e.g. -vvvvv) -h -ho

40、st arg mongo host to connect to ( /s1,s2 for sets) -port arg server port. Can also use -host hostname:port -ipv6 enable IPv6 support (disabled by default) -u -username arg username -p -password arg password -dbpath arg directly access mongod database files in the given path, instead of connecting to

41、 a mongod server - needs to lock the data directory, so cannot be used if a mongod is currently accessing the same path -directoryperdb if dbpath specified, each db is in a separate directory -d -db arg database to use -c -collection arg collection to use (some commands) -f -fields arg comma separat

42、ed list of field names e.g. -f name,age -fieldFile arg file with fields names - 1 per line -ignoreBlanks if given, empty fields in csv and tsv will be ignored -type arg type of file to import. default: json (json,csv,tsv) -file arg file to import from; if not specified stdin is used -drop drop collection first -headerline CSV,TSV only - use first line as headers -upsert insert or update objects that already exist -upsertFields arg comma-separated fields for the query part of the upsert. You should make sure this is indexed -stopOnError stop im