淺談MongoDB中的常用操作，你都知道多少？

2024-09-07 00:22:34

字體：大中小

供稿：網(wǎng)友

這篇文章給大家分享的是有關(guān)MongoDB中的常用操作的內(nèi)容，小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考。下文整理了很多MongoDB操作技巧，感興趣的朋友接下來(lái)一起跟隨小編看看吧。

1、shell登陸和顯示

假設(shè)在本機(jī)上有一個(gè)端口為17380的MongoDB服務(wù)，假設(shè)已經(jīng)把mongo bin文件加入到系統(tǒng)PATH下。

登陸：mongo --port 17380

顯示DB：show dbs

進(jìn)入某DB：use test_cswuyg

顯示集合：show tables

    2、簡(jiǎn)單查找
    查找文檔：db.test_mac_id.find({'a': 'b'})

    刪除文檔：db.test_mac_id.remove({'a': 'b'})

    查找找到某一天的數(shù)據(jù)：

    db.a.find({'D' : ISODate('2014-04-21T00:00:00Z')}) 或者 db.a.find({'D' : ISODate('2014-04-21')})

    刪除某一天的數(shù)據(jù)：

    db.region_mac_id_result.remove({"D" : ISODate('2014-04-17')})

    小于2014.6.5的數(shù)據(jù)：

    db.xxx.find({E: {$lt :ISODate('2014-06-05')}})

    大于等于2014.6.1的數(shù)據(jù)：

    db.xxx.find({E: {$gte: ISODate("2014-05-29")}}).count()

    兩個(gè)條件：

    db.xxx.find({E:{$gte: ISODate("2014-05-29"), $lte: ISODate("2014-06-04")}}).count()

    json中的嵌套對(duì)象查詢(xún)，采用“點(diǎn)”的方式：

    mongos> db.wyg.find({"a.b": {$exists: true}})

    { "_id" : "c", "a" : { "b" : 10 } }

    某個(gè)字段存在，且小于1000有多少：

    db.stat.find({_: ISODate("2014-06-17"), "123": {$exists: 1, $lte: 1000}}, {"123": 1}).count()

    3、存在和遍歷統(tǒng)計(jì)
    存在'i': 1，且存在old_id字段：

    mongos> var it = db.test.find({'i': 1, "old_id": {$exists: 1}})

    遍歷計(jì)數(shù)1：mongos> var count = 0;while(it.hasNext()){if (it.next()["X"].length==32)++count}print(count)

    遍歷計(jì)數(shù)2：mongos> var count = 0;while(it.hasNext()){var item = it.next(); if (item['X'].length==32 && item['_id'] != item['X'])++count;if(!item['X'])++count;}print(count)

    4、插入和更新
    > db.test.findOne({_id: 'cswuyg'})

    null

    > db.test.insert({'_id': 'cswuyg', 'super_admin': true})

    > db.test.findOne({'_id': 'cswuyg'})

    {

    "_id" : "cswuyg",

    "super_admin" : true

    }

    db.test.update({'_id': 'cswuyg'}, {$set: {'super_admin': true}})

    5、repair 操作
    對(duì)某個(gè)DB執(zhí)行repair：進(jìn)入要repair的db，執(zhí)行db.repairDatabase()

    對(duì)mongodb整個(gè)實(shí)例執(zhí)行repair：numactl --interleave=all /mongod --repair --dbpath=/home/disk1/mongodata/shard/

    6、mongodb任務(wù)操作
    停止某個(gè)操作：

[xxx]$ mongo --port 17380
MongoDB shell version: 2.4.5
connecting to: 127.0.0.1:17380/test
mongos> db.currentOp()
{ "inprog" : [ ...] }

mongos> db.killOp("shard0001:163415563")
    批量停止：

    db.currentOp().inprog.forEach(function(item){db.killOp(item.opid)})
    當(dāng)查詢(xún)超過(guò)1000秒的，停止：

    db.currentOp().inprog.forEach(function(item){if(item.secs_running > 1000 )db.killOp(item.opid)})
    停止某個(gè)數(shù)據(jù)源的查詢(xún)：

    db.currentOp().inprog.forEach(function(item){if(item.ns == "cswuyg.cswuyg")db.killOp(item.opid)})
    把所有在等待鎖的操作顯示出來(lái)：

    db.currentOp().inprog.forEach(function(item){if(item.waitingForLock)print(JSON.stringify(item))})
    把處于等待中的分片顯示出來(lái)：

     常用js腳本，可直接復(fù)制到mongo-shell下使用：

    顯示當(dāng)前所有的任務(wù)狀態(tài)：

print("##########");db.currentOp().inprog.forEach(function(item){if(item.waitingForLock){var lock_info = item["opid"];
print("waiting:",lock_info,item.op,item.ns);}});print("----");
db.currentOp().inprog.forEach(function(item){if(!item.waitingForLock){var lock_info = item["opid"];
print("doing",lock_info,item.op,item.ns);}});print("##########");
    殺掉某些特定任務(wù)：

    （1）

    db.currentOp().inprog.forEach(function(item){if(item.waitingForLock){var lock_info = item["opid"];if(item.op=="query" && item.secs_running >60 && item.ns=="cswuyg.cswuyg"){db.killOp(item.opid)}}})
    （2）

db.currentOp().inprog.forEach(function(item) {
var lock_info = item["opid"];
if (item.op == "query" && item.secs_running > 1000) {
print("kill", item.opid);
db.killOp(item.opid)
}
})
    7、刪除并返回?cái)?shù)據(jù)
    old_item = db.swuyg.findAndModify({query: {"_id": "aabbccdd"}, fields:{"D": 1,'E':1, 'F':1}, remove: true})

    fields里面為1的是要返回的數(shù)據(jù)。

    8、分布式集群部署情況
    (1) 細(xì)致到collection的顯示：sh.status()

    (2)僅顯示分片：

    use config; db.shards.find()

    { "_id" : "shard0000", "host" : "xxhost:10001" }

    { "_id" : "shard0001", "host" : "yyhost:10002" }

    ....

    (3)

    use admin

    db.runCommand({listshards: 1})

    列出所有的shard server

    9、正則表達(dá)式查找
    正則表達(dá)式查詢(xún)：
    mongos> db.a.find({"tt": /t*/i})
    { "_id" : ObjectId("54b21e0f570cb10de814f86b"), "aa" : "1", "tt" : "tt" }
    其中i表明是否是case-insensitive，有i則表示忽略大小寫(xiě)

    db.testing.find({"name":/[7-9]/})

    當(dāng)name的值為789這幾個(gè)數(shù)字組成的字符串時(shí)，查詢(xún)命中。

    10、查詢(xún)性能
    db.testing.find({name: 123}).explain()

    輸出結(jié)果：

{
  "cursor" : "BasicCursor",
  "isMultiKey" : false,
  "n" : 1,
  "nscannedObjects" : 10,
  "nscanned" : 10,
  "nscannedObjectsAllPlans" : 10,
  "nscannedAllPlans" : 10,
  "scanAndOrder" : false,
  "indexOnly" : false,
  "nYields" : 0,
  "nChunkSkips" : 0,
  "millis" : 0,
  "indexBounds" : {
  },
  "server" : "xxx:10001"
}
    11、更新或插入
    當(dāng)該key不存在的時(shí)候執(zhí)行插入操作，當(dāng)存在的時(shí)候則不管，可以使用setOnInsert

    db.wyg.update({'_id': 'id'}, {'$setOnInsert': {'a': 'a'}, '$set': {'b': 'b'}}, true)

    當(dāng)id存在的時(shí)候，忽略setOnInsert。

    當(dāng)id存在的時(shí)候，如果要插入，則插入{'a': 'a'}

    最后的參數(shù)true，則是指明，當(dāng)update不存在的_id時(shí)，執(zhí)行插入操作。默認(rèn)是false，只更新，不插入。

    push、setOnInsert：db.cswuyg.update({"_id": "abc"}, {$push: {"name": "c"}, $setOnInsert: {"cc":"xx"}}, true)

    12、計(jì)算DB中collection的數(shù)量
    db.system.namespaces.count()

    13、增加數(shù)字，采用$inc
    db.cswuyg.update({"a.b": {$exists: true}}, {$inc: {'a.b': 2}})

    也就是對(duì)象a.b的值，增加了2

    注意$inc只能用于數(shù)值。

    14、刪除某個(gè)key
    db.cswuyg.update({'_id': 'c'}, {$unset: {'b': {$exists: true}}})

    { "_id" : "c", "a" : { "b" : 12 }, "b" : 7 }

    轉(zhuǎn)變?yōu)椋?br />
    { "_id" : "c", "a" : { "b" : 12 } }

    15、增加key:value
    db.cswuyg.update({'_id': 'z'}, {'$set': {'hello': 'z'}})

    { "_id" : "z", "b" : 1 }

    轉(zhuǎn)變?yōu)椋?br />
    { "_id" : "z", "b" : 1, "hello" : "z" }

    16、刪除數(shù)據(jù)庫(kù)、刪除表
    刪除數(shù)據(jù)庫(kù)：db.dropDatabase();

    刪除表：db.mytable.drop();

    17、查找到數(shù)據(jù)只看某列
    只顯示key名為D的數(shù)據(jù)：db.test.find({}, {D: 1})

    18、查看分片存儲(chǔ)情況
    （1）所有DB的分片存儲(chǔ)信息，包括chunks數(shù)、shard key信息：db.printShardingStatus()

    （2）db.collection.getShardDistribution() 獲取collection各個(gè)分片的數(shù)據(jù)存儲(chǔ)情況

    （3）sh.status() 顯示本mongos集群所有DB的信息，包含了Shard Key信息

    19、查看collection的索引
    db.cswuyg.getIndexes()

    20、開(kāi)啟某collection的分片功能
    1. ./bin/mongo -Cport 20000

    2. mongos> use admin

    3. switched to db admin

    4. mongos> db.runCommand({'enablesharding"' 'test'})

    5. { "ok" : 1 }

    開(kāi)啟user collection分片功能：

    1. mongos> db.runCommand({'shardcollection': 'test.user', 'key': {'_id': 1}})

    { "collectionsharded" : "test.user", "ok" : 1 }

    21、判斷當(dāng)前是否是shard集群
    isdbgrid：用來(lái)確認(rèn)當(dāng)前是否是 Sharding Cluster

> db.runCommand({isdbgrid:1});
是：
{ "isdbgrid" : 1, "hostname" : "xxxhost", "ok" : 1 }
不是：
{
  "ok" : 0,
  "errmsg" : "no such cmd: isdbgrid",
  "code" : 59,
  "bad cmd" : {
    "isdbgrid" : 1
  }
}
    22、dump DB
    mongodump支持從DB磁盤(pán)文件、運(yùn)行中的MongoD服務(wù)中dump出bson數(shù)據(jù)文件。

    （1）關(guān)閉MongoD之后，從它的DB磁盤(pán)文件中dump出數(shù)據(jù)（注：僅限單實(shí)例mongod）：

    mongodump --dbpath=/home/disk1/mongodata/shard/ -d cswuyg -o /home/disk2/mongodata/shard

    參考：

    http://docs.mongodb.org/manual/reference/program/mongodump/

    http://stackoverflow.com/questions/5191186/how-do-i-dump-data-for-a-given-date

    （2）從運(yùn)行的MongoD中導(dǎo)出指定日期數(shù)據(jù)，采用-q查詢(xún)參數(shù)：

    mongodump -h xxxhost --port 17380 --db cswuyg --collection test -q "{D: {/$gte: {/$date: `date -d "20140410" +%s`000}, /$lt: {/$date: `date +%s`000}}}"

    mongodump -dbpath=/home/disk3/mongodb/data/shard1/ -d cswuyg -c test -o /home/disk9/mongodata/shard1_2/ -q "{_:{/$gte:{/$date:`date -d "20140916" +%s`000}, /$lt: {/$date: `date -d "20140918" +%s`000}}}"

    dump出來(lái)的bson文件去掉了索引、碎片空間，所有相比DB磁盤(pán)文件要小很多。

（編輯：武林網(wǎng)）

上一篇：MongoDB安全包括什么？怎么對(duì)角色管理？

下一篇：mongodb查找耗時(shí)的辦法是什么？