4

MongoTemplateを使用して、Personというエンティティを保存しようとしています。楽観的ロックを使用したいので、エンティティは@Versionアノテーションを使用してバージョン管理されます。

MongoTemplate.saveを使用して新しいPersonエンティティを空のコレクションに格納しようとすると、OptimisticLockingExceptionが発生します。既存のオブジェクトを更新するのではなく、新しいオブジェクトを作成しているので、これは予期していませんでした。（そして、他のスレッドはコレクションにアクセスしていません。）

これは予想される動作ですか、それとも私は何か間違ったことをしていますか？

（代わりにMongoOperations.insertを使用すると、すべてが機能します（ただし、CrudRepositoryには保存のみがあり、更新は行われないため、保存を使用します。）@ Versionアノテーションを削除すると、同様に機能します。）

ありがとう、ダニエル

私のエンティティクラス：

import org.bson.types.ObjectId;
import org.springframework.data.annotation.Id;
import org.springframework.data.annotation.Version;
import org.springframework.data.mongodb.core.mapping.Document;

@Document
public class Person {

    @Version
    private long versionId;

    @Id
    private ObjectId id;

    private final String name;

    public Person(String name) {
        this.name = name;
    }

    public long getVersionId() {
        return versionId;
    }

    public ObjectId getId() {
        return id;
    }

    public String getName() {
        return name;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;

        Person person = (Person) o;

        if (id != null ? !id.equals(person.id) : person.id != null) return false;

        return true;
    }

    @Override
    public int hashCode() {
        return id != null ? id.hashCode() : 0;
    }
}

私のテストセットアップ（EmbedMongoを使用してMongoDbインスタンスをセットアップしています）：

import com.mongodb.Mongo;
import de.flapdoodle.embed.mongo.MongodExecutable;
import de.flapdoodle.embed.mongo.MongodProcess;
import de.flapdoodle.embed.mongo.MongodStarter;
import de.flapdoodle.embed.mongo.config.MongodConfig;
import de.flapdoodle.embed.mongo.distribution.Version;
import de.flapdoodle.embed.process.runtime.Network;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.springframework.data.mapping.context.MappingContext;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.MongoOperations;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
import org.springframework.data.mongodb.core.convert.MappingMongoConverter;
import org.springframework.data.mongodb.core.mapping.MongoMappingContext;

public class MongoDbTest {

    private MongodExecutable mongodExe;
    private MongodProcess mongod;
    private Mongo mongo;
    private MongoOperations mongoOperations;

    @Before
    public void setUp() throws Exception {
        MongodStarter runtime = MongodStarter.getDefaultInstance();

        mongodExe = runtime.prepare(new MongodConfig(Version.Main.V2_0, 12345, Network.localhostIsIPv6()));
        mongod = mongodExe.start();
        mongo = new Mongo("localhost", 12345);

        MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongo, "database");

        MappingContext mappingContext = new MongoMappingContext();
        MappingMongoConverter mappingMongoConverter = new MappingMongoConverter(mongoDbFactory, mappingContext);

        mongoOperations = new MongoTemplate(mongoDbFactory, mappingMongoConverter);
    }

    @After
    public void tearDown() {
       mongod.stop();
       mongodExe.stop();
    }

    @Test
    public void testSave() {
        Person person = new Person("Joe");
        mongoOperations.save(person);  // This call throws OptimisticLockingException.
    }
}
4

1 に答える 1

10

versionプロパティの型がlongの場合、デフォルトでは0の値になりますが、これはSpringDataMongoDBでは受け入れられないようです。

PersonクラスのversionIdのタイプをLong/Integerに変更します。

@Version
private Long versionId;
于 2013-03-11T12:29:09.367 に答える