快捷導(dǎo)航

SpringBoot實(shí)現(xiàn)elasticsearch索引操作的代碼示例

更新時(shí)間：2023年07月02日 09:05:42 作者：我有一顆五葉草

這篇文章主要給大家介紹了SpringBoot如何實(shí)現(xiàn)elasticsearch 索引操作，文中有詳細(xì)的代碼示例，感興趣的同學(xué)可以參考閱讀下

0. 引入依賴

<dependency>
	<groupId>org.elasticsearch.client</groupId>
	<artifactId>elasticsearch-rest-high-level-client</artifactId>
	<version>7.12.1</version>
</dependency>

1. 實(shí)例創(chuàng)建與關(guān)閉

private RestHighLevelClient client;
void setUp() {
    this.client = new RestHighLevelClient(RestClient.builder(
            HttpHost.create("http://IP:9200")
    ));
}
void tearDown() throws IOException {
    this.client.close();
}

2. 創(chuàng)建索引

@RequestMapping("/create")
public String createHotelIndex() throws IOException {
    setUp();
    // 1.創(chuàng)建Request對(duì)象 "name" 是需要?jiǎng)?chuàng)建的索引名 一般在項(xiàng)目中只創(chuàng)建一次 所以這里是寫(xiě)死的
    CreateIndexRequest request = new CreateIndexRequest("name");
    // 2.準(zhǔn)備請(qǐng)求的參數(shù)：DSL語(yǔ)句
    request.source(MAPPING_TEMPLATE, XContentType.JSON);
    // 3.發(fā)送請(qǐng)求
    CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
    tearDown();
    return createIndexResponse.isAcknowledged() ? "創(chuàng)建成功" : "創(chuàng)建失敗";
}

3. 測(cè)試索引庫(kù)存在不存在

@RequestMapping("/testExistsHotelIndex/{indexName}")
public String testExistsHotelIndex(@PathVariable("indexName") String indexName) throws IOException {
	setUp();
	// 1.創(chuàng)建Request對(duì)象
	GetIndexRequest request = new GetIndexRequest(indexName);
	// 2.發(fā)送請(qǐng)求
	boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
	tearDown();
	return exists ? "索引庫(kù)已經(jīng)存在！" : "索引庫(kù)不存在！";
}

4. 刪除索引庫(kù)

@RequestMapping("/testDeleteHotelIndex")
void testDeleteHotelIndex() throws IOException {
    setUp();
    // 1.創(chuàng)建Request對(duì)象
    DeleteIndexRequest request = new DeleteIndexRequest("索引名稱");
    // 2.發(fā)送請(qǐng)求
    client.indices().delete(request, RequestOptions.DEFAULT);
    tearDown();
}

5. 遍歷導(dǎo)入數(shù)據(jù)

不建議遍歷導(dǎo)入，這樣效率低低

@RequestMapping("/addAll")
public List<HotelDoc> addAll() throws IOException {
    List<Hotel> list = hotelService.list();
    List<HotelDoc> docList = list.stream().map(p -> new HotelDoc(p)).collect(Collectors.toList());
    setUp();
    for (HotelDoc hotelDoc : docList) {
        String jsonString = JSON.toJSONString(hotelDoc);
        // 1.準(zhǔn)備Request對(duì)象
        IndexRequest request = new IndexRequest("索引名稱").id(hotelDoc.getId().toString());
        // 2.準(zhǔn)備Json文檔
        request.source(jsonString, XContentType.JSON);
        // 3.發(fā)送請(qǐng)求
        IndexResponse index = client.index(request, RequestOptions.DEFAULT);
        System.out.println(hotelDoc.getName() + ":" + index.status());
    }
    tearDown();
    return null;
}

6. 批量導(dǎo)入數(shù)據(jù)（推薦）

@RequestMapping("/testBulkRequest")
public void testBulkRequest() throws IOException {
	List<Hotel> hotels = hotelService.list();
	setUp();
	// 1.創(chuàng)建Request
	BulkRequest request = new BulkRequest();
	// 2.準(zhǔn)備參數(shù)，添加多個(gè)新增的Request
	for (Hotel hotel : hotels) {
		// 2.1.轉(zhuǎn)換為文檔類型HotelDoc
		HotelDoc hotelDoc = new HotelDoc(hotel);
		// 2.2.創(chuàng)建新增文檔的Request對(duì)象
		request.add(new IndexRequest("索引名稱")
			.id(hotelDoc.getId().toString())
			.source(JSON.toJSONString(hotelDoc), XContentType.JSON));
	}
	// 3.發(fā)送請(qǐng)求
	client.bulk(request, RequestOptions.DEFAULT);
	tearDown();
}

到此這篇關(guān)于SpringBoot實(shí)現(xiàn)elasticsearch索引操作的代碼示例的文章就介紹到這了,更多相關(guān)SpringBoot elasticsearch索引操作內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: