MongoDB基本管理命令
这篇MongoDB基本管理命令比较全面,转载保留,原文
MongoDB是一个NoSQL数据库系统:一个数据库可以包含多个集合(Collection),每个集合对应于关系数据库中的表;而每个集合中可以存储一组由列标识的记录,列是可以自由定义的,非常灵活,由一组列标识的实体的集合对应于关系数据库表中的行。下面通过熟悉MongoDB的基本管理命令,来了解MongoDB提供的DBMS的基本功能和行为。
MongoDB命令帮助系统
在安装MongoDB后,启动服务器进程(mongod),可以通过在客户端命令mongo实现对MongoDB的管理和监控。看一下MongoDB的命令帮助系统:
1 root@dev2:~# mongo 2 MongoDB shell version: 1.8.3 3 connecting to: test 4 > help 5 db.help() help on db methods 6 db.mycoll.help() help on collection methods 7 rs.help() help on replica set methods 8 help connect connecting to a db help 9 help admin administrative help 10 help misc misc things to know 11 help mr mapreduce help 12 13 show dbs show database names 14 show collections show collections in current database 15 show users show users in current database 16 show profile show most recent system.profile entries with time >= 1ms 17 use <db_name> set current database 18 db.foo.find() list objects in collection foo 19 db.foo.find( { a : 1 } ) list objects in foo where a == 1 20 it result of the last line evaluated; use to further iterate 21 DBQuery.shellBatchSize = x set default number of items to display on shell 22 exit quit the mongo shell
这是MongoDB最顶层的命令列表,主要告诉我们管理数据库相关的一些抽象的范畴:数据库操作帮助、集合操作帮助、管理帮助。如果你想了解数据库操作更详细的帮助命令,可以直接使用db.help(),如下所示:
1 > db.help() 2 DB methods: 3 db.addUser(username, password[, readOnly=false]) 4 db.auth(username, password) 5 db.cloneDatabase(fromhost) 6 db.commandHelp(name) returns the help for the command 7 db.copyDatabase(fromdb, todb, fromhost) 8 db.createCollection(name, { size : ..., capped : ..., max : ... } ) 9 db.currentOp() displays the current operation in the db 10 db.dropDatabase() 11 db.eval(func, args) run code server-side 12 db.getCollection(cname) same as db[‘cname‘] or db.cname 13 db.getCollectionNames() 14 db.getLastError() - just returns the err msg string 15 db.getLastErrorObj() - return full status object 16 db.getMongo() get the server connection object 17 db.getMongo().setSlaveOk() allow this connection to read from the nonmaster member of a replica pair 18 db.getName() 19 db.getPrevError() 20 db.getProfilingLevel() - deprecated 21 db.getProfilingStatus() - returns if profiling is on and slow threshold 22 db.getReplicationInfo() 23 db.getSiblingDB(name) get the db at the same server as this one 24 db.isMaster() check replica primary status 25 db.killOp(opid) kills the current operation in the db 26 db.listCommands() lists all the db commands 27 db.printCollectionStats() 28 db.printReplicationInfo() 29 db.printSlaveReplicationInfo() 30 db.printShardingStatus() 31 db.removeUser(username) 32 db.repairDatabase() 33 db.resetError() 34 db.runCommand(cmdObj) run a database command. if cmdObj is a string, turns it into { cmdObj : 1 } 35 db.serverStatus() 36 db.setProfilingLevel(level,<slowms>) 0=off 1=slow 2=all 37 db.shutdownServer() 38 db.stats() 39 db.version() current version of the server 40 db.getMongo().setSlaveOk() allow queries on a replication slave server
对数据库进行管理和操作的基本命令,可以从上面获取到。如果想要得到更多,而且每个命令的详细用法,可以使用上面列出的db.listCommands()查询。
另一个比较基础的是对指定数据库的集合进行操作、管理和监控,可以通过查询db.mycoll.help()获取到:
1 > db.mycoll.help() 2 DBCollection help 3 db.mycoll.find().help() - show DBCursor help 4 db.mycoll.count() 5 db.mycoll.dataSize() 6 db.mycoll.distinct( key ) - eg. db.mycoll.distinct( ‘x‘ ) 7 db.mycoll.drop() drop the collection 8 db.mycoll.dropIndex(name) 9 db.mycoll.dropIndexes() 10 db.mycoll.ensureIndex(keypattern[,options]) - options is an object with these possible fields: name, unique, dropDups 11 db.mycoll.reIndex() 12 db.mycoll.find([query],[fields]) - query is an optional query filter. fields is optional set of fields to return. 13 e.g. db.mycoll.find( {x:77} , {name:1, x:1} ) 14 db.mycoll.find(...).count() 15 db.mycoll.find(...).limit(n) 16 db.mycoll.find(...).skip(n) 17 db.mycoll.find(...).sort(...) 18 db.mycoll.findOne([query]) 19 db.mycoll.findAndModify( { update : ... , remove : bool [, query: {}, sort: {}, ‘new‘: false] } ) 20 db.mycoll.getDB() get DB object associated with collection 21 db.mycoll.getIndexes() 22 db.mycoll.group( { key : ..., initial: ..., reduce : ...[, cond: ...] } ) 23 db.mycoll.mapReduce( mapFunction , reduceFunction , <optional params> ) 24 db.mycoll.remove(query) 25 db.mycoll.renameCollection( newName , <dropTarget> ) renames the collection. 26 db.mycoll.runCommand( name , <options> ) runs a db command with the given name where the first param is the collection name 27 db.mycoll.save(obj) 28 db.mycoll.stats() 29 db.mycoll.storageSize() - includes free space allocated to this collection 30 db.mycoll.totalIndexSize() - size in bytes of all the indexes 31 db.mycoll.totalSize() - storage allocated for all data and indexes 32 db.mycoll.update(query, object[, upsert_bool, multi_bool]) 33 db.mycoll.validate() - SLOW 34 db.mycoll.getShardVersion() - only for use with sharding
有关数据库和集合管理的相关命令,是最基础和最常用的,如集合查询、索引操作等。
基本命令及实例
下面通过实际的例子来演示一些常见的命令:
(一)基本命令
1、show dbs
1 { 2 "host" : "dev2", 3 "version" : "1.8.3", 4 "process" : "mongod", 5 "uptime" : 845446, 6 "uptimeEstimate" : 839192, 7 "localTime" : ISODate("2011-12-27T04:03:12.512Z"), 8 "globalLock" : { 9 "totalTime" : 845445636925, 10 "lockTime" : 13630973982, 11 "ratio" : 0.016122827283818857, 12 "currentQueue" : { 13 "total" : 0, 14 "readers" : 0, 15 "writers" : 0 16 }, 17 "activeClients" : { 18 "total" : 0, 19 "readers" : 0, 20 "writers" : 0 21 } 22 }, 23 "mem" : { 24 "bits" : 64, 25 "resident" : 12208, 26 "virtual" : 466785, 27 "supported" : true, 28 "mapped" : 466139 29 }, 30 "connections" : { 31 "current" : 27, 32 "available" : 792 33 }, 34 "extra_info" : { 35 "note" : "fields vary by platform", 36 "heap_usage_bytes" : 70895216, 37 "page_faults" : 17213898 38 }, 39 "indexCounters" : { 40 "btree" : { 41 "accesses" : 4466653, 42 "hits" : 4465526, 43 "misses" : 1127, 44 "resets" : 0, 45 "missRatio" : 0.00025231420484197006 46 } 47 }, 48 "backgroundFlushing" : { 49 "flushes" : 14090, 50 "total_ms" : 15204393, 51 "average_ms" : 1079.0910574875797, 52 "last_ms" : 669, 53 "last_finished" : ISODate("2011-12-27T04:02:28.713Z") 54 }, 55 "cursors" : { 56 "totalOpen" : 3, 57 "clientCursors_size" : 3, 58 "timedOut" : 53 59 }, 60 "network" : { 61 "bytesIn" : 63460818650, 62 "bytesOut" : 763926196104, 63 "numRequests" : 67055921 64 }, 65 "opcounters" : { 66 "insert" : 7947057, 67 "query" : 35720451, 68 "update" : 16263239, 69 "delete" : 154, 70 "getmore" : 91707, 71 "command" : 68520 72 }, 73 "asserts" : { 74 "regular" : 0, 75 "warning" : 1, 76 "msg" : 0, 77 "user" : 7063866, 78 "rollovers" : 0 79 }, 80 "writeBacksQueued" : false, 81 "ok" : 1 82 }
有时,通过查看数据库服务器的状态,可以判断数据库是否存在问题,如果有问题,如数据损坏,可以及时执行修复。
1 > db.stats() 2 { 3 "db" : "fragment", 4 "collections" : 12, 5 "objects" : 384553, 6 "avgObjSize" : 3028.40198360174, 7 "dataSize" : 1164581068, 8 "storageSize" : 1328351744, 9 "numExtents" : 109, 10 "indexes" : 10, 11 "indexSize" : 16072704, 12 "fileSize" : 4226809856, 13 "ok" : 1 14 }
显示fragment数据库的统计信息。
1 > db.getCollectionNames() 2 [ 3 "17u", 4 "baseSe", 5 "bytravel", 6 "daodao", 7 "go2eu", 8 "lotour", 9 "lvping", 10 "mafengwo", 11 "sina", 12 "sohu", 13 "system.indexes" 14 ]
(二)基本DDL和DML
1、创建数据库
1 > show dbs 2 admin 0.03125GB 3 local (empty) 4 pagedb 0.03125GB 5 test 0.03125GB 6 > use LuceneIndexDB 7 switched to db LuceneIndexDB 8 > show dbs 9 admin 0.03125GB 10 local (empty) 11 pagedb 0.03125GB 12 test 0.03125GB 13 > db 14 LuceneIndexDB 15 > db.storeCollection.save({‘version‘:‘3.5‘, ‘segment‘:‘e3ol6‘}) 16 > show dbs 17 LuceneIndexDB 0.03125GB 18 admin 0.03125GB 19 local (empty) 20 pagedb 0.03125GB 21 test 0.03125GB 22 >
可见,在use指定数据库后,并且向指定其中的一个集合并插入数据后,数据库和集合都被创建了。
4、删除集合
删除集合,可以执行db.mycoll.drop()。
5、插入更新记录
直接使用集合的save方法,如下所示:
1 > <em>db.storeCollection.save({‘version‘:‘3.5‘, ‘segment‘:‘e3ol6‘})</em>
更新记录,使用save会将原来的记录值进行覆盖实现记录更新。
6、查询一条记录
使用findOne()函数,参数为查询条件,可选,系统会随机查询获取到满足条件的一条记录(如果存在查询结果数量大于等于1)示例如下所示:
7、查询多条记录
使用find()函数,参数指定查询条件,不指定条件则查询全部记录。
8、删除记录
使用集合的remove()方法,参数指定为查询条件,示例如下所示:
1 > db.storeCollection.remove({‘version‘:‘3.5‘}) 2 > db.storeCollection.findOne() 3 null
9、创建索引
可以使用集合的ensureIndex(keypattern[,options])方法,示例如下所示:
1 > use pagedb 2 switched to db pagedb 3 > db.page.ensureIndex({‘title‘:1, ‘url‘:-1}) 4 > db.system.indexes.find() 5 { "name" : "_id_", "ns" : "pagedb.page", "key" : { "_id" : 1 }, "v" : 0 } 6 { "name" : "_id_", "ns" : "pagedb.system.users", "key" : { "_id" : 1 }, "v" : 0} 7 { "_id" : ObjectId("4ef977633c1fc4613425accd"), "ns" : "pagedb.page", "key" : {"title" : 1, "url" : -1 }, "name" : "title_1_url_-1", "v" : 0 }
上述,ensureIndex方法参数中,数字1表示升序,-1表示降序。
使用db.system.indexes.find()可以查询全部索引。
10、查询索引
我们为集合建立的索引,那么可以通过集合的getIndexes()方法实现查询,示例如下所示:
1 > db.page.getIndexes() 2 [ 3 { 4 "name" : "_id_", 5 "ns" : "pagedb.page", 6 "key" : { 7 "_id" : 1 8 }, 9 "v" : 0 10 }, 11 { 12 "_id" : ObjectId("4ef977633c1fc4613425accd"), 13 "ns" : "pagedb.page", 14 "key" : { 15 "title" : 1, 16 "url" : -1 17 }, 18 "name" : "title_1_url_-1", 19 "v" : 0 20 } 21 ]
当然,如果需要查询系统中全部的索引,可以使用db.system.indexes.find()函数。
11、删除索引删除索引给出了两个方法:
1 db.mycoll.dropIndex(name) 2 db.mycoll.dropIndexes()
第一个通过指定索引名称,第二个删除指定集合的全部索引。
12、索引重建
可以通过集合的reIndex()方法进行索引的重建,示例如下所示:
use fragment
db.baseSe.count()
统计结果,如下所示:
1 > use fragment 2 switched to db fragment 3 > db.baseSe.count() 4 36749
上述统计了数据库fragment的baseSe集合中记录数。
14、查询并统计结果记录数use fragment
db.baseSe.find().count()
find()可以提供查询参数,然后查询并统计结果,如下所示:
15、查询指定数据库的集合当前可用的存储空间
use fragment
> db.baseSe.storageSize()
142564096
16、查询指定数据库的集合分配的存储空间
> db.baseSe.totalSize()
144096000
上述查询结果中,包括为集合(数据及其索引存储)分配的存储空间。
(三)启动与终止
(四)安全管理
1、以安全认证模式启动或者,也可以修改/etc/mongodb.conf,设置auth=true,重启mongod进程。
1 { 2 "user" : "admin", 3 "readOnly" : false, 4 "pwd" : "995d2143e0bf79cba24b58b3e41852cd" 5 }
说明:
db.$cmd.sys.unlock.findOne()
状态信息如下:
(五)数据备份、恢复与迁移管理
cd testbak
mongodump
2、备份指定数据库
mongodump -d pagedb
mongorestore --drop
mongorestore -d pagedb --drop
说明:将备份的pagedb的数据恢复到数据库。
mongorestore -d pagedb -c page --drop
说明:将备份的pagedb的的page集合的数据恢复到数据库。
--type支持的类型有三个:csv、tsv、json
其他各个选项的使用,可以查看帮助:
说明:将pagedb数据库中page集合的数据导出到pages.csv文件,其中各选项含义:
-f 指定cvs列名为_id,title,url,spiderName,pubDate
-q 指定查询条件
其他各个选项的使用,可以查看帮助: