博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
ElasticSearch Java Api(三) -更新索引库
阅读量:6323 次
发布时间:2019-06-22

本文共 5231 字,大约阅读时间需要 17 分钟。

官网文档:

一、UpdateRequest


创建一个UpdateRequest,然后将其发送给client.

UpdateRequest uRequest = new UpdateRequest();            uRequest.index("blog");            uRequest.type("article");            uRequest.id("2");            uRequest.doc(jsonBuilder().startObject().field("content", "学习目标 掌握java泛型的产生意义ssss").endObject());            client.update(uRequest).get();

二、prepareUpdate()


2.1使用脚本方式

首先打开elasticsearch-2.3.3/config/elasticsearch.yml,新增一行:

script.engine.groovy.inline.update: on

之后重启elasticsearch.

client.prepareUpdate("blog", "article", "1")                .setScript(new Script("ctx._source.title = \"git入门\"", ScriptService.ScriptType.INLINE, null, null))                .get();

2.2使用doc方式

client.prepareUpdate("blog", "article", "1")                    .setDoc(jsonBuilder().startObject().field("content", "SVN与Git对比。。。").endObject()).get();

三、updateRequest


UpdateRequest updateRequest = new UpdateRequest("blog", "article", "1")                    .doc(jsonBuilder().startObject().field("commet", "0").endObject());            client.update(updateRequest).get();

这种方式可以新增字段。

四、upsert


如果文档不存在则创建新的索引.

IndexRequest indexRequest = new IndexRequest("blog", "article", "10").source(jsonBuilder().startObject()                    .field("title", "Git安装10").field("content", "学习目标 git。。。10").endObject());UpdateRequest uRequest2 = new UpdateRequest("blog", "article", "10").doc(                    jsonBuilder().startObject().field("title", "Git安装").field("content", "学习目标 git。。。").endObject())                    .upsert(indexRequest);            client.update(uRequest2).get();

这个例子中,如果blog/article/10存在,那么根据UpdateRequest更新索引;如果不存在,新建indexRequest索引.

五、java demo


package cn.com.bropen.es;import java.io.IOException;import java.net.InetAddress;import java.net.UnknownHostException;import java.util.concurrent.ExecutionException;import org.elasticsearch.action.index.IndexRequest;import org.elasticsearch.action.update.UpdateRequest;import org.elasticsearch.client.Client;import org.elasticsearch.client.transport.TransportClient;import org.elasticsearch.common.transport.InetSocketTransportAddress;import org.elasticsearch.script.Script;import org.elasticsearch.script.ScriptService;import static org.elasticsearch.common.xcontent.XContentFactory.*;public class ElasticSearchUpdate {    private static Client client;    public static void main(String[] args) {        try {            // client startup            client = TransportClient.builder().build()                    .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));        } catch (UnknownHostException e) {            e.printStackTrace();        }        upMethod1();    }    public static void upMethod1() {        try {            // 方法一:创建一个UpdateRequest,然后将其发送给client.            UpdateRequest uRequest = new UpdateRequest();            uRequest.index("blog");            uRequest.type("article");            uRequest.id("22");            uRequest.doc(jsonBuilder().startObject().field("content", "学习目标 掌握java泛型的产生意义ssss").endObject());            client.update(uRequest).get();        } catch (IOException e) {            e.printStackTrace();        } catch (InterruptedException e) {            e.printStackTrace();        } catch (ExecutionException e) {            e.printStackTrace();        }    }    public static void upMethod2() {        // 方法二:prepareUpdate() 使用脚本更新索引        client.prepareUpdate("blog", "article", "1")                .setScript(new Script("ctx._source.title = \"git入门\"", ScriptService.ScriptType.INLINE, null, null))                .get();    }    public static void upMethod3() {        // 方法三:prepareUpdate() 使用doc更新索引        try {            client.prepareUpdate("blog", "article", "1")                    .setDoc(jsonBuilder().startObject().field("content", "SVN与Git对比。。。").endObject()).get();        } catch (IOException e) {            e.printStackTrace();        }    }    public static void upMethod4() {        // 方法四: 增加新的字段        try {            UpdateRequest updateRequest = new UpdateRequest("blog", "article", "1")                    .doc(jsonBuilder().startObject().field("commet", "0").endObject());            client.update(updateRequest).get();        } catch (IOException e) {            e.printStackTrace();        } catch (InterruptedException e) {            e.printStackTrace();        } catch (ExecutionException e) {            e.printStackTrace();        }    }    public static void upMethod5() {        // 方法五:upsert 如果文档不存在则创建新的索引        try {            IndexRequest indexRequest = new IndexRequest("blog", "article", "10").source(jsonBuilder().startObject()                    .field("title", "Git安装10").field("content", "学习目标 git。。。10").endObject());            UpdateRequest uRequest2 = new UpdateRequest("blog", "article", "10").doc(                    jsonBuilder().startObject().field("title", "Git安装").field("content", "学习目标 git。。。").endObject())                    .upsert(indexRequest);            client.update(uRequest2).get();        } catch (IOException e) {            e.printStackTrace();        } catch (InterruptedException e) {            e.printStackTrace();        } catch (ExecutionException e) {            e.printStackTrace();        }    }}

转载地址:http://iktaa.baihongyu.com/

你可能感兴趣的文章
SpringBoot 实战 (二) | 第一个 SpringBoot 工程详解
查看>>
Go goroutine理解
查看>>
IDE 插件新版本发布,开发效率 “biu” 起来了
查看>>
理解环境变量 JAVA_TOOL_OPTIONS
查看>>
看大牛是如何使用和理解线程池
查看>>
sql server 索引阐述系列八 统计信息
查看>>
c# Request对象(13)
查看>>
USB,蓝牙,以太网,还是WIFI?
查看>>
阿里云服务器更改时区为utc
查看>>
APP测试流程和测试点
查看>>
ansible实战
查看>>
PowerShell 远程管理之启用和执行命令
查看>>
mysql安装错误
查看>>
马斯克:我并不讨厌苹果 Apple Watch还不成熟
查看>>
win系统与linux系统之间文件备份
查看>>
PHP中实现函数重载
查看>>
白宫电子邮件系统疑被黑:第一夫人护照信息被曝光
查看>>
站在物联网风口,传感器产业弯道超车?
查看>>
Javascript类型转换的规则
查看>>
Shell脚本学习之sed详解
查看>>