您的位置:首页 > 其它

Elasticsearch删除一个type下的所有数据

2017-03-07 14:42 423 查看
学习记录。

直接上执行语句:

DELETE /mytest/test/_query

{

"query": {

"match_all": {}

}

}

注:1、mytest为index,test为type

      2、有朋友会问为什么执行了代码但是并没有删除?

原因是因为es在2.0 以上的不支持批量删除数据了,必须安装插件才能高效的批量删除。这个插件就是 delete-by-query

安装方法就是cmd到es的bin目录下运行这个代码 plugin install delete-by-query。网络好点应该是没问题的。

    安装好之后重启es,然后再测试就可以了啦!同样java api 也就可以通过以下方法进行批量删除了

                StringBuilder b = new StringBuilder();  

                b.append("{\"query\":{\"match_all\":{}}}");

            DeleteByQueryRequestBuilder response = new DeleteByQueryRequestBuilder(client,DeleteByQueryAction.INSTANCE);

                response.setIndices(index).setTypes(type).setSource(b.toString())

                        .execute()

                        .actionGet();

同样在maven项目的pom.xml文件中需添加:

<dependency>

            <groupId>org.elasticsearch.plugin</groupId>

            <artifactId>delete-by-query</artifactId>

            <version>2.4.1</version>

        </dependency>

我用的2.4.1这个版本!

补充:

很不好意思,当时再写这个文章的时候漏掉了clent连接的代码。因为是写在另外一个类里面的就给搞忘记了。十分抱歉。

下面就是要使用批量删除的clent正确的连接方式:

        Settings settings = Settings.settingsBuilder().put("cluster.name", "elasticsearch").build();

        TransportClient client = TransportClient.builder()

                .settings(settings)

                .addPlugin(DeleteByQueryPlugin.class)

                .build()

                .addTransportAddress(new InetSocketTransportAddress(

                        InetAddress.getByName("localhost"), 9300));

设置的时候需要制定使用删除插件。

报错的朋友应该也就是这个问题了!!感谢朋友们的留言才让我看到问题所在,哈哈!!
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  elasticsearch 数据
相关文章推荐