ElasticSearch的一些删除用法笔记

矫情吗；* 2022-06-16 05:15 683阅读 0赞

前面关于es的文章基本上都是添加，修改，更新操作，删除的例子仅仅有根据id删除单条数据的。但作为一个重度使用es的用户，我们肯定得了解所有相关删除操作的命令，才能更加方便的使用和维护es。

通常情况下，删除操作是非常敏感的，这一点不论在关系型数据库，还是nosql数据库都是同样的道理。在es里面也是如此，虽然es大部分时候都是读多写少的系统。

在es里面常用的删除需求，通常如下：

（1）根据某个主键id删除单条数据

（2）根据某个查询条件删除一批数据

（3）删除某个type的数据

（4）删除某个index的数据

（5）清空所有集群的索引数据

本片的例子中，均使用Java Api来完成，其他的方式请参考ES官网文档：

下面来依次看下上面的几个不同方式的删除例子：

（1）根据主键id删除

client.prepareDelete()
     .setIndex("spark")
     .setType("docsx")
     .setId("1")
     .execute()
     .actionGet();

（2）根据某个查询条件删除一批数据，这个删除非常灵活，灵活的同时，缺点也是 非常明显的，如果操作不当会删除大批数据，所以es官网将其作为一个es的插件功能，非必须情况下，不建议使用此插件（delete-by-query），想使用这个功能，需要提前在服务器集群上安装这个插件，每台机器都要装，装完之后还需要滚动重启，否则不生效，安装方式非常简单，执行下面的命令即可：

bin/plugin install delete-by-query

卸载命令：

bin/plugin remove delete-by-query

如果想要在java中使用，还需要引入下面的pom

<dependency>
                <groupId>org.elasticsearch.plugin</groupId>
                <artifactId>delete-by-query</artifactId>
                <version>2.3.4</version>
            </dependency>

此外，在初始化es的client的对象时，需要将插件加入到初始化的方法中：

static Client client = null;
    
    	static {
    		//设置集群名字
    		Settings settings = Settings.settingsBuilder()
    				.put("cluster.name", "search")
    				.put("client.transport.sniff", true)
    				.build();
    	
    			//初始化连接客户端
    		 	client = new TransportClient.Builder().settings(settings)
    		 	.addPlugin(DeleteByQueryPlugin.class)
    		 	.addPlugin(ReindexPlugin.class)
    		 	.build()
    		 	.addTransportAddress(
    		 	new InetSocketTransportAddress(
    		 	new InetSocketAddress("192.168.10.38",9300)))
     
        }

最后我们看下，如何删除指定查询条件的代码：

new DeleteByQueryRequestBuilder(client,
                    DeleteByQueryAction.INSTANCE)
                    .setIndices("spark")
                    .setTypes("docsx")
                    .setQuery(QueryBuilders.queryStringQuery("type:3"))
                    .execute()
                    .actionGet();

（3）删除某个type的数据，其实也用到了delete-by-query的插件，代码如下：

new DeleteByQueryRequestBuilder(client,
                    DeleteByQueryAction.INSTANCE)
                    .setIndices("spark")
                    .setTypes("docsx")
                    .setQuery(QueryBuilders.queryStringQuery("*:*"))
                    .execute()
                    .actionGet();

（4）删除某个index的数据，代码如下 ：

client.admin().indices().delete(new DeleteIndexRequest("spark")).actionGet();

（5）清空整个集群的索引数据，这个操作非常危险，需要注意

new DeleteByQueryRequestBuilder(client,
    				DeleteByQueryAction.INSTANCE)
    				.setSource("*")
    				.execute()
    				.actionGet();

总结：

删除有风险，操作需谨慎

有什么问题可以扫码关注微信公众号：我是攻城师(woshigcs)，在后台留言咨询。 技术债不能欠，健康债更不能欠， 求道之路，与君同行。

![输入图片说明][3214000f-5633-3c17-a3d7-83ebda9aebff.jpg]

[3214000f-5633-3c17-a3d7-83ebda9aebff.jpg]: /images/20220616/c198e454d6e24e80a157ab3eb325d94a.png