diff --git a/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountDataProcessor.java b/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountDataProcessor.java
index 719dec2..dc079d3 100644
--- a/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountDataProcessor.java
+++ b/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountDataProcessor.java
@@ -65,8 +65,13 @@ public class AccountDataProcessor implements DataProcessor<AccountData> {
       }
     }
 
-    idmDirectoriesDaoService.insertAccountRecords(newAccountRecords);
-    idmDirectoriesDaoService.updateAccountRecords(accountRecordsToUpdate);
+    if (!newAccountRecords.isEmpty()) {
+      idmDirectoriesDaoService.insertAccountRecords(newAccountRecords);
+    }
+
+    if (!accountRecordsToUpdate.isEmpty()) {
+      idmDirectoriesDaoService.updateAccountRecords(accountRecordsToUpdate);
+    }
 
     if (!accountsToDeleteRoles.isEmpty()) {
       idmDirectoriesDaoService.deleteAccountRolesByAccountIds(accountsToDeleteRoles);
diff --git a/backend/src/main/java/ervu_business_metrics/service/processor/impl/DomainDataProcessor.java b/backend/src/main/java/ervu_business_metrics/service/processor/impl/DomainDataProcessor.java
index ad7eba7..fce5f7c 100644
--- a/backend/src/main/java/ervu_business_metrics/service/processor/impl/DomainDataProcessor.java
+++ b/backend/src/main/java/ervu_business_metrics/service/processor/impl/DomainDataProcessor.java
@@ -28,8 +28,8 @@ public class DomainDataProcessor implements DataProcessor<DomainData> {
 
   @Override
   public void upsertData(List<DomainData> dataList) {
-    List<DomainRecord> newRecruitmentRecords = new ArrayList<>();
-    List<DomainRecord> recruitmentRecords = new ArrayList<>();
+    List<DomainRecord> newDomainRecords = new ArrayList<>();
+    List<DomainRecord> domainRecords = new ArrayList<>();
     Set<String> existingIds = idmDirectoriesDaoService.getDomainIds();
 
     for (DomainData data : dataList) {
@@ -88,15 +88,20 @@ public class DomainDataProcessor implements DataProcessor<DomainData> {
       domainRecord.setManaged(data.getManaged());
 
       if (existingIds.contains(data.getId())) {
-        recruitmentRecords.add(domainRecord);
+        domainRecords.add(domainRecord);
       }
       else {
-        newRecruitmentRecords.add(domainRecord);
+        newDomainRecords.add(domainRecord);
       }
     }
 
-    idmDirectoriesDaoService.insertDomainRecords(newRecruitmentRecords);
-    idmDirectoriesDaoService.updateDomainRecords(recruitmentRecords);
+    if (!newDomainRecords.isEmpty()) {
+      idmDirectoriesDaoService.insertDomainRecords(newDomainRecords);
+    }
+
+    if (!domainRecords.isEmpty()) {
+      idmDirectoriesDaoService.updateDomainRecords(domainRecords);
+    }
   }
 
   @Override
diff --git a/backend/src/main/java/ervu_business_metrics/service/processor/impl/RoleDataProcessor.java b/backend/src/main/java/ervu_business_metrics/service/processor/impl/RoleDataProcessor.java
index 5ae4720..d22e30c 100644
--- a/backend/src/main/java/ervu_business_metrics/service/processor/impl/RoleDataProcessor.java
+++ b/backend/src/main/java/ervu_business_metrics/service/processor/impl/RoleDataProcessor.java
@@ -59,8 +59,13 @@ public class RoleDataProcessor implements DataProcessor<RoleData> {
       }
     }
 
-    idmDirectoriesDaoService.insertRoleRecords(newRoleRecords);
-    idmDirectoriesDaoService.updateRoleRecords(roleRecords);
+    if (!newRoleRecords.isEmpty()) {
+      idmDirectoriesDaoService.insertRoleRecords(newRoleRecords);
+    }
+
+    if (!roleRecords.isEmpty()) {
+      idmDirectoriesDaoService.updateRoleRecords(roleRecords);
+    }
   }
 
   @Override