com.sh.wf.util

类 ESRestUtil

java.lang.Object

com.sh.wf.util.ESRestUtil

public class ESRestUtil
extends java.lang.Object

Description:

Title:首亨软件 - TSS/CRM等

从以下版本开始:

2018年7月24日

版本:

3.0

作者:

江兴春

构造器概要

构造器

构造器和说明
ESRestUtil()

方法概要

限定符和类型	方法和说明
static Datastore	convertJSON2Datastore(com.alibaba.fastjson.JSONObject obj)
static java.lang.String	DeleteRequest(java.lang.String endpoint)
static java.lang.String	DeleteRequest(java.lang.String endpoint, java.lang.String dsl)
static java.lang.String	DeleteRequest(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static com.alibaba.fastjson.JSONObject	DeleteRequestWithJSON(java.lang.String endpoint, java.lang.String dsl)
static com.alibaba.fastjson.JSONObject	DeleteRequestWithJSON(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static net.sf.json.JSONObject	DeleteRequestWithJSON2(java.lang.String endpoint, java.lang.String dsl)
static net.sf.json.JSONObject	DeleteRequestWithJSON2(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static java.lang.String	GetRequest(java.lang.String endpoint, java.lang.String dsl)
static java.lang.String	GetRequest(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static Datastore	getRequestWithDatastore(java.lang.String endpoint, java.lang.String dsl)
static Datastore	getRequestWithDatastore(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static com.alibaba.fastjson.JSONObject	GetRequestWithJSON(java.lang.String endpoint, java.lang.String dsl)
static com.alibaba.fastjson.JSONObject	GetRequestWithJSON(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static net.sf.json.JSONObject	GetRequestWithJSON2(java.lang.String endpoint, java.lang.String dsl)
static net.sf.json.JSONObject	GetRequestWithJSON2(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static void	main(java.lang.String[] args)
static java.lang.String	PostRequest(java.lang.String endpoint, java.lang.String dsl)
static java.lang.String	PostRequest(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static Datastore	postRequestWithDatastore(java.lang.String endpoint, java.lang.String dsl)
static com.alibaba.fastjson.JSONObject	PostRequestWithJSON(java.lang.String endpoint, java.lang.String dsl)
static com.alibaba.fastjson.JSONObject	PostRequestWithJSON(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static net.sf.json.JSONObject	PostRequestWithJSON2(java.lang.String endpoint, java.lang.String dsl)
static net.sf.json.JSONObject	PostRequestWithJSON2(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static java.lang.String	processRequest(java.lang.String method, java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params) 发起请求查询es数据
static com.alibaba.fastjson.JSONObject	processRequestWithJSON(java.lang.String method, java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static net.sf.json.JSONObject	processRequestWithJSON2(java.lang.String method, java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static java.lang.String	PutRequest(java.lang.String endpoint, java.lang.String dsl)
static java.lang.String	PutRequest(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static com.alibaba.fastjson.JSONObject	PutRequestWithJSON(java.lang.String endpoint, java.lang.String dsl)
static com.alibaba.fastjson.JSONObject	PutRequestWithJSON(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static net.sf.json.JSONObject	PutRequestWithJSON2(java.lang.String endpoint, java.lang.String dsl)
static net.sf.json.JSONObject	PutRequestWithJSON2(java.lang.String endpoint, java.lang.String dsl, java.util.Map<java.lang.String,java.lang.String> params)
static com.alibaba.fastjson.JSONObject	QueryBySQL(java.lang.String sql) 按SQL进行查询，要求elasticsearch7.3以后的版本
static net.sf.json.JSONObject	QueryBySQL2(java.lang.String sql)
static Datastore	queryIndexColumn(java.lang.String indexName)

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

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

构造器详细资料

ESRestUtil

public ESRestUtil()

方法详细资料

GetRequest

public static java.lang.String GetRequest(java.lang.String endpoint,
                                          java.lang.String dsl)

GetRequest

public static java.lang.String GetRequest(java.lang.String endpoint,
                                          java.lang.String dsl,
                                          java.util.Map<java.lang.String,java.lang.String> params)

PostRequest

public static java.lang.String PostRequest(java.lang.String endpoint,
                                           java.lang.String dsl)

PostRequest

public static java.lang.String PostRequest(java.lang.String endpoint,
                                           java.lang.String dsl,
                                           java.util.Map<java.lang.String,java.lang.String> params)

PutRequest

public static java.lang.String PutRequest(java.lang.String endpoint,
                                          java.lang.String dsl)

PutRequest

public static java.lang.String PutRequest(java.lang.String endpoint,
                                          java.lang.String dsl,
                                          java.util.Map<java.lang.String,java.lang.String> params)

DeleteRequest

public static java.lang.String DeleteRequest(java.lang.String endpoint,
                                             java.lang.String dsl)

DeleteRequest

public static java.lang.String DeleteRequest(java.lang.String endpoint)

DeleteRequest

public static java.lang.String DeleteRequest(java.lang.String endpoint,
                                             java.lang.String dsl,
                                             java.util.Map<java.lang.String,java.lang.String> params)

GetRequestWithJSON2

public static net.sf.json.JSONObject GetRequestWithJSON2(java.lang.String endpoint,
                                                         java.lang.String dsl)

GetRequestWithJSON

public static com.alibaba.fastjson.JSONObject GetRequestWithJSON(java.lang.String endpoint,
                                                                 java.lang.String dsl)

getRequestWithDatastore

public static Datastore getRequestWithDatastore(java.lang.String endpoint,
                                                java.lang.String dsl)

GetRequestWithJSON2

public static net.sf.json.JSONObject GetRequestWithJSON2(java.lang.String endpoint,
                                                         java.lang.String dsl,
                                                         java.util.Map<java.lang.String,java.lang.String> params)

GetRequestWithJSON

public static com.alibaba.fastjson.JSONObject GetRequestWithJSON(java.lang.String endpoint,
                                                                 java.lang.String dsl,
                                                                 java.util.Map<java.lang.String,java.lang.String> params)

getRequestWithDatastore

public static Datastore getRequestWithDatastore(java.lang.String endpoint,
                                                java.lang.String dsl,
                                                java.util.Map<java.lang.String,java.lang.String> params)

PostRequestWithJSON2

public static net.sf.json.JSONObject PostRequestWithJSON2(java.lang.String endpoint,
                                                          java.lang.String dsl)

PostRequestWithJSON

public static com.alibaba.fastjson.JSONObject PostRequestWithJSON(java.lang.String endpoint,
                                                                  java.lang.String dsl)

postRequestWithDatastore

public static Datastore postRequestWithDatastore(java.lang.String endpoint,
                                                 java.lang.String dsl)

convertJSON2Datastore

public static Datastore convertJSON2Datastore(com.alibaba.fastjson.JSONObject obj)

PostRequestWithJSON2

public static net.sf.json.JSONObject PostRequestWithJSON2(java.lang.String endpoint,
                                                          java.lang.String dsl,
                                                          java.util.Map<java.lang.String,java.lang.String> params)

PostRequestWithJSON

public static com.alibaba.fastjson.JSONObject PostRequestWithJSON(java.lang.String endpoint,
                                                                  java.lang.String dsl,
                                                                  java.util.Map<java.lang.String,java.lang.String> params)

PutRequestWithJSON2

public static net.sf.json.JSONObject PutRequestWithJSON2(java.lang.String endpoint,
                                                         java.lang.String dsl)

PutRequestWithJSON

public static com.alibaba.fastjson.JSONObject PutRequestWithJSON(java.lang.String endpoint,
                                                                 java.lang.String dsl)

PutRequestWithJSON2

public static net.sf.json.JSONObject PutRequestWithJSON2(java.lang.String endpoint,
                                                         java.lang.String dsl,
                                                         java.util.Map<java.lang.String,java.lang.String> params)

PutRequestWithJSON

public static com.alibaba.fastjson.JSONObject PutRequestWithJSON(java.lang.String endpoint,
                                                                 java.lang.String dsl,
                                                                 java.util.Map<java.lang.String,java.lang.String> params)

DeleteRequestWithJSON2

public static net.sf.json.JSONObject DeleteRequestWithJSON2(java.lang.String endpoint,
                                                            java.lang.String dsl)

DeleteRequestWithJSON

public static com.alibaba.fastjson.JSONObject DeleteRequestWithJSON(java.lang.String endpoint,
                                                                    java.lang.String dsl)

DeleteRequestWithJSON2

public static net.sf.json.JSONObject DeleteRequestWithJSON2(java.lang.String endpoint,
                                                            java.lang.String dsl,
                                                            java.util.Map<java.lang.String,java.lang.String> params)

DeleteRequestWithJSON

public static com.alibaba.fastjson.JSONObject DeleteRequestWithJSON(java.lang.String endpoint,
                                                                    java.lang.String dsl,
                                                                    java.util.Map<java.lang.String,java.lang.String> params)

QueryBySQL2

public static net.sf.json.JSONObject QueryBySQL2(java.lang.String sql)

QueryBySQL

public static com.alibaba.fastjson.JSONObject QueryBySQL(java.lang.String sql)

按SQL进行查询，要求elasticsearch7.3以后的版本

参数:

sql - String

返回:

JSONObject

queryIndexColumn

public static Datastore queryIndexColumn(java.lang.String indexName)

processRequestWithJSON2

public static net.sf.json.JSONObject processRequestWithJSON2(java.lang.String method,
                                                             java.lang.String endpoint,
                                                             java.lang.String dsl,
                                                             java.util.Map<java.lang.String,java.lang.String> params)

processRequestWithJSON

public static com.alibaba.fastjson.JSONObject processRequestWithJSON(java.lang.String method,
                                                                     java.lang.String endpoint,
                                                                     java.lang.String dsl,
                                                                     java.util.Map<java.lang.String,java.lang.String> params)

processRequest

public static java.lang.String processRequest(java.lang.String method,
                                              java.lang.String endpoint,
                                              java.lang.String dsl,
                                              java.util.Map<java.lang.String,java.lang.String> params)

发起请求查询es数据

参数:

method - GET/POST/PUT/DELETE

endpoint - shforce/employee/_search

dsl - 查询dsl语句

params - 参数

返回:

String

main

public static void main(java.lang.String[] args)