From 9be206554485d85eea092532800d990b6b0f12f8 Mon Sep 17 00:00:00 2001 From: bunny <1319900154@qq.com> Date: Sun, 31 Mar 2024 21:18:03 +0800 Subject: [PATCH] =?UTF-8?q?feat(=E6=96=B0=E5=A2=9E):=20=E6=89=B9=E9=87=8F?= =?UTF-8?q?=E6=8F=92=E5=85=A5=E6=96=87=E6=A1=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/itcast/hotel/HotelDocumentTest.java | 20 ++ .../cn/itcast/hotel/HotelDocumentTest.class | Bin 4779 -> 6365 bytes tb_hotel.sql | 245 ++++++++++++++++++ 3 files changed, 265 insertions(+) create mode 100644 tb_hotel.sql diff --git a/src/test/java/cn/itcast/hotel/HotelDocumentTest.java b/src/test/java/cn/itcast/hotel/HotelDocumentTest.java index 57d2f78..fd061d3 100644 --- a/src/test/java/cn/itcast/hotel/HotelDocumentTest.java +++ b/src/test/java/cn/itcast/hotel/HotelDocumentTest.java @@ -5,6 +5,7 @@ import cn.itcast.hotel.pojo.HotelDoc; import cn.itcast.hotel.service.IHotelService; import com.alibaba.fastjson.JSON; import org.apache.http.HttpHost; +import org.elasticsearch.action.bulk.BulkRequest; import org.elasticsearch.action.delete.DeleteRequest; import org.elasticsearch.action.get.GetRequest; import org.elasticsearch.action.get.GetResponse; @@ -21,6 +22,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import java.io.IOException; +import java.util.List; @SpringBootTest public class HotelDocumentTest { @@ -91,4 +93,22 @@ public class HotelDocumentTest { // 发送请求 client.delete(request, RequestOptions.DEFAULT); } + + // 批量插入文档 + @Test + void testBulkRequest() throws IOException { + BulkRequest request = new BulkRequest(); + // 批量查询 + List hotels = hotelService.list(); + hotels.forEach(hotel -> { + // 转换为HotelDoc + HotelDoc hotelDoc = new HotelDoc(hotel); + // 创建文档的请求体 + IndexRequest source = new IndexRequest("hotel").id(hotel.getId().toString()).source(JSON.toJSONString(hotelDoc), XContentType.JSON); + // 添加请求体 + request.add(source); + }); + // 发送请求 + client.bulk(request, RequestOptions.DEFAULT); + } } diff --git a/target/test-classes/cn/itcast/hotel/HotelDocumentTest.class b/target/test-classes/cn/itcast/hotel/HotelDocumentTest.class index 85060f2835e3600d5570633b6fdbbf7b2d4063fe..7a9698c8d5ecd6136b989b38333cb33b0f94ea86 100644 GIT binary patch delta 2016 zcmaJ>=~EkZ7=C^P*|2OOgc;=Qpg<`JC3LEIEK?Nh*gAn}ON#>@%o3K8vSicjhM9hf z!#DMlv;Tk}>e;G=)=-Gn1Fed+TI;Q~-uHdfv*^1=)0H@UNPgG*KF{+$zxTKM8&9w2 z7nkOb0=SG}n%`Dbz~LT-W@Cw~+%}w4#zS57w_VejkcPy6pgjb4?!!iX8ZO&bl z=4dc;Jz{geaa-|Figa|Ts;=n?Dc&RNW9o=jQh@Jy{D2=h{3PIK{K9albz_PY+ZBq& zCe?8{6t-9?LmHJLx|$$AizeKw>ZshKiq$qt+T^4<~o$CLMM>T#I@CCl~flL;*#A0%yTah$P);Rpl z(3s;$ZgI&thb4y9D~D1`gw=d?JQ+966jxvT6ur6vFg#6TA&nPVs|BO9q`c`F=M1R9 zvosgz929X3&(R1xPq7{>7`-JeDKplOeEP4)Dm0*!#wx6F)=sA;lQ(b}RcX{s(>xC*15YF9O>qdiki9t8U`fh_K0)EY%Z|`m-=HP5iq^n- zlwkvv)=r@Ee+*lBycU6+KmcqLM^UGGbu2Qw)q1Nzkt=m^(OIGki~D|ZQ`#b zli$I+EAYRU<)0)b)3){u?ilcI^p6{Nmu~30aACcqVJmU(q%T&##b0j6XZZuff13Eu z*ZO|;>g-xSaQt244_LJolP=(9!o8I=54kWavzV(0^TQP|Kg#OAlh91OUN-lgxIA+`1JD=0e|9ar#&9_T&3n@yNB3SdnTQj&~AUKPwdNSxB z=Vx(EFpar1=F`ddP-oUyv9=9ahU2ealF?x@?(FBE>Zo<_Tt(HiFN2}A8 zg=lozvI(6WZn63@A74>O9=^`r)i<>MmVRbE-;u;$aTb5zPuk&W=P#VYKdAf{f0XXs delta 726 zcmaKp+b#o97=_nVOH-|&HK}Rq6cPr}CNv}x5vh`hM7VKiT#IKAiC36ca6VV7sPnOS z2e07P6|wg2bTkoe_MU(Czt^|czuzJ|Ew0zE>=l4+JSSZf<;IfdMcGfqD?SzF&WKgc z8%I?ML3U`No0wu{08#cI#Wqfn=V_Ec8!_Ku49yFnfyN2eXdja#_E_>`$+C#z20sjDpc{P4Tc`B$*Jq;~`h95UB zx&m5hy{$;uiLGX7>9@4F3LKe6-+eREsK#0(_9B8HhZZKXAH5hspOn>QkWtgHm!|_r z(NYkdNaL6$!l*?CCyf7_c`BJ_R-6^8iNWaSSeQ0)HSLRHSSn`^>bfxqKZX!OjG=~$ z_`1n=qmHaB`F@W092ew=IOI!Q{lmXDGbhye=bkvC4xBziC