Skip to content

Commit 3c96436

Browse files
feat: clone options
1 parent d1560cb commit 3c96436

4 files changed

Lines changed: 38 additions & 4 deletions

File tree

examples/src/main/java/com/influxdb/v3/IOxExample.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ public static void main(final String[] args) throws Exception {
9898

9999
String influxQL =
100100
"select MEAN(value) from temperature group by time(1d) fill(none) order by time desc limit 10";
101-
try (Stream<Object[]> stream = client.query(influxQL, QueryOptions.INFLUX_QL)) {
101+
try (Stream<Object[]> stream = client.query(influxQL, QueryOptions.defaultInfluxQlQueryOptions())) {
102102
stream.forEach(row -> System.out.printf("| %-16s | %-18s |%n", row[1], row[2]));
103103
}
104104

src/main/java/com/influxdb/v3/client/query/QueryOptions.java

Lines changed: 26 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,19 +51,43 @@
5151
public final class QueryOptions {
5252

5353
/**
54-
* Default QueryAPI options.
54+
* Default QueryAPI options.<br>
55+
* Deprecated: use {@link #defaultQueryOptions()} instead.
5556
*/
57+
@Deprecated(forRemoval = true)
5658
public static final QueryOptions DEFAULTS = new QueryOptions(null, QueryType.SQL);
59+
5760
/**
58-
* Default QueryAPI options for InfluxQL.
61+
* Default QueryAPI options for InfluxQL.<br>
62+
* Deprecated: use {@link #defaultInfluxQlQueryOptions()} instead.
5963
*/
64+
@Deprecated(forRemoval = true)
6065
public static final QueryOptions INFLUX_QL = new QueryOptions(null, QueryType.InfluxQL);
6166

6267
private final String database;
6368
private final QueryType queryType;
6469
private final Map<String, String> headers;
6570
private GrpcCallOptions grpcCallOptions = GrpcCallOptions.getDefaultOptions();
6671

72+
/**
73+
* Provides default query options with no database specified and using SQL as the query type.
74+
*
75+
* @return A {@code QueryOptions} instance with default settings, including a null database
76+
* and {@code QueryType.SQL} as the query type.
77+
*/
78+
public static QueryOptions defaultQueryOptions() {
79+
return new QueryOptions(null, QueryType.SQL);
80+
}
81+
82+
/**
83+
* Provides default query options for executing InfluxQL queries with no database specified.
84+
*
85+
* @return A {@code QueryOptions} instance configured with a null database and {@code QueryType.InfluxQL}.
86+
*/
87+
public static QueryOptions defaultInfluxQlQueryOptions() {
88+
return new QueryOptions(null, QueryType.InfluxQL);
89+
}
90+
6791
/**
6892
* Construct QueryAPI options. The query type is set to SQL.
6993
*

src/main/java/com/influxdb/v3/client/write/WriteOptions.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,16 @@ public final class WriteOptions {
7878
private final Map<String, String> defaultTags;
7979
private final Map<String, String> headers;
8080

81+
/**
82+
* Creates a default instance of {@code WriteOptions} configured with standard values.
83+
*
84+
* @return A {@code WriteOptions} object with the default settings for write precision,
85+
* compression threshold, and no specified database.
86+
*/
87+
public static WriteOptions defaultWriteOptions() {
88+
return new WriteOptions(null, DEFAULT_WRITE_PRECISION, DEFAULT_GZIP_THRESHOLD);
89+
}
90+
8191
/**
8292
* Construct WriteAPI options.
8393
*

src/test/java/com/influxdb/v3/client/ITQueryWrite.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ void queryWrite() {
9595

9696
String influxQL = String.format("SELECT MEAN(value) FROM %s WHERE \"testId\"=%d "
9797
+ "group by time(1s) fill(none) order by time desc limit 1", measurement, testId);
98-
try (Stream<Object[]> stream = client.query(influxQL, QueryOptions.INFLUX_QL)) {
98+
try (Stream<Object[]> stream = client.query(influxQL, QueryOptions.defaultInfluxQlQueryOptions())) {
9999

100100
List<Object[]> rows = stream.collect(Collectors.toList());
101101

0 commit comments

Comments
 (0)