栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

8.3 SpringBoot集成ElasticSearch之删除文档

8.3 SpringBoot集成ElasticSearch之删除文档

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属性说明

序号属性名默认值说明
1waitForActiveShards-2活动分片数量,-2时不指定分片数量,-1或all指定全部分片
2timeout1m数值+时间单位(ms/s/m/h/M/y)
3refreshPolicyRefreshPolicy.NONE默认不刷新
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/434077.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号