A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

本帖最后由 谷粒姐姐 于 2018-9-13 16:34 编辑

.品优购-批量数据导入
3.1 需求分析
编写专门的导入程序,将商品数据导入到 Solr 系统中
3.2 查询商品数据列表3.2.1 工程搭建
(1)创建 pinyougou-solr-util(jar) ,引入 pinyougou-dao        以及 spring 相关依赖
(2)创建 spring 配置文件
图片1.png

内容为:
[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("===结束===");

}

0 个回复

您需要登录后才可以回帖 登录 | 加入黑马