diff --git a/README.md b/README.md index fc1c46f50..1bbaf3443 100644 --- a/README.md +++ b/README.md @@ -132,8 +132,9 @@ Searching entities using Elasticsearch Template @Autowired private ElasticsearchTemplate elasticsearchTemplate; - SearchQuery searchQuery = new SearchQuery(); - searchQuery.setElasticsearchQuery(fieldQuery("id", documentId)); + SearchQuery searchQuery = new NativeSearchQueryBuilder() + .withQuery(fieldQuery("id", documentId)) + .build(); Page sampleEntities = elasticsearchTemplate.queryForPage(searchQuery,SampleEntity.class); ``` diff --git a/src/docbkx/reference/elasticsearch-misc.xml b/src/docbkx/reference/elasticsearch-misc.xml index 44c6257c7..a5c3f935a 100644 --- a/src/docbkx/reference/elasticsearch-misc.xml +++ b/src/docbkx/reference/elasticsearch-misc.xml @@ -23,9 +23,10 @@ private ElasticsearchTemplate elasticsearchTemplate; -SearchQuery searchQuery = new SearchQuery(); -searchQuery.setElasticsearchQuery(matchAllQuery()); -searchQuery.setElasticsearchFilter(boolFilter().must(termFilter("id", documentId))); +SearchQuery searchQuery = new NativeSearchQueryBuilder() +.withQuery(matchAllQuery()) +.withFilter(boolFilter().must(termFilter("id", documentId))) +.build(); Page<SampleEntity> sampleEntities = elasticsearchTemplate.queryForPage(searchQuery,SampleEntity.class); @@ -42,41 +43,41 @@ Page<SampleEntity> sampleEntities = elasticsearchTemplate.queryForPage(sea Using Scan and Scroll - SearchQuery searchQuery = new SearchQuery(); - searchQuery.addIndices("test-index"); - searchQuery.addTypes("test-type"); - searchQuery.setElasticsearchQuery(matchAllQuery()); - searchQuery.setPageable(new PageRequest(0,1)); - String scrollId = elasticsearchTemplate.scan(searchQuery,1000,false); - List<SampleEntity> sampleEntities = new ArrayList<SampleEntity>(); - boolean hasRecords = true; - while (hasRecords){ - Page<SampleEntity> page = elasticsearchTemplate.scroll(scrollId, 5000L , new ResultsMapper<SampleEntity>() { - @Override - public Page<SampleEntity> mapResults(SearchResponse response) { - List<SampleEntity> chunk = new ArrayList<SampleEntity>(); - for(SearchHit searchHit : response.getHits()){ - if(response.getHits().getHits().length <= 0) { - return null; - } - SampleEntity user = new SampleEntity(); - user.setId(searchHit.getId()); - user.setMessage((String)searchHit.getSource().get("message")); - chunk.add(user); - } - return new PageImpl<SampleEntity>(chunk); - } - - }); - if(page != null) { - sampleEntities.addAll(page.getContent()); - hasRecords = page.hasNextPage(); - } - else{ - hasRecords = false; - } - } - } +SearchQuery searchQuery = new NativeSearchQueryBuilder() +.withQuery(matchAllQuery()) +.withIndices("test-index") +.withTypes("test-type") +.withPageable(new PageRequest(0,1)) +.build(); +String scrollId = elasticsearchTemplate.scan(searchQuery,1000,false); +List<SampleEntity> sampleEntities = new ArrayList<SampleEntity>(); +boolean hasRecords = true; +while (hasRecords){ +Page<SampleEntity> page = elasticsearchTemplate.scroll(scrollId, 5000L , new ResultsMapper<SampleEntity>() { +@Override +public Page<SampleEntity> mapResults(SearchResponse response) { +List<SampleEntity> chunk = new ArrayList<SampleEntity>(); +for(SearchHit searchHit : response.getHits()){ + if(response.getHits().getHits().length <= 0) { + return null; + } + SampleEntity user = new SampleEntity(); + user.setId(searchHit.getId()); + user.setMessage((String)searchHit.getSource().get("message")); + chunk.add(user); + } + return new PageImpl<SampleEntity>(chunk); +} + }); + if(page != null) { + sampleEntities.addAll(page.getContent()); + hasRecords = page.hasNextPage(); + } + else{ + hasRecords = false; + } + } +} \ No newline at end of file