[DE-541] forceOneShardAttributeValue test (#274)

Author: rashtao

ChangeLog.md

@@ -6,6 +6,10 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/) a
 
 ## [Unreleased]
 
+## [3.9.0] - 2023-04-18
+
+- upgraded dependency `com.arangodb:arangodb-java-driver:6.22.0` (DE-541)
+
 ## [3.8.0] - 2023-02-08
 
 - improved resolution of already fetched embedded entities (#270)

pom.xml

@@ -299,7 +299,7 @@
 			<dependency>
 				<groupId>com.arangodb</groupId>
 				<artifactId>arangodb-java-driver</artifactId>
-				<version>6.20.0</version>
+				<version>6.22.0</version>
 			</dependency>
 			<dependency>
 				<groupId>org.mockito</groupId>

src/test/java/com/arangodb/springframework/repository/ShardedCollectionRepositoryTest.java

@@ -20,12 +20,16 @@
 
 package com.arangodb.springframework.repository;
 
+import com.arangodb.model.AqlQueryOptions;
 import com.arangodb.springframework.AbstractArangoTest;
 import com.arangodb.springframework.annotation.Document;
 import org.junit.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.annotation.Id;
 
+import java.util.List;
+import java.util.Optional;
+
 import static org.assertj.core.api.Assertions.assertThat;
 
 /**
@@ -50,6 +54,19 @@ public void save() {
         assertThat(d3.country).isEqualTo("country1");
         assertThat(d3.name).isEqualTo("name3");
     }
+
+    @Test
+    public void forceOneShardAttributeValue() {
+        ShardedUser d = shardedRepository.save(new ShardedUser(null, "foo", "bar"));
+        Optional<ShardedUser> res = shardedRepository.findByName("foo", new AqlQueryOptions()
+                .forceOneShardAttributeValue("bar")
+        ).stream().findFirst();
+        assertThat(res).isPresent();
+        assertThat(res.get().key).isEqualTo(d.key);
+        assertThat(res.get().name).isEqualTo(d.name);
+        assertThat(res.get().country).isEqualTo(d.country);
+    }
+
 }
 
 @Document(shardKeys = "country", numberOfShards = 10)
@@ -68,4 +85,5 @@ public ShardedUser(String key, String name, String country) {
 }
 
 interface ShardedRepository extends ArangoRepository<ShardedUser, String> {
+    List<ShardedUser> findByName(String name, AqlQueryOptions options);
 }