solr单机版整合spring框架 (示例：导入索引)

傷城~ 2022-05-29 03:58 145阅读 0赞

1.mapper文件：

<?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="cn.e3mall.search.mapper.ItemMapper" >
    
        <select id="getItemList" resultType="SearchItem">
            SELECT
                a.id,
                a.title,
                a.sell_point,
                a.price,
                a.image,
                b.`name` category_name
            FROM
                `tb_item` a
            LEFT JOIN tb_item_cat b ON a.cid = b.id
            WHERE a.`status`=1
        </select>
    
    </mapper>

2.创建相应的数据集pojo：

public class SearchItem implements Serializable{ 
        private String id;
        private String title;
        private String sell_point;
        private long price;
        private String image;
        private String category_name;
    }
    
    
    
    public class E3Result { 
    
        // 定义jackson对象
        private static final ObjectMapper MAPPER = new ObjectMapper();
    
        // 响应业务状态
        private Integer status;
    
        // 响应消息
        private String msg;
    
        // 响应中的数据
        private Object data;
    
        public static E3Result build(Integer status, String msg, Object data) {
            return new E3Result(status, msg, data);
        }
    
        public static E3Result ok(Object data) {
            return new E3Result(data);
        }
    
        public static E3Resultok() {
            return new E3Result(null);
        }
    
        public E3Result() {
    
        }
    
        public static E3Resultbuild(Integer status, String msg) {
            return new E3Result(status, msg, null);
        }
    
        public E3Result(Integer status, String msg, Object data) {
            this.status = status;
            this.msg = msg;
            this.data = data;
        }
    
        public E3Result(Object data) {
            this.status = 200;
            this.msg = "OK";
            this.data = data;
        }
    
    // public Boolean isOK() { 
    // return this.status == 200;
    // }
    
        public Integer getStatus() {
            return status;
        }
    
        public void setStatus(Integer status) {
            this.status = status;
        }
    
        public String getMsg() {
            return msg;
        }
    
        public void setMsg(String msg) {
            this.msg = msg;
        }
    
        public Object getData() {
            return data;
        }
    
        public void setData(Object data) {
            this.data = data;
        }
    
        /** * 将json结果集转化为E3Result对象 * * @param jsonData json数据 * @param clazz E3Result中的object类型 * @return */
        public static E3Result formatToPojo(String jsonData, Class<?> clazz) {
            try {
                if (clazz == null) {
                    return MAPPER.readValue(jsonData, TaotaoResult.class);
                }
                JsonNode jsonNode = MAPPER.readTree(jsonData);
                JsonNode data = jsonNode.get("data");
                Object obj = null;
                if (clazz != null) {
                    if (data.isObject()) {
                        obj = MAPPER.readValue(data.traverse(), clazz);
                    } else if (data.isTextual()) {
                        obj = MAPPER.readValue(data.asText(), clazz);
                    }
                }
                return build(jsonNode.get("status").intValue(), jsonNode.get("msg").asText(), obj);
            } catch (Exception e) {
                return null;
            }
        }
    
        /** * 没有object对象的转化 * * @param json * @return */
        public static E3Result format(String json) {
            try {
                return MAPPER.readValue(json, TaotaoResult.class);
            } catch (Exception e) {
                e.printStackTrace();
            }
            return null;
        }
    
        /** * Object是集合转化 * @param jsonData json数据 * @param clazz 集合中的类型 * @return */
        public static E3Result formatToList(String jsonData, Class<?> clazz) {
            try {
                JsonNode jsonNode = MAPPER.readTree(jsonData);
                JsonNode data = jsonNode.get("data");
                Object obj = null;
                if (data.isArray() && data.size() > 0) {
                    obj = MAPPER.readValue(data.traverse(),
                            MAPPER.getTypeFactory().constructCollectionType(List.class, clazz));
                }
                return build(jsonNode.get("status").intValue(), jsonNode.get("msg").asText(), obj);
            } catch (Exception e) {
                return null;
            }
        }
    
    }

3.接口定义：

public interface ItemMapper {
    
        List<SearchItem> getItemList();
    }

4.接口实现类SearchItemServiceImpl：

@Service
    public class SearchItemServiceImpl implements SearchItemService { 
    
        @Autowired
        private ItemMapper itemMapper;
        @Autowired
        private SolrServer solrServer;
    
        /* 将数据导入索引库： E3Result :返回导入是否导入成功的一个实体类， 可用 返回json字符串 代替； */
        @Override
        public E3Result importItmes() {
            try {
                //查询商品列表
                List<SearchItem> itemList = itemMapper.getItemList();
                //导入索引库
                for (SearchItem searchItem : itemList) {
                    //创建文档对象
                    SolrInputDocument document = new SolrInputDocument();
                    //向文档中添加域
                    document.addField("id", searchItem.getId());
                    document.addField("item_title", searchItem.getTitle());
                    document.addField("item_sell_point", searchItem.getSell_point());
                    document.addField("item_price", searchItem.getPrice());
                    document.addField("item_image", searchItem.getImage());
                    document.addField("item_category_name", searchItem.getCategory_name());
                    //写入索引库
                    solrServer.add(document);
                }
                //提交
                solrServer.commit();
                //返回成功
                return E3Result.ok();
    
            } catch (Exception e) {
                e.printStackTrace();
                return E3Result.build(500, "索引导入失败");
            }
        }
    
        /* */
    
    }

5.关于solrserver的配置

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">
    
          
    
        <bean id="httpSolrServer" class="org.apache.solr.client.solrj.impl.HttpSolrServer">
            <constructor-arg index="0" value="http://localhost:8080/solr"/>
        </bean>
    
    </beans>

6.表现层Controller：

@Controller
    public class SearchItemController { 
    
        @Autowired
        private SearchItemService searchItemService;
    
        @RequestMapping("/index/item/import")
        @ResponseBody
        public E3Result impotItemIndex() {
            E3Result result = searchItemService.importItmes();
            return result;
        }
    
    }