adding tests cases

Signed-off-by: Breno Pessoa <[email protected]>

Author: brenopessoa

dynamodb-driver/src/test/java/org/jnosql/diana/dynamodb/key/DynamoDBKeyValueConfigurationTest.java

@@ -0,0 +1,23 @@
+package org.jnosql.diana.dynamodb.key;
+
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+
+import org.jnosql.diana.api.key.BucketManagerFactory;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+public class DynamoDBKeyValueConfigurationTest {
+	
+	private DynamoDBKeyValueConfiguration configuration;
+	
+	@BeforeEach
+	public void setUp(){
+		configuration = new DynamoDBKeyValueConfiguration();
+	}
+
+	@Test
+	public void shouldCreateKeyValueFactoryFromFile() {
+		BucketManagerFactory managerFactory = configuration.get();
+		assertNotNull(managerFactory);
+	}
+}

dynamodb-driver/src/test/java/org/jnosql/diana/dynamodb/key/DynamoDBKeyValueEntityManagerTest.java

@@ -0,0 +1,118 @@
+package org.jnosql.diana.dynamodb.key;
+
+import static java.util.Arrays.asList;
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.containsInAnyOrder;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadLocalRandom;
+import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+import java.util.stream.StreamSupport;
+
+import org.jnosql.diana.api.Value;
+import org.jnosql.diana.api.key.BucketManager;
+import org.jnosql.diana.api.key.BucketManagerFactory;
+import org.jnosql.diana.api.key.KeyValueEntity;
+import org.jnosql.diana.dynamodb.DynamoDBTestUtils;
+import org.junit.AfterClass;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+public class DynamoDBKeyValueEntityManagerTest {
+	
+	private BucketManager keyValueEntityManager;
+
+    private BucketManagerFactory keyValueEntityManagerFactory;
+    
+    private DynamoDBKeyValueConfiguration configuration;
+
+    private User userOtavio = new User("otavio");
+    private KeyValueEntity keyValueOtavio = KeyValueEntity.of("otavio", Value.of(userOtavio));
+
+    private User userSoro = new User("soro");
+    private KeyValueEntity keyValueSoro = KeyValueEntity.of("soro", Value.of(userSoro));
+
+    @BeforeEach
+    public void init() {
+        keyValueEntityManagerFactory = DynamoDBTestUtils.get();
+        keyValueEntityManager = keyValueEntityManagerFactory.getBucketManager("users-entity");
+    }
+
+
+    @Test
+    public void shouldPutValue() {
+        keyValueEntityManager.put("otavio", userOtavio);
+        Optional<Value> otavio = keyValueEntityManager.get("otavio");
+        assertTrue(otavio.isPresent());
+        assertEquals(userOtavio, otavio.get().get(User.class));
+    }
+
+    @Test
+    public void shouldPutKeyValue() {
+        keyValueEntityManager.put(keyValueOtavio);
+        Optional<Value> otavio = keyValueEntityManager.get("otavio");
+        assertTrue(otavio.isPresent());
+        assertEquals(userOtavio, otavio.get().get(User.class));
+    }
+
+    @Test
+    public void shouldPutIterableKeyValue() {
+
+
+        keyValueEntityManager.put(asList(keyValueSoro, keyValueOtavio));
+        Optional<Value> otavio = keyValueEntityManager.get("otavio");
+        assertTrue(otavio.isPresent());
+        assertEquals(userOtavio, otavio.get().get(User.class));
+
+        Optional<Value> soro = keyValueEntityManager.get("soro");
+        assertTrue(soro.isPresent());
+        assertEquals(userSoro, soro.get().get(User.class));
+    }
+
+    @Test
+    public void shouldMultiGet() {
+        User user = new User("otavio");
+        KeyValueEntity keyValue = KeyValueEntity.of("otavio", Value.of(user));
+        keyValueEntityManager.put(keyValue);
+        assertNotNull(keyValueEntityManager.get("otavio"));
+
+
+    }
+
+    @Test
+    public void shouldRemoveKey() {
+
+        keyValueEntityManager.put(keyValueOtavio);
+        assertTrue(keyValueEntityManager.get("otavio").isPresent());
+        keyValueEntityManager.remove("otavio");
+        assertFalse(keyValueEntityManager.get("otavio").isPresent());
+    }
+
+    @Test
+    public void shouldRemoveMultiKey() {
+
+        keyValueEntityManager.put(asList(keyValueSoro, keyValueOtavio));
+        List<String> keys = asList("otavio", "soro");
+        Iterable<Value> values = keyValueEntityManager.get(keys);
+        assertThat(StreamSupport.stream(values.spliterator(), false).map(value -> value.get(User.class)).collect(Collectors.toList()), containsInAnyOrder(userOtavio, userSoro));
+        keyValueEntityManager.remove(keys);
+        Iterable<Value> users = values;
+        assertEquals(0L, StreamSupport.stream(keyValueEntityManager.get(keys).spliterator(), false).count());
+    }
+    
+    @AfterAll
+    public static void shutDown() {
+    	DynamoDBTestUtils.shutDown();
+    }
+
+}

dynamodb-driver/src/test/java/org/jnosql/diana/dynamodb/key/User.java

@@ -0,0 +1,64 @@
+/*
+ *  Copyright (c) 2017 Otávio Santana and others
+ *   All rights reserved. This program and the accompanying materials
+ *   are made available under the terms of the Eclipse Public License v1.0
+ *   and Apache License v2.0 which accompanies this distribution.
+ *   The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
+ *   and the Apache License v2.0 is available at http://www.opensource.org/licenses/apache2.0.php.
+ *
+ *   You may elect to redistribute this code under either of these licenses.
+ *
+ *   Contributors:
+ *
+ *   Otavio Santana
+ */
+package org.jnosql.diana.dynamodb.key;
+
+import java.io.Serializable;
+import java.util.Objects;
+
+public class User implements Serializable {
+
+    private String nickName;
+
+    public User(String nickName) {
+        this.nickName = nickName;
+
+    }
+
+    public User() {
+    }
+
+    public void setNickName(String nickName) {
+        this.nickName = nickName;
+    }
+
+    public String getNickName() {
+        return nickName;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) {
+            return true;
+        }
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
+        User user = (User) o;
+        return Objects.equals(nickName, user.nickName);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hashCode(nickName);
+    }
+
+    @Override
+    public String toString() {
+        final StringBuilder sb = new StringBuilder("User{");
+        sb.append("nickName='").append(nickName).append('\'');
+        sb.append('}');
+        return sb.toString();
+    }
+}