Skip to content

Commit 21d3c99

Browse files
committed
chore: add V1 constructor
1 parent 0ff7b79 commit 21d3c99

File tree

2 files changed

+24
-0
lines changed

2 files changed

+24
-0
lines changed

client/src/main/java/com/influxdb/client/write/WriteParameters.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -80,6 +80,18 @@ public WriteParameters(@Nullable final String bucket,
8080
this.consistency = consistency;
8181
}
8282

83+
/**
84+
* Construct WriteAPI parameters.
85+
*
86+
* @param precision Precision for unix timestamps in the line protocol of the request payload.
87+
* If it is not specified then use {@link WritePrecision#NS}.
88+
* @param consistency The write consistency for the point. For more info see {@link WriteParameters}.
89+
*/
90+
public WriteParameters(@Nullable final WritePrecision precision,
91+
@Nullable final WriteConsistency consistency) {
92+
this(null, null, precision, consistency);
93+
}
94+
8395
/**
8496
* The backward internal constructor, please use
8597
* {@link #WriteParameters(String, String, WritePrecision, WriteConsistency)}.

client/src/test/java/com/influxdb/client/write/WriteParametersTest.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -100,4 +100,16 @@ void nullableParameters() {
100100
Assertions.assertThat(parameters.precisionSafe(options)).isEqualTo(WritePrecision.NS);
101101
Assertions.assertThat(parameters.consistencySafe(options)).isNull();
102102
}
103+
104+
@Test
105+
void v1Constructor() {
106+
InfluxDBClientOptions options = optionsBuilder.bucket("my-bucket").org("my-org").build();
107+
108+
WriteParameters parameters = new WriteParameters(WritePrecision.NS, WriteConsistency.ONE);
109+
110+
Assertions.assertThat(parameters.orgSafe(options)).isEqualTo("my-org");
111+
Assertions.assertThat(parameters.bucketSafe(options)).isEqualTo("my-bucket");
112+
Assertions.assertThat(parameters.precisionSafe(options)).isEqualTo(WritePrecision.NS);
113+
Assertions.assertThat(parameters.consistencySafe(options)).isEqualTo(WriteConsistency.ONE);
114+
}
103115
}

0 commit comments

Comments
 (0)