mongodb フィールド値自己増殖型実装コード

{
  "_id":1,
  "title": "title",
  "content": "content1",
  "type": "type"
}

db.createCollection("counters")

db.counters.insert({_id:"objId",sequence_value:0})

db.counters.findAndModify({
  query: {_id: "objId" },
  update: {$inc:{sequence_value:1}},
  new: true
}).sequence_value;

db.collection.findAndModify({
  query: <document>, //define selection criteria for which records to modify
  sort: <document>, //define selection criteria to retrieve multiple documents when the document should be modified
  new: <boolean>, //indicates that the modified document will be displayed
  fields: <document>, //Specify the set of fields to return
  upsert: <boolean> // if the selection criteria can not retrieve the document, then create a new document
  remove: <boolean> // true, the document specified by query will be removed from the database
)}

db.createCollection("sms")

db.sms.insert({
  _id: db.counters.findAndModify({query:{_id: "objId" },update: {$inc:{sequence_value:1}},"new":true}).sequence_ value,
  title: "title1",
  content: "SMS1",
  type: "1"
})

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

private MongoDatabase conn;
 
static{
  this.conn = getDatabase(databaseName)。

 
/**
 * データベースへの接続
 * @param 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;

 
/**
 * 最新シリアル番号の取得
 * @return シリアル番号
 */
プライベートスタティック 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){ もし
    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", "title" + i).
      append("content", "SMS"+i).を追加します。
      append("type", 1);
      documents.add(document)を実行します。
    
    collection.insertMany(documents)を実行します。
    System.out.println("document inserted successfully")を実行します。
 
  
}
 
/**
 * クエリーコレクション
 */
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()); 
  }
}