将MySQL中的数据导入到solr索引库-低调大师

将MySQL中的数据导入到solr索引库

2018-04-19 599

利用solrJ向索引库导入数据

需求：将MySQL中的数据导入到solr索引库

定义实体类：

[java] view plain copy

public class SearchItem implements Serializable{
private String id;
private String title;
private String sell_point;
private long price;
private String image;
private String category_name;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getSell_point() {
return sell_point;
}
public void setSell_point(String sell_point) {
this.sell_point = sell_point;
}
public long getPrice() {
return price;
}
public void setPrice(long price) {
this.price = price;
}
public String getImage() {
return image;
}
public String[] getImages() {
if(image != null && !"".equals(image)) {
String[] images = image.split(",");
return images;
}
return null;
}
public void setImage(String image) {
this.image = image;
}
public String getCategory_name() {
return category_name;
}
public void setCategory_name(String category_name) {
this.category_name = category_name;
}
public SearchItem(String id, String title, String sell_point, long price, String image, String category_name) {
super();
this.id = id;
this.title = title;
this.sell_point = sell_point;
this.price = price;
this.image = image;
this.category_name = category_name;
}
public SearchItem() {
super();
// TODO Auto-generated constructor stub
}
@Override
public String toString() {
return "SearchItem [id=" + id + ", title=" + title + ", sell_point=" + sell_point + ", price=" + price
+ ", image=" + image + ", category_name=" + category_name + "]";
}

定义mapper查询数据库：

[java] view plain copy

List<SearchItem> selectAllItem();

[html] view plain copy

<select id="selectAllItem" resultType="com.e3mall.search.SearchItem">
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
WHERE a.`status`=1
</select>
</mapper>

利用solrJ向索引库导入数据：

[java] view plain copy

/**
* 向索引库添加数据
*/
public E3Result saveSearch(){
try {
//从数据库中查询数据
List<SearchItem> selectAllItem = searchMapper.selectAllItem();
for (SearchItem searchItem : selectAllItem) {
// 创建一个文档对象SolrInputDocument
SolrInputDocument document = new SolrInputDocument();
// 向文档对象中添加域，文档中必须包含一个id域，所有的域的名称必须在schema.xml中定义
document.addField("id", searchItem.getId());
document.addField("item_title", searchItem.getTitle());
document.addField("item_sell_point", searchItem.getSell_point());
document.addField("item_price", searchItem.getPrice());
document.addField("item_image", searchItem.getImage());
document.addField("item_category_name", searchItem.getCategory_name());
// 把文档写入索引库
solrServer.add(document);
}
// 提交
solrServer.commit();
//返回成功
return E3Result.ok();
} catch (Exception e) {
// TODO: handle exception
return E3Result.build(500, "导入失败！");
}
}

原文地址 http://www.bieryun.com/3229.html

微信关注我们

原文链接：https://yq.aliyun.com/articles/583493

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

R常用包分类

1、聚类 var a = 12.toInt; 常用的包： fpc，cluster，pvclust，mclust 基于划分的方法: kmeans, pam, pamk, clara 基于层次的方法: hclust, pvclust, agnes, diana 基于模型的方法: mclust 基于密度的方法: dbscan 基于画图的方法: plotcluster, plot.hclust 基于验证的方法: cluster.stats 2、分类常用的包： rpart，party，randomForest，rpartOrdinal，tree，marginTree， maptree，survival 决策树: rpart, ctree 随机森林: cforest, randomForest 回归, Logistic回归, Poisson回归: glm, predict, residuals 生存分析: survfit, survdiff, coxph 3、关联规则与频繁项集常用的包： arules：支持挖掘频繁项集，最大频繁项集，频繁闭项目集和关联规则 DRM：回归和分类数据的重复关联模型...

2018-04-20

653

复习Java知识，主要是一边看偏头痛杨的博客，一边完成博主布置的任务。这是看2.偏头痛杨的Java入门教学系列之变量&数据类型篇的作业： 1.Java有多少种数据类型，数据类型的分类？两种数据类型：基本数据类型引用数据类型除了八种基本数据类型，其他的都是引用数据类型。 2.Java的工作机制？ Java程序的源代码（.java）编译成虚拟机（JVM）能看懂的字节码（.class），然后再由虚拟机解释执行成对应的操作系统能看懂的机器码 3.自动类型转换与强制类型转换的规则？从小到大自动转从大到小强制转自动类型转换： byte->short->int->long->float->double char->int->long->float->double 表达式类型的自动提升：当表达式中有多个数据类型运算式，自动提升为容量最大的数据类型。 byte,short,char之间不会自动转换，首先都提升为int 整个表达式的类型自动提升到与表达式中最高等级操作数同样的类型强制类型转换：容量大的数据类型转换为容量小的数...

2018-04-20

643

资源下载

更多资源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。