MongoDB
 sql >> Database >  >> NoSQL >> MongoDB

Inserisci il documento in mongodb con il campo di incremento automatico da java

Seguendo la documentazione per creazione di un campo sequenza con incremento automatico , lo adattiamo per essere utilizzato in Java con il driver Java MongoDB .

Esempio di implementazione:

import java.net.UnknownHostException;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;

public class TestAutoIncrement {

private final static String DB_NAME = "MyTestDB";
private final static String TEST_COLLECTION = "testCollection";
private final static String COUNTERS_COLLECTION = "countersCollection";

public static DBCollection testCollection;
public static DBCollection countersCollection;

public static void main(String[] args) {

    try {
        MongoClient mongoClient = new MongoClient();
        DB database = mongoClient.getDB(DB_NAME);
        testCollection = database.getCollection(TEST_COLLECTION);
        countersCollection = database.getCollection(COUNTERS_COLLECTION);
    } catch (UnknownHostException e) {
        e.printStackTrace();
    }

    if (countersCollection.count() == 0) {
        createCountersCollection();
    }

    createTestCollection();
}

public static void createCountersCollection() {

    BasicDBObject document = new BasicDBObject();
    document.append("_id", "userid");
    document.append("seq", 0);
    countersCollection.insert(document);
}

public static Object getNextSequence(String name) {

    BasicDBObject searchQuery = new BasicDBObject("_id", name);
    BasicDBObject increase = new BasicDBObject("seq", 1);
    BasicDBObject updateQuery = new BasicDBObject("$inc", increase);
    DBObject result = countersCollection.findAndModify(searchQuery, null, null,
            false, updateQuery, true, false);

    return result.get("seq");
}

public static void createTestCollection() {

    BasicDBObject document = new BasicDBObject();
    document.append("_id", getNextSequence("userid"));
    document.append("name", "Sarah");
    testCollection.insert(document);

    document = new BasicDBObject();
    document.append("_id", getNextSequence("userid"));
    document.append("name", "Bob");
    testCollection.insert(document);

    document = new BasicDBObject();
    document.append("_id", getNextSequence("userid"));
    document.append("name", "Alex");
    testCollection.insert(document);
  }

}

È necessario prestare particolare attenzione a findAndModify metodo . Nel driver Java MongoDB (2.12.4), il metodo è disponibile con 4 firme diverse.
Devi usarne una che ti permetta di passare una query oggetto, update oggetto e returnNew boolean (che deve essere impostato su true ).

Questo perché, secondo la documentazione :
Per impostazione predefinita, il documento restituito non include le modifiche apportate all'aggiornamento. Per restituire il documento con le modifiche apportate all'aggiornamento, utilizzare la nuova opzione.

Dobbiamo restituire il documento con le modifiche apportate all'aggiornamento.