com.actionsoft.sdk.local.api.cc

接口 EsAPI

所有超级接口:

java.lang.AutoCloseable, java.io.Closeable

public interface EsAPI
extends java.io.Closeable

通过ES高级别API执行常见操作

支持日志和审计的操作：不含getClient

方法概要

限定符和类型	方法和说明
BulkResponse	bulk(<any>... request) 批量写请求（增、删、改）
IndexResponse	create(java.lang.String index, java.lang.String id, java.lang.String json) 向索引插入数据
CreateIndexResponse	createIndex(java.lang.String index, java.lang.String settings, java.lang.String mappings) 创建索引
DeleteResponse	delete(java.lang.String index, java.lang.String id) 删除一行数据
BulkByScrollResponse	deleteByQuery(java.lang.String index, QueryBuilder builder) 按查询批量删除
Response	deleteIndex(java.lang.String index) 删除索引
boolean	exist(java.lang.String index) 查询索引是否存在
RestHighLevelClient	getClient() 获得高级别REST API客户端
SearchResponse	search(java.lang.String index, SearchSourceBuilder sourceBuilder) 搜索方法
UpdateResponse	setNull(java.lang.String index, java.lang.String id, java.lang.String field) 清空数据中属性数值
UpdateResponse	update(java.lang.String index, java.lang.String id, java.lang.String json) 更新索引数据
BulkByScrollResponse	updateByQuery(java.lang.String index, QueryBuilder builder) 按查询批量更新

从接口继承的方法 java.io.Closeable

close

方法详细资料

getClient

RestHighLevelClient getClient()

获得高级别REST API客户端

createIndex

CreateIndexResponse createIndex(java.lang.String index,
                                java.lang.String settings,
                                java.lang.String mappings)
                         throws java.io.IOException

创建索引

参数:

index - 索引名称

settings - 索引属性

mappings - 索引字段结构

返回:

抛出:

java.io.IOException

exist

boolean exist(java.lang.String index)
       throws java.io.IOException

查询索引是否存在

参数:

index -

返回:

抛出:

java.io.IOException

deleteIndex

Response deleteIndex(java.lang.String index)
              throws java.io.IOException

删除索引

参数:

index -

返回:

抛出:

java.io.IOException

create

IndexResponse create(java.lang.String index,
                     java.lang.String id,
                     java.lang.String json)
              throws java.io.IOException

向索引插入数据

参数:

index - 索引名

id - 数据id

json - json数据

返回:

抛出:

java.io.IOException

update

UpdateResponse update(java.lang.String index,
                      java.lang.String id,
                      java.lang.String json)
               throws java.io.IOException

更新索引数据

参数:

index - 索引名

id - 数据id

json - json数据

返回:

抛出:

java.io.IOException

setNull

UpdateResponse setNull(java.lang.String index,
                       java.lang.String id,
                       java.lang.String field)
                throws java.io.IOException

清空数据中属性数值

参数:

index - 索引

id - 数据id

field - 数据属性

返回:

抛出:

java.io.IOException

updateByQuery

BulkByScrollResponse updateByQuery(java.lang.String index,
                                   QueryBuilder builder)
                            throws java.io.IOException

按查询批量更新

参数:

index -

builder -

返回:

抛出:

java.io.IOException

delete

DeleteResponse delete(java.lang.String index,
                      java.lang.String id)
               throws java.io.IOException

删除一行数据

参数:

index -

id -

返回:

抛出:

java.io.IOException

deleteByQuery

BulkByScrollResponse deleteByQuery(java.lang.String index,
                                   QueryBuilder builder)
                            throws java.io.IOException

按查询批量删除

参数:

index -

builder -

返回:

抛出:

java.io.IOException

bulk

BulkResponse bulk(<any>... request)
           throws java.io.IOException

批量写请求（增、删、改）

参数:

request -

返回:

抛出:

java.io.IOException

search

SearchResponse search(java.lang.String index,
                      SearchSourceBuilder sourceBuilder)
               throws java.io.IOException

搜索方法

参数:

index -

sourceBuilder -

返回:

抛出:

java.io.IOException