Merge pull request #61 from abes-esr/THE-943-batch-reprise-apres-erre…

…ur-permettre-de-relancer-une-indexation-a-partir-dun-iddoc-donne Add : ajout d'un iddocToRestart, pour reprendre le batch à un iddoc d…
abes-esr · Nov 2, 2023 · 16eb104 · 16eb104
2 parents 9f757e5 + 92f78de
commit 16eb104
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 1 deletion.
diff --git a/src/main/java/fr/abes/theses_batch_indexation/reader/TheseItemReader.java b/src/main/java/fr/abes/theses_batch_indexation/reader/TheseItemReader.java
@@ -27,6 +27,9 @@ public class TheseItemReader {
     @Value("${index.name}")
     private String nomIndex;
 
+    @Value("${iddocToRestart}")
+    private Integer iddocToRestart;
+
     @Value("${table.name}")
     private String nomTable;
 
@@ -68,7 +71,7 @@ private void setWhereClause(OraclePagingQueryProvider queryProvider) {
             queryProvider.setWhereClause("where nom_index = '" + nomIndex + "'");
         } else {
             if (config.getWhereLimite() > 0)
-                queryProvider.setWhereClause("where rownum < " + config.getWhereLimite());
+                queryProvider.setWhereClause("where rownum < " + config.getWhereLimite() + " AND iddoc >= " + iddocToRestart.toString());
         }
     }
 

diff --git a/src/main/java/fr/abes/theses_batch_indexation/tasklet/InitialiserIndexESTasklet.java b/src/main/java/fr/abes/theses_batch_indexation/tasklet/InitialiserIndexESTasklet.java
@@ -39,9 +39,19 @@ public class InitialiserIndexESTasklet implements Tasklet {
     @Value("${index.pathRecherchePersonnes}")
     private String pathRecherchePersonnes;
 
+    @Value("${iddocToRestart}")
+    private Integer iddocToRestart;
+
 
     @Override
     public RepeatStatus execute(StepContribution stepContribution, ChunkContext chunkContext) throws Exception {
+
+        if (iddocToRestart > 0) {
+            log.warn("Index " + nomIndex.toLowerCase() + " non réinitialisé," +
+                    " car reprise de l'indexation à partir de l'iddoc : " + iddocToRestart);
+            return RepeatStatus.FINISHED;
+        }
+
         File f = selectIndex();
 
         if (f != null) {