mongodb数据库基础字段值自增长实现 - 主机乐

MongoDB 没有像 SQL 一样有自动增长的功能， MongoDB 的 _id 是系统自动生成的12字节唯一标识。但在某些情况下，我们可能需要实现 ObjectId 自动增长功能。由于 MongoDB 没有实现这个功能，我们可以通过编程的方式来实现，以下我们将在 counters 集合中实现_id字段自动增长。

1.创建计数器集合

期望_id字段从1,2,3,4到n，启动一个自动递增的整数序列，如：

4.java实现

java实现以上功能，数据库驱动版本不同运行效果有差异，仅供参考：

private MongoDatabase conn;

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

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;
}

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 addSms(){
int id = getNextSequenceValue();
if(id != 0){
DBCollection collection = conn.getCollection(“sms”);
List<Document> documents = new ArrayList<Document>();
for(int i = 0; i < 20; i++){
int id = getNextSequenceValue();
Document document = new Document(“_id”, id).
append(“title”, “标题” + i).
append(“content”, “短信” + i).
append(“type”, 1);
documents.add(document);
}
collection.insertMany(documents);
System.out.println(“文档插入成功”);

}
}

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());
}
}