<field name="item_title" type="text_ik" indexed="true" stored="true"/>

<field name="item_sell_point" type="text_ik" indexed="true" stored="true"/>

<field name="item_price" type="long" indexed="true" stored="true"/>

<field name="item_image" type="string" indexed="false" stored="true" />

<field name="item_category_name" type="string" indexed="true" stored="true" />

<field name="item_desc" type="text_ik" indexed="true" stored="false" />

 

<field name="item_keywords" type="text_ik" indexed="true" stored="false" multiValued="true"/>

<copyField source="item_title" dest="item_keywords"/>

<copyField source="item_sell_point" dest="item_keywords"/>

<copyField source="item_category_name" dest="item_keywords"/>

<copyField source="item_desc" dest="item_keywords"/>

@Controller
@RequestMapping("/manager")
public class ItemController {
 @Autowired
 private ItemService itemService;
 @RequestMapping("/importall")
 @ResponseBody
 public TaotaoResult importAllItem(){
   TaotaoResult result= itemService.importAllItem();
   return result;
 }
}<br>service层编写：<br>多表查询商品，显示在页面的逻辑编写：<br>mapper.java

package com.taotao.search.mapper;
 
import java.util.List;
 
import com.taotao.search.pojo.Item;
 
public interface ItemMapper {
 List<Item> getItemList();
 
}

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.taotao.search.mapper.ItemMapper">
<select id="getItemList" resultType="com.taotao.search.pojo.Item">
 SELECT
 a.id,
 a.title,
 a.sell_point,
 a.price,
 a.image,
 b. NAME category_name
 FROM
 tb_item a
 LEFT JOIN tb_item_cat b ON a.cid = b.id
</select>
</mapper>

//从索引库里面获取商品信息，现在这个dao层是从索引库获取信息，因为之前的写的逻辑是将db里面的数据导入到索引库。后面的查询都是从索引库中进行，而不从数据库了
@Repository
public class SearchDaoImpl implements SearchDao {
 @Autowired
 private SolrServer solrServer;
 
 @Override
 public SearchResult search(SolrQuery query) throws Exception {
  //这是从索引库里面，直接执行查询
  QueryResponse response = solrServer.query(query);
  //获取查询的结果
  SolrDocumentList documentList= response.getResults();
   
  SearchResult result=new SearchResult();
  //这是获取总记录数
  result.setRecordCount(documentList.getNumFound());
   
  List<Item> itemList=new ArrayList<>();
  //商品的高亮显示，即当鼠标移到字上时，该字体变色，这是从QueryResponse中获取的
  Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();
   
  for (SolrDocument solrDocument : documentList) {
    
   //每个SolrDocument都是一个商品pojo的内容，所以这里要创建一个商品的pojo对象，来获取详细的字段
   Item item=new Item();
   item.setId((String) solrDocument.get("id"));
   //高亮显示是title的高亮显示
   List<String> list = highlighting.get(solrDocument.get("id")).get("item_title");
   String title="";
   if (list!=null && list.size()>0) {
    title=list.get(0); 
   }
   else{
    title=(String) solrDocument.get("item_title"); 
   }
   
   item.setTitle(title);
   item.setPrice((Long) solrDocument.get("item_price"));
   item.setImage((String) solrDocument.get("item_image"));
   item.setCategory_name((String) solrDocument.get(" item_category_name"));
   item.setSell_point((String) solrDocument.get("item_sell_point"));
   itemList.add(item);
  }
   
   result.setItemList(itemList);
  
  return result;
 }
 
}

public class Item {
  private String id;
  private String title;
  private String sell_point;
  private long price;
  private String image;
  private String category_name;
  private String item_des;
 
}

@Controller
public class SearchController {
 @Autowired
 private SearchService searchService;
  
 @RequestMapping(value="/query", method=RequestMethod.GET)
 @ResponseBody
 public TaotaoResult search(@RequestParam("q")String queryString,
   @RequestParam(defaultValue="1")Integer page,
   @RequestParam(defaultValue="60")Integer rows) {
  //查询条件不能为空
  if (StringUtils.isBlank(queryString)) {
   return TaotaoResult.build(400, "查询条件不能为空");
  }
  SearchResult searchResult = null;
  try {
   queryString = new String(queryString.getBytes("iso8859-1"), "utf-8");
   searchResult = searchService.search(queryString, page, rows);
  } catch (Exception e) {
   e.printStackTrace();
   return TaotaoResult.build(500, ExceptionUtil.getStackTrace(e));
  }
  return TaotaoResult.ok(searchResult);
   
 } 
 }<br><br><br>
1
<span style="font-size: 16px">service层：利用solrJ的solrQurery来查询：</span>

@Controller
public class SearchController {
 @Autowired
 private SearchService searchService;
  
 @RequestMapping(value="/query", method=RequestMethod.GET)
 @ResponseBody
 public TaotaoResult search(@RequestParam("q")String queryString,
   @RequestParam(defaultValue="1")Integer page,
   @RequestParam(defaultValue="60")Integer rows) {
  //查询条件不能为空
  if (StringUtils.isBlank(queryString)) {
   return TaotaoResult.build(400, "查询条件不能为空");
  }
  SearchResult searchResult = null;
  try {
   queryString = new String(queryString.getBytes("iso8859-1"), "utf-8");
   searchResult = searchService.search(queryString, page, rows);
  } catch (Exception e) {
   e.printStackTrace();
   return TaotaoResult.build(500, ExceptionUtil.getStackTrace(e));
  }
  return TaotaoResult.ok(searchResult);
   
 } 
 }

@Service
public class SearchServiceImpl implements SearchService {
 @Autowired
 private SearchDao searchDao;
  
 
 @Override
 public SearchResult search(String queryString, int page, int rows) throws Exception {
 SolrQuery query=new SolrQuery();
 query.setQuery(queryString);
 query.setStart((page-1)*rows);
 query.setRows(rows);
 //设置默认的查询搜索域，即默认的查询
 query.set("df","item_keywords");
 //设置高亮显示
 query.setHighlight(true);
  
 query.addHighlightField("item_title");
 query.setHighlightSimplePre("<em style=\"color:red\">");
 query.setHighlightSimplePost("</em>");
//执行查询
 SearchResult searchResult = searchDao.search(query);
 //根据结果来计算商品总共多少页
 long recordCount=searchResult.getRecordCount();
 long pageCount=recordCount/rows;
 if (recordCount % rows > 0) {
  pageCount++; 
 }
 searchResult.setPageCount(pageCount);
 searchResult.setCurPage((long) page);
  
  return searchResult;
 }
 
}

public class SearchController {
 @Autowired
 private SearchService searchService;
  
 @RequestMapping("/search")
 public String search(@RequestParam("q")String queryString, @RequestParam(defaultValue="1")Integer page, Model model) {
  if (queryString != null) {
   try {
    queryString = new String(queryString.getBytes("iso8859-1"), "utf-8");
   } catch (UnsupportedEncodingException e) {
    e.printStackTrace();
   }
  }
  SearchResult searchResult = searchService.search(queryString, page);
  //向页面传递参数
  model.addAttribute("query", queryString);
  //model.addAttribute("totalPages", searchResult.getPageCount());
  model.addAttribute("itemList", searchResult.getItemList());
  model.addAttribute("page", page);
   
  return "search";
   
 }
}

@Service
public class SearchServiceImpl implements SearchService {
  
 @Value("${SEARCH_BASE_URL}")
 private String SEARCH_BASE_URL;
 
 @Override
 public SearchResult search(String queryString, int page) {
  //这里需要的是连接+参数.这里每页显示的记录条数，可以传递也可以不用传递
  // 调用taotao-search的服务
  //查询参数
  Map<String, String> param = new HashMap<>();
  param.put("q", queryString);
  param.put("page", page + "");
  try {
   //调用服务
   String json = HttpClientUtil.doGet(SEARCH_BASE_URL, param);
   //把字符串转换成java对象
   TaotaoResult taotaoResult = TaotaoResult.formatToPojo(json, SearchResult.class);
   SearchResult result = (SearchResult) taotaoResult.getData();
   return result;
  /* if (taotaoResult.getStatus() == 200) {
     
   }*/
    
  } catch (Exception e) {
   e.printStackTrace();
   return null;
  }
  
 }
 
}