Skip to content

Commit d5239c6

Browse files
committed
tests: additional QueryOptions test
1 parent 743a8aa commit d5239c6

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

src/test/java/com/influxdb/v3/client/query/QueryOptionsTest.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -256,6 +256,8 @@ public void queryOptionsCloneTest() {
256256
.withMaxInboundMessageSize(1024 * 1024 * 1024)
257257
.withMaxOutboundMessageSize(1024 * 1024 * 1024)
258258
.withDeadline(Deadline.after(2, TimeUnit.MINUTES))
259+
.withCompressorName("my-compressor")
260+
.withWaitForReady()
259261
.build();
260262

261263
Map<String, String> headers = Map.of("k1", "v1", "k2", "v2", "k3", "v3");
@@ -273,6 +275,16 @@ public void queryOptionsCloneTest() {
273275
Assertions.assertThat(queryOptions.headersSafe() == clone.headersSafe()).isFalse();
274276
}
275277

278+
@Test
279+
public void queryOptionsCompareTest() {
280+
Map<String, String> headers = Map.of("k1", "v1", "k2", "v2", "k3", "v3");
281+
282+
QueryOptions queryOptions = new QueryOptions("myQueryOptions", QueryType.SQL, headers);
283+
Assertions.assertThat(queryOptions).isEqualTo(queryOptions);
284+
Assertions.assertThat(queryOptions).isNotEqualTo("Some String");
285+
Assertions.assertThat(queryOptions).isNotEqualTo(null);
286+
}
287+
276288
@Test
277289
public void queryOptionsUnchangedByCall() throws IOException {
278290
int freePort = findFreePort();

0 commit comments

Comments
 (0)