solr批量操作使用

批量新增操作

   /**
     * 批量新增索引
     * @param allDocList
     * @return
     * @throws IOException
     * @throws SolrServerException
     */
    public static Boolean batchAdd(List<AllDoc> allDocList){
        if(!CollectionUtils.isEmpty(allDocList)){
            try {
                int total = allDocList.size();
                int count=0;
                for (AllDoc allDoc : allDocList) {
                    SolrQuery solrQuery = new SolrQuery();
                    solrQuery.setQuery("content_type_ik:"+allDoc.getType()+" AND content_id_ik:"+allDoc.getContentId()+" AND website_id_ik:" +  allDoc.getWebsiteId());
                    QueryResponse response = client.query(solrQuery);
                    SolrDocumentList documentList = response.getResults();
                    if(documentList == null || documentList.size() == 0) {
                        SolrInputDocument documents = new SolrInputDocument();
                        String id = UUID.randomUUID().toString();
                        documents.addField("id", id);
                        documents.addField("title_ik", allDoc.getTitle());
                        documents.addField("website_id_ik", allDoc.getWebsiteId());
                        documents.addField("content_type_ik", allDoc.getType());
                        documents.addField("content_id_ik", allDoc.getContentId());
                        client.add(documents);
                        ++count;
                    }
                }
                logger.info("添加數據到索引中，總共要添加"+total+"條記錄，實際添加第"+count+"條");
                client.commit();
                logger.info("批量添加數據到索引成功");
            }catch (Exception e){
                logger.error("批量新增索引失敗");
                e.printStackTrace();
                return false;
            }
        }
        return true;
    }

根據條件批量刪除索引

public static boolean deleteAllByQuery(String query){
        try {
            client.deleteByQuery(query);  //刪除所有，把刪除的條件設置為"*:*"就可以了
            client.commit();
            logger.info("索引批量刪除成功");
        } catch (Exception e) {
            logger.error("批量刪除索引失敗");
            e.printStackTrace();
            return false;
        }
        return true;
    }