From fe7cf8b63f2aa52840ccf379cb4108af587edbe4 Mon Sep 17 00:00:00 2001 From: ovo Date: Mon, 9 Dec 2024 23:01:22 +0800 Subject: [PATCH] feat(es): --- .../backend/controller/DemoController.java | 32 ++++++++++++++----- 1 file changed, 24 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/guwan/backend/controller/DemoController.java b/src/main/java/com/guwan/backend/controller/DemoController.java index 00b888a..b2458ab 100644 --- a/src/main/java/com/guwan/backend/controller/DemoController.java +++ b/src/main/java/com/guwan/backend/controller/DemoController.java @@ -19,6 +19,8 @@ import io.minio.GetObjectArgs; import io.minio.MinioClient; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; + +import org.elasticsearch.action.search.SearchResponse; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.GetMapping; @@ -202,14 +204,28 @@ public class DemoController { - @GetMapping("demo222") - public Result demo222() { - System.out.println("111111111111"+productEsMapper.search(new LambdaEsQueryWrapper() - .eq(ProductDocument::getPrice, 8999))); - - System.out.println(productEsMapper.search(new LambdaEsQueryWrapper() - .eq(ProductDocument::getPrice, 8999)).getHits().getHits()); - + @GetMapping("demo333") + public Result demo333() { + // 执行ES查询并格式化打印结果 + LambdaEsQueryWrapper wrapper = new LambdaEsQueryWrapper<>(); + wrapper.eq(ProductDocument::getPrice, 8999); + + List products = productEsMapper.selectList(wrapper); + + System.out.println("\n=== ES查询结果 ==="); + if (products.isEmpty()) { + System.out.println("未找到匹配的文档"); + } else { + products.forEach(product -> { + System.out.println("\n商品ID: " + product.getId()); + System.out.println("商品名称: " + product.getName()); + System.out.println("商品价格: " + product.getPrice()); + System.out.println("商品分类: " + product.getCategory()); + System.out.println("商品描述: " + product.getDescription()); + System.out.println("------------------------"); + }); + } + return Result.success("demo222"); }