remove search query

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

Author: otaviojava

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

@@ -30,8 +30,8 @@ public interface CouchbaseDocumentManager extends DocumentManager {
     /**
      * Executes the N1QL with params and then result que result
      *
-     * @param n1ql the query
-     * @param params    the params
+     * @param n1ql   the query
+     * @param params the params
      * @return the query result
      * @throws NullPointerException when either n1ql or params are null
      */
@@ -47,13 +47,4 @@ public interface CouchbaseDocumentManager extends DocumentManager {
      */
     Stream<DocumentEntity> n1qlQuery(String n1ql) throws NullPointerException;
 
-
-    /**
-     * Searches in Couchbase using Full Text Search
-     *
-     * @param query the query to be used
-     * @return the elements from the query
-     * @throws NullPointerException when either the query or index are null
-     */
-    Stream<DocumentEntity> search(SearchQuery query) throws NullPointerException;
 }

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

@@ -25,6 +25,8 @@
 import com.couchbase.client.java.query.QueryOptions;
 import com.couchbase.client.java.query.QueryResult;
 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.document.Document;
 import jakarta.nosql.document.DocumentDeleteQuery;
 import jakarta.nosql.document.DocumentEntity;
@@ -136,18 +138,18 @@ public void delete(DocumentDeleteQuery query) {
 
         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);
-//        }
+        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);
+        }
 
     }
 
@@ -207,12 +209,6 @@ public Stream<DocumentEntity> n1qlQuery(String n1ql) throws NullPointerException
     }
 
 
-    @Override
-    public Stream<DocumentEntity> search(SearchQuery query) throws NullPointerException {
-        requireNonNull(query, "query is required");
-
-        return null;
-    }
 
     @Override
     public void close() {