MSEARCH-794: fix status setting query

folio-org · Aug 16, 2024 · d2315cf · d2315cf
1 parent 1e55259
commit d2315cf
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/main/java/org/folio/search/service/reindex/jdbc/ReindexStatusRepository.java b/src/main/java/org/folio/search/service/reindex/jdbc/ReindexStatusRepository.java
@@ -3,6 +3,7 @@
 import static org.folio.search.model.reindex.ReindexStatusEntity.END_TIME_MERGE_COLUMN;
 import static org.folio.search.model.reindex.ReindexStatusEntity.END_TIME_UPLOAD_COLUMN;
 import static org.folio.search.model.reindex.ReindexStatusEntity.START_TIME_MERGE_COLUMN;
+import static org.folio.search.model.reindex.ReindexStatusEntity.STATUS_COLUMN;
 import static org.folio.search.model.reindex.ReindexStatusEntity.TOTAL_MERGE_RANGES_COLUMN;
 import static org.folio.search.service.reindex.ReindexConstants.REINDEX_STATUS_TABLE;
 import static org.folio.search.utils.JdbcUtils.getFullTableName;
@@ -37,7 +38,7 @@ public class ReindexStatusRepository {
   private static final String UPDATE_FOR_ENTITIES_SQL = """
     UPDATE %s
     SET %s
-    WHERE entity_type in ?;
+    WHERE entity_type in (?);
     """;
 
   private final FolioExecutionContext context;
@@ -67,9 +68,10 @@ public void setReindexUploadFailed(ReindexEntityType entityType) {
   public void setReindexMergeFailed(List<ReindexEntityType> entityTypes) {
     var inTypes = entityTypes.stream()
       .map(ReindexEntityType::name)
-      .collect(Collectors.joining(",", "(", ")"));
+      .collect(Collectors.joining("," ));
     var fullTableName = getFullTableName(context, REINDEX_STATUS_TABLE);
-    var sql = UPDATE_FOR_ENTITIES_SQL.formatted(fullTableName, "%s = ?".formatted(END_TIME_MERGE_COLUMN));
+    var sql = UPDATE_FOR_ENTITIES_SQL.formatted(
+      fullTableName, "%s = ?, %s = ?".formatted(STATUS_COLUMN, END_TIME_MERGE_COLUMN));
 
     jdbcTemplate.update(sql, ReindexStatus.MERGE_FAILED.name(), Timestamp.from(Instant.now()), inTypes);
   }