快速上手:导入删除查询
引入依赖：
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-elasticsearch</artifactId> </dependency>
控制层：
@Autowired private EsProductService esProductService; @ApiOperation(value = "简单搜索：根据关键字,品牌名称或者产品名称,产品编号,副标题搜索(字符串：Text类型最大拆分)") @RequestMapping(value = "/search/keyword", method = RequestMethod.GET) @ResponseBody public CommonResult<CommonPage<EsProduct>> searchKeyword(@RequestParam(required = false) String keyword, @RequestParam(required = false, defaultValue = "0") Integer pageNum, @RequestParam(required = false, defaultValue = "5") Integer pageSize) { Page<EsProduct> esProductPage = esProductService.searchKeyword(keyword, pageNum, pageSize); return CommonResult.success(CommonPage.restPage(esProductPage)); } @ApiOperation(value = "删除索引库") @ApiImplicitParam(name = "indexName", value = "索引库名称", defaultValue = "product", paramType = "query", dataType = "String") @RequestMapping(value = "/deleteAll", method = RequestMethod.GET) @ResponseBody public CommonResult<Object> deleteAll(String indexName) { int i = esProductService.deleteAll(indexName); return CommonResult.success(i); } @ApiOperation(value = "导入所有产品信息数据库中商品到ES") @RequestMapping(value = "/importAll", method = RequestMethod.GET) @ResponseBody public CommonResult<Integer> importAllList() { int count = esProductService.importAll(); return CommonResult.success(count); }
service接口：
public interface EsProductService { /** * 从数据库中导入所有商品到ES */ int importAll(); /** * 根据关键字,品牌名称或者产品名称搜索(字符串：Text类型最大拆分) * @param keyword * @param pageNum * @param pageSize * @return */ Page<EsProduct> searchKeyword(String keyword, Integer pageNum, Integer pageSize); /** * 删除索引库 * @return */ int deleteAll(String indexName); }
业务实现类：
@Service public class EsProductServiceImpl implements EsProductService { private static final Logger LOGGER = LoggerFactory.getLogger(EsProductServiceImpl.class); @Autowired private EsProductDao productDao; @Autowired private EsProductRepository productRepository; @Autowired private ElasticsearchTemplate elasticsearchTemplate; @Override public int importAll() { List<EsProduct> esProductList = productDao.getAllEsProductList(null); Iterable<EsProduct> esProductIterable = productRepository.saveAll(esProductList); Iterator<EsProduct> iterator = esProductIterable.iterator(); int result = 0; while (iterator.hasNext()) { result++; iterator.next(); } return result; } /** * 根据关键字,品牌名称或者产品名称,产品编号搜索(字符串：Text类型最大拆分) * @param keyword * @param pageNum * @param pageSize * @return */ @Override public Page<EsProduct> searchKeyword(String keyword, Integer pageNum, Integer pageSize) { Pageable pageable = PageRequest.of(pageNum, pageSize); return productRepository.findByKeywordsOrProductNameOrBrandNameOrProductSnOrSubTitle(keyword,keyword,keyword,keyword,keyword,pageable); } /** * 删除索引库 * @return */ @Override public int deleteAll(String indexName) { boolean product = elasticsearchTemplate.deleteIndex(indexName); if(product){ return 1; } return 0; } }
EsProductDao接口
public interface EsProductDao { List<EsProduct> getAllEsProductList(@Param("id") Long id); }
EsProductDao.xml
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.macro.mall.search.dao.EsProductDao"> <resultMap id="esProductListMap" type="com.macro.mall.search.domain.EsProduct"> <id column="productId" jdbcType="BIGINT" property="id" /> <result column="productSn" jdbcType="VARCHAR" property="productSn"/> <result column="brandId" jdbcType="BIGINT" property="brandId"/> <result column="brandName" jdbcType="VARCHAR" property="brandName"/> <result column="productCategoryId" jdbcType="BIGINT" property="productCategoryId"/> <result column="productName" jdbcType="VARCHAR" property="productName"/> <result column="sale" jdbcType="BIGINT" property="sale"/> <result column="subTitle" jdbcType="VARCHAR" property="subTitle"/> <result column="price" jdbcType="DECIMAL" property="price"/> <result column="keywords" jdbcType="VARCHAR" property="keywords"/> <association property="productCategorie" columnPrefix="pc" javaType="com.macro.mall.search.domain.EsProductCategory"> <id column="productCategoryId" property="id" jdbcType="BIGINT"/> <result column="productCategoryName" property="productCategoryName" jdbcType="VARCHAR"/> </association> <collection property="attributeList" ofType="com.macro.mall.search.domain.EsProductAttribute" javaType="java.util.ArrayList"> <id column="paProductAttributeId" property="paProductAttributeId" jdbcType="BIGINT"/> <result column="paProductAttributeName" property="paProductAttributeName" jdbcType="VARCHAR"/> <collection property="attributeValues" ofType="com.macro.mall.search.domain.EsProductAttributeValue" javaType="java.util.ArrayList"> <id column="pavProductAttributeValueId" property="pavProductAttributeValueId" jdbcType="BIGINT"/> <result column="pavProductAttributeValue" property="pavProductAttributeValue" jdbcType="VARCHAR"/> </collection> </collection> </resultMap> <select id="getAllEsProductList" resultMap="esProductListMap"> SELECT p.id productId, p.product_sn productSn, p.brand_id brandId, p.brand_name brandName, p.product_category_id productCategoryId, p.name productName, p.sale sale, p.sub_title subTitle, p.price price, p.keywords keywords, pav.id pavProductAttributeValueId, pav.`value` pavProductAttributeValue, pa.id paProductAttributeId, pa.`name` paProductAttributeName, pc.id pcProductCategoryId, pc.`name` pcProductCategoryName FROM pms_product p LEFT JOIN pms_product_attribute_value pav ON p.id = pav.product_id LEFT JOIN pms_product_attribute pa ON pav.product_attribute_id= pa.id LEFT JOIN pms_product_category pc ON p.`product_category_id` = pc.`id` WHERE delete_status = 0 AND publish_status = 1 <if test="id!=null"> and p.id=#{id} </if> </select> </mapper>
EsProductRepository接口
public interface EsProductRepository extends ElasticsearchRepository<EsProduct, Long> { /** * 根据关键字,产品名称，品牌名称,产品编号搜索 * @param keywords * @param productName * @param brandName * @param page * @return */ Page<EsProduct> findByKeywordsOrProductNameOrBrandNameOrProductSnOrSubTitle(String keywords,String productName,String brandName,String productSn,String subTitle,Pageable page); }
EsProduct实体类：
@Document(indexName = "product", type = "productInfo",shards = 2,replicas = 1,refreshInterval = "-1") public class EsProduct implements Serializable { private static final long serialVersionUID = 2372551074091780419L; @Id private Long id; @Field(analyzer = "ik_max_word",type = FieldType.Text) private String productSn; private Long brandId; @Field(analyzer = "ik_max_word",type = FieldType.Text) private String brandName; private Long productCategoryId; @Field(analyzer = "ik_max_word",type = FieldType.Text) private String productName; private Long sale; @Field(analyzer = "ik_max_word",type = FieldType.Text) private String subTitle; private BigDecimal price; @Field(analyzer = "ik_max_word",type = FieldType.Text) private String keywords; private List<EsProductAttribute> attributeList; private EsProductCategory productCategorie; //提供一下get和set方法，我就不写了 }
EsProductAttribute实体类：
EsProductAttribute实体类： pub
EsProductAttributeValue实体类：
public class EsProductAttributeValue implements Serializable { private static final long serialVersionUID = 6713756365860464751L; private Long pavProductAttributeValueId; @Field(analyzer = "ik_max_word",type = FieldType.Text) private String pavProductAttributeValue; //提供get 和set方法 }
测试一下：
删除测试
导入数据到es测试
无条件全部搜索测试
有条件搜索测试
如果启动报错，可以将原来的
@Document(indexName = "search", type = "article",shards = 1,replicas = 0)
改一下索引库的名称
@Document(indexName = "search11", type = "article",shards = 1,replicas = 0)
再次启动删除索引库再重新导入，之后就不会报错了。
