一、概念

 es1.4-5.0，默认脚本语言是Grovvy

es5.0+，默认脚本语言是painless

 二、简单使用

将price减一

# 将id=1的price减一
POST goods/_update/1
{"script": {"source": "ctx._source.price -= 1"}
}# 简写
POST goods/_update/1
{"script": "ctx._source.price -= 1"
}

其中，ctx是一个上下文对象 ，用在对数据的修改上

三、CRUD

1、数据备份

（数据来源可以查看：CSDN）

#将goods中的数据备份到goods2中
POST _reindex
{"source": {"index": "goods"},"dest": {"index": "goods2"}
}

2. 新增数组中的值

# 将id=1的tags新增一个值
POST goods/_update/1
{"script": "ctx._source.tags.add('无线充电')"
}

3. 根据id删除

# 删除id=11的数据
POST goods/_update/11
{"script": "ctx.op='delete'"
}

 4. upsert

如果数据存在执行script中的内存，如果数据不存在，执行upsert中内存

POST goods/_update/15
{"script": {"source": "ctx._source.price += 100"},"upsert": {"name":"香蕉","price": 599}
}

第一次执行结果

 第二次执行结果

 5. 查询

使用expression和painless两种语言进行查询，查询结果相同

GET goods/_search
{"script_fields": {"new_price": {"script": {"lang": "expression","source": "doc['price'].value * 0.9"}}}
}GET goods/_search
{"script_fields": {"new_price": {"script": {"lang": "painless","source": "doc['price'] * 0.9"}}}
}

painless，doc['age'].value和doc['age']都能正确输出，但是doc['age'] * 0.9报错
expression，doc['age'].value和doc['age']都能正确输出，doc['age'] * 0.9和doc['age'].value * 0.9也都不报错

但是，painless，如果字段为空，*0.9会报错

expression：只能访问数字、布尔值、日期等，存储的字段不可用

es源数据是map类型的，在取值的时候，要根据doc['xxx']取值

update用ctx，查询的时候用doc

6. 参数化查询

给interest加一个值aaa

POST indexname/_update/2
{"script": {"lang": "painless","source": "ctx._source.interest.add('aaa')"}
}

es在首次执行脚本的时候，会对执行的脚本进行编译，并且把编译的结果放在缓冲区内。es的缓冲区默认只有100M,编译操作很消耗性能，es每分钟支持的编译次数是15次
解决方案是：

POST indexname/_update/2
{"script": {"lang": "painless","source": "ctx._source.interest.add(params.inserest_name)","params": {"inserest_name":"bbb"}}
}

这样，参数是动态传递的，没有硬编码，下次参数内容发生改变，但是脚本没有发生改变，不需要重新编译，节省性能

同理，也可以这样

GET indexname/_search
{"script_fields": {"new_age": {"script": {"lang": "painless","source":"doc['age'].value * params.num","params": {"num": 0.9}}}}
}

如果是expression，就要把params.num改成num

GET indexname/_search
{"script_fields": {"new_age": {"script": {"lang": "expression","source":"doc['age'].value * num","params": {"num": 0.9}}}}
}

结果数组

GET indexname/_search
{"script_fields": {"age": {"script": {"lang": "painless","source":"doc['age'].value"}},"new_age": {"script": {"lang": "painless","source":"[doc['age'].value - params.num_1,doc['age'].value - params.num_2,doc['age'].value - params.num_3]","params": {"num_1": 1,"num_2": 2,"num_3": 3}}}}
}

四、stored scripts：scripts模板

1. 操作脚本

因为脚本编译比较消耗性能，可以把脚本保存在集群的缓存中

语法

/_scripts/{script_id}

创建脚本

POST _scripts/age_num
{"script":{"lang": "painless","source":"doc['age'].value - params.num"}
}

查看脚本

GET _scripts/age_num

使用脚本

GET indexname/_search
{"script_fields": {"age": {"script": {"lang": "painless","source":"doc['age'].value"}},"new_age": {"script": {"id": "age_num","params": {"num": 0.9}}}}
}

2. scripting的函数式编程

在source中加"""，三个双引号

POST indexname/_update/2
{"script": {"lang": "painless","source": """ctx._source.interest.add(params.inserest_name);ctx._source.age-=1;""","params": {"inserest_name": "bbb"}}
}

如果name中包含aa：name+bb；否则，不操作。==~是匹配的意思

POST indexname/_update/2
{"script": {"lang": "painless","source": """if(ctx._source.name ==~ /[\s\S]*aa[\s\S]*/){ctx._source.name+="bb"}else{ctx.op="noop"}"""}
}

for循环取insterst的总数

GET indexname/_search
{"aggs": {"agg_insterst": {"sum": {"script": {"lang": "painless","source": """int total=0;for(int i=0; i