全文检索工具：第五章：Spring-data-elasticSearch搜索

快速上手:导入删除查询

引入依赖：

        <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实体类：

public class EsProductAttribute implements Serializable {

    private static final long serialVersionUID = 4965902919813623705L;

    private Long paProductAttributeId;
    @Field(analyzer = "ik_max_word",type = FieldType.Text)
    private String paProductAttributeName;//属性名称


    private List<EsProductAttributeValue> attributeValues;
    //提供get和set方法

}

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)

再次启动删除索引库再重新导入，之后就不会报错了。