mongodb完成字段值自動(dòng)增長(zhǎng)功能示例

2024-09-07 00:22:35

字體：大中小

供稿：網(wǎng)友

MongoDB是一個(gè)基于分布式文件存儲(chǔ)的數(shù)據(jù)庫(kù)，是由C++語(yǔ)言編寫(xiě)的，目的在于為web應(yīng)用聽(tīng)可擴(kuò)展的高性能數(shù)據(jù)存儲(chǔ)解決方案。MongoDB與SQL還是存在很大不同的，例如它沒(méi)有像 SQL 一樣有自動(dòng)增長(zhǎng)的功能，那么mongodb字段值自增長(zhǎng)要如何實(shí)現(xiàn)呢？

       1.創(chuàng)建計(jì)數(shù)器集合
       期望_id字段從1,2,3,4到n，啟動(dòng)一個(gè)自動(dòng)遞增的整數(shù)序列，如：

{
  "_id":1,
  "title": "標(biāo)題",
  "content": "內(nèi)容1",
  "type": "類(lèi)型"
}
       為此，創(chuàng)建 counters 集合，序列字段值可以實(shí)現(xiàn)自動(dòng)長(zhǎng)：

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

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

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

db.createCollection("sms")
       在sms集合中新增文檔，實(shí)現(xiàn)_id自增長(zhǎng)：

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

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

       4.java實(shí)現(xiàn)
       java實(shí)現(xiàn)以上功能，數(shù)據(jù)庫(kù)驅(qū)動(dòng)版本不同運(yùn)行效果有差異，僅供參考：

private MongoDatabase conn;

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

/**
* 連接數(shù)據(jù)庫(kù)
* @param databaseName 數(shù)據(jù)庫(kù)名稱(chēng)
* @return       數(shù)據(jù)庫(kù)連接對(duì)象
*/
private static MongoDatabase getDatabase(databaseName){
  MongoDatabase mongoDatabase = null;
  try{
    // 連接到 mongodb 服務(wù)
    MongoClient mongoClient = new MongoClient( "localhost" , 27017 );

    // 連接到數(shù)據(jù)庫(kù)
    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;
}

/**
* 獲取最新序列號(hào)
* @return 序列號(hào)
*/
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());
  }

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

上一篇：MongoDB如何限制對(duì)內(nèi)存使用及查看內(nèi)存運(yùn)用情況？

下一篇：MongoDB內(nèi)建角色包括哪些？?jī)?yōu)點(diǎn)是什么？