示例示例Java调用ES的步骤如下：安装ES，安装完成后，启动ES；
Java调用ES的步骤如下：
1、安装ES，安装完成后，启动ES；
2、在Java项目中添加ES的相关依赖，并导入ES的jar包；
3、连接ES，使用Transport连接ES，并设置相关参数；
4、创建索引，使用client.admin().indices().prepareCreate("indexName")方法创建索引；
5、添加文档，使用client.prepareIndex("indexName", "typeName")方法添加文档；
6、查询文档，使用client.prepareSearch("indexName").setTypes("typeName")方法查询文档；
7、更新文档，使用client.prepareUpdate("indexName", "typeName", "docId")方法更新文档；
8、删除文档，使用client.prepareDelete("indexName", "typeName", "docId")方法删除文档；
以下是一个示例代码：
// 创建ES客户端
Settings settings = Settings.builder()
.put("cer.name", "my-application")
.build();
Transport client = new PreBuiltTransport(settings)
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost"), 9300));
// 创建索引
client.admin().indices().prepareCreate("indexName")
.setSettings(Settings.builder()
.put("number_of_shards", 3)
.put("number_of_replicas", 2)
)
.get();
// 添加文档
Map
json.put("user","kimchy");
json.put("postDate",new Date());
json.put("message","trying out Elasticsearch");
IndexResponse response = client.prepareIndex("indexName", "typeName")
.setSource(json)
.get();
// 查询文档
SearchResponse searchResponse = client.prepareSearch("indexName")
.setTypes("typeName")
.setQuery(QueryBuilders.termQuery("user", "kimchy"))
.get();
// 更新文档
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.index("indexName");
updateRequest.type("typeName");
updateRequest.id("docId");
updateRequest.doc(json);
UpdateResponse updateResponse = client.update(updateRequest).get();
// 删除文档
DeleteResponse deleteResponse = client.prepareDelete("indexName", "typeName", "docId")
.get();
本站系公益性非盈利分享网址，本文来自用户投稿，不代表码文网立场，如若转载，请注明出处
评论列表（51条）