feat: add batch write api for adding points (#25)

Author: zhiheng123

opengemini-client-jdk/src/main/java/io/opengemini/client/jdk/OpenGeminiJdkClient.java

@@ -17,6 +17,7 @@
 import java.net.http.HttpResponse;
 import java.nio.charset.StandardCharsets;
 import java.util.List;
+import java.util.StringJoiner;
 import java.util.concurrent.CompletableFuture;
 
 public class OpenGeminiJdkClient extends BaseClient {
@@ -78,6 +79,14 @@ public CompletableFuture<Void> write(String database, Point point) {
         return httpExcute(writeUrl, Void.class, UrlConst.POST, HttpRequest.BodyPublishers.ofString(body));
     }
 
+    public CompletableFuture<Void> writeBatch(String database, List<Point> points) {
+        String writeUrl = getWriteUrl(database);
+        StringJoiner sj = new StringJoiner("\n");
+        points.forEach(point -> sj.add(point.toString()));
+
+        return httpExcute(writeUrl, Void.class, UrlConst.POST, HttpRequest.BodyPublishers.ofString(sj.toString()));
+    }
+
     private <T> CompletableFuture<T> httpExcute(String url, Class<T> type) {
         return httpExcute(url, type, UrlConst.GET);
     }

opengemini-client-jdk/src/test/java/io/opengemini/client/jdk/OpenGeminiJdkClientTest.java

@@ -11,6 +11,7 @@
 import org.junit.jupiter.api.Test;
 
 import java.time.Duration;
+import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
@@ -106,7 +107,7 @@ private Point generalTestPoint(String measurementName, int valueIndex, int field
     @SneakyThrows
     @Test
     void testWritePoint() {
-        String databaseName = "write_test_database_0001";
+        String databaseName = "write_database_0001";
         CompletableFuture<Void> createdb = openGeminiJdkClient.createDatabase(databaseName);
         createdb.get();
 
@@ -132,7 +133,6 @@ void testWritePoint() {
         Assertions.assertTrue(x.getColumns().contains("tag0"));
     }
 
-
     @SneakyThrows
     @Test
     void testWritePointMoreFields() {
@@ -163,4 +163,35 @@ void testWritePointMoreFields() {
         Assertions.assertTrue(x.getColumns().contains("field29"));
         Assertions.assertTrue(x.getColumns().contains("tag29"));
     }
+
+    @SneakyThrows
+    @Test
+    void testWriteBatchPoints() {
+        String databaseName = "writePointBatch_database_0001";
+        CompletableFuture<Void> createdb = openGeminiJdkClient.createDatabase(databaseName);
+        createdb.get();
+
+        String measurementName = "writePointBatch_measurement_0001";
+        Point testPoint1 = generalTestPoint(measurementName, 1, 1);
+        Point testPoint2 = generalTestPoint(measurementName, 2, 1);
+        Point testPoint3 = generalTestPoint(measurementName, 3, 1);
+
+        CompletableFuture<Void> writeRsp = openGeminiJdkClient.writeBatch(
+                databaseName, Arrays.asList(testPoint1, testPoint2, testPoint3));
+        writeRsp.get();
+        Thread.sleep(3000);
+
+        Query selectQuery = new Query("select * from " + measurementName, databaseName, "");
+        CompletableFuture<QueryResult> rst = openGeminiJdkClient.query(selectQuery);
+        QueryResult queryResult = rst.get();
+
+        CompletableFuture<Void> dropdb = openGeminiJdkClient.dropDatabase(databaseName);
+        dropdb.get();
+
+        Series x = queryResult.getResults().get(0).getSeries().get(0);
+        System.out.println(x);
+        Assertions.assertEquals(x.getValues().size(), 3);
+        Assertions.assertTrue(x.getColumns().contains("field0"));
+        Assertions.assertTrue(x.getColumns().contains("tag0"));
+    }
 }