1.po开发
在项目目录“/src/main/java/com/example/es”下新建po目录，并在po目录下新建Employee实体类，具体代码如下。

@Data
public class Employee implements IdProvider {@JsonProperty("id")private String id;@JsonProperty("name")private String name;@JsonProperty("age")private Integer age;@JsonProperty("birthday")private String birthday;@JsonProperty("job")private String job;@JsonProperty("salary")private Float salary;@Overridepublic String getId() {return id;}
}

2.mapper开发
在项目目录“/src/main/java/com/example/es”下新建mapper目录，并在mapper目录下新建EmployeeMapper接口，具体代码如下。

@EasyMapper(indices = "employee", clusterRouter = "sampleCluster")
public interface EmployeeMapper {/*** 更新员工，支持部分更新，如果文档不存在，则做插入操作** @param employee 员工* @return UpdateResponse*/@Update(docAsUpsert = true)UpdateResponse updateEmployee(Employee employee);/*** 更新员工，支持部分更新** @param employee 员工* @return GetResult*/@UpdateGetResult updateEmployeeGetResult(Employee employee);/*** 更新员工，支持部分更新** @param employee 员工* @return RestStatus状态码*/@UpdateRestStatus updateEmployeeRestStatus(Employee employee);/*** 更新员工，支持部分更新** @param employee 员工* @return 更新成功，返回true*/@UpdateBoolean updateEmployeeBoolean(Employee employee);/*** 更新员工，支持部分更新** @param employee 员工* @return 更新成功，返回true*/@Updateboolean updateEmployeeBool(Employee employee);/*** 更新员工，支持部分更新** @param employee 员工* @return Result*/@UpdateResult updateEmployeeResult(Employee employee);/*** 更新员工，支持部分更新** @param employee 员工*/@Updatevoid updateEmployeeVoid(Employee employee);/*** 异步更新员工，支持部分更新** @param employee 订单* @return 异步结果*/@UpdateCompletableFuture<Result> updateEmployeeFuture(Employee employee);/*** 异步更新员工，支持部分更新** @param employee 员工* @return 异步结果*/@UpdateCompletableFuture<Void> updateEmployeeFutureVoid(Employee employee);
}

3.controller开发
在项目目录“/src/main/java/com/example/es”下新建controller目录，并在controller目录下新建EmployeeController类，以deleteEmployee接口为例演示开发步骤，具体代码如下。

@RestController
@RequestMapping("/updateEmployee")
public class EmployeeController {@Resourceprivate EmployeeMapper employeeMapper;@ResponseBody@RequestMapping(value = "/updateEmployee", method = RequestMethod.POST)public UpdateResponse updateEmployee(@RequestBody Employee employee) {return employeeMapper.updateEmployee(employee);}
}

4.测试
启动项目，然后在postman中请求“http://localhost:8080/employee/updateEmployee”，返回请求执行结果。

{"id": "10001","name": "Mike Owen","age": 31,"birthday": "1991-08-01","job": "CEO","salary": 60000.0
}

(1).文档存在进行修改的返回结果

{"shardInfo": {"total": 2,"successful": 1,"failures": [],"failed": 0,"fragment": false},"shardId": {"index": {"name": "employee","uuid": "_na_","fragment": false},"id": -1,"indexName": "employee","fragment": true},"id": "10001","type": "_doc","version": 2,"seqNo": 14,"primaryTerm": 7,"result": "UPDATED","getResult": null,"index": "employee","fragment": false
}

(2).文档不存在进行插入的返回结果

{"shardInfo": {"total": 2,"successful": 1,"failures": [],"failed": 0,"fragment": false},"shardId": {"index": {"name": "employee","uuid": "_na_","fragment": false},"id": -1,"indexName": "employee","fragment": true},"id": "10001","type": "_doc","version": 1,"seqNo": 13,"primaryTerm": 7,"result": "CREATED","getResult": null,"index": "employee","fragment": false
}

5.@Update属性说明

序号	属性名	默认值	说明
1	docAsUpsert	false	设置true，当文档不存在时，做插入操作
2	retryOnConflict	0	设置版本冲突时，重试的次数
3	refreshPolicy	RefreshPolicy.NONE	默认不刷新
4	waitForActiveShards	-2	活动分片数量，-2时不指定分片数量，-1或all指定全部分片
5	scriptedUpsert	false	运行脚本，无论文档是否存在