mongodb完成字段值自動增長功能示例

2024-09-07 00:22:35

字體：大中小

來源：轉載

供稿：網友

MongoDB是一個基于分布式文件存儲的數據庫，是由C++語言編寫的，目的在于為web應用聽可擴展的高性能數據存儲解決方案。MongoDB與SQL還是存在很大不同的，例如它沒有像 SQL 一樣有自動增長的功能，那么mongodb字段值自增長要如何實現呢？

       1.創建計數器集合
       期望_id字段從1,2,3,4到n，啟動一個自動遞增的整數序列，如：

{
  "_id":1,
  "title": "標題",
  "content": "內容1",
  "type": "類型"
}
       為此，創建 counters 集合，序列字段值可以實現自動長：

db.createCollection("counters")
       初始化集合，以objId作為主鍵，sequence_value 字段是序列通過自動增長后的一個值：

db.counters.insert({_id:"objId",sequence_value:0})
       2.查詢序列號
       查詢返回更新后的序列號

db.counters.findAndModify({
  query: {_id: "objId" },
  update: {$inc:{sequence_value:1}},
  new: true
}).sequence_value;
        3.測試
       創建測試集合sms：

db.createCollection("sms")
       在sms集合中新增文檔，實現_id自增長：

db.sms.insert({
  _id: db.counters.findAndModify({query:{_id: "objId" },update: {$inc:{sequence_value:1}},"new":true}).sequence_value,
  title: "標題1",
  content: "短信1",
  type: "1"
})
       查詢sms集合：

db.sms.find({}).sort({_id:1})

       4.java實現
       java實現以上功能，數據庫驅動版本不同運行效果有差異，僅供參考：

private MongoDatabase conn;

static{
  this.conn = getDatabase(databaseName);
}

/**
* 連接數據庫
* @param databaseName 數據庫名稱
* @return       數據庫連接對象
*/
private static MongoDatabase getDatabase(databaseName){
  MongoDatabase mongoDatabase = null;
  try{
    // 連接到 mongodb 服務
    MongoClient mongoClient = new MongoClient( "localhost" , 27017 );

    // 連接到數據庫
    MongoDatabase mongoDatabase = mongoClient.getDatabase(databaseName);
    System.out.println("Connect to database successfully");

  }catch(Exception e){
    System.err.println( e.getClass().getName() + ": " + e.getMessage() );
  }
  return mongoDatabase;
}

/**
* 獲取最新序列號
* @return 序列號
*/
private static int getNextSequenceValue(){
  DBCollection collection = conn.getCollection("counters");
  DBObject query = new BasicDBObject("_id", new BasicDBObject("$eq", "objId"));
  DBObject newDocument =new BasicDBObject();
  newDocument.put("$inc", new BasicDBObject().append("sequence_value", 1));
  newDocument.put("new": true);
  DBObject ret = collection.findAndModify(query, newDocument);
  if (ret == null){
    return 0;
  }else{
    return (Integer)ret.get("sequence_value");
  }
}
/**
* 查詢集合
*/
public static void findSms(){
  DBCollection collection = conn.getCollection("sms");
  FindIterable<Document> findIterable = collection.find();
  MongoCursor<Document> mongoCursor = findIterable.iterator();
  while(mongoCursor.hasNext()){
    System.out.println(mongoCursor.next());
  }

（編輯：武林網）

上一篇：MongoDB如何限制對內存使用及查看內存運用情況？

下一篇：MongoDB內建角色包括哪些？優點是什么？