本帖最后由 谷粒姐姐 于 2018-9-13 16:34 编辑
.品优购-批量数据导入 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.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;
}修改 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("===结束===");
} | 
收藏
淘帖
踩
