create delete query wrapper

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

Author: otaviojava

jnosql-couchbase-driver/src/main/java/org/eclipse/jnosql/communication/couchbase/document/DefaultCouchbaseDocumentManager.java

@@ -27,15 +27,19 @@
 import com.couchbase.client.java.search.SearchQuery;
 import com.couchbase.client.java.search.result.SearchResult;
 import com.couchbase.client.java.search.result.SearchRow;
+import jakarta.nosql.Sort;
 import jakarta.nosql.document.Document;
+import jakarta.nosql.document.DocumentCondition;
 import jakarta.nosql.document.DocumentDeleteQuery;
 import jakarta.nosql.document.DocumentEntity;
 import jakarta.nosql.document.DocumentQuery;
 
 import java.time.Duration;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import java.util.Objects;
+import java.util.Optional;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 import java.util.stream.Collectors;
@@ -135,21 +139,13 @@ public Iterable<DocumentEntity> update(Iterable<DocumentEntity> entities) {
     public void delete(DocumentDeleteQuery query) {
         Objects.requireNonNull(query, "query is required");
 
-
         Collection collection = bucket.collection(query.getDocumentCollection());
-
-        QueryConverter.QueryConverterResult delete = QueryConverter.delete(query, database);
-        if (nonNull(delete.getStatement())) {
-            ParameterizedN1qlQuery n1qlQuery = N1qlQuery.parameterized(delete.getStatement(), delete.getParams());
-            bucket.query(n1qlQuery);
-        }
-
-        if (!delete.getKeys().isEmpty()) {
-            delete.getKeys()
-                    .stream()
-                    .map(s -> getPrefix(query.getDocumentCollection(), s))
-                    .forEach(bucket::remove);
-        }
+        DocumentQuery delete = DeleteQueryWrapper.of(query);
+        Stream<DocumentEntity> entities = select(delete);
+        entities.map(d -> d.find(ID_FIELD))
+                .filter(Objects::nonNull)
+                .map(Objects::toString)
+                .forEach(collection::remove);
 
     }
 
@@ -209,7 +205,6 @@ public Stream<DocumentEntity> n1qlQuery(String n1ql) throws NullPointerException
     }
 
 
-
     @Override
     public void close() {
     }

jnosql-couchbase-driver/src/main/java/org/eclipse/jnosql/communication/couchbase/document/DeleteQueryWrapper.java

@@ -0,0 +1,53 @@
+package org.eclipse.jnosql.communication.couchbase.document;
+
+import jakarta.nosql.Sort;
+import jakarta.nosql.document.DocumentCondition;
+import jakarta.nosql.document.DocumentDeleteQuery;
+import jakarta.nosql.document.DocumentQuery;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.Optional;
+
+final class DeleteQueryWrapper implements DocumentQuery {
+
+    private final DocumentDeleteQuery query;
+
+    private DeleteQueryWrapper(DocumentDeleteQuery query) {
+        this.query = query;
+    }
+
+    @Override
+    public long getLimit() {
+        return 0;
+    }
+
+    @Override
+    public long getSkip() {
+        return 0;
+    }
+
+    @Override
+    public String getDocumentCollection() {
+        return query.getDocumentCollection();
+    }
+
+    @Override
+    public Optional<DocumentCondition> getCondition() {
+        return this.query.getCondition();
+    }
+
+    @Override
+    public List<Sort> getSorts() {
+        return Collections.emptyList();
+    }
+
+    @Override
+    public List<String> getDocuments() {
+        return Collections.emptyList();
+    }
+
+    static DocumentQuery of(DocumentDeleteQuery query) {
+        return new DeleteQueryWrapper(query);
+    }
+}