feat: create implementation to duration

Signed-off-by: Otavio Santana <[email protected]>

Author: otaviojava

jnosql-nosql-oracle/src/main/java/org/eclipse/jnosql/databases/oracle/communication/DefaultOracleNoSQLDocumentManager.java

@@ -20,6 +20,7 @@
 import jakarta.json.JsonValue;
 import jakarta.json.bind.Jsonb;
 import oracle.nosql.driver.NoSQLHandle;
+import oracle.nosql.driver.TimeToLive;
 import oracle.nosql.driver.ops.DeleteRequest;
 import oracle.nosql.driver.ops.GetRequest;
 import oracle.nosql.driver.ops.GetResult;
@@ -86,26 +87,17 @@ public String name() {
     @Override
     public DocumentEntity insert(DocumentEntity entity) {
         Objects.requireNonNull(entity, "entity is required");
-        Map<String, Object> entityMap = new HashMap<>(entity.toMap());
-        entityMap.put(ENTITY, entity.name());
-        String id = entity.find(ID).map(Document::get)
-                .map(Object::toString)
-                .orElseGet(() -> UUID.randomUUID().toString());
-
-        MapValue mapValue = new MapValue().put(ORACLE_ID, id).put(ENTITY, entity.name());
-        MapValue contentVal = mapValue.putFromJson("content", jsonB.toJson(entityMap),
-                OPTIONS);
-        PutRequest putRequest = new PutRequest()
-                .setValue(contentVal)
-                .setTableName(name());
-
-        serviceHandle.put(putRequest);
+        put(entity, TimeToLive.DO_NOT_EXPIRE);
         return entity;
     }
 
+
     @Override
     public DocumentEntity insert(DocumentEntity entity, Duration ttl) {
-       throw new UnsupportedOperationException("Oracle NoSQL database does not support TTL");
+       Objects.requireNonNull(entity, "entity is required");
+        Objects.requireNonNull(ttl, "ttl is required");
+        put(entity, TimeToLive.ofHours(ttl.toHours()));
+        return entity;
     }
 
     @Override
@@ -117,7 +109,10 @@ public Iterable<DocumentEntity> insert(Iterable<DocumentEntity> entities) {
 
     @Override
     public Iterable<DocumentEntity> insert(Iterable<DocumentEntity> entities, Duration ttl) {
-        throw new UnsupportedOperationException("Oracle NoSQL database does not support TTL");
+        Objects.requireNonNull(entities, "entities is required");
+        Objects.requireNonNull(ttl, "ttl is required");
+        StreamSupport.stream(entities.spliterator(), false).forEach(d -> insert(d, ttl));
+        return entities;
     }
 
     @Override
@@ -286,4 +281,23 @@ private List<DocumentEntity> executeSQL(String sql, List<FieldValue> params) {
         } while (!queryRequest.isDone());
         return entities;
     }
+
+    private void put(DocumentEntity entity, TimeToLive ttl) {
+        Map<String, Object> entityMap = new HashMap<>(entity.toMap());
+        entityMap.put(ENTITY, entity.name());
+        String id = entity.find(ID).map(Document::get)
+                .map(Object::toString)
+                .orElseGet(() -> UUID.randomUUID().toString());
+
+        MapValue mapValue = new MapValue().put(ORACLE_ID, id).put(ENTITY, entity.name());
+        MapValue contentVal = mapValue.putFromJson("content", jsonB.toJson(entityMap),
+                OPTIONS);
+        PutRequest putRequest = new PutRequest()
+                .setValue(contentVal)
+                .setTTL(ttl)
+                .setTableName(name());
+
+        serviceHandle.put(putRequest);
+    }
+
 }

jnosql-nosql-oracle/src/main/java/org/eclipse/jnosql/databases/oracle/communication/NoSQLHandleConfigConfiguration.java

@@ -20,11 +20,14 @@
 
 import java.util.List;
 import java.util.function.Function;
+import java.util.logging.Logger;
 
 enum NoSQLHandleConfigConfiguration implements Function<Settings, NoSQLHandleConfiguration> {
 
     INSTANCE;
 
+    private static final Logger LOGGER = Logger.getLogger(NoSQLHandleConfigConfiguration.class.getName());
+
     private static final String DEFAULT_HOST = "http://localhost:8080";
     private static final int DEFAULT_TABLE_READ_LIMITS = 25;
     private static final int DEFAULT_TABLE_WRITE_LIMITS = 25;
@@ -40,6 +43,9 @@ public NoSQLHandleConfiguration apply(Settings settings) {
 
         DeploymentType deploymentType = settings.get(OracleNoSQLConfigurations.DEPLOYMENT.get())
                 .map(Object::toString).map(DeploymentType::parse).orElse(DeploymentType.ON_PREMISES);
+
+        LOGGER.info("Connecting to Oracle NoSQL database at " + host + " using " + deploymentType + " deployment type");
+
         NoSQLHandleConfig config = new NoSQLHandleConfig(host);
 
         deploymentType.apply(settings).ifPresent(config::setAuthorizationProvider);