документы, не удаленные с помощью mongo-jackson

Я гоняюсь за серьезной ошибкой в ​​​​нашем приложении и после некоторых копаний разбил его на этот пример. Используя коллекцию Джексона, я не могу удалить документы. Обычно это работает для одного документа, который я только что вставил. В следующем примере я просто пытаюсь очистить unittest-коллекцию.

import java.net.UnknownHostException;

import net.vz.mongodb.jackson.DBCursor;
import net.vz.mongodb.jackson.JacksonDBCollection;

import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.test.model.Account;

public class MongoTest {

  public static void main(String[] args) {
    try {
        Mongo mongo = new Mongo("localhost", 27017);
        DB db = mongo.getDB("orion-unittest");

        // get a single collection
        DBCollection collection = db.getCollection("account");
        JacksonDBCollection<Account, String> jacksonCollection = JacksonDBCollection.wrap(collection, Account.class, String.class);

        // doesn't work
        DBCursor<Account> jacksonCursor = jacksonCollection.find();
        while (jacksonCursor.hasNext()) {
            jacksonCollection.remove(jacksonCursor.next());
        }
        System.out.println(jacksonCollection.getCount());

        // works!
        com.mongodb.DBCursor cursor = collection.find();
        while (cursor.hasNext()) {
            collection.remove(cursor.next());
        }
        System.out.println(collection.getCount());

    } catch (UnknownHostException e) {
        e.printStackTrace();
    } catch (MongoException e) {
        e.printStackTrace();
    }
  }

}

Вывод консоли:
6
0

Странная часть, когда я отслеживаю действия сервера mongo, я вижу, что команды удаления передаются. я что-то пропустил, или это баг джексон маппера?

здесь класс Account - ничего особенного. идентификатор заполняется ключом _id:

import net.vz.mongodb.jackson.Id;

public class Account {
    @Id
    String id;
    String nickname = null;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getNickname() {
        return nickname;
    }

    public void setNickname(String nickname) {
        this.nickname = nickname;
    }
}

person Yannick    schedule 02.04.2012    source источник


Ответы (2)


Я не использовал mongo-jackson-mapper, но, как я видел в исходный код вызывает только сам метод dbCollection.remove. Итак, я предполагаю, что ваша проблема связана с WriteConcern. Попробуй это :

jacksonCollection.remove(jacksonCursor.next(), WriteConcern.FSYNC_SAFE);

и тест 2 удаляет отдельно (не один за другим), так что вы действительно можете понять, удаляется он или нет (у него также может быть задержка удаления).

person frail    schedule 03.04.2012

Я нашел решение, используя @ObjectId вместо @Id. проблема заключалась в том, что до того, как мой идентификатор был сериализован в

{"_id": ObjectId("4f7551a74206b4f8e692bda3")} 

а не что-то вроде:

{"_id": "4f7551a74206b4f8e692bda3"} 

... который не выполнил запрос, выполненный путем удаления при попытке найти соответствующий объект. аннотация @ObjectId теперь соответствует результатам сериализации.

person Yannick    schedule 03.04.2012