@Test void testBulkRequest() throws IOException { List<Hotel> list = hotelService.list(); for (Hotel hotel : list){ HotelDoc hotelDoc = new HotelDoc(hotel); IndexRequest indexRequest = new IndexRequest("hotel") .id(hotelDoc.getId().toString()) .source(JSON.toJSONString(hotelDoc), XContentType.JSON); client.index(indexRequest,RequestOptions.DEFAULT); } }

你的代码示例是一个简单的方法，用于将MySQL中的酒店数据同步到Elasticsearch中。在这个方法中，你首先从`hotelService`中获取酒店数据的列表。

然后，你使用`for`循环遍历每个酒店对象，并将其转换为`HotelDoc`对象。`HotelDoc`可能是一个自定义的数据对象，用于表示酒店数据在Elasticsearch中的文档结构。

接下来，你创建一个`IndexRequest`对象，将`hotelDoc`对象的JSON表示作为文档的源，并指定文档的ID。这样可以确保每个文档都有一个唯一的标识符。

最后，你使用Elasticsearch客户端的`index`方法将文档写入到名为"hotel"的索引中。

请注意，这段代码是在单线程中执行的，因此每个酒店对象都会按顺序进行索引请求。如果你想使用多线程来提高同步速度，你可以将循环部分放入一个线程池中，并使用多个线程同时处理不同的酒店对象。

你也可以根据需要添加错误处理和日志记录来增强代码的健壮性和可维护性。