JavaRestClient批量导入数据

2024-01-02 16:50:02

目录

一、批量导入数据


一、批量导入数据

批量查询酒店数据,然后批量导入索引库中?

  1. 利用mybatis-plus查询酒店数据
  2. 将查询到的酒店数据 (Hotel) 转换为文档类型数据 (HotelDoc)
  3. 利用lavaRestClient中的Bulk批处理,实现批量新增文档,示例代码如下
@Test
void testBulk() throws IOException {
    // 批量查询酒店数据
    List<Hotel> hotels = hotelService.list();
    // 1.创建BuLk请求
    BulkRequest request = new BulkRequest();
    // 2.添加要批量提交的请求:这里添加了两个新增文档的请求
    for(){
        // 转换为文档类型HotelDoc
        HotelDoc hotelDoc = new HotelDoc(hotel);
        // 创建邢增文档的Request对象
        request.add(new IndexRequest("hotel").id(hotelDoc.getId().toString()).source(JSON.toJSONString(hotelDoc),XContentType.JSON));
    }
   
    // 3.发起bulk请求
    client.bulk(request,RequestOptions.DEFAULT);
}

文章来源:https://blog.csdn.net/m0_60769905/article/details/135339265
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。