【fix sonar】JeroElasticsearchTemplate文件
This commit is contained in:
-70
@@ -156,13 +156,6 @@ public class JeroElasticsearchTemplate {
|
|||||||
public boolean createIndex(String indexName) {
|
public boolean createIndex(String indexName) {
|
||||||
String url = this.getBaseUrl(indexName).toString();
|
String url = this.getBaseUrl(indexName).toString();
|
||||||
|
|
||||||
/* 返回结果 (仅供参考)
|
|
||||||
"createIndex": {
|
|
||||||
"shards_acknowledged": true,
|
|
||||||
"acknowledged": true,
|
|
||||||
"index": "hello_world"
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
try {
|
try {
|
||||||
return RestUtil.put(url).getBoolean("acknowledged");
|
return RestUtil.put(url).getBoolean("acknowledged");
|
||||||
} catch (org.springframework.web.client.HttpClientErrorException ex) {
|
} catch (org.springframework.web.client.HttpClientErrorException ex) {
|
||||||
@@ -210,36 +203,6 @@ public class JeroElasticsearchTemplate {
|
|||||||
url += "&include_type_name=true";
|
url += "&include_type_name=true";
|
||||||
}
|
}
|
||||||
log.info("getIndexMapping-url:" + url);
|
log.info("getIndexMapping-url:" + url);
|
||||||
/*
|
|
||||||
* 参考返回JSON结构:
|
|
||||||
*
|
|
||||||
*{
|
|
||||||
* // 索引名称
|
|
||||||
* "[indexName]": {
|
|
||||||
* "mappings": {
|
|
||||||
* // 分类名称
|
|
||||||
* "[typeName]": {
|
|
||||||
* "properties": {
|
|
||||||
* // 字段名
|
|
||||||
* "input_number": {
|
|
||||||
* // 字段类型
|
|
||||||
* "type": "long"
|
|
||||||
* },
|
|
||||||
* "input_string": {
|
|
||||||
* "type": "text",
|
|
||||||
* "fields": {
|
|
||||||
* "keyword": {
|
|
||||||
* "type": "keyword",
|
|
||||||
* "ignore_above": 256
|
|
||||||
* }
|
|
||||||
* }
|
|
||||||
* }
|
|
||||||
* }
|
|
||||||
* }
|
|
||||||
* }
|
|
||||||
* }
|
|
||||||
* }
|
|
||||||
*/
|
|
||||||
try {
|
try {
|
||||||
return RestUtil.get(url);
|
return RestUtil.get(url);
|
||||||
} catch (org.springframework.web.client.HttpClientErrorException e) {
|
} catch (org.springframework.web.client.HttpClientErrorException e) {
|
||||||
@@ -304,22 +267,6 @@ public class JeroElasticsearchTemplate {
|
|||||||
*/
|
*/
|
||||||
public boolean saveOrUpdate(String indexName, String typeName, String dataId, JSONObject data) {
|
public boolean saveOrUpdate(String indexName, String typeName, String dataId, JSONObject data) {
|
||||||
String url = this.getBaseUrl(indexName, typeName).append("/").append(dataId).append("?refresh=wait_for").toString();
|
String url = this.getBaseUrl(indexName, typeName).append("/").append(dataId).append("?refresh=wait_for").toString();
|
||||||
/* 返回结果(仅供参考)
|
|
||||||
"createIndexA2": {
|
|
||||||
"result": "created",
|
|
||||||
"_shards": {
|
|
||||||
"total": 2,
|
|
||||||
"successful": 1,
|
|
||||||
"failed": 0
|
|
||||||
},
|
|
||||||
"_seq_no": 0,
|
|
||||||
"_index": "test_index_1",
|
|
||||||
"_type": "test_type_1",
|
|
||||||
"_id": "a2",
|
|
||||||
"_version": 1,
|
|
||||||
"_primary_term": 1
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// 去掉 data 中为空的值
|
// 去掉 data 中为空的值
|
||||||
@@ -368,7 +315,6 @@ public class JeroElasticsearchTemplate {
|
|||||||
JSONObject data = dataList.getJSONObject(i);
|
JSONObject data = dataList.getJSONObject(i);
|
||||||
String id = data.getString("id");
|
String id = data.getString("id");
|
||||||
// 该行的操作
|
// 该行的操作
|
||||||
// {"create": {"_id":"${id}", "_index": "${indexName}", "_type": "${typeName}"}}
|
|
||||||
JSONObject action = new JSONObject();
|
JSONObject action = new JSONObject();
|
||||||
JSONObject actionInfo = new JSONObject();
|
JSONObject actionInfo = new JSONObject();
|
||||||
actionInfo.put("_id", id);
|
actionInfo.put("_id", id);
|
||||||
@@ -393,22 +339,6 @@ public class JeroElasticsearchTemplate {
|
|||||||
*/
|
*/
|
||||||
public boolean delete(String indexName, String typeName, String dataId) {
|
public boolean delete(String indexName, String typeName, String dataId) {
|
||||||
String url = this.getBaseUrl(indexName, typeName).append("/").append(dataId).toString();
|
String url = this.getBaseUrl(indexName, typeName).append("/").append(dataId).toString();
|
||||||
/* 返回结果(仅供参考)
|
|
||||||
{
|
|
||||||
"_index": "es_demo",
|
|
||||||
"_type": "docs",
|
|
||||||
"_id": "001",
|
|
||||||
"_version": 3,
|
|
||||||
"result": "deleted",
|
|
||||||
"_shards": {
|
|
||||||
"total": 1,
|
|
||||||
"successful": 1,
|
|
||||||
"failed": 0
|
|
||||||
},
|
|
||||||
"_seq_no": 28,
|
|
||||||
"_primary_term": 18
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
try {
|
try {
|
||||||
return "deleted".equals(RestUtil.delete(url).getString("result"));
|
return "deleted".equals(RestUtil.delete(url).getString("result"));
|
||||||
} catch (org.springframework.web.client.HttpClientErrorException ex) {
|
} catch (org.springframework.web.client.HttpClientErrorException ex) {
|
||||||
|
|||||||
Reference in New Issue
Block a user