46分布式电商项目 - 批量导入商品数据到solr索引库

代码已上传至GitHub
地址：https://github.com/ylw-github/pingyougou.git
版本：279050cd76aa2ba9b6e45201b12dce926e2da82f

具体的工程搭建不讲解，工程截图如下：

SolrUtils完整工具类：

package com.pyg.solr.utils;

import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.data.solr.core.SolrTemplate;
import org.springframework.stereotype.Component;

import com.alibaba.fastjson.JSON;
import com.pyg.mapper.TbItemMapper;
import com.pyg.pojo.TbItem;
import com.pyg.pojo.TbItemExample;
import com.pyg.pojo.TbItemExample.Criteria;

@Component
public class SolrUtils {

	// 注入商品mapper接口代理对象
	@Autowired
	private TbItemMapper itemMapper;
	
	//注入solr模版对象
	@Autowired
	private SolrTemplate solrTemplate;

	/**
	 * 需求:查询数据库数据,把数据导入索引库
	 * 
	 * @param args
	 */
	public void importData() {
		// 创建example对象
		TbItemExample example = new TbItemExample();
		// 设置参数:必须是已审核商品
		Criteria createCriteria = example.createCriteria();
		// 设置查询参数
		createCriteria.andStatusEqualTo("1");
		// 查询数据库
		List<TbItem> list = itemMapper.selectByExample(example);
		
		//导入规格数据
		//循环集合,获取规格
		for (TbItem tbItem : list) {
			String spec = tbItem.getSpec();
			//转换成map对象
			Map<String, String> specMap = (Map<String, String>) JSON.parse(spec);
			//把值添加动态域
			tbItem.setSpecMap(specMap);
		}
		
		//添加索引库
		solrTemplate.saveBeans(list);

		//提交
		solrTemplate.commit();

	}
	// java -jar xx.jar
	public static void main(String[] args) {
		// 加载spring配置文件
		ApplicationContext app = new ClassPathXmlApplicationContext(
				"classpath*:spring/*.xml");
		//获取SolrUtils对象
		SolrUtils solrUtils = app.getBean(SolrUtils.class);
		//调用导入索引库方法
		solrUtils.importData();
	}

}

2）修改 TbItem.java ，添加属性

package com.pyg.pojo;

import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
import java.util.Map;

import javax.xml.ws.FaultAction;

import org.apache.solr.client.solrj.beans.Field;
import org.springframework.data.solr.core.mapping.Dynamic;

public class TbItem implements Serializable{
    /**
	 * 
	 */
	private static final long serialVersionUID = -4730788370859047528L;
	@Field
	private Long id;
	@Field("item_title")
    private String title;
	
    private String sellPoint;
    @Field("item_price")
    private BigDecimal price;

    private Integer stockCount;

    private Integer num;

    private String barcode;
    @Field("item_image")
    private String image;
   
    
    @Field("item_goodsid")
    private Long goodsId;

    @Field("item_category")
    private String category;
    
    @Field("item_brand")
    private String brand;

    private String spec;
    
    @Field("item_seller")
    private String seller;
    
    //定义一个map,用来封装动态域: 规格数据
    @Dynamic
    @Field("item_spec_*")
    private Map<String, String> specMap;
        
	  getter ...
	  setter ...

运行SolrUtils工具类，然后登录solr 的web查看

数据导入成功