From 5d5a36b7528afd40f772feda3ba6b866d038c745 Mon Sep 17 00:00:00 2001 From: bunny <1319900154@qq.com> Date: Sun, 31 Mar 2024 20:31:59 +0800 Subject: [PATCH] =?UTF-8?q?feat(=E6=96=B0=E5=A2=9E):=20=E6=8F=92=E5=85=A5?= =?UTF-8?q?=E6=96=87=E6=A1=A3=EF=BC=8C=E8=AE=B0=E5=BE=97=E8=BD=AC=E6=8D=A2?= =?UTF-8?q?=E6=88=90JSON=E5=AF=B9=E8=B1=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 8 +-- src/main/resources/application.yaml | 2 +- .../cn/itcast/hotel/HotelDocumentTest.java | 52 ++++++++++++++++++ target/classes/application.yaml | 2 +- .../cn/itcast/hotel/HotelDocumentTest.class | Bin 0 -> 2894 bytes 5 files changed, 58 insertions(+), 6 deletions(-) create mode 100644 src/test/java/cn/itcast/hotel/HotelDocumentTest.java create mode 100644 target/test-classes/cn/itcast/hotel/HotelDocumentTest.class diff --git a/pom.xml b/pom.xml index da041ee..24783ee 100644 --- a/pom.xml +++ b/pom.xml @@ -1,5 +1,5 @@ - 4.0.0 @@ -49,13 +49,13 @@ - + com.alibaba fastjson - 1.2.71 + 2.0.47 - + org.apache.commons commons-lang3 diff --git a/src/main/resources/application.yaml b/src/main/resources/application.yaml index 52233d6..415932d 100644 --- a/src/main/resources/application.yaml +++ b/src/main/resources/application.yaml @@ -2,7 +2,7 @@ server: port: 8089 spring: datasource: - url: jdbc:mysql://mysql:3306/tb_hotel?useSSL=false + url: jdbc:mysql://106.15.251.123:3305/tb_hotel?useSSL=false username: root password: "02120212" driver-class-name: com.mysql.jdbc.Driver diff --git a/src/test/java/cn/itcast/hotel/HotelDocumentTest.java b/src/test/java/cn/itcast/hotel/HotelDocumentTest.java new file mode 100644 index 0000000..630c6e8 --- /dev/null +++ b/src/test/java/cn/itcast/hotel/HotelDocumentTest.java @@ -0,0 +1,52 @@ +package cn.itcast.hotel; + +import cn.itcast.hotel.pojo.Hotel; +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.index.IndexRequest; +import org.elasticsearch.client.RequestOptions; +import org.elasticsearch.client.RestClient; +import org.elasticsearch.client.RestHighLevelClient; +import org.elasticsearch.common.xcontent.XContentType; +import org.junit.jupiter.api.AfterEach; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.test.context.SpringBootTest; + +@SpringBootTest +public class HotelDocumentTest { + private RestHighLevelClient client; + @Autowired + private IHotelService hotelService; + + @BeforeEach + void setup() throws Exception { + this.client = new RestHighLevelClient(RestClient.builder( + HttpHost.create("http://192.168.1.4:9200")) + ); + } + + @AfterEach + void teardown() throws Exception { + this.client.close(); + } + + // 插入文档，记得转换成JSON对象 + @Test + void testAddDocument() throws Exception { + // 根据id查询酒店数据 + Hotel hotel = hotelService.getById(61083L); + // 转换为文档类型，其中有经纬度转换 + HotelDoc hotelDoc = new HotelDoc(hotel); + + // 1. 准备Request对象 + IndexRequest request = new IndexRequest("hotel").id(String.valueOf(hotelDoc.getId())); + // 2. 准备JSON文档 + request.source(JSON.toJSONString(hotelDoc), XContentType.JSON); + // 3. 发送请求 + client.index(request, RequestOptions.DEFAULT); + } +} diff --git a/target/classes/application.yaml b/target/classes/application.yaml index 52233d6..415932d 100644 --- a/target/classes/application.yaml +++ b/target/classes/application.yaml @@ -2,7 +2,7 @@ server: port: 8089 spring: datasource: - url: jdbc:mysql://mysql:3306/tb_hotel?useSSL=false + url: jdbc:mysql://106.15.251.123:3305/tb_hotel?useSSL=false username: root password: "02120212" driver-class-name: com.mysql.jdbc.Driver diff --git a/target/test-classes/cn/itcast/hotel/HotelDocumentTest.class b/target/test-classes/cn/itcast/hotel/HotelDocumentTest.class new file mode 100644 index 0000000000000000000000000000000000000000..cf748cc648c1c5750098e51a0d658183f40cf90e GIT binary patch literal 2894 zcmb7GYgZFT7=9*z3vs=HHxO%;ssVukYVi`P4TuFAp%O%?y=^u_vN73-yAv+<{-uAS zpZf#qX@S<$o__9+=}+kCJG+qtlTZui%xrdMp7)vOz3pHB{PqWctN1R82wDuZnrOoT zhNF3F&Ef^i&GLnGUf7D^z=Y#E>J~#wtbf@+JHw##vRo7_UpclfEYHqyyWj{{@kQaQ z87G@diZxM~3f>urGMv^YtdeEt1kWi|;xjbNNME(XWH_Z?-Q;}q#@O)a`1Rq@;j1@q zjE#&$(SgGzj^HS?q88~j@1Wq#a?Mppm%wVL; zP9Y;ahS}KT=GdXxrb2{hlOYrlF>qR|+|9sa0qAR<>|gG{8T1-BYvK)@V>oZS+)*~^ z&vR0V0-w?29ch<~}IW4w)GjsE`rA&LQ9F)(Oi2*V7AtDa0sH%r2=S%tD#SY_yn z&GpwfS}(^BVg#cG#!S48s|*)k%Q%5%g__))%`gm9V#kr3s5w@_d1j>xg5sx2BnQ=YR~OS+Pyi@^tu$6_pxXoWnxKl>$YW) zlmF6I+TyE}33;DnnoBLrQ;;gDA3`%7SjIyGk4&uKBg%$)i3zDlXE$u=DqX`KO@$9j znPaDYae}Nkno#wK2;B#08(k5(>A1*hz z{>#c8gw;Yx$D2<{b7%T);z4qWp^?F`xKO#TJrvZARTEj{D9nP8W%#~PscX)+ks6H% zR!aVVM~`2k>j=ug?!~gJoT6BEe1~#A;kr^;mCIfa%=#tWOjbRsDAuL-gr|k&`V?HY zlHMk_b`S7GS;=+B6B&YSost>y?2)A7iurOeExaXNQYgQY(zXiA7L^(LU3uB6at?{x zS62+`DmX#6`9hUT4AJQgTZDcwK&QK^#cFqj;X-hSe3^PR&zDP%5*~G2hfj)C>4|A- zy#(2=s9k5|x=T%@$^OJDovds>qNvg&GMSgHg`u~Oc}*E3{GcGwcB**$?4%7u#_+=M zVHj%Q_U197S?D;fzpHM21RPBT`F7XQemGet?XcF5VLSk-bGnp@>ud9%9&9L{3c_NN z-UskFPyH}L-7G@?)Q*EEYK~xV==lK6d74{krY|ZQpU^K(Go!g}U>ocwdWfJvqh1D% zqe!C}Zh#9(zkm|0wgiXo)0czZcV^%PjFr~k(XrCfd2k1ZQad=djZ?p%rwZ9gmT4;v zp%=$!?jep<_%jvwr?f{i^maKbdIOYqjgHf*HrhV$GkUi0X4QiJVg!9480f1(Zf}ab zrh&1(i~J*9OLLqhyGozQ9*a!(ffl+E}V*%BH&~Sxn7shcL j8+1**cN5R(Vk79r7x