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内建角色包括哪些？优点是什么？