黑马程序员技术交流社区

标题: 【郑州校区】品优购电商系统开发 第九章 三 [打印本页]

---

作者: 我是楠楠    时间: 2020-6-4 10:33
标题: 【郑州校区】品优购电商系统开发 第九章 三

【郑州校区】品优购电商系统开发 第九章 三

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

3.2.2 代码编写
创建 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.3 数据导入 Solr 索引库
3.3.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.3.2 添加 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>

3.2.3 调用模板类导入 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.2 修改导入工具
修改 pinyougou-solr-util 的 SolrUtil.java ,引入 fastJSON 依赖

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

/**

* 导入商品数据

*/

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

}

---

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

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