Java之品优购课程讲义_day09(4)
2018-09-13 16:39
661 查看
品优购-批量数据导入
3.1 需求分析
编写专门的导入程序,将商品数据导入到 Solr 系统中
3.2 查询商品数据列表3.2.1 工程搭建
(1)创建 pinyougou-solr-util(jar) ,引入 pinyougou-dao 以及 spring 相关依赖
(2)创建 spring 配置文件
内容为:
< context:component-scan base-package="com.pinyougou.solrutil">
</context:component-scan>
代码编写
创建 com.pinyougou.solrutil 包,创建类 SolrUtil ,实现商品数据的查询(已审核商品)
3.1 数据导入 Solr 索引库
3.1.1 实体类
(1)将 demo 工程中添加了@Field 注解的实体类拷贝到 pinyougou-pojo 中
(2)在 pinyougou-pojo 中引入依赖
3.1.1 添加 Solr 配置文件
添加 applicationContext-solr.xml 到 spring 目录
调用模板类导入 solr
修改 pinyougou-solr-util 的 SolrUtil.java
3.4 规格导入动态域
3.4.1 @Dynamic 注 解
修改 TbItem.java ,添加属性
修改 pinyougou-solr-util 的 SolrUtil.java ,引入 fastJSON 依赖
3.1 需求分析
编写专门的导入程序,将商品数据导入到 Solr 系统中
3.2 查询商品数据列表3.2.1 工程搭建
(1)创建 pinyougou-solr-util(jar) ,引入 pinyougou-dao 以及 spring 相关依赖
(2)创建 spring 配置文件
内容为:
< context:component-scan base-package="com.pinyougou.solrutil">
</context:component-scan>
代码编写
创建 com.pinyougou.solrutil 包,创建类 SolrUtil ,实现商品数据的查询(已审核商品)
@Component public class SolrUtil { @Autowired private TbItemMapper itemMapper; /** * 导入商品数据 */ public void importItemData(){ TbItemExample example=new TbItemExample(); Criteria criteria = example.createCriteria(); criteria.andStatusEqualTo("1");//已审核 List<TbItem> itemList = itemMapper.selectByExample(example); System.out.println("===商品列表==="); for(TbItem item:itemList){ System.out.println(item.getTitle()); } System.out.println("===结束==="); } public static void main(String[] args) { ApplicationContext context=new ClassPathXmlApplicationContext("classpath*:spring/applicationContext*.xml"); SolrUtil solrUtil= (SolrUtil) context.getBean("solrUtil"); solrUtil.importItemData(); } }
3.1 数据导入 Solr 索引库
3.1.1 实体类
(1)将 demo 工程中添加了@Field 注解的实体类拷贝到 pinyougou-pojo 中
(2)在 pinyougou-pojo 中引入依赖
<dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-solr</artifactId> <version>1.5.5.RELEASE</version> </dependency>
3.1.1 添加 Solr 配置文件
添加 applicationContext-solr.xml 到 spring 目录
<solr:solr-server id="solrServer" url="http://127.0.0.1:8080/solr" /> <!-- solr 模板,使用 solr 模板可对索引库进行 CRUD 的操作 --> <bean id="solrTemplate" class="org.springframework.data.solr.core.SolrTemplate"> <constructor-arg ref="solrServer" /> </bean>
调用模板类导入 solr
修改 pinyougou-solr-util 的 SolrUtil.java
@Autowired private SolrTemplate solrTemplate; /** * 导入商品数据 */ public void importItemData(){ TbItemExample example=new TbItemExample(); Criteria criteria = example.createCriteria(); criteria.andStatusEqualTo("1");//已审核 List<TbItem> itemList = itemMapper.selectByExample(example); System.out.println("===商品列表==="); for(TbItem item:itemList){ System.out.println(item.getTitle()); } solrTemplate.saveBeans(itemList); solrTemplate.commit(); System.out.println("===结束==="); }
3.4 规格导入动态域
3.4.1 @Dynamic 注 解
修改 TbItem.java ,添加属性
@Dynamic @Field("item_spec_*") private Map<String,String> specMap; public Map<String, String> getSpecMap() { return specMap; } public void setSpecMap(Map<String, String> specMap) { this.specMap = specMap; } 3.4.1 修改导入工具
修改 pinyougou-solr-util 的 SolrUtil.java ,引入 fastJSON 依赖
/** * 导入商品数据 */ public void importItemData(){
TbItemExample example=new TbItemExample(); Criteria criteria = example.createCriteria(); criteria.andStatusEqualTo("1");//已审核 List<TbItem> itemList = itemMapper.selectByExample(example); System.out.println("===商品列表==="); for(TbItem item:itemList){ Map specMap= JSON.parseObject(item.getSpec());//将 spec 字段中的 json 字符 串转换为 map item.setSpecMap(specMap);//给带注解的字段赋值 System.out.println(item.getTitle()); } solrTemplate.saveBeans(itemList); solrTemplate.commit(); System.out.println("===结束==="); }
相关文章推荐
- Java之品优购课程讲义_day09(1)
- Java之品优购课程讲义_day09(2)
- Java之品优购课程讲义_day09(6)
- Java之品优购课程讲义_day08(8)
- Java之品优购课程讲义_day17(6)
- Java之品优购课程讲义_day16(1)
- Java之品优购课程讲义_day16(2)
- Java之品优购课程讲义_day15(5)
- Java之品优购课程讲义_day16(3)
- Java之品优购课程讲义_day18(1)
- Java之品优购课程讲义_day08(5)
- Java之品优购课程讲义_day15(6)
- Java之品优购课程讲义_day16(4)
- Java之品优购课程讲义_day08(6)
- Java之品优购课程讲义_day11(3)
- Java之品优购课程讲义_day15(7)
- Java之品优购课程讲义_day16(5)
- Java之品优购课程讲义_day11(4)