From 5014aa655bc81db254cf105ad93f31b9b775b861 Mon Sep 17 00:00:00 2001 From: Thomasr Date: Tue, 14 Jan 2025 03:30:45 -0500 Subject: [PATCH] Fix migration of snapshot history --- .../org/lowcoder/runner/migrations/DatabaseChangelog.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/api-service/lowcoder-server/src/main/java/org/lowcoder/runner/migrations/DatabaseChangelog.java b/server/api-service/lowcoder-server/src/main/java/org/lowcoder/runner/migrations/DatabaseChangelog.java index e373ebc29..20611b8d8 100644 --- a/server/api-service/lowcoder-server/src/main/java/org/lowcoder/runner/migrations/DatabaseChangelog.java +++ b/server/api-service/lowcoder-server/src/main/java/org/lowcoder/runner/migrations/DatabaseChangelog.java @@ -359,7 +359,7 @@ public void addTimeSeriesSnapshotHistory(MongockTemplate mongoTemplate, CommonCo } // Delete the migrated records - Query deleteQuery = new Query(Criteria.where("createdAt").gte(thresholdDate)); + Query deleteQuery = new Query(Criteria.where("createdAt").lte(thresholdDate)); DeleteResult deleteResult = mongoTemplate.remove(deleteQuery, ApplicationHistorySnapshot.class); log.info("Deleted {} records from the source collection.", deleteResult.getDeletedCount()); @@ -390,7 +390,7 @@ public void addTimeSeriesSnapshotHistory(MongockTemplate mongoTemplate, CommonCo .toCollection(); // Delete the migrated records - Query deleteQuery = new Query(Criteria.where("createdAt").gte(thresholdDate)); + Query deleteQuery = new Query(Criteria.where("createdAt").lte(thresholdDate)); DeleteResult deleteResult = mongoTemplate.remove(deleteQuery, ApplicationHistorySnapshot.class); log.info("Deleted {} records from the source collection.", deleteResult.getDeletedCount());