@@ -138,10 +138,10 @@ public void testQuery() throws Exception {
138138 String uuid = UUID .randomUUID ().toString ();
139139 long timestamp = Instant .now ().getEpochSecond ();
140140 String record = String .format (
141- "host9 ,tag=empty "
141+ "host10 ,tag=empty "
142142 + "name=\" intel\" ,"
143143 + "mem_total=2048,"
144- + "disk_free=100 ,"
144+ + "disk_free=100i ,"
145145 + "temperature=100.86,"
146146 + "isActive=true,"
147147 + "testId=\" %s\" %d" ,
@@ -151,16 +151,19 @@ public void testQuery() throws Exception {
151151 client .writeRecord (record , new WriteOptions (null , WritePrecision .S , null ));
152152
153153 Map <String , Object > parameters = Map .of ("testId" , uuid );
154- String sql = "Select * from host9 where \" testId\" =$testId" ;
154+ String sql = "Select * from host10 where \" testId\" =$testId" ;
155155 try (Stream <Object []> stream = client .query (sql , parameters )) {
156156 stream .findFirst ()
157157 .ifPresent (objects -> {
158- Assertions .assertThat (objects [0 ].getClass ()).isEqualTo (Double .class );
159- Assertions .assertThat (objects [0 ]).isEqualTo (100.0 );
158+ Assertions .assertThat (objects [0 ].getClass ()).isEqualTo (Long .class );
159+ Assertions .assertThat (objects [0 ]).isEqualTo (100L );
160160
161161 Assertions .assertThat (objects [1 ].getClass ()).isEqualTo (Boolean .class );
162162 Assertions .assertThat (objects [1 ]).isEqualTo (true );
163163
164+ Assertions .assertThat (objects [2 ].getClass ()).isEqualTo (Double .class );
165+ Assertions .assertThat (objects [2 ]).isEqualTo (2048.0 );
166+
164167 Assertions .assertThat (objects [3 ].getClass ()).isEqualTo (String .class );
165168 Assertions .assertThat (objects [3 ]).isEqualTo ("intel" );
166169
0 commit comments