Improve ds to save errors

InseeFrLab · Jan 27, 2024 · 82d580d · 82d580d
1 parent c707e23
commit 82d580d
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/main/java/fr/insee/trevas/lab/utils/Utils.java b/src/main/java/fr/insee/trevas/lab/utils/Utils.java
@@ -106,6 +106,13 @@ public static void writeSparkDatasetsJDBC(Bindings bindings,
                                               Map<String, QueriesForBindingsToSave> queriesForBindingsToSave
     ) {
         queriesForBindingsToSave.forEach((name, values) -> {
+            if (!bindings.containsKey(name)) {
+                try {
+                    throw new Exception(name + " is not defined in script");
+                } catch (Exception e) {
+                    throw new RuntimeException(e);
+                }
+            }
             Object ds = bindings.get(name);
             if (!(ds instanceof PersistentDataset)) {
                 try {