diff --git a/entity/Leadimport_entity/entityfields/load_data/onActionProcess.js b/entity/Leadimport_entity/entityfields/load_data/onActionProcess.js
index b42cd1b12af1eb245629b52bd9ee7cf6ec7ecaa3..8c39bbcf296e9b9e952f61454209665d5822ee11 100644
--- a/entity/Leadimport_entity/entityfields/load_data/onActionProcess.js
+++ b/entity/Leadimport_entity/entityfields/load_data/onActionProcess.js
@@ -1,3 +1,4 @@
+import("system.logging");
 import("system.eMath");
 import("system.question");
 import("system.neon");
@@ -42,7 +43,7 @@ if (binMetadatas.length > 0)
 
     var toInsert = [];
 
-    db.deleteData(insertTable, "ROW_ID = '" + assignmentRowId + "'");//delete existing
+    db.deleteData(insertTable, newWhere([insertTable, "ROW_ID"], assignmentRowId).build());//delete existing
 
     for (i = 0; i < table.length; i++)//and load new
     {
@@ -67,7 +68,7 @@ if (binMetadatas.length > 0)
     var updCols = ["STATUS"];
     var updTypes = db.getColumnTypes(updTable, updCols);
 
-    db.updateData(updTable, updCols, updTypes, [$KeywordRegistry.importStatus$loaded()], newWhere([updTable, "LEADIMPORTID"], assignmentRowId));
+    db.updateData(updTable, updCols, updTypes, [$KeywordRegistry.importStatus$loaded()], newWhere([updTable, "LEADIMPORTID"], assignmentRowId).build());
 
     neon.refreshAll();