fix: Check if the pageable sort already contains the additional sort.

If it does or is equal to, don't add it a second time.

Fixes #2940

Author: michael-simons

src/main/java/org/springframework/data/neo4j/repository/query/CypherQueryCreator.java

@@ -23,6 +23,7 @@
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.Optional;
 import java.util.Queue;
 import java.util.concurrent.atomic.AtomicInteger;
@@ -223,7 +224,10 @@ private QueryFragments createQueryFragments(@Nullable Condition condition, Sort
 			queryFragments.setReturnExpression(Functions.count(Constants.NAME_OF_TYPED_ROOT_NODE.apply(nodeDescription)), true);
 		} else {
 
-			var theSort = pagingParameter.getSort().and(sort);
+			var theSort = pagingParameter.getSort();
+			if (!Objects.equals(theSort, sort)) {
+				theSort = theSort.and(sort);
+			}
 
 			if (pagingParameter.isUnpaged() && scrollPosition == null && maxResults != null) {
 				queryFragments.setLimit(limitModifier.apply(maxResults.intValue()));

src/test/java/org/springframework/data/neo4j/integration/issues/IssuesIT.java

@@ -44,6 +44,7 @@
 import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestMethodOrder;
+import org.junit.jupiter.api.extension.ExtendWith;
 import org.neo4j.cypherdsl.core.Condition;
 import org.neo4j.cypherdsl.core.Cypher;
 import org.neo4j.cypherdsl.core.Node;
@@ -182,19 +183,24 @@
 import org.springframework.data.neo4j.repository.config.EnableNeo4jRepositories;
 import org.springframework.data.neo4j.repository.query.QueryFragmentsAndParameters;
 import org.springframework.data.neo4j.test.BookmarkCapture;
+import org.springframework.data.neo4j.test.LogbackCapture;
+import org.springframework.data.neo4j.test.LogbackCapturingExtension;
 import org.springframework.data.neo4j.test.Neo4jImperativeTestConfiguration;
 import org.springframework.data.neo4j.test.Neo4jIntegrationTest;
 import org.springframework.transaction.PlatformTransactionManager;
 import org.springframework.transaction.annotation.EnableTransactionManagement;
 import org.springframework.transaction.annotation.Transactional;
 
+import ch.qos.logback.classic.Level;
+
 /**
  * @author Michael J. Simons
  * @soundtrack Sodom - Sodom
  */
 @Neo4jIntegrationTest
 @DisplayNameGeneration(SimpleDisplayNameGeneratorWithTags.class)
 @TestMethodOrder(MethodOrderer.DisplayName.class)
+@ExtendWith(LogbackCapturingExtension.class)
 class IssuesIT extends TestBase {
 
 	// GH-2210
@@ -1316,6 +1322,20 @@ void shouldSupportGeoResultWithSelfRef(@Autowired LocatedNodeWithSelfRefReposito
 		assertSupportedGeoResultBehavior(repository);
 	}
 
+	@Test
+	@Tag("GH-2940")
+	void shouldNotGenerateDuplicateOrder(@Autowired LocatedNodeRepository repository, LogbackCapture logbackCapture) {
+
+		try {
+			logbackCapture.addLogger("org.springframework.data.neo4j.cypher", Level.DEBUG);
+			var nodes = repository.findAllByName("NEO4J_HQ", PageRequest.of(0, 10, Sort.by(Sort.Order.asc("name"))));
+			assertThat(nodes).isNotEmpty();
+			assertThat(logbackCapture.getFormattedMessages()).noneMatch(l -> l.contains("locatedNode.name, locatedNode.name"));
+		} finally {
+			logbackCapture.resetLogLevel();
+		}
+	}
+
 	@Configuration
 	@EnableTransactionManagement
 	@EnableNeo4jRepositories(namedQueriesLocation = "more-custom-queries.properties")

src/test/java/org/springframework/data/neo4j/integration/issues/gh2908/LocatedNodeRepository.java

@@ -15,11 +15,15 @@
  */
 package org.springframework.data.neo4j.integration.issues.gh2908;
 
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
 import org.springframework.data.neo4j.repository.Neo4jRepository;
 
 /**
  * Repository spotting all supported Geo* results.
  * @author Michael J. Simons
  */
 public interface LocatedNodeRepository extends HasNameAndPlaceRepository<LocatedNode>, Neo4jRepository<LocatedNode, String> {
+
+	Page<LocatedNode> findAllByName(String whatever, PageRequest name);
 }

src/test/java/org/springframework/data/neo4j/test/LogbackCapture.java

@@ -23,7 +23,6 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.stream.Collectors;
 
 import org.junit.jupiter.api.extension.ExtensionContext;
 
@@ -54,7 +53,7 @@ public void addLogger(String loggerName, Level level) {
 	}
 
 	public List<String> getFormattedMessages() {
-		return listAppender.list.stream().map(e -> e.getFormattedMessage()).collect(Collectors.toList());
+		return listAppender.list.stream().map(ILoggingEvent::getFormattedMessage).toList();
 	}
 
 	void start() {
@@ -75,6 +74,6 @@ public void close() {
 	}
 
 	public void resetLogLevel() {
-		this.additionalLoggers.entrySet().forEach(entry -> entry.getKey().setLevel(entry.getValue()));
+		this.additionalLoggers.forEach(Logger::setLevel);
 	}
 }