8.2 SpringBoot集成ElasticSearch之新增文档

8.2 SpringBoot集成ElasticSearch之新增文档

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

@Data
public class EmployeeEntity {
	@JsonProperty("employeeId")
    private String employeeId;
    
    @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;
}

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

@EasyMapper(indices = "employee", clusterRouter = "sampleCluster")
public interface EmployeeMapper {
    
    @Index
    Boolean indexEmployeeBoolean(EmployeeEntity employeeEntity);

    
    @Index
    String indexEmployeeString(EmployeeEntity employeeEntity);

    
    @Index
    void indexEmployeeVoid(EmployeeEntity employeeEntity);

    
    @Index
    IndexResponse indexEmployeeIndexResponse(EmployeeEntity employeeEntity);

    
    @Index
    RestStatus indexEmployeeRestStatus(EmployeeEntity employeeEntity);

    
    @Index
    CompletableFuture indexEmployeeCompletableFuture(EmployeeEntity employeeEntity);

    
    @Index
    CompletableFuture indexEmployeeFutureVoid(EmployeeEntity employeeEntity);
}

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

@RestController
@RequestMapping("/employee")
public class EmployeeController {
    @Resource
    private EmployeeMapper employeeMapper;

    @ResponseBody
    @RequestMapping(value = "/indexEmployeeString", method = RequestMethod.POST)
    public String indexEmployeeString(@RequestBody EmployeeCondition employeeCondition) {
        return employeeMapper.indexEmployeeString(employeeCondition);
    }
}

4.测试
启动项目，然后在postman中请求“http://localhost:8080/employee/indexEmployeeString”，成功后返回文档id。

{
    "employeeId":10000008,
	"name": "Damian Lillard",
	"job": "Vue engineer",
	"age": 25,
	"salary": 18000.00,
	"birthday": "1996-10-01"
}

qfuPv3wBpyKimLS2Ar_q

5.@Index属性说明

序号属性名默认值说明1timeout1m数值+时间单位(ms/s/m/h/M/y)2refreshPolicyRefreshPolicy.NONE默认不刷新3pipeline可选4versionTypeVersionType.INTERNAL5waitForActiveShards-2活动分片数量，-2时不指定分片数量，-1或all指定全部分片

6.指定文档id新增(一般将文档id的值设置为文档主键字段)
(1).入参实体需实现IdProvider接口

@Data
public class EmployeeEntity implements IdProvider {
    @JsonProperty("id")
    private String id;

	@JsonProperty("employeeId")
    private String employeeId;

    @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).测试
启动项目，然后在postman中请求“http://localhost:8080/employee/indexEmployeeString”，成功后返回文档id。

{
    "id":"10000009",
    "employeeId":10000009,
	"name": "Damian Lillard",
	"job": "Vue engineer",
	"age": 25,
	"salary": 18000.00,
	"birthday": "1996-10-01"
}

10000009

7.批量新增
(1).mapper开发
在项目目录“/src/main/java/com/example/es”的EmployeeMapper类中新增批量创建员工接口，具体代码如下。

@EasyMapper(indices = "employee", clusterRouter = "sampleCluster")
public interface EmployeeMapper {
	
    @Bulk(bulkType = BulkType.INDEX)
    List bulkIndexEmployeeList(List employeeEntityList);

    
    @Bulk(bulkType = BulkType.INDEX)
    List bulkIndexEmployeeList(EmployeeEntity... employeeEntities);

    
    @Bulk(bulkType = BulkType.INDEX)
    BulkItemResponse[] bulkIndexEmployeeArray(EmployeeEntity... employeeEntities);

    
    @Bulk(bulkType = BulkType.INDEX)
    BulkResponse bulkIndexEmployeeBulkResponse(EmployeeEntity... employeeEntities);
}

(2).controller开发
在项目目录“/src/main/java/com/example/es”下的EmployeeController类中新增批量创建员工接口，以接口bulkIndexEmployeeList为例演示开发步骤，具体代码如下。

@RestController
@RequestMapping("/employee")
public class EmployeeController {
    @Resource
    private EmployeeMapper employeeMapper;

    @ResponseBody
    @RequestMapping(value = "/bulkIndexEmployeeList", method = RequestMethod.POST)
    public List bulkIndexEmployeeList(@RequestBody List employeeConditionList) {
        return employeeMapper.bulkIndexEmployeeList(employeeConditionList);
    }
}

(3).测试
启动项目，然后在postman中请求“http://localhost:8080/employee/bulkIndexEmployeeList”，成功后返回对应的信息。

[
  {
    "id": "10000011",
    "employeeId": 10000011,
    "name": "Stephen Curry",
    "job": "Java engineer",
    "age": 27,
    "salary": 20000.00,
    "birthday": "1995-08-06"
  },
  {
    "id": "10000012",
    "employeeId": 10000012,
    "name": "Stephen Curry",
    "job": "Java engineer",
    "age": 27,
    "salary": 20000.00,
    "birthday": "1995-08-06"
  }
]

[
    {
        "id": "10000011",
        "opType": "INDEX",
        "response": {
            "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": "10000011",
            "type": "_doc",
            "version": 1,
            "seqNo": 4,
            "primaryTerm": 1,
            "result": "CREATED",
            "index": "employee",
            "fragment": false
        },
        "failure": null,
        "type": "_doc",
        "index": "employee",
        "version": 1,
        "failureMessage": null,
        "itemId": 0,
        "failed": false,
        "fragment": false
    },
    {
        "id": "10000012",
        "opType": "INDEX",
        "response": {
            "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": "10000012",
            "type": "_doc",
            "version": 1,
            "seqNo": 4,
            "primaryTerm": 1,
            "result": "CREATED",
            "index": "employee",
            "fragment": false
        },
        "failure": null,
        "type": "_doc",
        "index": "employee",
        "version": 1,
        "failureMessage": null,
        "itemId": 1,
        "failed": false,
        "fragment": false
    }
]

(4).注解
@Bulk注解标明此方法是批量方法，同时必须要指定BulkType标明是何种类型的批量 *** 作。做批量更新 *** 作时，如果想文档不存在则做插入 *** 作，设置@Update(docAsUpsert=true)。

(5).@Bulk属性说明

序号属性名默认值说明1bulkType必填可选类型:INDEX/DELETE/UPDATE2timeout1m数值+时间单位(ms/s/m/h/M/y)3waitForActiveShards-2活动分片数量，-2时不指定分片数量，-1或all指定全部分片4index可选bulkType = INDEX有效5delete可选bulkType = DELETE有效6update可选bulkType = UPDATE有效7refreshPolicyRefreshPolicy.NONE