[DE-60] Deprecate usage of deprecated server API (#440)

* request next cursor batch using POST method instead of PUT * deprecated collection id * deprecated load/unload collection * deprecated DocumentCreateOptions.overwrite() * deprecated minReplicationFactor in favor of writeConcern * deprecated traversal API
arangodb · Jun 7, 2022 · 9f95607 · 9f95607
1 parent 7a5c01f
commit 9f95607
Show file tree

Hide file tree

Showing 16 changed files with 124 additions and 14 deletions.
diff --git a/src/main/java/com/arangodb/ArangoCollection.java b/src/main/java/com/arangodb/ArangoCollection.java
@@ -661,7 +661,9 @@ <T> MultiDocumentEntity<DocumentDeleteEntity<T>> deleteDocuments(
      * @throws ArangoDBException
      * @see <a href="https://www.arangodb.com/docs/stable/http/collection-modifying.html#load-collection">API
      * Documentation</a>
+     * @deprecated MMFiles only
      */
+    @Deprecated
     CollectionEntity load() throws ArangoDBException;
 
     /**
@@ -672,7 +674,9 @@ <T> MultiDocumentEntity<DocumentDeleteEntity<T>> deleteDocuments(
      * @throws ArangoDBException
      * @see <a href="https://www.arangodb.com/docs/stable/http/collection-modifying.html#unload-collection">API
      * Documentation</a>
+     * @deprecated MMFiles only
      */
+    @Deprecated
     CollectionEntity unload() throws ArangoDBException;
 
     /**

diff --git a/src/main/java/com/arangodb/async/ArangoCollectionAsync.java b/src/main/java/com/arangodb/async/ArangoCollectionAsync.java
@@ -615,7 +615,9 @@ CompletableFuture<IndexEntity> ensureFulltextIndex(
      * @return information about the collection
      * @see <a href="https://www.arangodb.com/docs/stable/http/collection-modifying.html#load-collection">API
      * Documentation</a>
+     * @deprecated MMFiles only
      */
+    @Deprecated
     CompletableFuture<CollectionEntity> load();
 
     /**
@@ -625,7 +627,9 @@ CompletableFuture<IndexEntity> ensureFulltextIndex(
      * @return information about the collection
      * @see <a href="https://www.arangodb.com/docs/stable/http/collection-modifying.html#unload-collection">API
      * Documentation</a>
+     * @deprecated MMFiles only
      */
+    @Deprecated
     CompletableFuture<CollectionEntity> unload();
 
     /**

diff --git a/src/main/java/com/arangodb/entity/CollectionEntity.java b/src/main/java/com/arangodb/entity/CollectionEntity.java
@@ -41,6 +41,11 @@ public CollectionEntity() {
         super();
     }
 
+    /**
+     * @deprecated Accessing collections by their internal ID instead of accessing them by name is deprecated and highly
+     * discouraged. This functionality may be removed in future versions of ArangoDB.
+     */
+    @Deprecated
     public String getId() {
         return id;
     }

diff --git a/src/main/java/com/arangodb/entity/CollectionPropertiesEntity.java b/src/main/java/com/arangodb/entity/CollectionPropertiesEntity.java
@@ -38,7 +38,7 @@ public class CollectionPropertiesEntity extends CollectionEntity {
     private Collection<String> shardKeys;
     private final ReplicationFactor replicationFactor;
     private final MinReplicationFactor minReplicationFactor;
-
+    private Integer writeConcern;
     private String shardingStrategy; // cluster option
     private String smartJoinAttribute; // enterprise option
 
@@ -119,14 +119,30 @@ public void setReplicationFactor(final Integer replicationFactor) {
         this.replicationFactor.setReplicationFactor(replicationFactor);
     }
 
+    /**
+     * @deprecated use {@link #getWriteConcern()} instead
+     */
+    @Deprecated
     public Integer getMinReplicationFactor() {
         return minReplicationFactor.getMinReplicationFactor();
     }
 
+    /**
+     * @deprecated use {@link #setWriteConcern(Integer)} instead
+     */
+    @Deprecated
     public void setMinReplicationFactor(final Integer minReplicationFactor) {
         this.minReplicationFactor.setMinReplicationFactor(minReplicationFactor);
     }
 
+    public Integer getWriteConcern() {
+        return writeConcern;
+    }
+
+    public void setWriteConcern(final Integer writeConcern) {
+        this.writeConcern = writeConcern;
+    }
+
     /**
      * @return whether the collection is a satellite collection. Only in an enterprise cluster setup (else returning null).
      */

diff --git a/src/main/java/com/arangodb/entity/GraphEntity.java b/src/main/java/com/arangodb/entity/GraphEntity.java
@@ -41,6 +41,7 @@ public class GraphEntity implements Entity {
     private String smartGraphAttribute;
     private ReplicationFactor replicationFactor;
     private Integer minReplicationFactor;
+    private Integer writeConcern;
 
     public String getName() {
         return name != null ? name : _key;
@@ -74,10 +75,18 @@ public Boolean getSatellite() {
         return this.replicationFactor.getSatellite();
     }
 
+    /**
+     * @deprecated use {@link #getWriteConcern()} instead
+     */
+    @Deprecated
     public Integer getMinReplicationFactor() {
         return minReplicationFactor;
     }
 
+    public Integer getWriteConcern() {
+        return writeConcern;
+    }
+
     public String getSmartGraphAttribute() {
         return smartGraphAttribute;
     }

diff --git a/src/main/java/com/arangodb/entity/MinReplicationFactor.java b/src/main/java/com/arangodb/entity/MinReplicationFactor.java
@@ -20,9 +20,13 @@
 
 package com.arangodb.entity;
 
+import com.arangodb.model.CollectionCreateOptions;
+
 /**
  * @author Heiko Kernbach
+ * @deprecated use {@link CollectionCreateOptions#writeConcern(Integer)} instead
  */
+@Deprecated
 public class MinReplicationFactor {
 
     private Integer minReplicationFactor;

diff --git a/src/main/java/com/arangodb/entity/PathEntity.java b/src/main/java/com/arangodb/entity/PathEntity.java
@@ -27,6 +27,7 @@
  * @see <a href= "https://www.arangodb.com/docs/stable/http/traversal.html#executes-a-traversal">API
  * Documentation</a>
  */
+@Deprecated
 public class PathEntity<V, E> implements Entity {
 
     private Collection<E> edges;

diff --git a/src/main/java/com/arangodb/entity/TraversalEntity.java b/src/main/java/com/arangodb/entity/TraversalEntity.java
@@ -27,6 +27,7 @@
  * @see <a href= "https://www.arangodb.com/docs/stable/http/traversal.html#executes-a-traversal">API
  * Documentation</a>
  */
+@Deprecated
 public class TraversalEntity<V, E> implements Entity {
 
     private Collection<V> vertices;

diff --git a/src/main/java/com/arangodb/internal/InternalArangoDatabase.java b/src/main/java/com/arangodb/internal/InternalArangoDatabase.java
@@ -186,7 +186,7 @@ protected Request queryRequest(
 
     protected Request queryNextRequest(final String id, final AqlQueryOptions options, Map<String, String> meta) {
 
-        final Request request = request(dbName, RequestType.PUT, PATH_API_CURSOR, id);
+        final Request request = request(dbName, RequestType.POST, PATH_API_CURSOR, id);
 
         if (meta != null) {
             request.getHeaderParam().putAll(meta);

diff --git a/src/main/java/com/arangodb/model/CollectionCreateOptions.java b/src/main/java/com/arangodb/model/CollectionCreateOptions.java
@@ -37,6 +37,7 @@ public class CollectionCreateOptions {
     private Long journalSize;
     private final ReplicationFactor replicationFactor;
     private final MinReplicationFactor minReplicationFactor;
+    private Integer writeConcern;
     private KeyOptions keyOptions;
     private Boolean waitForSync;
     private Boolean doCompact;
@@ -89,6 +90,10 @@ public Integer getReplicationFactor() {
         return replicationFactor.getReplicationFactor();
     }
 
+    /**
+     * @deprecated use {@link #getWriteConcern()} instead
+     */
+    @Deprecated
     public Integer getMinReplicationFactor() {
         return minReplicationFactor.getMinReplicationFactor();
     }
@@ -118,12 +123,31 @@ public CollectionCreateOptions replicationFactor(final Integer replicationFactor
      *                             are allowed. Having `minReplicationFactor > 1` requires additional insync copies on follower servers
      *                             to allow writes.
      * @return options
+     * @deprecated use {@link #writeConcern(Integer)} instead
      */
+    @Deprecated
     public CollectionCreateOptions minReplicationFactor(final Integer minReplicationFactor) {
         this.minReplicationFactor.setMinReplicationFactor(minReplicationFactor);
         return this;
     }
 
+    public Integer getWriteConcern() {
+        return writeConcern;
+    }
+
+    /**
+     * @param writeConcern write concern for this collection (default: 1).
+     *                     It determines how many copies of each shard are required to be in sync on the different
+     *                     DB-Servers. If there are less then these many copies in the cluster a shard will refuse to
+     *                     write. Writes to shards with enough up-to-date copies will succeed at the same time however.
+     *                     The value of writeConcern can not be larger than replicationFactor. (cluster only)
+     * @return options
+     */
+    public CollectionCreateOptions writeConcern(final Integer writeConcern) {
+        this.writeConcern = writeConcern;
+        return this;
+    }
+
     public Boolean getSatellite() {
         return replicationFactor.getSatellite();
     }

diff --git a/src/main/java/com/arangodb/model/DocumentCreateOptions.java b/src/main/java/com/arangodb/model/DocumentCreateOptions.java
@@ -93,7 +93,9 @@ public Boolean getOverwrite() {
      *                  the old document.
      * @return options
      * @since ArangoDB 3.4
+     * @deprecated use {@link #overwriteMode(OverwriteMode)} instead
      */
+    @Deprecated
     public DocumentCreateOptions overwrite(final Boolean overwrite) {
         this.overwrite = overwrite;
         return this;

diff --git a/src/main/java/com/arangodb/model/GraphCreateOptions.java b/src/main/java/com/arangodb/model/GraphCreateOptions.java
@@ -143,6 +143,10 @@ public GraphCreateOptions satellite(final Boolean satellite) {
         return this;
     }
 
+    /**
+     * @deprecated use {@link #getWriteConcern()} instead
+     */
+    @Deprecated
     public Integer getMinReplicationFactor() {
         return getOptions().getMinReplicationFactor();
     }
@@ -157,12 +161,31 @@ public Integer getMinReplicationFactor() {
      *                             are allowed. Having `minReplicationFactor > 1` requires additional insync copies on follower servers
      *                             to allow writes.
      * @return options
+     * @deprecated use {@link #writeConcern(Integer)} instead
      */
+    @Deprecated
     public GraphCreateOptions minReplicationFactor(final Integer minReplicationFactor) {
         getOptions().setMinReplicationFactor(minReplicationFactor);
         return this;
     }
 
+    public Integer getWriteConcern() {
+        return getOptions().getWriteConcern();
+    }
+
+    /**
+     * @param writeConcern Write concern for new collections in the graph.
+     *                     It determines how many copies of each shard are required to be in sync on the different
+     *                     DB-Servers. If there are less then these many copies in the cluster a shard will refuse to
+     *                     write. Writes to shards with enough up-to-date copies will succeed at the same time however.
+     *                     The value of writeConcern can not be larger than replicationFactor. (cluster only)
+     * @return options
+     */
+    public GraphCreateOptions writeConcern(final Integer writeConcern) {
+        getOptions().setWriteConcern(writeConcern);
+        return this;
+    }
+
     public Integer getNumberOfShards() {
         return getOptions().getNumberOfShards();
     }
@@ -216,6 +239,7 @@ private SmartOptions getOptions() {
     public static class SmartOptions {
         private ReplicationFactor replicationFactor;
         private Integer minReplicationFactor;
+        private Integer writeConcern;
         private Integer numberOfShards;
         private String smartGraphAttribute;
         private Boolean isDisjoint;
@@ -242,14 +266,30 @@ public void setSatellite(final Boolean satellite) {
             replicationFactor.setSatellite(satellite);
         }
 
+        /**
+         * @deprecated use {{@link #getWriteConcern()}} instead
+         */
+        @Deprecated
         public Integer getMinReplicationFactor() {
             return minReplicationFactor;
         }
 
+        /**
+         * @deprecated use {{@link #setWriteConcern(Integer)}} instead
+         */
+        @Deprecated
         public void setMinReplicationFactor(final Integer minReplicationFactor) {
             this.minReplicationFactor = minReplicationFactor;
         }
 
+        public Integer getWriteConcern() {
+            return writeConcern;
+        }
+
+        public void setWriteConcern(final Integer writeConcern) {
+            this.writeConcern = writeConcern;
+        }
+
         public Integer getNumberOfShards() {
             return numberOfShards;
         }

diff --git a/src/test/java/com/arangodb/ArangoDatabaseTest.java b/src/test/java/com/arangodb/ArangoDatabaseTest.java
@@ -122,18 +122,18 @@ void createCollectionWithReplicationFactor(ArangoDatabase db) {
 
     @ParameterizedTest(name = "{index}")
     @MethodSource("dbs")
-    void createCollectionWithMinReplicationFactor(ArangoDatabase db) {
+    void createCollectionWithWriteConcern(ArangoDatabase db) {
         assumeTrue(isAtLeastVersion(3, 5));
         assumeTrue(isCluster());
 
         String name = "collection-" + rnd();
         final CollectionEntity result = db.createCollection(name,
-                new CollectionCreateOptions().replicationFactor(2).minReplicationFactor(2));
+                new CollectionCreateOptions().replicationFactor(2).writeConcern(2));
         assertThat(result).isNotNull();
         assertThat(result.getId()).isNotNull();
         CollectionPropertiesEntity props = db.collection(name).getProperties();
         assertThat(props.getReplicationFactor()).isEqualTo(2);
-        assertThat(props.getMinReplicationFactor()).isEqualTo(2);
+        assertThat(props.getWriteConcern()).isEqualTo(2);
         assertThat(props.getSatellite()).isNull();
     }
 

diff --git a/src/test/java/com/arangodb/ArangoGraphTest.java b/src/test/java/com/arangodb/ArangoGraphTest.java
@@ -87,15 +87,15 @@ void exists(ArangoGraph graph) {
 
     @ParameterizedTest(name = "{index}")
     @MethodSource("dbs")
-    void createWithReplicationAndMinReplicationFactor(ArangoDatabase db) {
+    void createWithReplicationAndWriteConcern(ArangoDatabase db) {
         assumeTrue(isAtLeastVersion(3, 5));
         assumeTrue(isCluster());
 
         final Collection<EdgeDefinition> edgeDefinitions = new ArrayList<>();
-        final GraphEntity graph = db.createGraph(GRAPH_NAME + "_1", edgeDefinitions, new GraphCreateOptions().isSmart(true).replicationFactor(2).minReplicationFactor(2));
+        final GraphEntity graph = db.createGraph(GRAPH_NAME + "_1", edgeDefinitions, new GraphCreateOptions().isSmart(true).replicationFactor(2).writeConcern(2));
         assertThat(graph).isNotNull();
         assertThat(graph.getName()).isEqualTo(GRAPH_NAME + "_1");
-        assertThat(graph.getMinReplicationFactor()).isEqualTo(2);
+        assertThat(graph.getWriteConcern()).isEqualTo(2);
         assertThat(graph.getReplicationFactor()).isEqualTo(2);
         db.graph(GRAPH_NAME + "_1").drop();
     }

diff --git a/src/test/java/com/arangodb/async/ArangoDatabaseTest.java b/src/test/java/com/arangodb/async/ArangoDatabaseTest.java
@@ -123,16 +123,16 @@ void createCollectionWithReplicationFactor() throws InterruptedException, Execut
     }
 
     @Test
-    void createCollectionWithMinReplicationFactor() throws ExecutionException, InterruptedException {
+    void createCollectionWithWriteConcern() throws ExecutionException, InterruptedException {
         assumeTrue(isAtLeastVersion(3, 5));
         assumeTrue(isCluster());
 
         final CollectionEntity result = db.createCollection(COLLECTION_NAME,
-                new CollectionCreateOptions().replicationFactor(2).minReplicationFactor(2)).get();
+                new CollectionCreateOptions().replicationFactor(2).writeConcern(2)).get();
         assertThat(result).isNotNull();
         assertThat(result.getId()).isNotNull();
         assertThat(db.collection(COLLECTION_NAME).getProperties().get().getReplicationFactor()).isEqualTo(2);
-        assertThat(db.collection(COLLECTION_NAME).getProperties().get().getMinReplicationFactor()).isEqualTo(2);
+        assertThat(db.collection(COLLECTION_NAME).getProperties().get().getWriteConcern()).isEqualTo(2);
         assertThat(db.collection(COLLECTION_NAME).getProperties().get().getSatellite()).isNull();
         db.collection(COLLECTION_NAME).drop();
     }

diff --git a/src/test/java/com/arangodb/async/ArangoGraphTest.java b/src/test/java/com/arangodb/async/ArangoGraphTest.java
@@ -94,14 +94,14 @@ void create() throws InterruptedException, ExecutionException {
     }
 
     @Test
-    void createWithReplicationAndMinReplicationFactor() throws ExecutionException, InterruptedException {
+    void createWithReplicationAndWriteConcern() throws ExecutionException, InterruptedException {
         assumeTrue(isAtLeastVersion(3, 5));
         assumeTrue(isCluster());
         final Collection<EdgeDefinition> edgeDefinitions = new ArrayList<>();
-        final GraphEntity graph = db.createGraph(GRAPH_NAME + "_1", edgeDefinitions, new GraphCreateOptions().isSmart(true).replicationFactor(2).minReplicationFactor(2)).get();
+        final GraphEntity graph = db.createGraph(GRAPH_NAME + "_1", edgeDefinitions, new GraphCreateOptions().isSmart(true).replicationFactor(2).writeConcern(2)).get();
         assertThat(graph).isNotNull();
         assertThat(graph.getName()).isEqualTo(GRAPH_NAME + "_1");
-        assertThat(graph.getMinReplicationFactor()).isEqualTo(2);
+        assertThat(graph.getWriteConcern()).isEqualTo(2);
         assertThat(graph.getReplicationFactor()).isEqualTo(2);
         db.graph(GRAPH_NAME + "_1").drop();
     }