org.chinandc.idcds.common.es

类 JeecgElasticsearchTemplate

java.lang.Object

org.chinandc.idcds.common.es.JeecgElasticsearchTemplate

@Component
public class JeecgElasticsearchTemplate
extends java.lang.Object

关于 ElasticSearch 的一些方法（创建索引、添加数据、查询等）

字段概要

字段

限定符和类型	字段和说明
static int	ES_MAX_SIZE

构造器概要

构造器

构造器和说明
JeecgElasticsearchTemplate(java.lang.String baseUrl, boolean checkEnabled)

方法概要

限定符和类型	方法和说明
<T> org.springframework.http.ResponseEntity<T>	_cat(java.lang.String urlAfter, java.lang.Class<T> responseType) cat 查询ElasticSearch系统数据，返回json
com.alibaba.fastjson.JSONObject	buildBoolQuery(com.alibaba.fastjson.JSONArray must, com.alibaba.fastjson.JSONArray mustNot, com.alibaba.fastjson.JSONArray should)
com.alibaba.fastjson.JSONObject	buildQuery(java.util.List<java.lang.String> _source, com.alibaba.fastjson.JSONObject query, int from, int size)
com.alibaba.fastjson.JSONObject	buildQueryString(java.lang.String query)
com.alibaba.fastjson.JSONObject	buildQueryString(java.lang.String field, java.lang.String... args)
com.alibaba.fastjson.JSONObject	buildRangeQuery(java.lang.String field, java.lang.Object min, java.lang.Object max, boolean containMin, boolean containMax)
boolean	createIndex(java.lang.String indexName) 创建索引 查询地址：PUT http://{baseUrl}/{indexName}
boolean	delete(java.lang.String indexName, java.lang.String typeName, java.lang.String dataId) 删除索引数据 请求地址：DELETE http://{baseUrl}/{indexName}/{typeName}/{dataId}
java.lang.StringBuilder	getBaseUrl()
java.lang.StringBuilder	getBaseUrl(java.lang.String indexName)
java.lang.StringBuilder	getBaseUrl(java.lang.String indexName, java.lang.String typeName)
com.alibaba.fastjson.JSONObject	getDataById(java.lang.String indexName, java.lang.String typeName, java.lang.String dataId) 根据ID获取索引数据，未查询到返回null 查询地址：GET http://{baseUrl}/{indexName}/{typeName}/{dataId}
com.alibaba.fastjson.JSONObject	getIndexMapping(java.lang.String indexName, java.lang.String typeName) 获取索引字段映射（可获取字段类型）
<T> java.util.Map<java.lang.String,T>	getIndexMappingFormat(java.lang.String indexName, java.lang.String typeName, java.lang.Class<T> clazz) 获取索引字段映射，返回Java实体类
com.alibaba.fastjson.JSONArray	getIndices() 查询所有索引 查询地址：GET http://{baseUrl}/_cat/indices
com.alibaba.fastjson.JSONArray	getIndices(java.lang.String indexName) 查询单个索引 查询地址：GET http://{baseUrl}/_cat/indices/{indexName}
boolean	indexExists(java.lang.String indexName) 索引是否存在
boolean	removeIndex(java.lang.String indexName) 删除索引 查询地址：DELETE http://{baseUrl}/{indexName}
boolean	save(java.lang.String indexName, java.lang.String typeName, java.lang.String dataId, com.alibaba.fastjson.JSONObject data) 保存数据，详见：saveOrUpdate
boolean	saveBatch(java.lang.String indexName, java.lang.String typeName, com.alibaba.fastjson.JSONArray dataList) 批量保存数据
boolean	saveOrUpdate(java.lang.String indexName, java.lang.String typeName, java.lang.String dataId, com.alibaba.fastjson.JSONObject data) 保存或修改索引数据 查询地址：PUT http://{baseUrl}/{indexName}/{typeName}/{dataId}
com.alibaba.fastjson.JSONObject	search(java.lang.String indexName, java.lang.String typeName, com.alibaba.fastjson.JSONObject queryObject) 查询数据 请求地址：POST http://{baseUrl}/{indexName}/{typeName}/_search
boolean	update(java.lang.String indexName, java.lang.String typeName, java.lang.String dataId, com.alibaba.fastjson.JSONObject data) 更新数据，详见：saveOrUpdate

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

ES_MAX_SIZE

public static final int ES_MAX_SIZE

另请参阅:

常量字段值

构造器详细资料

JeecgElasticsearchTemplate

public JeecgElasticsearchTemplate(@Value(value="${jeecg.elasticsearch.cluster-nodes}")
                                  java.lang.String baseUrl,
                                  @Value(value="${jeecg.elasticsearch.check-enabled}")
                                  boolean checkEnabled)

方法详细资料

getBaseUrl

public java.lang.StringBuilder getBaseUrl(java.lang.String indexName,
                                          java.lang.String typeName)

getBaseUrl

public java.lang.StringBuilder getBaseUrl(java.lang.String indexName)

getBaseUrl

public java.lang.StringBuilder getBaseUrl()

_cat

public <T> org.springframework.http.ResponseEntity<T> _cat(java.lang.String urlAfter,
                                                           java.lang.Class<T> responseType)

cat 查询ElasticSearch系统数据，返回json

getIndices

public com.alibaba.fastjson.JSONArray getIndices()

查询所有索引

查询地址：GET http://{baseUrl}/_cat/indices

getIndices

public com.alibaba.fastjson.JSONArray getIndices(java.lang.String indexName)

查询单个索引

查询地址：GET http://{baseUrl}/_cat/indices/{indexName}

indexExists

public boolean indexExists(java.lang.String indexName)

索引是否存在

getDataById

public com.alibaba.fastjson.JSONObject getDataById(java.lang.String indexName,
                                                   java.lang.String typeName,
                                                   java.lang.String dataId)

根据ID获取索引数据，未查询到返回null

查询地址：GET http://{baseUrl}/{indexName}/{typeName}/{dataId}

参数:

indexName - 索引名称

typeName - type，一个任意字符串，用于分类

dataId - 数据id

返回:

createIndex

public boolean createIndex(java.lang.String indexName)

创建索引

查询地址：PUT http://{baseUrl}/{indexName}

removeIndex

public boolean removeIndex(java.lang.String indexName)

删除索引

查询地址：DELETE http://{baseUrl}/{indexName}

getIndexMapping

public com.alibaba.fastjson.JSONObject getIndexMapping(java.lang.String indexName,
                                                       java.lang.String typeName)

获取索引字段映射（可获取字段类型）

参数:

indexName - 索引名称

typeName - 分类名称

返回:

getIndexMappingFormat

public <T> java.util.Map<java.lang.String,T> getIndexMappingFormat(java.lang.String indexName,
                                                                   java.lang.String typeName,
                                                                   java.lang.Class<T> clazz)

获取索引字段映射，返回Java实体类

参数:

indexName -

typeName -

返回:

save

public boolean save(java.lang.String indexName,
                    java.lang.String typeName,
                    java.lang.String dataId,
                    com.alibaba.fastjson.JSONObject data)

保存数据，详见：saveOrUpdate

update

public boolean update(java.lang.String indexName,
                      java.lang.String typeName,
                      java.lang.String dataId,
                      com.alibaba.fastjson.JSONObject data)

更新数据，详见：saveOrUpdate

saveOrUpdate

public boolean saveOrUpdate(java.lang.String indexName,
                            java.lang.String typeName,
                            java.lang.String dataId,
                            com.alibaba.fastjson.JSONObject data)

保存或修改索引数据

查询地址：PUT http://{baseUrl}/{indexName}/{typeName}/{dataId}

参数:

indexName - 索引名称

typeName - type，一个任意字符串，用于分类

dataId - 数据id

data - 要存储的数据

返回:

saveBatch

public boolean saveBatch(java.lang.String indexName,
                         java.lang.String typeName,
                         com.alibaba.fastjson.JSONArray dataList)

批量保存数据

参数:

indexName - 索引名称

typeName - type，一个任意字符串，用于分类

dataList - 要存储的数据数组，每行数据必须包含id

返回:

delete

public boolean delete(java.lang.String indexName,
                      java.lang.String typeName,
                      java.lang.String dataId)

删除索引数据

请求地址：DELETE http://{baseUrl}/{indexName}/{typeName}/{dataId}

search

public com.alibaba.fastjson.JSONObject search(java.lang.String indexName,
                                              java.lang.String typeName,
                                              com.alibaba.fastjson.JSONObject queryObject)

查询数据

请求地址：POST http://{baseUrl}/{indexName}/{typeName}/_search

buildQuery

public com.alibaba.fastjson.JSONObject buildQuery(java.util.List<java.lang.String> _source,
                                                  com.alibaba.fastjson.JSONObject query,
                                                  int from,
                                                  int size)

参数:

_source - （源滤波器）指定返回的字段，传null返回所有字段

query -

from - 从第几条数据开始

size - 返回条目数

返回:

{ "query": query }

buildBoolQuery

public com.alibaba.fastjson.JSONObject buildBoolQuery(com.alibaba.fastjson.JSONArray must,
                                                      com.alibaba.fastjson.JSONArray mustNot,
                                                      com.alibaba.fastjson.JSONArray should)

返回:

{ "bool" : { "must": must, "must_not": mustNot, "should": should } }

buildQueryString

public com.alibaba.fastjson.JSONObject buildQueryString(java.lang.String field,
                                                        java.lang.String... args)

参数:

field - 要查询的字段

args - 查询参数，参考： *哈哈* OR *哒* NOT *呵* OR *啊*

返回:

buildQueryString

public com.alibaba.fastjson.JSONObject buildQueryString(java.lang.String query)

返回:

{ "query_string": { "query": query } }

buildRangeQuery

public com.alibaba.fastjson.JSONObject buildRangeQuery(java.lang.String field,
                                                       java.lang.Object min,
                                                       java.lang.Object max,
                                                       boolean containMin,
                                                       boolean containMax)

参数:

field - 查询字段

min - 最小值

max - 最大值

containMin - 范围内是否包含最小值

containMax - 范围内是否包含最大值

返回:

{ "range" : { field : { 『 "gt『e』?containMin" : min 』?min!=null , 『 "lt『e』?containMax" : max 』}} }