Java API批量操作Elasticsearch

朱雀 2022-05-24 07:07 213阅读 0赞

上一节讲到如何对索引进行增删改查操作，但是都是针对于单个的来说，这节课就开始介绍如何批量的创建、修改、删除索引。废话不多说，我们直接看具体代码。

**1.批量创建索引**

*/\*\**

*\* 批量添加索引*

*\**  ***@throws***  *IOException*

*\*/*

@Test

**public void**  batchAddIndex()  **throws**  IOException \{

BulkRequestBuilder bulkRequest =  **client** .prepareBulk();

bulkRequest.add( **client** .prepareIndex( **"batch\_test1"** ,  **"batch"** ,  **"1"** )

.setSource( *jsonBuilder* ()

.startObject()

.field( **"user"** ,  **"lzq"** )

.field( **"postDate"** ,  **new**  Date())

.field( **"message"** ,  **"trying out Elasticsearch"** )

.endObject()

)

);

bulkRequest.add( **client** .prepareIndex( **"batch\_test2"** ,  **"batch"** ,  **"2"** )

.setSource( *jsonBuilder* ()

.startObject()

.field( **"user"** ,  **"zx"** )

.field( **"postDate"** ,  **new**  Date())

.field( **"message"** ,  **"another post"** )

.endObject()

)

);

BulkResponse bulkResponse = bulkRequest.get();

**if**  (bulkResponse.hasFailures()) \{

System. ***out*** .println( **"failures..............:"** \+bulkResponse.buildFailureMessage()

);

![27_method_get-resource_shareToken_D52CBC3998B64059ACBE456B87F909D1_entryId_197404653][]

如图所示：批量创建的两个索引，在es系统里面都可以找到，所以说明索引创建是成功的。

这里需要注意的是，索引的名称不能大写，必须是小写或者下划线之类的。还有buildFailureMessage函数返回的是批量操作错误的失败信息，hasFailures返回的是批量操作是否正确。

**2.批量修改索引**

*/\*\**

*\* 批量修改索引*

*\**  ***@throws***  *IOException*

*\*/*

@Test

**public void**  batchUpdateIndex()  **throws**  IOException \{

BulkRequestBuilder bulkRequest =  **client** .prepareBulk();

bulkRequest.add( **client** .prepareUpdate( **"batch\_test1"** ,  **"batch"** ,  **"1"** ).setDoc( *jsonBuilder* ()

.startObject()

.field( **"user"** ,  **"修改lzq"** )

.field( **"postDate"** ,  **new**  Date())

.field( **"message"** ,  **"batch\_test1被我修改了"** )

.endObject()));

bulkRequest.add( **client** .prepareUpdate( **"batch\_test2"** ,  **"batch"** ,  **"2"** ).setDoc( *jsonBuilder* ()

.startObject()

.field( **"user"** ,  **"修改zx"** )

.field( **"postDate"** ,  **new**  Date())

.field( **"message"** ,  **"batch\_test1被我修改了"** )

.endObject()));

BulkResponse bulkResponse = bulkRequest.get();

**if**  (bulkResponse.hasFailures()) \{

System. ***out*** .println( **"failures..............:"** \+bulkResponse.buildFailureMessage()

);

![28_method_get-resource_shareToken_D52CBC3998B64059ACBE456B87F909D1_entryId_197404653][]

如图所示，表示批量修改已经成功。这边需要注意的是索引是什么类型的数据，修改的时候传入的数据类型就必须是什么类型的数据。

**3.批量删除索引**

*/\*\**

*\* 批量删除索引*

*\**  ***@throws***  *IOException*

*\*/*

@Test

**public void**  batchDeleteIndex()  **throws**  IOException \{

BulkRequestBuilder bulkRequest =  **client** .prepareBulk();

bulkRequest.add( **client** .prepareDelete( **"batch\_test1"** ,  **"batch"** ,  **"1"** ));

bulkRequest.add( **client** .prepareDelete( **"batch\_test2"** ,  **"batch"** ,  **"2"** ));

BulkResponse bulkResponse = bulkRequest.get();

**if**  (bulkResponse.hasFailures()) \{

System. ***out*** .println( **"failures.............:"** \+bulkResponse.buildFailureMessage()

);

![26_method_get-resource_shareToken_D52CBC3998B64059ACBE456B87F909D1_entryId_197404653][]

如图所示，数据已经被清空了，所以表示删除操作是成功的。

注意事项：

**1.记住索引不能大写**

**2.保存的是什么类型的，修改也必须是对应的类型**

**3.记住只有批量添加修改删除，没有批量查询操作**

对文章有什么疑问或者想要看更多文章可以加我订阅号，欢迎大家的踩踩~

![70][]

[27_method_get-resource_shareToken_D52CBC3998B64059ACBE456B87F909D1_entryId_197404653]: https://note.youdao.com/yws/api/group/76450073/noteresource/F44B9E612ED24CADA78DE58107D286D0/version/27?method=get-resource&shareToken=D52CBC3998B64059ACBE456B87F909D1&entryId=197404653
[28_method_get-resource_shareToken_D52CBC3998B64059ACBE456B87F909D1_entryId_197404653]: https://note.youdao.com/yws/api/group/76450073/noteresource/16271C8539814DD987BA8713F5B27E48/version/28?method=get-resource&shareToken=D52CBC3998B64059ACBE456B87F909D1&entryId=197404653
[26_method_get-resource_shareToken_D52CBC3998B64059ACBE456B87F909D1_entryId_197404653]: https://note.youdao.com/yws/api/group/76450073/noteresource/83C0D21DDF4844F7A854FD0F9706CCF2/version/26?method=get-resource&shareToken=D52CBC3998B64059ACBE456B87F909D1&entryId=197404653
[70]: /images/20220524/d57cea9431c149029c5e44c7c579de54.png