...
|
...
|
@@ -84,7 +84,7 @@ public class UserInfoDataSyncServiceImpl { |
|
|
// 批量增加
|
|
|
BulkRequest bulkAddRequest = new BulkRequest();
|
|
|
for (UserInfo info : userInfoList) {
|
|
|
IndexRequest indexRequest = new IndexRequest("grass", "userInfo", String.valueOf(info.getYoho_uid()));
|
|
|
IndexRequest indexRequest = new IndexRequest("user", "userInfo", String.valueOf(info.getYoho_uid()));
|
|
|
indexRequest.source(JSON.toJSONString(info), XContentType.JSON);
|
|
|
bulkAddRequest.add(indexRequest);
|
|
|
}
|
...
|
...
|
@@ -115,7 +115,7 @@ public class UserInfoDataSyncServiceImpl { |
|
|
try {
|
|
|
BoolQueryBuilder queryBuilder = new BoolQueryBuilder();
|
|
|
queryBuilder.must(QueryBuilders.matchAllQuery());
|
|
|
DeleteByQueryRequest deleteRequest = new DeleteByQueryRequest("grass");
|
|
|
DeleteByQueryRequest deleteRequest = new DeleteByQueryRequest("user");
|
|
|
deleteRequest.setQuery(queryBuilder);
|
|
|
deleteRequest.setDocTypes("userInfo");
|
|
|
BulkByScrollResponse response = rhlClient.deleteByQuery(deleteRequest, RequestOptions.DEFAULT);
|
...
|
...
|
|