程序包 com.sh.wf.util

类 ESRestUtil

java.lang.Object

com.sh.wf.util.ESRestUtil

public class ESRestUtil
extends Object

Description:

Title:首亨软件 - TSS/CRM等

从以下版本开始:

2018年7月24日

构造器概要

构造器

构造器	说明
ESRestUtil()

方法概要

修饰符和类型	方法	说明
static Datastore	convertJSON2Datastore(JSONObject obj)
static String	DeleteRequest(String endpoint)
static String	DeleteRequest(String endpoint, String dsl)
static String	DeleteRequest(String endpoint, String dsl, Map<String,String> params)
static JSONObject	DeleteRequestWithJSON(String endpoint, String dsl)
static JSONObject	DeleteRequestWithJSON(String endpoint, String dsl, Map<String,String> params)
static JSONObject	DeleteRequestWithJSON2(String endpoint, String dsl)
static JSONObject	DeleteRequestWithJSON2(String endpoint, String dsl, Map<String,String> params)
static String	GetRequest(String endpoint, String dsl)
static String	GetRequest(String endpoint, String dsl, Map<String,String> params)
static Datastore	getRequestWithDatastore(String endpoint, String dsl)
static Datastore	getRequestWithDatastore(String endpoint, String dsl, Map<String,String> params)
static JSONObject	GetRequestWithJSON(String endpoint, String dsl)
static JSONObject	GetRequestWithJSON(String endpoint, String dsl, Map<String,String> params)
static JSONObject	GetRequestWithJSON2(String endpoint, String dsl)
static JSONObject	GetRequestWithJSON2(String endpoint, String dsl, Map<String,String> params)
static String	PostRequest(String endpoint, String dsl)
static String	PostRequest(String endpoint, String dsl, Map<String,String> params)
static Datastore	postRequestWithDatastore(String endpoint, String dsl)
static JSONObject	PostRequestWithJSON(String endpoint, String dsl)
static JSONObject	PostRequestWithJSON(String endpoint, String dsl, Map<String,String> params)
static JSONObject	PostRequestWithJSON2(String endpoint, String dsl)
static JSONObject	PostRequestWithJSON2(String endpoint, String dsl, Map<String,String> params)
static String	processRequest(String method, String endpoint, String dsl, Map<String,String> params)	发起请求查询es数据
static JSONObject	processRequestWithJSON(String method, String endpoint, String dsl, Map<String,String> params)
static JSONObject	processRequestWithJSON2(String method, String endpoint, String dsl, Map<String,String> params)
static String	PutRequest(String endpoint, String dsl)
static String	PutRequest(String endpoint, String dsl, Map<String,String> params)
static JSONObject	PutRequestWithJSON(String endpoint, String dsl)
static JSONObject	PutRequestWithJSON(String endpoint, String dsl, Map<String,String> params)
static JSONObject	PutRequestWithJSON2(String endpoint, String dsl)
static JSONObject	PutRequestWithJSON2(String endpoint, String dsl, Map<String,String> params)
static JSONObject	QueryBySQL(String sql)	按SQL进行查询，要求elasticsearch7.3以后的版本
static JSONObject	QueryBySQL2(String sql)
static Datastore	queryIndexColumn(String indexName)

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

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

构造器详细资料

ESRestUtil

public ESRestUtil()

方法详细资料

GetRequest

public static String GetRequest(String endpoint,
 String dsl)

GetRequest

public static String GetRequest(String endpoint,
 String dsl,
 Map<String,String> params)

PostRequest

public static String PostRequest(String endpoint,
 String dsl)

PostRequest

public static String PostRequest(String endpoint,
 String dsl,
 Map<String,String> params)

PutRequest

public static String PutRequest(String endpoint,
 String dsl)

PutRequest

public static String PutRequest(String endpoint,
 String dsl,
 Map<String,String> params)

DeleteRequest

public static String DeleteRequest(String endpoint,
 String dsl)

DeleteRequest

public static String DeleteRequest(String endpoint)

DeleteRequest

public static String DeleteRequest(String endpoint,
 String dsl,
 Map<String,String> params)

GetRequestWithJSON2

public static JSONObject GetRequestWithJSON2(String endpoint,
 String dsl)

GetRequestWithJSON

public static JSONObject GetRequestWithJSON(String endpoint,
 String dsl)

getRequestWithDatastore

public static Datastore getRequestWithDatastore(String endpoint,
 String dsl)

GetRequestWithJSON2

public static JSONObject GetRequestWithJSON2(String endpoint,
 String dsl,
 Map<String,String> params)

GetRequestWithJSON

public static JSONObject GetRequestWithJSON(String endpoint,
 String dsl,
 Map<String,String> params)

getRequestWithDatastore

public static Datastore getRequestWithDatastore(String endpoint,
 String dsl,
 Map<String,String> params)

PostRequestWithJSON2

public static JSONObject PostRequestWithJSON2(String endpoint,
 String dsl)

PostRequestWithJSON

public static JSONObject PostRequestWithJSON(String endpoint,
 String dsl)

postRequestWithDatastore

public static Datastore postRequestWithDatastore(String endpoint,
 String dsl)

convertJSON2Datastore

public static Datastore convertJSON2Datastore(JSONObject obj)

PostRequestWithJSON2

public static JSONObject PostRequestWithJSON2(String endpoint,
 String dsl,
 Map<String,String> params)

PostRequestWithJSON

public static JSONObject PostRequestWithJSON(String endpoint,
 String dsl,
 Map<String,String> params)

PutRequestWithJSON2

public static JSONObject PutRequestWithJSON2(String endpoint,
 String dsl)

PutRequestWithJSON

public static JSONObject PutRequestWithJSON(String endpoint,
 String dsl)

PutRequestWithJSON2

public static JSONObject PutRequestWithJSON2(String endpoint,
 String dsl,
 Map<String,String> params)

PutRequestWithJSON

public static JSONObject PutRequestWithJSON(String endpoint,
 String dsl,
 Map<String,String> params)

DeleteRequestWithJSON2

public static JSONObject DeleteRequestWithJSON2(String endpoint,
 String dsl)

DeleteRequestWithJSON

public static JSONObject DeleteRequestWithJSON(String endpoint,
 String dsl)

DeleteRequestWithJSON2

public static JSONObject DeleteRequestWithJSON2(String endpoint,
 String dsl,
 Map<String,String> params)

DeleteRequestWithJSON

public static JSONObject DeleteRequestWithJSON(String endpoint,
 String dsl,
 Map<String,String> params)

QueryBySQL2

public static JSONObject QueryBySQL2(String sql)

QueryBySQL

public static JSONObject QueryBySQL(String sql)

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

参数:

sql - String

返回:

JSONObject

queryIndexColumn

public static Datastore queryIndexColumn(String indexName)

processRequestWithJSON2

public static JSONObject processRequestWithJSON2(String method,
 String endpoint,
 String dsl,
 Map<String,String> params)

processRequestWithJSON

public static JSONObject processRequestWithJSON(String method,
 String endpoint,
 String dsl,
 Map<String,String> params)

processRequest

public static String processRequest(String method,
 String endpoint,
 String dsl,
 Map<String,String> params)

发起请求查询es数据

参数:

method - GET/POST/PUT/DELETE

endpoint - shforce/employee/_search

dsl - 查询dsl语句

params - 参数

返回:

String