189 8069 5689

solrJ项目开发的示例分析

solrJ项目开发的示例分析，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

“专业、务实、高效、创新、把客户的事当成自己的事”是我们每一个人一直以来坚持追求的企业文化。 成都创新互联是您可以信赖的网站建设服务商、专业的互联网服务提供商! 专注于网站制作、网站建设、软件开发、设计服务业务。我们始终坚持以客户需求为导向，结合用户体验与视觉传达，提供有针对性的项目解决方案，提供专业性的建议，创新互联建站将不断地超越自我，追逐市场，引领市场！

  1. solrJ操作类  SolrService

    package com.youxuepai.res.assistant.service.solr;

import com.youxuepai.res.assistant.dto.solr.BasicQueryParamDTO;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrInputDocument;

/**
 * Interface SolrService ... solr操作教辅资源
 *
 * @author gaobo
 * @group 
 * @date 2019/8/22
 */
public interface SolrService {

  /**
   * solr添加List对象列表
   */
   void saveOrUpdate(List beans, SolrClient client);


  /**
   * solr添加Obj对象
   */
   void saveOrUpdate(T beans, SolrClient client);


  /**
   * 原子更新solr
   * 只根据ID更新部分字段
   * @param bean
   * @param client
   * @param 
   */
   void atmoUpdate(T bean, SolrClient client);
  /**
   * solr根据Id删除对象索引
   * @param id
   * @return
   */
  boolean deleteById(String id,SolrClient client);

  /**
   * 转换javabean对象为查询params.
   *
   * @param bean 添加入solr的实体类
   */
   SolrQuery ConvertQueryParam(T bean);


   SolrInputDocument beanToSolrMap(T bean);



  /**
   * 查询solr数据
   *
   * @param client solr实例
   * @param queryParam 过滤参数bean
   * @param bean 基础查询信息bean
   */
   QueryResponse queryByBean(
      SolrClient client,
      BasicQueryParamDTO queryParam,
      T bean) throws IOException, SolrServerException;

  /**
   * 查询solr数据
   *
   * @param client solr实例
   * @param queryParam 过滤参数bean
   */
   QueryResponse queryByBean(
      SolrClient client,
      BasicQueryParamDTO queryParam
  ) throws IOException, SolrServerException;

  /**
   * 查询solr数据
   *
   * @param client solr实例
   * @param bean 基础查询信息bean
   */
   QueryResponse queryByBean(
      SolrClient client,
      T bean) throws IOException, SolrServerException;
}

  2. solrJ操作类 SolrServiceImpl

    package com.youxuepai.res.assistant.service.solr.impl;

import com.youxuepai.res.assistant.dto.solr.BasicQueryParamDTO;
import com.youxuepai.res.assistant.service.solr.SolrService;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrQuery.ORDER;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.beans.DocumentObjectBinder;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrInputDocument;
import org.apache.solr.common.SolrInputField;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

/**
 * 类 SolrServiceImpl 公共添加solr方法
 *
 * @author gaobo
 * @group 
 * @date 2019/8/22
 */
@Service
public class SolrServiceImpl implements SolrService {

  Logger logger = LoggerFactory.getLogger(SolrServiceImpl.class);

  DocumentObjectBinder binder = new DocumentObjectBinder();

  /**
   * solr添加对象列表
   */
  @Override
  public  void saveOrUpdate(List beans, SolrClient client) {
    for (T bean : beans) {
      saveOrUpdate(bean, client);
    }
    try {
      client.commit();
    } catch (SolrServerException | IOException e) {
      logger.error("保存文档出错," + beans.size(), e);
      throw new RuntimeException(e.getMessage());
    }
  }

  @Override
  public  void saveOrUpdate(T beans, SolrClient client) {
    SolrInputDocument doc = binder.toSolrInputDocument(beans);
    try {
      client.add(doc);
      client.commit();
    } catch (Exception e) {
      logger.error("保存文档出错," + doc.toString(), e);
      throw new RuntimeException(e.getMessage());
    }
  }

  final String PRIMARY_KEY = "assistantResourceId";

  /**
   * 原子更新solr
   * 只根据ID更新部分字段
   * @param bean
   * @param client
   * @param 
   */
  @Override
  public  void atmoUpdate(T bean, SolrClient client) {
    SolrInputDocument doc = beanToSolrMap(bean);
      try {
        client.add(doc);
        client.commit();
      } catch (Exception e) {
        logger.error("保存文档出错," + doc.toString(), e);
        throw new RuntimeException(e.getMessage());
      }
  }


  /**
   * solr根据Id删除对象索引
   * @param id
   * @return
   */
  @Override
  public  boolean deleteById(String id,SolrClient client) {
    try {
      client.deleteById(id);
      client.commit();
    } catch (Exception e) {
      e.printStackTrace();
      return false;
    }
    return true;
  }



  /**
   * 转换javabean对象为查询params.
   *
   * @param bean 添加入solr的实体类
   */
  @Override
  public  SolrQuery ConvertQueryParam(T bean) {
    Map paramMap = beanToMap(bean);
//    添加默认参数
    SolrQuery solrQuery = new SolrQuery();
    paramMap.entrySet().forEach(
        filterMap -> solrQuery.addFilterQuery(filterMap.getKey() + ":" + filterMap.getValue())
    );
    return solrQuery;
  }

  private  Map beanToMap(T bean){
    SolrInputDocument doc = binder.toSolrInputDocument(bean);
    Collection values = doc.values();
    return values.stream()
        .filter(entity -> entity.getValue() != null && !entity.getValue().equals(""))
        .collect(Collectors.toMap(map -> map.getName(), map -> map.getValue()));
  }
  @Override
  public  SolrInputDocument beanToSolrMap(T bean) {
    Map paramMap = beanToMap(bean);

    SolrInputDocument inputDoc = new SolrInputDocument();
    for (String field : paramMap.keySet()) {
      Map fieldMap = new HashMap<>(16);
      if (field.equals(PRIMARY_KEY)) {
        inputDoc.setField(PRIMARY_KEY, paramMap.get(field));
      } else {
        fieldMap.put("set", paramMap.get(field));
        inputDoc.setField(field, fieldMap);
      }
    }
    return inputDoc;
  }

  /**
   * 查询solr数据
   * @param client solr实例
   * @param queryParam 过滤参数bean
   * @param bean 基础查询信息bean
   * @param 
   * @return
   * @throws IOException
   * @throws SolrServerException
   */
  @Override
  public  QueryResponse queryByBean(SolrClient client, BasicQueryParamDTO queryParam, T bean)
      throws IOException, SolrServerException {
    SolrQuery solrQuery = new SolrQuery();
    if (bean != null) {
      solrQuery = this.ConvertQueryParam(bean);
    }
    solrQuery.set("q", "*:*");
    if (queryParam != null) {
      boolean isKeywords = queryParam.getKeywords() != null;
      boolean isPage = queryParam.getPageNo() != null && queryParam.getPageSize() != null;
      boolean isRank = queryParam.getRankParm()!=null;
      // 搜索关键字是否有值
      if (isKeywords) {
        solrQuery.remove("q");
        solrQuery.set("q", "content:" + "*" + queryParam.getKeywords() + "*");
      }
      //是否分页
      if (isPage) {
        solrQuery.setStart((queryParam.getPageNo() - 1) * queryParam.getPageSize());
        solrQuery.setRows(queryParam.getPageSize());
      }
      //是否排序
      if (isRank) {
        if (queryParam.getRankType() != null && queryParam.getRankType() == 1) {
          solrQuery.addSort(queryParam.getRankParm(), SolrQuery.ORDER.desc);
        } else if (queryParam.getRankType() != null && queryParam.getRankType() == 2) {
          solrQuery.addSort(queryParam.getRankParm(), ORDER.asc);
        } else {
          solrQuery.addSort(queryParam.getRankParm(), SolrQuery.ORDER.desc);
        }
      }
    }

    QueryResponse response = client.query(solrQuery);
    return response;
  }

  /**
   * 查询solr数据
   * @param client solr实例
   * @param queryParam 过滤参数bean
   * @param 
   * @return
   * @throws IOException
   * @throws SolrServerException
   */
  @Override
  public  QueryResponse queryByBean(SolrClient client, BasicQueryParamDTO queryParam)
      throws IOException, SolrServerException {
    return this.queryByBean(client, queryParam,null);
  }

  /**
   * 查询solr数据
   * @param client solr实例
   * @param bean 基础查询信息bean
   * @param 
   * @return
   * @throws IOException
   * @throws SolrServerException
   */
  @Override
  public  QueryResponse queryByBean(SolrClient client, T bean)
      throws IOException, SolrServerException {
    return this.queryByBean(client, null, bean);
  }
}

  3. solrClient 对象获取  SolrClientService

    package com.youxuepai.res.assistant.service.solr;

import org.apache.solr.client.solrj.SolrClient;

/**
 * Interface SolrClientService ...
 * 获取solr实例
 * @group 
 * @author gaobo
 * @date 2019/9/5
 */
public interface SolrClientService {

  /**
   * 获取教辅资源solr核心client
   * @return SolrClient
   */
  SolrClient getAssResourceSolrClient();


}

  4. solrClient 对象获取  SolrClientServiceImpl

    package com.youxuepai.res.assistant.service.solr.impl;

import com.youxuepai.res.assistant.common.solr.SolrHandler;
import com.youxuepai.res.assistant.service.solr.SolrClientService;
import org.apache.solr.client.solrj.SolrClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

/**
 * 类 SolrClientServiceImpl
 *  获取solr实例Service
 * @group 
 * @author gaobo
 * @date 2019/8/23
 */
@Service
public class SolrClientServiceImpl implements SolrClientService {

  @Value("${solr.host}")
  private String solrHost;
  @Value("${solr.assistantResourceCoreName}")
  private String assResourceCoreName;

  /**
   * 获取教辅资源solr核心client
   * @return SolrClient
   */
  @Override
  public SolrClient getAssResourceSolrClient() {
    String solrUrl = solrHost + assResourceCoreName;
    SolrHandler instance = SolrHandler.getInstance(solrUrl);
    return instance.getClient();
  }
}

  5. solr操作dto AssistantResource

    package com.youxuepai.res.assistant.entity;

import com.baomidou.mybatisplus.annotation.TableId;
import java.io.Serializable;
import java.util.Date;
import org.apache.solr.client.solrj.beans.Field;

/**
 * 
    
 * 教辅资源 主表
 * 
    
 *
 * @author ${author}
 * @since 2019-08-12
 */
public class AssistantResource implements Serializable {

  private static final long serialVersionUID = 1L;

  @TableId
  @Field("assistantResourceId")
  private String assistantResourceId;

  /**
   * 关联的教辅ID,在教材知识体系中
   */
  @Field("assistantId")
  private Integer assistantId;

  /**
   * 教辅名称,来自教材知识体系中
   */
  @Field("assistantName")
  private String assistantName;

  /**
   * 教辅资源名称，由系统生成
   */
  private String resourceName;

  /**
   * ISBN 格式如 978-7-107-18617-5
   */
  @Field("isbn")
  private String isbn;

  /**
   * 教辅项目编码
   */
  @Field("projectCode")
  private String projectCode;

  /**
   * 教辅品牌ID
   */
  @Field("assistantBrandId")
  private Integer brandId;

  /**
   * 学段ID
   */
  @Field("periodId")
  private Integer periodId;

  /**
   * 科目ID
   */
  @Field("subjectId")
  private Integer subjectId;

  /**
   * 版本ID
   */
  @Field("editionId")
  private Integer editionId;

  /**
   * 学制ID
   */
  @Field("eduSystem")
  private Integer eduSystem;
  /**
   * 封面图url
   */
  @Field("coverUrl")
  private String coverUrl;

  /**
   * 教辅简介
   */
  @Field("introduce")
  private String introduce;

  /**
   * 必选修
   */
  @Field("volumneId")
  private Integer volumneId;
  /**
   * 关联教材目录数量
   */
  @Field("chaptersNum")
  private String chaptersNum;
  /**
   * 年级ID
   */
  @Field("gradeId")
  private Integer gradeId;

  /**
   * 是否删除 0-未删除，1-已删除
   */
  private Integer isDeleted;

  /**
   * 是否添加素材 0-未添加，1-已添加
   */
  @Field("materialStatus")
  private Integer materialStatus;

  /**
   * 素材上传的URL,基目录
   */
  private String materialUrl;

  /**
   * 发布状态
   */
  @Field("publishStatus")
  private Integer publishStatus;

  /**
   * 是否锁定目录,0-未锁定，1-锁定
   */
  private Integer lockStatus;

  /**
   * 是否导入源文件,0-未导入，1-已导入
   */
  @Field("importSourceStatus")
  private Integer importSourceStatus;

  /**
   * 是否导入资源zip包,0-未导入，1-已导入
   */
  @Field("importZipStatus")
  private Integer importZipStatus;

  /**
   * 是否生成资源zip包,0-未生成，1-已生成
   */
  @Field("generateZipStatus")
  private Integer generateZipStatus;
  @Field("created")
  private Date created;

  private String createdBy;
  @Field("updated")
  private Date updated;

  private String updatedBy;


  public String getAssistantResourceId() {
    return assistantResourceId;
  }

  public void setAssistantResourceId(String assistantResourceId) {
    this.assistantResourceId = assistantResourceId;
  }

  public Integer getAssistantId() {
    return assistantId;
  }

  public void setAssistantId(Integer assistantId) {
    this.assistantId = assistantId;
  }

  public String getAssistantName() {
    return assistantName;
  }

  public void setAssistantName(String assistantName) {
    this.assistantName = assistantName;
  }

  public String getResourceName() {
    return resourceName;
  }

  public void setResourceName(String resourceName) {
    this.resourceName = resourceName;
  }

  public String getIsbn() {
    return isbn;
  }

  public void setIsbn(String isbn) {
    this.isbn = isbn;
  }

  public String getProjectCode() {
    return projectCode;
  }

  public void setProjectCode(String projectCode) {
    this.projectCode = projectCode;
  }

  public Integer getBrandId() {
    return brandId;
  }

  public void setBrandId(Integer brandId) {
    this.brandId = brandId;
  }

  public Integer getPeriodId() {
    return periodId;
  }

  public void setPeriodId(Integer periodId) {
    this.periodId = periodId;
  }

  public Integer getSubjectId() {
    return subjectId;
  }

  public void setSubjectId(Integer subjectId) {
    this.subjectId = subjectId;
  }

  public Integer getEditionId() {
    return editionId;
  }

  public void setEditionId(Integer editionId) {
    this.editionId = editionId;
  }

  public Integer getEduSystem() {
    return eduSystem;
  }

  public void setEduSystem(Integer eduSystem) {
    this.eduSystem = eduSystem;
  }

  public String getCoverUrl() {
    return coverUrl;
  }

  public void setCoverUrl(String coverUrl) {
    this.coverUrl = coverUrl;
  }

  public String getIntroduce() {
    return introduce;
  }

  public void setIntroduce(String introduce) {
    this.introduce = introduce;
  }

  public Integer getVolumneId() {
    return volumneId;
  }

  public void setVolumneId(Integer volumneId) {
    this.volumneId = volumneId;
  }

  public String getChaptersNum() {
    return chaptersNum;
  }

  public void setChaptersNum(String chaptersNum) {
    this.chaptersNum = chaptersNum;
  }

  public Integer getGradeId() {
    return gradeId;
  }

  public void setGradeId(Integer gradeId) {
    this.gradeId = gradeId;
  }

  public Integer getIsDeleted() {
    return isDeleted;
  }

  public void setIsDeleted(Integer isDeleted) {
    this.isDeleted = isDeleted;
  }

  public Integer getMaterialStatus() {
    return materialStatus;
  }

  public void setMaterialStatus(Integer materialStatus) {
    this.materialStatus = materialStatus;
  }

  public String getMaterialUrl() {
    return materialUrl;
  }

  public void setMaterialUrl(String materialUrl) {
    this.materialUrl = materialUrl;
  }

  public Integer getPublishStatus() {
    return publishStatus;
  }

  public void setPublishStatus(Integer publishStatus) {
    this.publishStatus = publishStatus;
  }

  public Integer getLockStatus() {
    return lockStatus;
  }

  public void setLockStatus(Integer lockStatus) {
    this.lockStatus = lockStatus;
  }

  public Integer getImportSourceStatus() {
    return importSourceStatus;
  }

  public void setImportSourceStatus(Integer importSourceStatus) {
    this.importSourceStatus = importSourceStatus;
  }

  public Integer getImportZipStatus() {
    return importZipStatus;
  }

  public void setImportZipStatus(Integer importZipStatus) {
    this.importZipStatus = importZipStatus;
  }

  public Integer getGenerateZipStatus() {
    return generateZipStatus;
  }

  public void setGenerateZipStatus(Integer generateZipStatus) {
    this.generateZipStatus = generateZipStatus;
  }

  public Date getCreated() {
    return created;
  }

  public void setCreated(Date created) {
    this.created = created;
  }

  public String getCreatedBy() {
    return createdBy;
  }

  public void setCreatedBy(String createdBy) {
    this.createdBy = createdBy;
  }

  public Date getUpdated() {
    return updated;
  }

  public void setUpdated(Date updated) {

    this.updated = updated;
  }

  public String getUpdatedBy() {
    return updatedBy;
  }

  public void setUpdatedBy(String updatedBy) {
    this.updatedBy = updatedBy;
  }

  @Override
  public String toString() {
    return "AssistantResource{" +
        "assistantResourceId='" + assistantResourceId + '\'' +
        ", assistantId=" + assistantId +
        ", assistantName='" + assistantName + '\'' +
        ", resourceName='" + resourceName + '\'' +
        ", isbn='" + isbn + '\'' +
        ", projectCode='" + projectCode + '\'' +
        ", brandId=" + brandId +
        ", periodId=" + periodId +
        ", subjectId=" + subjectId +
        ", editionId=" + editionId +
        ", eduSystem=" + eduSystem +
        ", coverUrl='" + coverUrl + '\'' +
        ", introduce='" + introduce + '\'' +
        ", volumneId=" + volumneId +
        ", chaptersNum='" + chaptersNum + '\'' +
        ", gradeId=" + gradeId +
        ", isDeleted=" + isDeleted +
        ", materialStatus=" + materialStatus +
        ", materialUrl='" + materialUrl + '\'' +
        ", publishStatus=" + publishStatus +
        ", lockStatus=" + lockStatus +
        ", importSourceStatus=" + importSourceStatus +
        ", importZipStatus=" + importZipStatus +
        ", generateZipStatus=" + generateZipStatus +
        ", created=" + created +
        ", createdBy='" + createdBy + '\'' +
        ", updated=" + updated +
        ", updatedBy='" + updatedBy + '\'' +
        '}';
  }
}

     

看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注创新互联行业资讯频道，感谢您对创新互联的支持。


文章名称：solrJ项目开发的示例分析
文章URL：http://cdxtjz.cn/article/jccsds.html

其他资讯