Skip to content

Commit

Permalink
feat: update keyvlaue api
Browse files Browse the repository at this point in the history
Signed-off-by: Otavio Santana <otaviopolianasantana@gmail.com>
  • Loading branch information
otaviojava committed Mar 11, 2024
1 parent 52aaf32 commit c24e04f
Show file tree
Hide file tree
Showing 16 changed files with 29 additions and 17 deletions.
Expand Up @@ -18,7 +18,6 @@
import jakarta.data.exceptions.NonUniqueResultException;
import org.eclipse.jnosql.mapping.PreparedStatement;
import jakarta.nosql.QueryMapper;
import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.communication.Value;
import org.eclipse.jnosql.communication.keyvalue.BucketManager;
import org.eclipse.jnosql.communication.keyvalue.KeyValueEntity;
Expand Down
@@ -1,3 +1,17 @@
/*
* Copyright (c) 2024 Contributors to the Eclipse Foundation
* 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.eclipse.jnosql.mapping.keyvalue;

import jakarta.nosql.Template;
Expand Down Expand Up @@ -56,7 +70,7 @@ public interface KeyValueTemplate extends Template {
*/
default <T> Iterable<T> put(Iterable<T> entities) {
Objects.requireNonNull(entities, "entities is required");
return StreamSupport.stream(entities.spliterator(), false).map(this::put).collect(Collectors.toList());
return StreamSupport.stream(entities.spliterator(), false).map(this::put).toList();
}

/**
Expand All @@ -72,7 +86,7 @@ default <T> Iterable<T> put(Iterable<T> entities) {
default <T> Iterable<T> put(Iterable<T> entities, Duration ttl) {
Objects.requireNonNull(entities, "entities is required");
Objects.requireNonNull(ttl, "ttl is required");
return StreamSupport.stream(entities.spliterator(), false).map(d -> put(d, ttl)).collect(toList());
return StreamSupport.stream(entities.spliterator(), false).map(d -> put(d, ttl)).toList();
}

/**
Expand Down
Expand Up @@ -17,7 +17,6 @@
import jakarta.enterprise.context.ApplicationScoped;
import jakarta.enterprise.inject.Vetoed;
import jakarta.inject.Inject;
import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.communication.keyvalue.BucketManager;

import java.util.Objects;
Expand Down
Expand Up @@ -15,7 +15,7 @@
package org.eclipse.jnosql.mapping.keyvalue.query;


import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.core.query.AbstractRepository;

/**
Expand Down
Expand Up @@ -14,7 +14,7 @@
*/
package org.eclipse.jnosql.mapping.keyvalue.query;

import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.core.query.AbstractRepositoryProxy;
import org.eclipse.jnosql.mapping.core.repository.DynamicQueryMethodReturn;

Expand Down
Expand Up @@ -15,7 +15,7 @@
package org.eclipse.jnosql.mapping.keyvalue.query;


import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.metadata.EntityMetadata;

import java.util.Objects;
Expand Down
Expand Up @@ -18,7 +18,7 @@
import jakarta.data.repository.BasicRepository;
import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;
import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.communication.keyvalue.BucketManager;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplateProducer;
import org.eclipse.jnosql.mapping.metadata.EntitiesMetadata;
Expand Down
Expand Up @@ -15,7 +15,7 @@
package org.eclipse.jnosql.mapping.keyvalue.query;


import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.core.query.AbstractRepository;
import org.eclipse.jnosql.mapping.metadata.EntitiesMetadata;
import org.eclipse.jnosql.mapping.metadata.EntityMetadata;
Expand Down
Expand Up @@ -16,7 +16,7 @@

import jakarta.data.repository.CrudRepository;
import jakarta.enterprise.context.spi.CreationalContext;
import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.DatabaseQualifier;
import org.eclipse.jnosql.mapping.DatabaseType;
import org.eclipse.jnosql.mapping.metadata.EntitiesMetadata;
Expand Down
Expand Up @@ -16,7 +16,7 @@


import jakarta.enterprise.context.spi.CreationalContext;
import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.communication.keyvalue.BucketManager;
import org.eclipse.jnosql.mapping.DatabaseQualifier;
import org.eclipse.jnosql.mapping.DatabaseType;
Expand Down
Expand Up @@ -18,7 +18,7 @@
import jakarta.enterprise.inject.Instance;
import jakarta.inject.Inject;
import org.eclipse.jnosql.mapping.PreparedStatement;
import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.communication.Value;
import org.eclipse.jnosql.communication.keyvalue.BucketManager;
import org.eclipse.jnosql.communication.keyvalue.KeyValueEntity;
Expand Down
Expand Up @@ -15,7 +15,7 @@
package org.eclipse.jnosql.mapping.keyvalue;

import jakarta.inject.Inject;
import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.communication.keyvalue.BucketManager;
import org.eclipse.jnosql.mapping.core.Converters;
import org.eclipse.jnosql.mapping.keyvalue.spi.KeyValueExtension;
Expand Down
Expand Up @@ -14,7 +14,7 @@
*/
package org.eclipse.jnosql.mapping.keyvalue.query;

import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.metadata.EntityMetadata;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
Expand Down
Expand Up @@ -15,7 +15,7 @@
package org.eclipse.jnosql.mapping.keyvalue.query;

import jakarta.inject.Inject;
import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.communication.keyvalue.BucketManager;
import org.eclipse.jnosql.mapping.core.Converters;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueEntityConverter;
Expand Down
Expand Up @@ -24,7 +24,7 @@
import jakarta.data.repository.Update;
import jakarta.inject.Inject;
import org.eclipse.jnosql.mapping.PreparedStatement;
import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.assertj.core.api.SoftAssertions;
import org.eclipse.jnosql.mapping.NoSQLRepository;
import org.eclipse.jnosql.mapping.core.Converters;
Expand Down
Expand Up @@ -15,7 +15,7 @@
package org.eclipse.jnosql.mapping.keyvalue.spi;

import jakarta.inject.Inject;
import jakarta.nosql.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.keyvalue.KeyValueTemplate;
import org.eclipse.jnosql.mapping.core.Converters;
import org.eclipse.jnosql.mapping.Database;
import org.eclipse.jnosql.mapping.DatabaseType;
Expand Down

0 comments on commit c24e04f

Please sign in to comment.