Elasticsearch java api 插入数据
2017-11-03 16:08
357 查看
首先java依赖的jar包要与es服务端的版本对应
这里是es5.5.1的版本。
Elasticsearch5.5.1 java api 创建客户端,插入数据。
需要注意的是要在客户端上创建index,type和mapping。在命令行模式没有type mapping也是可以插入数据的,这点不同。
package com.jiayun.core.elasticsearch.utils;
import java.net.InetAddress;
import java.net.UnknownHostException;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import com.alibaba.fastjson.JSONObject;
public class ES551Client {
@SuppressWarnings({ "resource", "unused" })
public static void main(String[] args) throws UnknownHostException {
//client
// 设置集群名称
Settings settings = Settings.builder().put("cluster.name", "my-application").build();
// 创建client
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("120.77.151.154"), 9300));
JSONObject json = new JSONObject();
json.put("user", "小明");
json.put("title", "Java Engineer");
json.put("desc", "web 开发");
IndexResponse response = client.prepareIndex("accounts", "person")
.setSource(json, XContentType.JSON)
.get();
String _index = response.getIndex();
System.out.println(_index);
}
}
这里是es5.5.1的版本。
Elasticsearch5.5.1 java api 创建客户端,插入数据。
需要注意的是要在客户端上创建index,type和mapping。在命令行模式没有type mapping也是可以插入数据的,这点不同。
package com.jiayun.core.elasticsearch.utils;
import java.net.InetAddress;
import java.net.UnknownHostException;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import com.alibaba.fastjson.JSONObject;
public class ES551Client {
@SuppressWarnings({ "resource", "unused" })
public static void main(String[] args) throws UnknownHostException {
//client
// 设置集群名称
Settings settings = Settings.builder().put("cluster.name", "my-application").build();
// 创建client
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("120.77.151.154"), 9300));
JSONObject json = new JSONObject();
json.put("user", "小明");
json.put("title", "Java Engineer");
json.put("desc", "web 开发");
IndexResponse response = client.prepareIndex("accounts", "person")
.setSource(json, XContentType.JSON)
.get();
String _index = response.getIndex();
System.out.println(_index);
}
}
相关文章推荐
- Python中elasticsearch如何插入和更新数据
- elasticsearch系列(一):创建mapping和插入数据
- 分布式搜索elasticsearch java API 之(七)------与MongoDB同步数据
- elasticsearch 插入数据
- 使用Python往Elasticsearch插入数据
- 实时数据之python操作elasticsearch监控数据插入图表分析
- 提高ElasticSearch插入数据性能
- ElasticSearch插入数据
- elasticsearch使用java api批量插入数据
- 分布式搜索elasticsearch java API 之(七)------与MongoDB同步数据
- elasticsearch 创建type及插入数据
- java操作nsq数据插入elasticsearch
- ElasticSearch插入数据问题
- (五)ElasticSearch插入数据
- Python中elasticsearch插入和更新数据的实现方法
- elasticsearch插入数据
- 使用Python往Elasticsearch插入数据
- elasticsearch Insert 插入数据和delete 删除数据(Java)
- Elasticsearch教程(七) elasticsearch Insert 插入数据(Java)
- ElasticSearch插入数据优化