将MySQL中的数据导入到solr索引库-阿里云开发者社区

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

2018-07-06 1606

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

云数据库 RDS MySQL，集群系列 2核4GB

RDS MySQL Serverless 基础系列，0.5-2RCU 50GB

云数据库 RDS MySQL，高可用系列 2核4GB

简介： 利用solrJ向索引库导入数据http://www.bieryun.com/3229.html 需求：将MySQL中的数据导入到solr索引库定义实体类： [java] view plain copy public class SearchItem implements Seri.

利用solrJ向索引库导入数据http://www.bieryun.com/3229.html

需求：将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, "导入失败！");
}
}

相关实践学习

如何在云端创建MySQL数据库

开始实验后，系统会自动创建一台自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS。

全面了解阿里云能为你做什么

阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs

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

热门文章

最新文章

相关课程

相关电子书

相关实验场景

推荐镜像