qindongliang1922 阅读(152) 评论(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),在后台留言咨询。
技术债不能欠,健康债更不能欠, 求道之路,与君同行。