java应用服务器_Java应用服务器如何学习SolrDay26

bin&＃xff1a;solr的运行脚本
contrib&＃xff1a;solr的一些扩展jar包&＃xff0c;用于增强solr的功能。
dist&＃xff1a;该目录包含build过程中产生的war和jar文件&＃xff0c;以及相关的依赖文件。
docs&＃xff1a;solr的API文档
example&＃xff1a;solr工程的例子目录&＃xff1a;
licenses&＃xff1a;solr相关的一些许可信息

SolrJ核心包 /solr-4.10.3/dist/solr-solrj-4.10.3.jar
SolrJ依赖包 /solr-4.10.3/dist/solrj-lib下的所有包
日志依赖包 /solr-4.10.3/example/lib/ext目录下的所有jar包
JDBC驱动包 mysql-connector-java-5.1.10-bin.jar

public class Product {
private Integer pid;
private String name;
private String catalog_name;
private double price;
private String description;
private String picture;
// 补全get、set方法
}

package cn.gzsxt.solr.dao;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import cn.gzsxt.solr.pojo.Product;
public class ProductDao {
private Connection connection;
private PreparedStatement pst;
private ResultSet rs;/*** 采集数据&＃xff0c;查询所有商品* &＃64;return*/
public List getAllProducts() {List products &＃61; new ArrayList<>();
try {//1、加载驱动Class.forName("com.mysql.jdbc.Driver");//2、获取Connection连接connection &＃61; DriverManager.getConnection("jdbc:mysql://localhost:3306/solr", "root", "gzsxt");//3、获取PreparedStatement,执行预编译pst &＃61; connection.prepareStatement("select pid,name, catalog_name,price,description,picture from products");//4、执行sql搜索rs &＃61; pst.executeQuery();Product p &＃61; null;
while(rs.next()){p &＃61; new Product();p.setPid(rs.getInt("pid"));p.setName(rs.getString("name"));p.setPrice(rs.getFloat("price"));p.setPicture(rs.getString("picture"));p.setDescription(rs.getString("description")); p.setCatalog_name(rs.getString("catalog_name"));products.add(p);}} catch (Exception e) {e.printStackTrace();}finally {
if(null!&＃61;rs){
try {rs.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}
if(null!&＃61;pst){
try {pst.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}
if(null!&＃61;connection){
try {connection.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}
return products;}
}

package cn.gzsxt.solr.test;
import org.junit.Test;
import cn.gzsxt.solr.dao.ProductDao;
public class ProductDaoTest {&＃64;Test
public void getAllProducts(){ProductDao dao &＃61; new ProductDao();System.out.println(dao.getAllProducts());}
}

public SolrInputDocument(Map fields){_documentBoost &＃61; 1.0F;_fields &＃61; fields;
}
public void addField(String name, Object value){addField(name, value, 1.0F);
}

name属性&＃xff1a;域的名称
type属性&＃xff1a; 域的类型&＃xff08;标签&＃xff0c;加载了分词器&＃xff0c;指定了分词属性&＃xff09;
indexed属性&＃xff1a;是否索引
stored属性&＃xff1a;是否存储
multiValued属性&＃xff1a;是否支持多个值

name属性&＃xff1a;域类型的名称
class属性&＃xff1a;指定域类型的solr类型。
&＃xff1a;指定分词器。
&＃xff1a;表示在创建索引时&＃xff0c;对域做分词处理。
&＃xff1a;表示在检索索引时&＃xff0c;对域做分词处理。
标签&＃xff1a;指定分词器
标签&＃xff1a;指定过滤器


multiValued&＃61;"false" />






/*** 将采集到的商品数据&＃xff0c;转换成solr文档类型* &＃64;param products* &＃64;return*/
public List getDocuments(List products){List docs &＃61; new ArrayList<>();SolrInputDocument doc &＃61; null;
for (Product product : products) {doc &＃61; new SolrInputDocument();doc.addField("id", product.getPid());doc.addField("product_name", product.getName());doc.addField("product_price", product.getPrice());doc.addField("product_catalog_name", product.getCatalog_name());doc.addField("product_description", product.getDescription());doc.addField("product_picture", product.getPicture());docs.add(doc);}
return docs;}

&＃64;Test
public void createIndex(){// 1、 创建HttpSolrServer对象&＃xff0c;通过它和Solr服务器建立连接。// 参数&＃xff1a;solr服务器的访问地址HttpSolrServer server &＃61; new HttpSolrServer("http://localhost:8080/solr/solrCore0719");// 2、 通过HttpSolrServer对象将SolrInputDocument添加到索引库。ProductDao dao &＃61; new ProductDao();
try {server.add(dao.getDocuments(dao.getAllProducts()));// 3、 提交。server.commit(); System.out.println("创建索引库成功!!!");} catch (SolrServerException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}

&＃64;Test
public void queryIndex() throws Exception {// 创建HttpSolrServer对象&＃xff0c;通过它和Solr服务器建立连接。// 参数&＃xff1a;solr服务器的访问地址HttpSolrServer server &＃61; new HttpSolrServer("http://localhost:8080/solr/solrCore0719");// 创建SolrQuery对象SolrQuery query &＃61; new SolrQuery();// 设置查询条件,参考主界面query.set("q", "*:*");// 调用server的查询方法&＃xff0c;查询索引库QueryResponse response &＃61; server.query(query);// 查询结果SolrDocumentList results &＃61; response.getResults();// 查询结果总数
long cnt &＃61; results.getNumFound();System.out.println("查询结果总数:" &＃43; cnt);System.out.println("--------------------分隔符-------------------");
for (SolrDocument solrDocument : results) {System.out.println("商品id:"&＃43;solrDocument.get("id"));System.out.println("商品名称:"&＃43;solrDocument.get("product_name"));System.out.println("商品价格:"&＃43;solrDocument.get("product_price")); System.out.println("商品类别:"&＃43;solrDocument.get("product_catalog_name"));System.out.println("商品图片:"&＃43;solrDocument.get("product_picture"));System.out.println("----------------------------------------");}}

&＃64;Test
public void queryDynamic(){//1、连接solr服务器HttpSolrServer server &＃61; new HttpSolrServer("http://localhost:8080/solr/solrCore0719");//2、创建查询对象&＃xff0c;封装查询条件SolrQuery query &＃61; new SolrQuery();//设置默认搜索的域query.set("df", "product_name");//参考管理界面中的 "q"标签&＃xff0c;封装查询的关键词query.set("q", "音乐盒");//添加价格过滤query.addFilterQuery("product_price:[10 TO 50]");//添加类别过滤query.addFilterQuery("product_catalog_name:幽默杂货");//设置排序 价格升序query.set("sort","product_price asc");//设置分页信息 第二页 每页10条 start&＃61;(page-1)*pageSizequery.set("start", 10);query.set("rows",10);//设置要查询字段query.set("fl", "id,product_name,product_price");//3、执行查询
try {QueryResponse response &＃61; server.query(query);//获取查询的响应码
int status &＃61; response.getStatus();System.out.println("响应码:"&＃43;status);
if(0&＃61;&＃61;status){SolrDocumentList solrDocumentList &＃61; response.getResults();
long numFound &＃61; solrDocumentList.getNumFound();System.out.println("共查询到"&＃43;numFound&＃43;"条满足条件的数据!");System.out.println("--------------");
for (SolrDocument s : solrDocumentList) {System.out.println("商品的id:"&＃43;s.get("id"));System.out.println("商品的名称:"&＃43;s.get("product_name"));System.out.println("商品的价格:"&＃43;s.get("product_price"));System.out.println("商品的图片:"&＃43;s.get("product_picture"));System.out.println("商品的类别名称:"&＃43;s.get("product_catalog_name"));System.out.println("商品的描述:"&＃43;s.get("product_decsription"));System.out.println("-----------分隔符---------------");}}} catch (SolrServerException e) {e.printStackTrace();}}

class&＃61;"org.apache.solr.handler.dataimport.DataImportHandler">data-config.xml