ElasticsearchClient - java - 基础篇 - 索引 - 创建基本索引_这是谁？_elasticsearch java创建索引

irpas 02-07 7540

世界上并没有完美的程序，但是我们并不因此而沮丧，因为写程序就是一个不断追求完美的过程。 -侯氏工坊

文章目录参考导言创建索引索引数据索引单个文档索引多个文档

参考 elasticsearch - java - elasticsearch和kibana的安装和配置elasticsearch - java - elasticsearch对接spring bootElasticsearchClient客户端深入学习访问基础篇和高级篇所有栏目内容参考栏目预告导言 elasticsearch可以自动识别数据类型本章的目的是将数据索引到elasticsearch中，没有使用mapping及analyzer等操作后续会优先搜索部分的实现创建索引

原语句

PUT /test

java实现

创建索引/** * @describe 创建索引 * @param index 索引名称 * @return 创建索引的结果 * @throws Exception 抛出异常 */ private Boolean createIndex(String index) throws Exception { // 判断索引是否存在 BooleanResponse b = elasticsearchClient.indices().exists(_0 -> _0 .index(index)); if (!b.value()) { // 创建索引 CreateIndexResponse re = elasticsearchClient.indices() .create(_0 -> _0 .index(index)); return re.acknowledged(); } return b.value(); } 创建数据流索引/** * @describe 创建数据流索引 * @param index 索引名称 * @return 创建索引的结果 * @throws Exception 抛出异常 */ private Boolean createDataStreamIndex(String index) throws Exception { // 判断索引是否存在 BooleanResponse b = elasticsearchClient.indices().exists(_0 -> _0 .index(index)); if (!b.value()) { // 创建数据流索引 CreateDataStreamResponse re = elasticsearchClient.indices() .createDataStream(_0 -> _0 .name(index)); return re.acknowledged(); } return b.value(); } 索引数据索引单个文档原语句POST /test/_doc { "name": "hello" } java实现/** * @describe 索引单个文档 * @param index 索引名称 * @param o 文档对象 * @return 索引文档结果 * @throws Exception 抛出异常 */ private IndexResponse index(String index, Object o) throws Exception { return elasticsearchClient .index(_0 -> _0 .index(index) .document(o) ); } 索引多个文档

原语句

POST /test/_bulk {"create": {}} {"name": "good"} {"create": {}} {"name": "me"}

java实现

/** * @describe 索引多个文档 * @param index 索引名称 * @param ls 文档列表 * @return 索引文档结果 * @throws Exception 抛出异常 */ private BulkResponse bulk(String index, List<?> ls) throws Exception { return elasticsearchClient.bulk(_0 -> { _0.index(index); ls.forEach(_1 -> _0 .operations(_2 -> _2 .create(_3 -> _3 .document(_1)))); return _0; }); }