黑马程序员技术交流社区

标题: 【郑州校区】Java之品优购课程讲义_day09（4） [打印本页]

---

作者: 谷粒姐姐    时间: 2018-9-13 16:32
标题: 【郑州校区】Java之品优购课程讲义_day09（4）

.品优购-批量数据导入

3.1 需求分析

编写专门的导入程序，将商品数据导入到 Solr 系统中

3.2 查询商品数据列表3.2.1 工程搭建

（1）创建 pinyougou-solr-util（jar） ,引入 pinyougou-dao        以及 spring 相关依赖

（2）创建 spring 配置文件

内容为：

[AppleScript] 纯文本查看 复制代码

<        context:component-scan        base-package="com.pinyougou.solrutil">

</context:component-scan>

代码编写

创建 com.pinyougou.solrutil 包，创建类 SolrUtil ,实现商品数据的查询(已审核商品)

[AppleScript] 纯文本查看 复制代码

@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 中引入依赖

[AppleScript] 纯文本查看 复制代码

<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 目录

[AppleScript] 纯文本查看 复制代码

<!--  solr 服务器地址 -->



<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

[AppleScript] 纯文本查看 复制代码

@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 ，添加属性

[AppleScript] 纯文本查看 复制代码

@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 依赖

[AppleScript] 纯文本查看 复制代码

/**



* 导入商品数据



*/



public  void  importItemData(){

[AppleScript] 纯文本查看 复制代码

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("===结束===");



}

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2