JAVAAPI对Elasticsearch的增删改查_esjavaapi批量修改数据资源-CSDN文库

共2个文件

java：1个

xml：1个

5星 · 超过95%的资源需积分: 46 98 浏览量 2017-10-27 09:03:13 上传评论收藏 1KB RAR 举报

在Java开发中，Elasticsearch是一个非常流行的分布式搜索引擎和数据分析平台。它提供了丰富的API，使得开发者可以方便地进行数据的增、删、改、查操作。在这个名为"JAVA API对Elasticsearch的增删改查"的主题中，我们将探讨如何使用Java API与Elasticsearch进行交互。我们需要在项目中引入Elasticsearch的Java客户端库。`pom.xml`文件通常是Maven项目的配置文件，里面包含了依赖管理的部分。为了使用Elasticsearch的Java API，你需要在`pom.xml`中添加Elasticsearch的依赖项，如下所示： ```xml <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-high-level-client</artifactId> <version>7.x.x</version>  </dependency> ``` 接下来，我们来讨论如何实现基本的数据操作。 1. **创建（Create）**：在Elasticsearch中，创建文档通常涉及到`IndexRequest`和`RestHighLevelClient`。下面是一个简单的例子，展示了如何创建一个名为`employee`的索引，并插入一条员工数据： ```java import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.common.xcontent.XContentType; public class EmployeeCRUDApp { public static void main(String[] args) { RestHighLevelClient client = new RestHighLevelClient(// 创建客户端连接); IndexRequest request = new IndexRequest("employee") // 指定索引 .id("1") // 指定文档ID .source(XContentType.JSON, "name", "John Doe", "age", 30); // 设置文档内容 try { IndexResponse response = client.index(request, RequestOptions.DEFAULT); System.out.println("Document created with status: " + response.getResult()); } catch (Exception e) { e.printStackTrace(); } } } ``` 2. **读取（Read）**：要查询文档，我们可以使用`GetRequest`。以下代码展示了如何获取ID为"1"的员工文档： ```java GetRequest getRequest = new GetRequest("employee", "1"); GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT); if (getResponse.isExists()) { System.out.println("Document found: " + getResponse.getSourceAsString()); } else { System.out.println("Document not found"); } ``` 3. **更新（Update）**：使用`UpdateRequest`可以更新文档。下面的例子将员工的年龄改为35： ```java UpdateRequest updateRequest = new UpdateRequest("employee", "1") .doc(XContentType.JSON, "age", 35) .docAsUpsert(true); // 如果文档不存在，就新建一个 client.update(updateRequest, RequestOptions.DEFAULT); ``` 4. **删除（Delete）**：删除操作通过`DeleteRequest`完成。以下代码会删除ID为"1"的员工文档： ```java DeleteRequest deleteRequest = new DeleteRequest("employee", "1"); DeleteResponse deleteResponse = client.delete(deleteRequest, RequestOptions.DEFAULT); System.out.println("Document deleted with status: " + deleteResponse.getResult()); ``` 这些基本操作构成了Elasticsearch与Java集成的核心。在实际应用中，你可能需要处理更复杂的情况，如批量操作、搜索查询、聚合分析等。Elasticsearch的Java API提供了丰富的功能，能满足各种数据处理需求。记得在开发过程中，确保正确配置Elasticsearch服务器，并根据需求优化索引设置，以获得最佳性能。如果你在实践中遇到问题，可以参考官方文档，或者联系提供的邮箱地址寻求帮助。

资源推荐

资源详情

资源评论

收起资源包目录

增删改例子.rar （2个子文件）

pom.xml 982B

EmployeeCRUDApp.java 3KB

package com.roncoo.es.score.first; import java.io.IOException; import java.net.InetAddress; import org.elasticsearch.action.delete.DeleteResponse; import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.update.UpdateResponse; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.transport.InetSocketTransportAddress; import org.elasticsearch.common.xcontent.XContentBuilder; import org.elasticsearch.common.xcontent.XContentFactory; import org.elasticsearch.transport.client.PreBuiltTransportClient; /** * @package: com.roncoo.es.score.first * @ClassName: EmployeeCRUDApp * @author yelinsheng * @created 2017年10月23日下午5:20:04 * @version 1.0 * */ @SuppressWarnings("unused") public class EmployeeCRUDApp { @SuppressWarnings("resource") public static void main(String[] args) throws IOException { //构建client Settings settings = Settings.builder() .put("cluster.name", "elasticsearch") .build(); TransportClient client = new PreBuiltTransportClient(settings) .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost"), 9300)); // createEmployee(client); // deleteEmployee(client); // updateEmployee(client); // getEmployee(client); client.close(); } /** * 创建员工信息（创建一个document） * @param client * @throws IOException */ private static void createEmployee(TransportClient client) throws IOException { IndexResponse response = client.prepareIndex("company", "employee", "23") .setSource(XContentFactory.jsonBuilder() .startObject() .field("name", "jack23") .field("age", 21) .field("position", "technique") .field("country", "china") .field("join_date", "2017-10-23") .field("salary", 10000) .endObject()) .get(); System.out.println(response.getResult()); } /** * 删除员工信息（删除一个document） * @param client * @throws IOException */ private static void deleteEmployee(TransportClient client) throws IOException { DeleteResponse response = client.prepareDelete("company", "employee", "2").get(); System.out.println(response.getResult()); } /** * 更新员工信息（更新一个document） * @param client * @throws IOException */ private static void updateEmployee(TransportClient client) throws IOException { UpdateResponse response = client.prepareUpdate("company", "employee", "23") .setDoc(XContentFactory.jsonBuilder() .startObject() .field("position", "technique manager") .endObject()) .get(); System.out.println(response.getResult() + " : " + response.getVersion()); } /** * 获取员工信息（得到一个document） * @param client */ private static void getEmployee(TransportClient client) { GetResponse response = client.prepareGet("company", "employee", "1").get(); System.out.println(response.getSourceAsString()); } }

评论收藏

内容反馈