|
44 | 44 | import com.influxdb.v3.client.Point; |
45 | 45 | import com.influxdb.v3.client.PointValues; |
46 | 46 | import com.influxdb.v3.client.config.ClientConfig; |
| 47 | +import com.influxdb.v3.client.query.QueryOptions; |
47 | 48 | import com.influxdb.v3.client.write.WriteOptions; |
48 | 49 | import com.influxdb.v3.client.write.WritePrecision; |
49 | 50 |
|
@@ -278,7 +279,7 @@ public void testQueryRows() throws Exception { |
278 | 279 | } |
279 | 280 |
|
280 | 281 | @Test |
281 | | - public void testQueryRowWithParam() throws Exception { |
| 282 | + public void testQueryRowWithParamOptions() throws Exception { |
282 | 283 | try (InfluxDBClient client = InfluxDBClient.getInstance( |
283 | 284 | System.getenv("TESTING_INFLUXDB_URL"), |
284 | 285 | System.getenv("TESTING_INFLUXDB_TOKEN").toCharArray(), |
@@ -324,7 +325,7 @@ public void testQueryRowWithParam() throws Exception { |
324 | 325 | Map<String, Object> parameters = Map.of("testId", uuid); |
325 | 326 | // Result set much be ordered by time |
326 | 327 | String sql = String.format("Select * from %s where \"testId\"=$testId order by time", measurement); |
327 | | - try (Stream<Map<String, Object>> stream = client.queryRows(sql, parameters)) { |
| 328 | + try (Stream<Map<String, Object>> stream = client.queryRows(sql, parameters, QueryOptions.DEFAULTS)) { |
328 | 329 | List<Map<String, Object>> results = stream.collect(Collectors.toList()); |
329 | 330 | for (int i = 0; i <= 9; i++) { |
330 | 331 | Map<String, Object> row = results.get(i); |
|
0 commit comments