保定专业网站建设公司,快速排名工具免费查询,服务器是什么设备,郑州二七区最新消息1.下载solr 官网#xff1a;http://lucene.apache.org/solr/ 2.目录结构如下 3.启动solr#xff08;默认使用jetty部署#xff09; 在path路径下将 bin文件夹对应的目录加入#xff0c;然后输入 solr start#xff08;或者 solr start -p port#xff0c;指定端口启动http://lucene.apache.org/solr/ 2.目录结构如下 3.启动solr默认使用jetty部署 在path路径下将 bin文件夹对应的目录加入然后输入 solr start或者 solr start -p port指定端口启动。在浏览器中访问如下 当然还可以启动其他样例的服务在example目录下有一个READEME.txt如果感兴趣请看一下。命令格式如下 Solr example
------------This directory contains Solr examples. Each example is contained in a
separate directory. To run a specific example, do:bin/solr -e EXAMPLE where EXAMPLE is one of:cloud : SolrCloud exampledih : Data Import Handler (rdbms, mail, rss, tika)schemaless : Schema-less example (schema is inferred from data during indexing)techproducts : Kitchen sink example providing comprehensive examples of Solr features 4.Individual SolrCore 在server/solr目录下有一个README.txt的文件其中说明了如何建立solr core。最简单的建立是直接复制solr中为我们提供好的例子打开server/solr/configsets目录会发现里面已经有三个例子因为我们是要从数据库导入数据所以复制 “data_driven_schema_configs” 这个例子并改名为 “myCollections”。 5.导入需要的jar包 为了导入数据和链接mysql我们还需要导入两个重要的jar包。由于mysql的jar包并没有在项目中我是复制了一份放到了dist目录下面了。另外两个需要的jar包就是dist目录下带有“dataimport”标识的jar包。 然后打开myCollections/conf/solrconfig.xml引用上面提到的jar包如下。 6.建立数据库 建立好之后随便写入一点儿数据。 7.添加requestHandler 继续修改myCollections/conf/solrconfig.xml搜索 requestHandler name/select classsolr.SearchHandler ,然后在该行之上添加如下代码。 requestHandler name/dataimport classorg.apache.solr.handler.dataimport.DataImportHandler lst namedefaults str nameconfigdata-config.xml/str /lst /requestHandler 8.建立连接配置文件 在myCollections/conf目录下新建data-config.xml, 内容如下。 ?xml version1.0 encodingUTF-8?
dataConfig dataSource namesource1 typeJdbcDataSource drivercom.mysql.jdbc.Driver urljdbc:mysql://localhost:3306/solrdata userroot password123456 batchSize-1 / document entity namegoods pkid dataSourcesource1 queryselect * from goods deltaImportQueryselect * from goods where id${dih.delta.id} deltaQueryselect id from goods where updateTime ${dataimporter.last_index_time} field columnid nameid/ field columnname namename/ field columnnumber namenumber/ field columnupdateTime nameupdateTime/ /entity /document
/dataConfig 说明 dataSource是数据库数据源。Entity就是一张表对应的实体pk是主键query是查询语句。Field对应一个字段column是数据库里的column名后面的name属性对应着Solr的Filed的名字。其中solrdata是数据库名goods是表名。 其中deltaQuery是增量索引原理是从数据库中根据deltaQuery指定的SQL语句查询出所有需要增量导入的数据的ID号。然后根据deltaImportQuery指定的SQL语句返回所有这些ID的数据即为这次增量导入所要处理的数据。核心思想是通过内置变量“${dih.delta.id}”和 “${dataimporter.last_index_time}”来记录本次要索引的id和最近一次索引的时间。 9.managed-schema配置field信息 搜索 field name 添加关联数据库表Column的信息。 注意默认的 filed 不要删除哦 10.添加我们刚刚建立的core (1).点击Core Admin配置我们建立的solr Core的信息如下所示。 (2).点击 Add Core如下所示。 (3).测试索引是否成功 索引成功 (4).监测查询成功 查询成功 11.通过代码调用solr服务 简单建立一个java项目依赖上dist目录下的solr-solrj-6.0.0.jar。 测试代码如下。 import java.lang.reflect.Method;
import java.sql.Timestamp;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrInputDocument;
import com.entity.Good;SuppressWarnings(deprecation)
public class Solr {private static HttpSolrServer solrServer;static {//注意请求地址格式浏览器中的地址有 ‘#’需要把‘#’去掉solrServer new HttpSolrServer(http://localhost:8983/solr/hjz);solrServer.setConnectionTimeout(5000);}/*** 添加单个文档 。* * param article 文章对象* param articleAddon 文章正文对象*/public static void insert(Good good) {SolrInputDocument doc new SolrInputDocument();doc.addField(id, good.getId());doc.addField(name, good.getName());doc.addField(number, good.getNumber());doc.addField(updateTime, good.getUpdateTime());try {solrServer.add(doc);solrServer.commit();} catch (Exception e) {e.printStackTrace();}}/*** 根据文档id删除文档 。*/public static void deleteById(String id) {try {solrServer.deleteById(id);solrServer.commit();} catch (Exception e) {e.printStackTrace();}}/*** 删除所有文档为安全起见使用时再解注函数体 。*/public static void deleteAll() {try {solrServer.deleteByQuery(*:*);solrServer.commit();} catch (Exception e) {e.printStackTrace();}}/*** 更新文档其实也是通过insert操作来完成 。* * param article 文章对象* param articleAddon 文章内容对象如果不更新正文可以为null。*/public static void update(Good good) {insert(good);}/*** 根据文档id查询单个文档 。* return */public static T T getById(int id, ClassT clazz) {SolrQuery query new SolrQuery();query.setQuery(id: id);try {QueryResponse rsp solrServer.query(query);return rsp.getBeans(clazz).get(0);} catch (Exception e) {e.printStackTrace();}return null;} /*** param obj 对象索引* param idName 主键名称*/public static void deleteByObject(Object obj, String idName){try {Class? clazz obj.getClass();//将idName的首字母变成大写if(Character.isLowerCase(idName.charAt(0))) idName Character.toUpperCase(idName.charAt(0)) idName.substring(1);Method method clazz.getMethod(getidName);String idValue (String) method.invoke(obj);deleteById(idValue);} catch (Exception e) {e.printStackTrace();}}public static void main(String[] args){Good good new Good(123, 9999, hjzgg5211314, new Timestamp(System.currentTimeMillis()));//Solr.update(good);//System.out.println(Solr.getById(123, Good.class));deleteByObject(good, id);}
} View Code 对应的实体类。 import java.sql.Timestamp;import org.apache.solr.client.solrj.beans.Field;public class Good{Field(id)private String id;Field(number)private int number;Field(name)private String name;Field(updateTime)private Timestamp updateTime;Overridepublic String toString() {return Good [id id , number number , name name , updateTime updateTime ];}public Good(){}public Good(String id, int number, String name, Timestamp updateTime) {super();this.id id;this.number number;this.name name;this.updateTime updateTime;}public String getId() {return id;}public void setId(String id) {this.id id;}public int getNumber() {return number;}public void setNumber(int number) {this.number number;}public String getName() {return name;}public void setName(String name) {this.name name;}public Timestamp getUpdateTime() {return updateTime;}public void setUpdateTime(Timestamp updateTime) {this.updateTime updateTime;}} View Code 每测试一次可以在浏览器中通过query方式查看测试结果是否正确。 12.参考资料 Solr之搭建Solr6.0服务并从Mysql上导入数据 Solr参考指南 可以下载 转载于:https://www.cnblogs.com/hujunzheng/p/5647896.html
