[Core] Ajout du type de flux "HardReplace"

klee-contrib · Mar 21, 2024 · 7574a46 · 7574a46
1 parent 8767f5e
commit 7574a46
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 4 deletions.
diff --git a/TopModel.Core/Model/DataFlowType.cs b/TopModel.Core/Model/DataFlowType.cs
@@ -12,6 +12,11 @@ public enum DataFlowType
     /// </summary>
     Replace,
 
+    /// <summary>
+    /// Remplacement des données (truncate cascade puis bulk insert).
+    /// </summary>
+    HardReplace,
+
     /// <summary>
     /// Fusion des données (bulk merge).
     /// </summary>

diff --git a/TopModel.Core/schema.json b/TopModel.Core/schema.json
@@ -1072,6 +1072,7 @@
               "enum": [
                 "insert",
                 "replace",
+                "hardReplace",
                 "merge",
                 "mergeDisable"
               ]

diff --git a/TopModel.Generator.Jpa/SpringDataFlowGenerator.cs b/TopModel.Generator.Jpa/SpringDataFlowGenerator.cs
@@ -62,7 +62,7 @@ private static void WriteBeanFlow(JavaWriter fw, DataFlow dataFlow)
         fw.WriteLine();
         fw.WriteLine(1, @$"@Bean(""{dataFlow.Name.ToPascalCase()}Flow"")");
         fw.WriteLine(1, @$"public static Flow {dataFlow.Name.ToCamelCase()}Flow(");
-        if (dataFlow.Type == DataFlowType.Replace)
+        if (dataFlow.Type == DataFlowType.Replace || dataFlow.Type == DataFlowType.HardReplace)
         {
             fw.WriteLine(1, @$"			@Qualifier(""{dataFlow.Name.ToPascalCase()}TruncateStep"") Step {dataFlow.Name.ToCamelCase()}TruncateStep,");
         }
@@ -82,7 +82,7 @@ private static void WriteBeanFlow(JavaWriter fw, DataFlow dataFlow)
             isFirst = false;
         }
 
-        if (dataFlow.Type == DataFlowType.Replace)
+        if (dataFlow.Type == DataFlowType.Replace || dataFlow.Type == DataFlowType.HardReplace)
         {
             fw.WriteLine(3, @$".{(isFirst ? "start" : "next")}({dataFlow.Name.ToCamelCase()}TruncateStep) //");
             fw.WriteLine(3, @$".next({dataFlow.Name.ToCamelCase()}Step) //");
@@ -112,7 +112,7 @@ private static void WriteBeanTruncateStep(JavaWriter fw, DataFlow dataFlow)
         fw.AddImport("javax.sql.DataSource");
         fw.WriteLine(1, @$"		@Qualifier(""{dataFlow.Target}"") DataSource dataSource) {{");
         fw.WriteLine(1, @$"return new StepBuilder(""{dataFlow.Name.ToPascalCase()}TruncateStep"", jobRepository) //");
-        fw.WriteLine(2, @$"		.tasklet(new QueryTasklet(dataSource, ""truncate table {dataFlow.Class.SqlName}""), transactionManager) //");
+        fw.WriteLine(2, @$"		.tasklet(new QueryTasklet(dataSource, ""truncate table {dataFlow.Class.SqlName}{(dataFlow.Type == DataFlowType.HardReplace ? " cascade" : string.Empty)}""), transactionManager) //");
 
         fw.WriteLine(3, ".build();");
         fw.WriteLine(1, "}");
@@ -315,7 +315,7 @@ private void WriteClassFlow(string fileName, DataFlow dataFlow, string tag)
         WriteBeanFlow(fw, dataFlow);
         WriteBeanStep(fw, dataFlow, tag);
 
-        if (dataFlow.Type == DataFlowType.Replace)
+        if (dataFlow.Type == DataFlowType.Replace || dataFlow.Type == DataFlowType.HardReplace)
         {
             WriteBeanTruncateStep(fw, dataFlow);
         }

diff --git a/docs/model/dataFlows.md b/docs/model/dataFlows.md
@@ -34,6 +34,10 @@ Le flux de données doit insérer les éléments provenant de la source qui ne s
 
 Le flux de données doit supprimer tous les éléments déjà existants, puis insérer les éléments provenant de la source.
 
+### HardReplace
+
+Le flux de données doit supprimer **en cascade** tous les éléments déjà existants, puis insérer les éléments provenant de la source.
+
 ### Merge-disable
 
 Le comportement est le même que pour les flux de type merge, mais flux de données doit également effectuer une suppression logique (passer la propriété définie dans `activeProperty` à `false`) de tous les éléments qui ne font pas l'objet d'une mise à jour.