es脚本实现字段之间进行比对

落日映苍穹つ 2022-10-05 00:43 388阅读 0赞

**script**

{ 
      "script": { 
        "source": "ctx._source.['extra'] = 'test'",
        "lang": "painless"
      },
      "query": { 
        "term": { 
          "user": "kimchy"
        }
      }
    }

**java**

BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
     Map<String, Object> params = new HashMap<>(16);
     params.put("user","kimchy");
     Script script = new Script(Script.DEFAULT_SCRIPT_TYPE, "painless", "ctx._source.['extra'] = 'test'", params);
     ScriptQueryBuilder scriptQueryBuilder = QueryBuilders.scriptQuery(script);
     System.out.println(scriptQueryBuilder.toString());

[以下内容转载于ZhaoYingChao88][ZhaoYingChao88]  
**示例script**

{ 
    	"from": 0,
    	"size": 100,
    	"query": { 
    		"bool": { 
    			"filter": { 
    				"script": { 
    					"script": { 
    						"inline": "doc['count'].value - doc['num'].value == 0",
    						"lang": "painless"
    					},
    					"boost": 1
    				}
    			}
    		}
    	}
    }

**javaApi 如下:**

Map<String, Object> params = new HashMap<>();
            Script script = new Script(ScriptType.INLINE,"painless","doc['count'].value - doc['num'].value == 0",params);
            ScriptQueryBuilder scriptQueryBuilder = new ScriptQueryBuilder(script);
            StringBuffer queryString = new StringBuffer();
           // queryString.append("goods_id:18506");
            QueryStringQueryBuilder queryStringQueryBuilder = new QueryStringQueryBuilder(queryString.toString());
            BoolQueryBuilder booleanQueryBuilder = QueryBuilders.boolQuery();
            booleanQueryBuilder.must(scriptQueryBuilder);
            if (queryString.length() > 0){ 
                booleanQueryBuilder.must(queryStringQueryBuilder);
            }
            System.out.println("查询条件:" + booleanQueryBuilder);
            SearchResponse searchResponse = getClient().prepareSearch("goods_recommend")
                    .setTypes("tags")
                    .setQuery(booleanQueryBuilder)
                    .get();
            SearchHit[] hits = searchResponse.getHits().getHits();
            List list = new ArrayList();
            for (int i = 0; i < hits.length; i++) { 
                System.out.println(JSON.toJSON(hits[i]));
            // list.add(hits[i].getId());
            }

**ES中Date型字段不能直接用>,<,+,-进行比较和计算，会报错。**  
可以先把Date类型取得getMillis()，取得时间戳，然后就可以进行比较了。

使用TransportClient代码如下,param是传入的参数，可以在script中使用

Map<String, Object> params = Maps.newHashMap();
            params.put("datesub", 5);
            QueryBuilder qb = QueryBuilders.boolQuery()
                    .must(QueryBuilders.scriptQuery(
                            new Script(Script.DEFAULT_SCRIPT_TYPE, 
                                    Script.DEFAULT_SCRIPT_LANG, 
                                    "doc['updated_time'].value.getMillis() - doc['create_time'].value.getMillis() < params.datesub", 
                                    params)));

**script**

{ 
    	"from": 0,
    	"size": 100,
    	"query": { 
    		"bool": { 
    			"filter": { 
    				"script": { 
    					"script": { 
    						"inline": "doc['updated_time'].value.getMillis() - doc['updated_time'].value.getMillis() == 0",
    						"lang": "painless"
    					},
    					"boost": 1
    				}
    			}
    		}
    	}
    }

[ZhaoYingChao88]: https://zyc88.blog.csdn.net/article/details/103605428