ElasticSearch DSL Script使用案例分享

the best elasticsearch highlevel java rest api-----bboss      

ElasticSearch DSL Script使用案例分享，涉及到的功能点：

• 脚本片段使用
• 多行文本使用
• 添加属性字段

1前言
先看看elasticsearch官方的script dsl块文本的写法：通过一对"""   """来包含块文本

{ "query": { "function_score": { "script_score": { "script": { "lang": "painless", "source": """ int total = 0; for (int i = 0; i < doc['goals'].length; ++i) { total += doc['goals'][i]; } return total; """ } } } } }

对应的bboss script dsl块文本的写法：通过一对@"""   """来包含块文本

{ "query": { "function_score": { "script_score": { "script": { "lang": "painless", "source": @""" int total = 0; for (int i = 0; i < doc['goals'].length; ++i) { total += doc['goals'][i]; } return total; """ } } } } }

bboss中管理的dsl块文本和elasticsearch官方的dsl中的块文本唯一的区别就是在开头的"""前面加了个@符号

2.定义dsl配置
在demo.xml文件中增加以下配置

 <property name="scriptPianduan"> <![CDATA[ "params": { "last": #[last], "nick": #[nick] } ]]> </property> <property name="scriptDsl"> <![CDATA[{ "script": { "lang": "painless", "source": @""" ##块文本开始 ctx._source.last = params.last; ctx._source.nick = params.nick """,##块文本结束 @{scriptPianduan} } }]]> </property>

2.执行脚本处理
定义类ScriptImpl,增加方法updateDocumentByScriptPath来执行脚本

package org.bboss.elasticsearchtest.script; /* * Copyright 2008 biaoping.yin * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ import org.bboss.elasticsearchtest.crud.DocumentCRUD; import org.frameworkset.elasticsearch.ElasticSearchHelper; import org.frameworkset.elasticsearch.client.ClientInterface; import java.util.HashMap; import java.util.Map; public class ScriptImpl { private String mappath = "esmapper/demo.xml"; public void updateDocumentByScriptPath(){ //初始化数据，会创建type为demo的indice demo，并添加docid为2的文档 DocumentCRUD documentCRUD = new DocumentCRUD(); documentCRUD.testCreateIndice(); documentCRUD.testBulkAddDocument(); //创建加载配置文件的客户端工具，用来检索文档，单实例多线程安全 ClientInterface clientUtil = ElasticSearchHelper.getConfigRestClientUtil(mappath); Map<String,Object> params = new HashMap<String,Object>(); //为id为2的文档增加last和nick两个属性 params.put("last","gaudreau"); params.put("nick","hockey"); //通过script脚本为文档id为2的文档增加last和nick两个属性，为了演示效果强制refresh，实际环境慎用 clientUtil.updateByPath("demo/demo/2/_update?refresh","scriptDsl",params); //获取更新后的文档，会看到新加的2个字段属性 String doc = clientUtil.getDocument("demo","demo","2"); System.out.println(doc); } }

3.一个比较复杂Script的案例

<property name="updateStoreProductDynamicTemplate"> <![CDATA[ { "query": { "bool": { "must": [ { "term": { "_id": #[id] } } ] } }, "script": { "lang": "painless", "source": @""" ctx._source.is_expired_dynamic_price=params.is_expired_dynamic_price; ctx._source.dynamic_price_template_id=params.dynamic_price_template_id; ctx._source.dynamic_price_template.id=params.dynamic_price_template_id; ctx._source.dynamic_price_template.code=params.dynamic_price_template_code; ctx._source.dynamic_price_template.name=params.dynamic_price_template.name; ctx._source.dynamic_price_template.count_products=params.dynamic_price_template.count_products; ctx._source.dynamic_price_template.is_deleted=params.dynamic_price_template.is_deleted; ctx._source.dynamic_price_template.user_id_update=params.dynamic_price_template.user_id_update; ctx._source.dynamic_price_template.rules=params.ctx._source.dynamic_price_template.rules; """, "params": { "is_expired_dynamic_price": #[isExpiredDynamicPrice], "dynamic_price_template_id": #[dynamicPriceTemplateId], "dynamic_price_template_code":#[dynamicPriceTemplate->code], "dynamic_price_template.name":#[dynamicPriceTemplate->name], "dynamic_price_template.count_products":#[dynamicPriceTemplate->countProducts], "dynamic_price_template.is_deleted":#[dynamicPriceTemplate->isDeleted], "dynamic_price_template.user_id_update":#[dynamicPriceTemplate->userIdUpdate], "dynamic_price_template.rules": [ #foreach($rule in $dynamicPriceTemplate.rules) #if($velocityCount > 0),#end { "id": #[dynamicPriceTemplate->rules[$velocityCount].id], "sort_num": #[dynamicPriceTemplate->rules[$velocityCount]->sortNum], "act_expired_time_tick": #[dynamicPriceTemplate->rules[$velocityCount]->actExpiredTimeTick], "act_expired_time_value": #[dynamicPriceTemplate->rules[$velocityCount]->actExpiredTimeValue], "act_expired_time_unit": #[dynamicPriceTemplate->rules[$velocityCount]->actExpiredTimeUnit], "price_new_type": #[dynamicPriceTemplate->rules[$velocityCount]->priceNewType], "price_new_coefficient": #[dynamicPriceTemplate->rules[$velocityCount]->priceNewCoefficient], "price_new_custom": #[dynamicPriceTemplate->rules[$velocityCount]->priceNewCustom], "auto_set_commend": #[dynamicPriceTemplate->rules[$velocityCount].autoSetCommend], "auto_set_tag": #[dynamicPriceTemplate->rules[$velocityCount]->autoSetTag] } #end ] } } } ]]> </property> 

4 参考资料
https://my.oschina.net/bboss/blog/1556866#h3_37

https://www.elastic.co/guide/en/elasticsearch/painless/6.3/painless-examples.html

elasticsearch技术交流群：166471282

elasticsearch微信公众号：