feat: supported /batch api from RemoteDatabase

Fixed issue #3817

Author: lvca

network/src/main/java/com/arcadedb/remote/RemoteBatchResult.java

@@ -0,0 +1,53 @@
+/*
+ * Copyright © 2021-present Arcade Data Ltd (info@arcadedata.com)
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * SPDX-FileCopyrightText: 2021-present Arcade Data Ltd (info@arcadedata.com)
+ * SPDX-License-Identifier: Apache-2.0
+ */
+package com.arcadedb.remote;
+
+/**
+ * Result of a remote batch import operation via the /batch HTTP endpoint.
+ *
+ * @author Luca Garulli (l.garulli@arcadedata.com)
+ */
+public class RemoteBatchResult {
+  private final long verticesCreated;
+  private final long edgesCreated;
+  private final long elapsedMs;
+
+  RemoteBatchResult(final long verticesCreated, final long edgesCreated, final long elapsedMs) {
+    this.verticesCreated = verticesCreated;
+    this.edgesCreated = edgesCreated;
+    this.elapsedMs = elapsedMs;
+  }
+
+  public long getVerticesCreated() {
+    return verticesCreated;
+  }
+
+  public long getEdgesCreated() {
+    return edgesCreated;
+  }
+
+  public long getElapsedMs() {
+    return elapsedMs;
+  }
+
+  @Override
+  public String toString() {
+    return "RemoteBatchResult{verticesCreated=" + verticesCreated + ", edgesCreated=" + edgesCreated + ", elapsedMs=" + elapsedMs + "}";
+  }
+}

network/src/main/java/com/arcadedb/remote/RemoteDatabase.java

@@ -262,6 +262,17 @@ public RemoteTransactionExplicitLock acquireLock() {
     return explicitLock;
   }
 
+  /**
+   * Returns a builder for configuring a remote batch graph import.
+   * The builder mirrors the server-side GraphBatch.Builder parameters.
+   *
+   * @return a new {@link RemoteGraphBatch.Builder}
+   */
+  public RemoteGraphBatch.Builder batch() {
+    checkDatabaseIsOpen();
+    return new RemoteGraphBatch.Builder(this);
+  }
+
   @Override
   public void begin() {
     begin(transactionIsolationLevel);
@@ -572,6 +583,42 @@ private String getUrl(final String command, final String databaseName) {
     return getUrl(command) + "/" + databaseName;
   }
 
+  JSONObject sendBatch(final String content, final Map<String, String> queryParams) {
+    checkDatabaseIsOpen();
+
+    final StringBuilder urlBuilder = new StringBuilder(getUrl("batch", databaseName));
+    if (queryParams != null && !queryParams.isEmpty()) {
+      urlBuilder.append('?');
+      boolean first = true;
+      for (final Map.Entry<String, String> entry : queryParams.entrySet()) {
+        if (!first)
+          urlBuilder.append('&');
+        urlBuilder.append(entry.getKey()).append('=').append(entry.getValue());
+        first = false;
+      }
+    }
+
+    try {
+      final HttpRequest request = createRequestBuilder("POST", urlBuilder.toString())
+          .POST(HttpRequest.BodyPublishers.ofString(content))
+          .header("Content-Type", "application/x-ndjson")
+          .build();
+
+      final HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
+
+      if (response.statusCode() != 200) {
+        final Exception detail = manageException(response, "batch import");
+        throw new DatabaseOperationException("Error on batch import", detail);
+      }
+
+      return new JSONObject(response.body());
+    } catch (final DatabaseOperationException e) {
+      throw e;
+    } catch (final Exception e) {
+      throw new DatabaseOperationException("Error on batch import", e);
+    }
+  }
+
   protected ResultSet createResultSet(final JSONObject response) {
     final ResultSet resultSet = new InternalResultSet();