Add fuzzy search using ElasticsearchTemplate

Author: kasramp

src/main/java/com/madadipouya/elasticsearch/springdata/example/controller/BookController.java

@@ -41,6 +41,12 @@ public Book getBookByIsbn(@PathVariable String isbn) throws BookNotFoundExceptio
         return bookService.getByIsbn(isbn).orElseThrow(() -> new BookNotFoundException("The given isbn is invalid"));
     }
 
+    @ResponseStatus(HttpStatus.OK)
+    @GetMapping(value = "/query")
+    public List<Book> getBooksByAuthorAndTitle(@RequestParam(value = "title") String title, @RequestParam(value = "author") String author) {
+        return bookService.findByTitleAndAuthor(title, author);
+    }
+
     @ResponseStatus(HttpStatus.OK)
     @PutMapping(value = "/{id}")
     public Book updateBook(@PathVariable String id, @RequestBody BookDto book) throws BookNotFoundException {

src/main/java/com/madadipouya/elasticsearch/springdata/example/service/BookService.java

@@ -15,6 +15,8 @@ public interface BookService {
 
     List<Book> findByAuthor(String authorName);
 
+    List<Book> findByTitleAndAuthor(String title, String author);
+
     Book create(Book book) throws DuplicateIsbnException;
 
     void deleteById(String id);

src/main/java/com/madadipouya/elasticsearch/springdata/example/service/impl/DefaultBookService.java

@@ -1,10 +1,14 @@
 package com.madadipouya.elasticsearch.springdata.example.service.impl;
 
-import com.madadipouya.elasticsearch.springdata.example.service.exception.BookNotFoundException;
 import com.madadipouya.elasticsearch.springdata.example.model.Book;
 import com.madadipouya.elasticsearch.springdata.example.repository.BookRepository;
 import com.madadipouya.elasticsearch.springdata.example.service.BookService;
+import com.madadipouya.elasticsearch.springdata.example.service.exception.BookNotFoundException;
 import com.madadipouya.elasticsearch.springdata.example.service.exception.DuplicateIsbnException;
+import org.elasticsearch.index.query.BoolQueryBuilder;
+import org.elasticsearch.index.query.QueryBuilders;
+import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
+import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
@@ -16,8 +20,11 @@ public class DefaultBookService implements BookService {
 
     private final BookRepository bookRepository;
 
-    public DefaultBookService(BookRepository bookRepository) {
+    private final ElasticsearchTemplate elasticsearchTemplate;
+
+    public DefaultBookService(BookRepository bookRepository, ElasticsearchTemplate elasticsearchTemplate) {
         this.bookRepository = bookRepository;
+        this.elasticsearchTemplate = elasticsearchTemplate;
     }
 
     @Override
@@ -37,6 +44,13 @@ public List<Book> findByAuthor(String authorName) {
         return bookRepository.findByAuthorName(authorName);
     }
 
+    @Override
+    public List<Book> findByTitleAndAuthor(String title, String author) {
+        BoolQueryBuilder criteria = QueryBuilders.boolQuery();
+        criteria.must().addAll(List.of(QueryBuilders.matchQuery("authorName", author), QueryBuilders.matchQuery("title", title)));
+        return elasticsearchTemplate.queryForList(new NativeSearchQueryBuilder().withQuery(criteria).build(), Book.class);
+    }
+
     @Override
     public Book create(Book book) throws DuplicateIsbnException {
         if (getByIsbn(book.getIsbn()).isEmpty()) {