@@ -185,12 +185,14 @@ internal class ITQueryKotlinApi : AbstractITInfluxDBClientKotlin() {
185
185
val lines = queryKotlinApi.queryRaw(flux).toList()
186
186
187
187
assertThat(lines).hasSize(7 )
188
- assertThat(lines[0 ]).isEqualTo(" #datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,string ,string,string,string,long " )
189
- assertThat(lines[1 ]).isEqualTo(" #group,false,false,true,true,true ,true,true,true,false " )
188
+ assertThat(lines[0 ]).isEqualTo(" #datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,long ,string,string,string,string " )
189
+ assertThat(lines[1 ]).isEqualTo(" #group,false,false,true,true,false ,true,true,true,true " )
190
190
assertThat(lines[2 ]).isEqualTo(" #default,_result,,,,,,,," )
191
- assertThat(lines[3 ]).isEqualTo(" ,result,table,_start,_stop,_field,_measurement,host,region,_value" )
192
- assertThat(lines[4 ]).endsWith(" ,free,mem,A,west,21" )
193
- assertThat(lines[5 ]).endsWith(" ,free,mem,B,west,42" )
191
+ assertThat(lines[3 ]).isEqualTo(" ,result,table,_start,_stop,_value,_field,_measurement,host,region" )
192
+ assertThat(lines[4 ].endsWith(" 42,free,mem,B,west" ) ||
193
+ lines[4 ].endsWith(" 21,free,mem,A,west" ), name = lines[4 ]).isTrue()
194
+ assertThat(lines[5 ].endsWith(" 42,free,mem,B,west" ) ||
195
+ lines[5 ].endsWith(" 21,free,mem,A,west" ), name = lines[5 ]).isTrue()
194
196
assertThat(lines[6 ]).isEmpty()
195
197
}
196
198
@@ -199,12 +201,14 @@ internal class ITQueryKotlinApi : AbstractITInfluxDBClientKotlin() {
199
201
val lines = queryKotlinApi.queryRaw(flux, AbstractInfluxDBClient .DEFAULT_DIALECT ).toList()
200
202
201
203
assertThat(lines).hasSize(7 )
202
- assertThat(lines[0 ]).isEqualTo(" #datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,string ,string,string,string,long " )
203
- assertThat(lines[1 ]).isEqualTo(" #group,false,false,true,true,true ,true,true,true,false " )
204
+ assertThat(lines[0 ]).isEqualTo(" #datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,long ,string,string,string,string " )
205
+ assertThat(lines[1 ]).isEqualTo(" #group,false,false,true,true,false ,true,true,true,true " )
204
206
assertThat(lines[2 ]).isEqualTo(" #default,_result,,,,,,,," )
205
- assertThat(lines[3 ]).isEqualTo(" ,result,table,_start,_stop,_field,_measurement,host,region,_value" )
206
- assertThat(lines[4 ]).endsWith(" ,free,mem,A,west,21" )
207
- assertThat(lines[5 ]).endsWith(" ,free,mem,B,west,42" )
207
+ assertThat(lines[3 ]).isEqualTo(" ,result,table,_start,_stop,_value,_field,_measurement,host,region" )
208
+ assertThat(lines[4 ].endsWith(" 42,free,mem,B,west" ) ||
209
+ lines[4 ].endsWith(" 21,free,mem,A,west" ), name = lines[4 ]).isTrue()
210
+ assertThat(lines[5 ].endsWith(" 42,free,mem,B,west" ) ||
211
+ lines[5 ].endsWith(" 21,free,mem,A,west" ), name = lines[5 ]).isTrue()
208
212
assertThat(lines[6 ]).isEmpty()
209
213
}
210
214
@@ -213,12 +217,14 @@ internal class ITQueryKotlinApi : AbstractITInfluxDBClientKotlin() {
213
217
val lines = queryKotlinApi.queryRaw(Query ().dialect(AbstractInfluxDBClient .DEFAULT_DIALECT ).query(flux)).toList()
214
218
215
219
assertThat(lines).hasSize(7 )
216
- assertThat(lines[0 ]).isEqualTo(" #datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,string ,string,string,string,long " )
217
- assertThat(lines[1 ]).isEqualTo(" #group,false,false,true,true,true ,true,true,true,false " )
220
+ assertThat(lines[0 ]).isEqualTo(" #datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,long ,string,string,string,string " )
221
+ assertThat(lines[1 ]).isEqualTo(" #group,false,false,true,true,false ,true,true,true,true " )
218
222
assertThat(lines[2 ]).isEqualTo(" #default,_result,,,,,,,," )
219
- assertThat(lines[3 ]).isEqualTo(" ,result,table,_start,_stop,_field,_measurement,host,region,_value" )
220
- assertThat(lines[4 ]).endsWith(" ,free,mem,A,west,21" )
221
- assertThat(lines[5 ]).endsWith(" ,free,mem,B,west,42" )
223
+ assertThat(lines[3 ]).isEqualTo(" ,result,table,_start,_stop,_value,_field,_measurement,host,region" )
224
+ assertThat(lines[4 ].endsWith(" 42,free,mem,B,west" ) ||
225
+ lines[4 ].endsWith(" 21,free,mem,A,west" ), name = lines[4 ]).isTrue()
226
+ assertThat(lines[5 ].endsWith(" 42,free,mem,B,west" ) ||
227
+ lines[5 ].endsWith(" 21,free,mem,A,west" ), name = lines[5 ]).isTrue()
222
228
assertThat(lines[6 ]).isEmpty()
223
229
}
224
230
}
@@ -292,11 +298,11 @@ internal class ITQueryKotlinApi : AbstractITInfluxDBClientKotlin() {
292
298
293
299
val lines = queryKotlinApi.queryRaw(flux, organization.id).toList()
294
300
assertThat(lines).hasSize(6 )
295
- assertThat(lines[0 ]).isEqualTo(" #datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,string ,string,string,string,long " )
296
- assertThat(lines[1 ]).isEqualTo(" #group,false,false,true,true,true ,true,true,true,false " )
301
+ assertThat(lines[0 ]).isEqualTo(" #datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,long ,string,string,string,string " )
302
+ assertThat(lines[1 ]).isEqualTo(" #group,false,false,true,true,false ,true,true,true,true " )
297
303
assertThat(lines[2 ]).isEqualTo(" #default,_result,,,,,,,," )
298
- assertThat(lines[3 ]).isEqualTo(" ,result,table,_start,_stop,_field,_measurement,host,region,_value " )
299
- assertThat(lines[4 ]).endsWith(" ,free,mem,A,west,21 " )
304
+ assertThat(lines[3 ]).isEqualTo(" ,result,table,_start,_stop,_value, _field,_measurement,host,region" )
305
+ assertThat(lines[4 ]).endsWith(" ,21, free,mem,A,west" )
300
306
assertThat(lines[5 ]).isEmpty()
301
307
}
302
308
@@ -313,7 +319,7 @@ internal class ITQueryKotlinApi : AbstractITInfluxDBClientKotlin() {
313
319
val lines = queryKotlinApi.queryRaw(flux, dialect, organization.id).toList()
314
320
315
321
assertThat(lines).hasSize(2 )
316
- assertThat(lines[0 ]).endsWith(" ,free,mem,A,west,21 " )
322
+ assertThat(lines[0 ]).endsWith(" ,21, free,mem,A,west" )
317
323
assertThat(lines[1 ]).isEmpty()
318
324
}
319
325
0 commit comments