diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/search/SearchResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/search/SearchResource.java index bc0ba88c0a7..eb53ec43dbd 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/search/SearchResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/search/SearchResource.java @@ -409,14 +409,10 @@ public class SearchResource { @Parameter(description = "Search Index name, defaults to table_search_index") @DefaultValue("table_search_index") @QueryParam("index") - String index, - @Parameter(description = "Filter documents by deleted param. By default deleted is false") - @DefaultValue("false") - @QueryParam("deleted") - boolean deleted) + String index) throws IOException { - return searchRepository.searchByField(fieldName, fieldValue, index, deleted); + return searchRepository.searchByField(fieldName, fieldValue, index); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/search/SearchClient.java b/openmetadata-service/src/main/java/org/openmetadata/service/search/SearchClient.java index ff81ddf08dc..7f82ec76b2e 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/search/SearchClient.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/search/SearchClient.java @@ -257,8 +257,7 @@ public interface SearchClient { Response.Status.NOT_IMPLEMENTED, NOT_IMPLEMENTED_ERROR_TYPE, NOT_IMPLEMENTED_METHOD); } - Response searchByField(String fieldName, String fieldValue, String index, Boolean deleted) - throws IOException; + Response searchByField(String fieldName, String fieldValue, String index) throws IOException; Response aggregate(AggregationRequest request) throws IOException; diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/search/SearchRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/search/SearchRepository.java index a45ecafb722..e6ebe5462f8 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/search/SearchRepository.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/search/SearchRepository.java @@ -1160,9 +1160,9 @@ public class SearchRepository { .withIsConnectedVia(isConnectedVia(entityType))); } - public Response searchByField(String fieldName, String fieldValue, String index, Boolean deleted) + public Response searchByField(String fieldName, String fieldValue, String index) throws IOException { - return searchClient.searchByField(fieldName, fieldValue, index, deleted); + return searchClient.searchByField(fieldName, fieldValue, index); } public Response aggregate(AggregationRequest request) throws IOException { diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java b/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java index d1f28802a31..738757584a7 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java @@ -1308,17 +1308,13 @@ public class ElasticSearchClient implements SearchClient { } @Override - public Response searchByField(String fieldName, String fieldValue, String index, Boolean deleted) + public Response searchByField(String fieldName, String fieldValue, String index) throws IOException { es.org.elasticsearch.action.search.SearchRequest searchRequest = new es.org.elasticsearch.action.search.SearchRequest( Entity.getSearchRepository().getIndexOrAliasName(index)); SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); - BoolQueryBuilder query = - QueryBuilders.boolQuery() - .must(QueryBuilders.wildcardQuery(fieldName, fieldValue)) - .filter(QueryBuilders.termQuery("deleted", deleted)); - searchSourceBuilder.query(query); + searchSourceBuilder.query(QueryBuilders.wildcardQuery(fieldName, fieldValue)); searchRequest.source(searchSourceBuilder); String response = client.search(searchRequest, RequestOptions.DEFAULT).toString(); return Response.status(OK).entity(response).build(); diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/search/opensearch/OpenSearchClient.java b/openmetadata-service/src/main/java/org/openmetadata/service/search/opensearch/OpenSearchClient.java index 855264ffa62..2d11473a5de 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/search/opensearch/OpenSearchClient.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/search/opensearch/OpenSearchClient.java @@ -1382,17 +1382,13 @@ public class OpenSearchClient implements SearchClient { } @Override - public Response searchByField(String fieldName, String fieldValue, String index, Boolean deleted) + public Response searchByField(String fieldName, String fieldValue, String index) throws IOException { os.org.opensearch.action.search.SearchRequest searchRequest = new os.org.opensearch.action.search.SearchRequest( Entity.getSearchRepository().getIndexOrAliasName(index)); SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); - BoolQueryBuilder query = - QueryBuilders.boolQuery() - .must(QueryBuilders.wildcardQuery(fieldName, fieldValue)) - .filter(QueryBuilders.termQuery("deleted", deleted)); - searchSourceBuilder.query(query); + searchSourceBuilder.query(QueryBuilders.wildcardQuery(fieldName, fieldValue)); searchRequest.source(searchSourceBuilder); String response = client.search(searchRequest, RequestOptions.DEFAULT).toString(); return Response.status(OK).entity(response).build();