Skip to content

Implement clear method on BaseMorphiaRepository #7

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 1 commit into from
Mar 23, 2016
Merged

Implement clear method on BaseMorphiaRepository #7

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
75 changes: 59 additions & 16 deletions morphia/src/it/java/org/seedstack/mongodb/morphia/MorphiaRepositoryIT.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,9 @@
import com.google.inject.ProvisionException;
import com.google.inject.TypeLiteral;
import com.google.inject.util.Types;
import org.assertj.core.api.Assertions;
import org.junit.Test;
import org.mongodb.morphia.mapping.MappingException;
import org.mongodb.morphia.query.UpdateException;
import org.seedstack.business.domain.Repository;
import org.seedstack.mongodb.morphia.fixtures.dummyobject.Dummy1;
import org.seedstack.mongodb.morphia.fixtures.dummyobject.Dummy2;
Expand All @@ -23,17 +24,25 @@
import org.seedstack.mongodb.morphia.fixtures.dummyobject.Dummy5;
import org.seedstack.mongodb.morphia.fixtures.dummyobject.Dummy6;
import org.seedstack.mongodb.morphia.fixtures.user.Address;
import org.seedstack.mongodb.morphia.fixtures.user.EntityStringId;
import org.seedstack.mongodb.morphia.fixtures.user.User;
import org.seedstack.mongodb.morphia.internal.MorphiaErrorCodes;
import org.seedstack.seed.SeedException;
import org.seedstack.seed.it.AbstractSeedIT;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.fail;

public class MorphiaRepositoryIT extends AbstractSeedIT {

@Inject
@Morphia
private Repository<User, Long> userRepository;

@Inject
@Morphia
private Repository<EntityStringId, String> entityStringIdRepository;

@Inject
private Injector injector;

Expand All @@ -45,7 +54,7 @@ public void repository_injection_test_no_client_for_aggregate() {
Key.get(TypeLiteral.get(Types.newParameterizedType(Repository.class, Dummy1.class, Long.class)),
Morphia.class));
} catch (ProvisionException e) {
Assertions.assertThat(e.getCause().getMessage())
assertThat(e.getCause().getMessage())
.isEqualTo(SeedException.createNew(MorphiaErrorCodes.UNKNOW_DATASTORE_CLIENT).getMessage());
}
}
Expand All @@ -57,7 +66,7 @@ public void repository_injection_test_no_dbName_for_aggregate() {
Key.get(TypeLiteral.get(Types.newParameterizedType(Repository.class, Dummy2.class, Long.class)),
Morphia.class));
} catch (ProvisionException e) {
Assertions.assertThat(e.getCause().getMessage())
assertThat(e.getCause().getMessage())
.isEqualTo(SeedException.createNew(MorphiaErrorCodes.UNKNOW_DATASTORE_DATABASE).getMessage());
}
}
Expand All @@ -69,7 +78,7 @@ public void repository_injection_test_no_mongoDb_client() {
Key.get(TypeLiteral.get(Types.newParameterizedType(Repository.class, Dummy3.class, Long.class)),
Morphia.class));
} catch (ProvisionException e) {
Assertions.assertThat(e.getCause().getMessage())
assertThat(e.getCause().getMessage())
.isEqualTo(SeedException.createNew(MorphiaErrorCodes.UNKNOW_DATASTORE_CLIENT).getMessage());
}
}
Expand All @@ -81,7 +90,7 @@ public void repository_injection_test_no_mongoDb_database() {
Key.get(TypeLiteral.get(Types.newParameterizedType(Repository.class, Dummy4.class, Long.class)),
Morphia.class));
} catch (ProvisionException e) {
Assertions.assertThat(e.getCause().getMessage())
assertThat(e.getCause().getMessage())
.isEqualTo(SeedException.createNew(MorphiaErrorCodes.UNKNOW_DATABASE_NAME).getMessage());
}
}
Expand All @@ -93,7 +102,7 @@ public void repository_injection_test_no_mongodb_for_aggregate() {
Key.get(TypeLiteral.get(Types.newParameterizedType(Repository.class, Dummy5.class, Long.class)),
Morphia.class));
} catch (ProvisionException e) {
Assertions.assertThat(e.getCause().getMessage())
assertThat(e.getCause().getMessage())
.isEqualTo(SeedException.createNew(MorphiaErrorCodes.UNKNOW_DATASTORE_CONFIGURATION).getMessage());
}
}
Expand All @@ -105,37 +114,71 @@ public void repository_injection_async_client() {
Key.get(TypeLiteral.get(Types.newParameterizedType(Repository.class, Dummy6.class, Long.class)),
Morphia.class));
} catch (ProvisionException e) {
Assertions.assertThat(e.getCause().getMessage())
assertThat(e.getCause().getMessage())
.isEqualTo(SeedException.createNew(MorphiaErrorCodes.ERROR_ASYNC_CLIENT).getMessage());
}
}


@Test
public void mongodb_repository_test() {
Assertions.assertThat(userRepository).isNotNull();
assertThat(userRepository).isNotNull();
User user1 = getUser(1L, "N°", "1");
userRepository.persist(user1);
User user2 = userRepository.load(user1.getEntityId());
Assertions.assertThat(user1.getId()).isEqualTo(user2.getId());
Assertions.assertThat(user1.getEntityId()).isEqualTo(user2.getEntityId());
assertThat(user1.getId()).isEqualTo(user2.getId());
assertThat(user1.getEntityId()).isEqualTo(user2.getEntityId());
userRepository.delete(user1);
User user3 = userRepository.load(user1.getEntityId());
Assertions.assertThat(user3).isEqualTo(null);
assertThat(user3).isEqualTo(null);
User user5 = getUser(2L, "N°", "2");
userRepository.delete(user5);
userRepository.save(user5);
userRepository.persist(user5);
User user6 = userRepository.load(user5.getEntityId());
Assertions.assertThat(user6.getId()).isEqualTo(user5.getId());
assertThat(user6.getId()).isEqualTo(user5.getId());
userRepository.delete(user5);
user6 = userRepository.load(user5.getEntityId());
Assertions.assertThat(user6).isEqualTo(null);
assertThat(user6).isEqualTo(null);
userRepository.persist(user5);
Assertions.assertThat(userRepository.load(2L)).isNotEqualTo(null);
assertThat(userRepository.load(2L)).isNotEqualTo(null);
}

@Test(expected = MappingException.class)
public void mongodb_repository_save_without_id() {
EntityStringId saved = entityStringIdRepository.save(new EntityStringId(null));
fail("should not have saved");
}

@Test(expected = UpdateException.class)
public void mongodb_repository_save_with_inexistent_id() {
userRepository.save(getUser(100L, "Robert", "SMITH"));
fail("should not have saved");
}

@Test
public void mongodb_repository_save() {
userRepository.persist(getUser(200L, "Robert", "SMITH"));
assertThat(userRepository.save(getUser(200L, "Jane", "SMITH")).getEntityId()).isEqualTo(200L);
}

@Test
public void mongodb_repository_persist_load() {
userRepository.persist(getUser(300L, "Robert", "SMITH"));
assertThat(userRepository.load(300L).getEntityId()).isEqualTo(300L);
}

@Test
public void mongodb_repository_clear() {
userRepository.persist(getUser(400L, "Robert", "SMITH"));
userRepository.persist(getUser(401L, "Jayne", "SMITH"));
assertThat(userRepository.load(400L).getEntityId()).isEqualTo(400L);
assertThat(userRepository.load(401L).getEntityId()).isEqualTo(401L);
userRepository.clear();
assertThat(userRepository.load(400L)).isNull();
assertThat(userRepository.load(401L)).isNull();
}

public User getUser(long id, String firstname, String lastName) {
return new User(id, firstname, lastName, new Address("France", "75001", "Paris", "Champ Elysee avenue", 1));
}

}
30 changes: 30 additions & 0 deletions morphia/src/it/java/org/seedstack/mongodb/morphia/fixtures/user/EntityStringId.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,30 @@
/**
* Copyright (c) 2013-2016, The SeedStack authors <http://seedstack.org>
*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
package org.seedstack.mongodb.morphia.fixtures.user;

import org.mongodb.morphia.annotations.Entity;
import org.mongodb.morphia.annotations.Id;
import org.seedstack.business.domain.AggregateRoot;

@Entity
public class EntityStringId implements AggregateRoot<String> {
@Id
private String id;

public EntityStringId() {
}

public EntityStringId(String id) {
this.id = id;
}

@Override
public String getEntityId() {
return id;
}
}
2 changes: 1 addition & 1 deletion morphia/src/it/resources/logback-test.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
<pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<root level="WARN">
<root level="INFO">
<appender-ref ref="STDOUT"/>
</root>
</configuration>
26 changes: 17 additions & 9 deletions morphia/src/main/java/org/seedstack/mongodb/morphia/BaseMorphiaRepository.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,16 +17,21 @@
import org.seedstack.seed.Application;

/**
* This class serves as inheritance base for the Mongodb repositories.
* This class can serve as a base class for Morphia repositories. It provides methods for common CRUD operations as
* well as access to the data store through the {@link #getDatastore()} ()} protected method.
*
* @param <A> Mongodb Entity Type (DDD: Aggregate)
* @param <K> key type
* @author redouane.loulou@ext.mpsa.com Date: 20/10/2015
* @param <A> Aggregate root class
* @param <K> Key class
* @author redouane.loulou@ext.mpsa.com
*/
public abstract class BaseMorphiaRepository<A extends AggregateRoot<K>, K> extends BaseRepository<A, K> {

private Datastore datastore;

/**
* Provides access to the Morphia data store for implementing custom data access methods.
*
* @return the Morphia data store.
*/
protected Datastore getDatastore() {
return datastore;
}
Expand All @@ -41,6 +46,11 @@ protected A doLoad(K id) {
return datastore.get(aggregateRootClass, id);
}

@Override
protected void doClear() {
datastore.delete(datastore.createQuery(aggregateRootClass));
}

@Override
protected void doDelete(K id) {
datastore.delete(aggregateRootClass, id);
Expand All @@ -49,18 +59,16 @@ protected void doDelete(K id) {
@Override
protected void doDelete(A aggregate) {
datastore.delete(aggregate);

}

@Override
protected void doPersist(A aggregate) {
datastore.save(aggregate);

}

@Override
protected A doSave(A aggregate) {
return datastore.get(aggregateRootClass, datastore.save(aggregate).getId());
datastore.merge(aggregate);
return aggregate;
}

}