MongoDB 之 Capped Collection


       MongoDB 支持 Capped Collection,一種固定大小的集合,當集合的大小達到指定大小時,
新數據覆蓋老數據,MongoDB Replica set 中的 oplog 就是 Capped Collection 類型。


1 查看 oplog 是否是 Capped Collection

 [mongo@redhatB ~]$ mongo 127.0.0.1:27018
MongoDB shell version: 2.2.1
connecting to: 127.0.0.1:27018/test

rs0:PRIMARY> use local;
switched to db local
 
rs0:PRIMARY> show collections;
me
oplog.rs
replset.minvalid
slaves
system.indexes
system.replset

rs0:PRIMARY> db.oplog.rs.isCapped();
true

 

     備注:通過 db.collection.isCapped() 命令可以查看一個集合是否是 Capped Collection 。
  
  
   Capped Collection 具有以下特性,在使用的時候需要注意:
  
   1 不可以對 Capped Collection 進行分片。
  
   2 在 2.2 版本以后,創建的Capped Collection 默認在  _id 字段上創建索引,而在 2.2 版本或以前沒有。
  
   3 在 Capped Collection 插入文檔后可以進行更新(update)操作,當更新不能導致原來文檔占用
       空間增長,否則更新失敗。
    
   4 不可以對 capped collection 執行刪除文檔操作,但可以刪除整個集合。
   
       接下來會測試其中的部分特性。  


2 創建 Capped Collection

 rs0:PRIMARY> db.createCollection("mycoll1",{capped:true,size:1024}); 
{ "ok" : 1 }

 

   備注:通過 db.createCollection 命令創建 Capped Collection 集合,創建時必須指定
             集合大小,用於預先分配空間。


3 查看一個集合是否是 Capped Collection
 
   可以通過以下兩種方法查看一個集合是否是 Capped Collection 。

 

 rs0:PRIMARY> db.mycoll1.isCapped();
true

rs0:PRIMARY> db.mycoll1.stats();
{
        "ns" : "test.mycoll1",
        "count" : 0,
        "size" : 0,
        "storageSize" : 4096,
        "numExtents" : 1,
        "nindexes" : 1,
        "lastExtentSize" : 4096,
        "paddingFactor" : 1,
        "systemFlags" : 1,
        "userFlags" : 0,
        "totalIndexSize" : 8176,
        "indexSizes" : {
                "_id_" : 8176
        },
        "capped" : true,
        "max" : 2147483647,
        "ok" : 1
}

 

      備注:"capped" 屬性為 true 表示是 Capped Collection 。


4 測試:插入記錄

 

 rs0:PRIMARY>  for (var i = 1; i <= 10000; i++) db.mycoll1.save({id : i, name : 'francs'});

rs0:PRIMARY> db.mycoll1.find().count();
56

rs0:PRIMARY> db.mycoll1.find();
{ "_id" : ObjectId("50b811cf68b1911e7096db7f"), "id" : 9945, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db80"), "id" : 9946, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db81"), "id" : 9947, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db82"), "id" : 9948, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db83"), "id" : 9949, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db84"), "id" : 9950, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db85"), "id" : 9951, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db86"), "id" : 9952, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db87"), "id" : 9953, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db88"), "id" : 9954, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db89"), "id" : 9955, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db8a"), "id" : 9956, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db8b"), "id" : 9957, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db8c"), "id" : 9958, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db8d"), "id" : 9959, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db8e"), "id" : 9960, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db8f"), "id" : 9961, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db90"), "id" : 9962, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db91"), "id" : 9963, "name" : "francs" }
{ "_id" : ObjectId("50b811cf68b1911e7096db92"), "id" : 9964, "name" : "francs" }
Type "it" for more

 

   備注:由於限制了集合大小不小,目標插入 10000 條,結果只插入了 56 條數據,並且老數據被新數據
             覆蓋。另外不可以刪除 Capped Collection 的文檔,下面測試下。
 
5  測試: 刪除 capped collection 中的文檔

 

 rs0:PRIMARY> db.mycoll1.remove({id:9956});
canot remove from a capped collection  

   備注:刪除文檔時拋出異常。


6  測試:更新 capped collection 中的文檔

 

 rs0:PRIMARY> db.mycoll1.find({id:9956});
{ "_id" : ObjectId("50b811cf68b1911e7096db8a"), "id" : 9956, "name" : "francs" }

rs0:PRIMARY> db.mycoll1.update({id:9956},{$set:{name:'aaa_francs'}});
failing update: objects in a capped ns cannot grow

rs0:PRIMARY> db.mycoll1.update({id:9956},{$set:{name:'bbb'}});

rs0:PRIMARY> db.mycoll1.find({id:9956});
{ "_id" : ObjectId("50b811cf68b1911e7096db8a"), "id" : 9956, "name" : "bbb" }

 

      備注:這里正好驗證了特性3,更新后的值不能超過原有空間,否則更新失敗。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM