Skip to content

Commit

Permalink
updates api
Browse files Browse the repository at this point in the history
  • Loading branch information
otaviojava committed Sep 9, 2019
1 parent 89bd70a commit adb979a
Show file tree
Hide file tree
Showing 10 changed files with 29 additions and 28 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,7 @@ public <K> Iterable<Value> get(Iterable<K> keys) {
}

@Override
public <K> void remove(K key) {
public <K> void delete(K key) {
requireNonNull(key, "key is required");
try {
bucket.remove(key.toString());
Expand All @@ -139,9 +139,9 @@ public <K> void remove(K key) {
}

@Override
public <K> void remove(Iterable<K> keys) {
public <K> void delete(Iterable<K> keys) {
requireNonNull(keys, "keys is required");
keys.forEach(this::remove);
keys.forEach(this::delete);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -65,8 +65,8 @@ public static void afterClass() {
CouchbaseKeyValueConfiguration configuration = CouchbaseKeyValueTcConfiguration.getTcConfiguration();
BucketManagerFactory keyValueEntityManagerFactory = configuration.get();
BucketManager keyValueEntityManager = keyValueEntityManagerFactory.getBucketManager(CouchbaseUtil.BUCKET_NAME);
keyValueEntityManager.remove(KEY_OTAVIO);
keyValueEntityManager.remove(KEY_SORO);
keyValueEntityManager.delete(KEY_OTAVIO);
keyValueEntityManager.delete(KEY_SORO);
}


Expand Down Expand Up @@ -165,7 +165,7 @@ public void shouldRemoveKey() {

keyValueEntityManager.put(entityOtavio);
assertTrue(keyValueEntityManager.get(KEY_OTAVIO).isPresent());
keyValueEntityManager.remove(KEY_OTAVIO);
keyValueEntityManager.delete(KEY_OTAVIO);
assertFalse(keyValueEntityManager.get(KEY_OTAVIO).isPresent());
}

Expand All @@ -176,7 +176,7 @@ public void shouldRemoveMultiKey() {
List<String> keys = asList(KEY_OTAVIO, KEY_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);
keyValueEntityManager.delete(keys);
Iterable<Value> users = values;
assertEquals(0L, StreamSupport.stream(keyValueEntityManager.get(keys).spliterator(), false).count());
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -106,13 +106,13 @@ public <K> Iterable<Value> get(Iterable<K> keys) throws NullPointerException {
}

@Override
public <K> void remove(K key) throws NullPointerException {
public <K> void delete(K key) throws NullPointerException {
client.deleteItem(DeleteItemRequest.builder().tableName(tableName).key(DynamoDBUtils.createAttributeValues(key)).build());
}

@Override
public <K> void remove(Iterable<K> keys) throws NullPointerException {
keys.forEach(this::remove);
public <K> void delete(Iterable<K> keys) throws NullPointerException {
keys.forEach(this::delete);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ public void shouldMultiGet() {
public void shouldRemoveKey() {
keyValueEntityManager.put(keyValueOtavio);
assertTrue(keyValueEntityManager.get("otavio").isPresent());
keyValueEntityManager.remove("otavio");
keyValueEntityManager.delete("otavio");
assertFalse(keyValueEntityManager.get("otavio").isPresent());
}

Expand All @@ -107,8 +107,9 @@ 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);
assertThat(StreamSupport.stream(values.spliterator(), false).map(value -> value.get(User.class))
.collect(Collectors.toList()), containsInAnyOrder(userOtavio, userSoro));
keyValueEntityManager.delete(keys);
Iterable<Value> users = values;
assertEquals(0L, StreamSupport.stream(keyValueEntityManager.get(keys).spliterator(), false).count());
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -85,13 +85,13 @@ public <K> Iterable<Value> get(Iterable<K> keys) throws NullPointerException {
}

@Override
public <K> void remove(K key) {
public <K> void delete(K key) {
map.remove(key);
}

@Override
public <K> void remove(Iterable<K> keys) {
StreamSupport.stream(keys.spliterator(), false).forEach(this::remove);
public <K> void delete(Iterable<K> keys) {
StreamSupport.stream(keys.spliterator(), false).forEach(this::delete);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -101,7 +101,7 @@ public void shouldRemoveKey() {

keyValueEntityManager.put(keyValueOtavio);
assertTrue(keyValueEntityManager.get("otavio").isPresent());
keyValueEntityManager.remove("otavio");
keyValueEntityManager.delete("otavio");
assertFalse(keyValueEntityManager.get("otavio").isPresent());
}

Expand All @@ -112,7 +112,7 @@ public void shouldRemoveMultiKey() {
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);
keyValueEntityManager.delete(keys);
Iterable<Value> users = values;
assertEquals(0L, StreamSupport.stream(keyValueEntityManager.get(keys).spliterator(), false).count());
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -80,13 +80,13 @@ public <K> Iterable<Value> get(Iterable<K> keys) throws NullPointerException {
}

@Override
public <K> void remove(K key) {
public <K> void delete(K key) {
cache.remove(key);
}

@Override
public <K> void remove(Iterable<K> keys) {
StreamSupport.stream(keys.spliterator(), false).forEach(this::remove);
public <K> void delete(Iterable<K> keys) {
StreamSupport.stream(keys.spliterator(), false).forEach(this::delete);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ public void shouldRemoveKey() {

keyValueEntityManager.put(entityOtavio);
assertTrue(keyValueEntityManager.get("otavio").isPresent());
keyValueEntityManager.remove("otavio");
keyValueEntityManager.delete("otavio");
assertFalse(keyValueEntityManager.get("otavio").isPresent());
}

Expand All @@ -124,7 +124,7 @@ public void shouldRemoveMultiKey() {
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(otavio, soro));
keyValueEntityManager.remove(keys);
keyValueEntityManager.delete(keys);
Iterable<Value> users = values;
assertEquals(0L, StreamSupport.stream(keyValueEntityManager.get(keys).spliterator(), false).count());
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,7 @@ public <K> Iterable<Value> get(Iterable<K> keys) throws NullPointerException {


@Override
public <K> void remove(K key) throws NullPointerException {
public <K> void delete(K key) throws NullPointerException {

DeleteValue deleteValue = createDeleteValue(nameSpace, key);

Expand All @@ -152,8 +152,8 @@ public <K> void remove(K key) throws NullPointerException {
}

@Override
public <K> void remove(Iterable<K> keys) throws NullPointerException {
StreamSupport.stream(keys.spliterator(), false).forEach(this::remove);
public <K> void delete(Iterable<K> keys) throws NullPointerException {
StreamSupport.stream(keys.spliterator(), false).forEach(this::delete);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@ public void shouldRemoveKey() {

keyValueEntityManager.put(keyValueOtavio);
assertTrue(keyValueEntityManager.get("otavio").isPresent());
keyValueEntityManager.remove("otavio");
keyValueEntityManager.delete("otavio");
assertFalse(keyValueEntityManager.get("otavio").isPresent());
}

Expand All @@ -111,7 +111,7 @@ public void shouldRemoveMultiKey() {
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);
keyValueEntityManager.delete(keys);
Iterable<Value> users = values;
assertEquals(0L, StreamSupport.stream(keyValueEntityManager.get(keys).spliterator(), false).count());
}
Expand Down

0 comments on commit adb979a

Please sign in to comment.