Mongodb upsert бросает исключение DuplicateKeyException

Я получаю эту ошибку [2] время от времени при попытке повысить (увеличить или вставить) документ с помощью метода [1].

[1]

public NGram save(final NGram ngram) {
    Criteria cr = where("_id").is(ngram.getNgram())
            .and("f3c").is(ngram.getF3c())
            .and("tokCount").is(ngram.getTokCount())
            .and("first").is(ngram.getFirst())
            ;
    if( ngram.getTokCount() > 1 ) {
        cr.and("second").is(ngram.getSecond());
    }
    if( ngram.getTokCount() > 2 ) {
        cr.and("third").is(ngram.getThird());
    }
    final Query qry = new Query( cr );
    final Update updt = new Update().inc("count", ngram.getCount());
    template.upsert(qry, updt, NGram.class);
    return ngram;
}

[2]

Caused by: org.springframework.dao.DuplicateKeyException: E11000 duplicate key error index: sytrue.ngram.$_id_  dup key: { : "page two" }; nested exception is com.mongodb.MongoException$DuplicateKey: E11000 duplicate key error index: sytrue.ngram.$_id_  dup key: { : "page two" }
at org.springframework.data.mongodb.core.MongoExceptionTranslator.translateExceptionIfPossible(MongoExceptionTranslator.java:52)
at org.springframework.data.mongodb.core.MongoTemplate.potentiallyConvertRuntimeException(MongoTemplate.java:1665)
at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:390)
at org.springframework.data.mongodb.core.MongoTemplate.doUpdate(MongoTemplate.java:920)
at org.springframework.data.mongodb.core.MongoTemplate.upsert(MongoTemplate.java:894)
at com.sytrue.ngram.repo.impl.NGramRepositoryImpl.save(NGramRepositoryImpl.java:43)
at sun.reflect.GeneratedMethodAccessor41.invoke(Unknown Source)

Upsert никогда не должен возвращать мне это исключение. Я прав?


spring mongodb upsert
person biliboc    schedule 09.05.2013    source источник
comment
случайно два upserts происходят одновременно?   -  person Abhishek Kumar    schedule 09.05.2013
comment
нет, я сериализую эти upserts через очередь.   -  person biliboc    schedule 09.05.2013

Ответы (1)


arrow_upward
18
arrow_downward

Проблема, о которой я только догадываюсь, может быть следующей:

Вы выполняете операции поиска, основанные на многих критериях. Это означает, что в случае сбоя из-за несоответствия параметра (в критериях) он попытается вставить документ.

Таким образом, есть вероятность, что вы пытаетесь обновить тот же документ с тем же _id, но некоторые другие критерии не совпадают, что приводит к повторной вставке, что вызовет исключение дублирующего ключа. Рассмотрим приведенный ниже пример

test:Mongo > db.example.update({ _id : 1, a : 1, b : 1},{ $set : {d : 1}}, true, false)
test:Mongo > db.example.find()
{ "_id" : 1, "a" : 1, "b" : 1, "d" : 1 }
test:Mongo > db.example.update({ _id : 1, a : 1, b : 2},{ $set : {d : 1}}, true, false)
E11000 duplicate key error index: test.example.$_id_  dup key: { : 1.0 }
person Abhishek Kumar    schedule 09.05.2013