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;
@Override
public String getId() {
return id;
}
}
2.mapper开发
在项目目录“/src/main/java/com/example/es”下新建mapper目录,并在mapper目录下新建EmployeeMapper接口,具体代码如下。
@EasyMapper(indices = "employee", clusterRouter = "sampleCluster")
public interface EmployeeMapper {
@Delete
Boolean deleteEmployeeBoolean(String id);
@Delete
void deleteEmployeeVoid(String id);
@Delete
RestStatus deleteEmployee(Employee employee);
@Delete
DeleteResponse deleteEmployeeDeleteResponse(String id);
@Delete
RestStatus deleteEmployee(String id);
@Delete
CompletableFuture deleteEmployeeBooleanFuture(String id);
@Delete
CompletableFuture deleteEmployeeVoidFuture(String id);
}
3.controller开发
在项目目录“/src/main/java/com/example/es”下新建controller目录,并在controller目录下新建EmployeeController类,以deleteEmployee接口为例演示开发步骤,具体代码如下。
@RestController
@RequestMapping("/employee")
public class EmployeeController {
@Resource
private EmployeeMapper employeeMapper;
@ResponseBody
@RequestMapping(value = "/deleteEmployee", method = RequestMethod.DELETE)
public RestStatus deleteEmployee(@RequestBody Employee employee) {
return employeeMapper.deleteEmployee(employee);
}
}
4.测试
启动项目,然后在postman中请求“http://localhost:8080/employee/deleteEmployee”,返回请求执行结果。
{
"id":"10001"
}
"OK"
5.@Delete属性说明
| 序号 | 属性名 | 默认值 | 说明 |
|---|---|---|---|
| 1 | waitForActiveShards | -2 | 活动分片数量,-2时不指定分片数量,-1或all指定全部分片 |
| 2 | timeout | 1m | 数值+时间单位(ms/s/m/h/M/y) |
| 3 | refreshPolicy | RefreshPolicy.NONE | 默认不刷新 |



