From 3bc9d9b1321cc1579ca7f348ed97ae662b61e4c1 Mon Sep 17 00:00:00 2001 From: Summer Xia Date: Tue, 27 Dec 2022 14:43:24 +0800 Subject: [PATCH] fix(sql): No offset for retrievePipelinesForPipelineConfigId and retrieve --- .../orca/sql/pipeline/persistence/SqlExecutionRepository.kt | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/orca-sql/src/main/kotlin/com/netflix/spinnaker/orca/sql/pipeline/persistence/SqlExecutionRepository.kt b/orca-sql/src/main/kotlin/com/netflix/spinnaker/orca/sql/pipeline/persistence/SqlExecutionRepository.kt index 07dc3e99a1..eb7f0df3e4 100644 --- a/orca-sql/src/main/kotlin/com/netflix/spinnaker/orca/sql/pipeline/persistence/SqlExecutionRepository.kt +++ b/orca-sql/src/main/kotlin/com/netflix/spinnaker/orca/sql/pipeline/persistence/SqlExecutionRepository.kt @@ -396,7 +396,7 @@ class SqlExecutionRepository( it.orderBy(field("id").desc()) .run { if (criteria.pageSize > 0) { - limit(criteria.pageSize) + offset((criteria.page - 1) * criteria.pageSize).limit(criteria.pageSize) } else { this } @@ -436,7 +436,7 @@ class SqlExecutionRepository( .statusIn(criteria.statuses) }, seek = { - it.orderBy(field("id").desc()).limit(criteria.pageSize) + it.orderBy(field("id").desc()).offset((criteria.page - 1) * criteria.pageSize).limit(criteria.pageSize) } ) } else { @@ -449,7 +449,7 @@ class SqlExecutionRepository( .statusIn(criteria.statuses) }, seek = { - it.orderBy(field("id").desc()).limit(criteria.pageSize) + it.orderBy(field("id").desc()).offset((criteria.page - 1) * criteria.pageSize).limit(criteria.pageSize) } ) }