数据库数据一键上传到solr索引库工具类

@Component
public class SolrUtil {

    @Autowired
    private TbItemMapper itemMapper;

    @Autowired
    private SolrTemplate solrTemplate;
    
    public void importItemList(){

        TbItemExample example = new TbItemExample();
        TbItemExample.Criteria criteria = example.createCriteria();
        criteria.andStatusEqualTo("1");//审核通过的商品才能存入solr索引库
        List<TbItem> itemList = itemMapper.selectByExample(example);
        System.out.println("--商品列表--");
        for (TbItem item : itemList) {
            System.out.println(item.getId()+"::"+
                    item.getTitle()+"::"+item.getBrand()+"::"+
                    item.getPrice()+"::"+item.getCategory());

            Map specMap = JSON.parseObject(item.getSpec(), Map.class);
            item.setSpecMap(specMap);
        }
        System.out.println("--结束--");

        solrTemplate.saveBeans(itemList);
        solrTemplate.commit();
    }

    public static void main(String[] args) {
        //不仅要加载本项目下的配置文件, 还要加载添加的jar summer-dao下面的配置文件
        ApplicationContext context =
                new ClassPathXmlApplicationContext
                        ("classpath*:spring/applicationContext*.xml");
        SolrUtil solrUtil = context.getBean("solrUtil", SolrUtil.class);
        solrUtil.importItemList();
    }

}