|
32 | 32 | import com.influxdb.client.service.DbrPsService; |
33 | 33 | import com.influxdb.client.write.Point; |
34 | 34 | import com.influxdb.query.InfluxQLQueryResult; |
| 35 | + |
35 | 36 | import org.assertj.core.api.Assertions; |
36 | 37 | import org.assertj.core.api.ListAssert; |
37 | 38 | import org.junit.jupiter.api.BeforeEach; |
38 | 39 | import org.junit.jupiter.api.Test; |
39 | 40 | import org.junit.platform.runner.JUnitPlatform; |
40 | 41 | import org.junit.runner.RunWith; |
41 | 42 |
|
42 | | -import static org.assertj.core.api.InstanceOfAssertFactories.*; |
| 43 | +import static org.assertj.core.api.InstanceOfAssertFactories.BIG_DECIMAL; |
| 44 | +import static org.assertj.core.api.InstanceOfAssertFactories.INSTANT; |
| 45 | +import static org.assertj.core.api.InstanceOfAssertFactories.list; |
43 | 46 |
|
44 | 47 | @RunWith(JUnitPlatform.class) |
45 | 48 | class ITInfluxQLQueryApi extends AbstractITClientTest { |
@@ -76,10 +79,9 @@ void setUp() throws IOException { |
76 | 79 | void testShowDatabases() { |
77 | 80 | InfluxQLQueryResult result = influxQLQueryApi.query(new InfluxQLQuery("SHOW DATABASES", DATABASE_NAME)); |
78 | 81 | assertSingleSeriesRecords(result) |
79 | | - .hasSize(1) |
80 | | - .first() |
81 | | - .extracting(record -> record.getValueByKey("name")) |
82 | | - .isEqualTo(DATABASE_NAME); |
| 82 | + .map(record -> record.getValueByKey("name")) |
| 83 | + // internal buckets are also available by DBRP mapping |
| 84 | + .contains(DATABASE_NAME); |
83 | 85 | } |
84 | 86 |
|
85 | 87 |
|
|
0 commit comments