Use bulk update where possible

filiphr · May 14, 2024 · 286afff · 286afff
1 parent 042d0ce
commit 286afff
Show file tree

Hide file tree

Showing 9 changed files with 12 additions and 12 deletions.
diff --git a/...ble/cmmn/engine/impl/persistence/entity/data/impl/MybatisCaseInstanceDataManagerImpl.java b/...ble/cmmn/engine/impl/persistence/entity/data/impl/MybatisCaseInstanceDataManagerImpl.java
@@ -203,14 +203,14 @@ public void updateLockTime(String caseInstanceId, Date lockDate, String lockOwne
     public void clearLockTime(String caseInstanceId) {
         HashMap<String, Object> params = new HashMap<>();
         params.put("id", caseInstanceId);
-        getDbSqlSession().directUpdate("clearCaseInstanceLockTime", params);
+        getDbSqlSession().update("clearCaseInstanceLockTime", params);
     }
 
     @Override
     public void clearAllLockTimes(String lockOwner) {
         HashMap<String, Object> params = new HashMap<>();
         params.put("lockOwner", lockOwner);
-        getDbSqlSession().directUpdate("clearAllCaseInstanceLockTimes", params);
+        getDbSqlSession().update("clearAllCaseInstanceLockTimes", params);
     }
 
     protected void setSafeInValueLists(CaseInstanceQueryImpl caseInstanceQuery) {

diff --git a/...e-engine-common/src/main/java/org/flowable/common/engine/impl/db/AbstractDataManager.java b/...e-engine-common/src/main/java/org/flowable/common/engine/impl/db/AbstractDataManager.java
@@ -320,7 +320,7 @@ protected void bulkUpdateEntities(String statement, Map<String, Object> paramete
         executeChangeWithInClause(entities, entitiesParameter -> {
             Map<String, Object> copyParameters = new HashMap<>(parameters);
             copyParameters.put(collectionNameInSqlStatement, entitiesParameter);
-            getDbSqlSession().directUpdate(statement, copyParameters);
+            getDbSqlSession().update(statement, copyParameters);
         });
     }
 

diff --git a/...va/org/flowable/engine/impl/persistence/entity/data/impl/MybatisExecutionDataManager.java b/...va/org/flowable/engine/impl/persistence/entity/data/impl/MybatisExecutionDataManager.java
@@ -314,21 +314,21 @@ public void updateProcessInstanceLockTime(String processInstanceId, Date lockDat
 
     @Override
     public void updateAllExecutionRelatedEntityCountFlags(boolean newValue) {
-        getDbSqlSession().directUpdate("updateExecutionRelatedEntityCountEnabled", newValue);
+        getDbSqlSession().update("updateExecutionRelatedEntityCountEnabled", newValue);
     }
 
     @Override
     public void clearProcessInstanceLockTime(String processInstanceId) {
         HashMap<String, Object> params = new HashMap<>();
         params.put("id", processInstanceId);
-        getDbSqlSession().directUpdate("clearProcessInstanceLockTime", params);
+        getDbSqlSession().update("clearProcessInstanceLockTime", params);
     }
 
     @Override
     public void clearAllProcessInstanceLockTimes(String lockOwner) {
         HashMap<String, Object> params = new HashMap<>();
         params.put("lockOwner", lockOwner);
-        getDbSqlSession().directUpdate("clearAllProcessInstanceLockTimes", params);
+        getDbSqlSession().update("clearAllProcessInstanceLockTimes", params);
     }
 
     protected void setSafeInValueLists(ExecutionQueryImpl executionQuery) {

diff --git a/...iption/service/impl/persistence/entity/data/impl/MybatisEventSubscriptionDataManager.java b/...iption/service/impl/persistence/entity/data/impl/MybatisEventSubscriptionDataManager.java
@@ -363,7 +363,7 @@ public boolean updateEventSubscriptionLockTime(String eventSubscriptionId, Date
 
     @Override
     public void clearEventSubscriptionLockTime(String eventSubscriptionId) {
-        getDbSqlSession().directUpdate("clearEventSubscriptionLockTime", eventSubscriptionId);
+        getDbSqlSession().update("clearEventSubscriptionLockTime", eventSubscriptionId);
     }
 
     @Override

diff --git a/...le/job/service/impl/persistence/entity/data/impl/MybatisExternalWorkerJobDataManager.java b/...le/job/service/impl/persistence/entity/data/impl/MybatisExternalWorkerJobDataManager.java
@@ -135,7 +135,7 @@ public void resetExpiredJob(String jobId) {
         Map<String, Object> params = new HashMap<>(2);
         params.put("id", jobId);
         params.put("now", jobServiceConfiguration.getClock().getCurrentTime());
-        getDbSqlSession().directUpdate("resetExpiredExternalWorkerJob", params);
+        getDbSqlSession().update("resetExpiredExternalWorkerJob", params);
     }
 
     @Override

diff --git a/.../flowable/job/service/impl/persistence/entity/data/impl/MybatisHistoryJobDataManager.java b/.../flowable/job/service/impl/persistence/entity/data/impl/MybatisHistoryJobDataManager.java
@@ -117,7 +117,7 @@ public void bulkUpdateJobLockWithoutRevisionCheck(List<HistoryJobEntity> history
     public void resetExpiredJob(String jobId) {
         Map<String, Object> params = new HashMap<>(2);
         params.put("id", jobId);
-        getDbSqlSession().directUpdate("resetExpiredHistoryJob", params);
+        getDbSqlSession().update("resetExpiredHistoryJob", params);
     }
 
     @Override

diff --git a/...ava/org/flowable/job/service/impl/persistence/entity/data/impl/MybatisJobDataManager.java b/...ava/org/flowable/job/service/impl/persistence/entity/data/impl/MybatisJobDataManager.java
@@ -140,7 +140,7 @@ public void resetExpiredJob(String jobId) {
         Map<String, Object> params = new HashMap<>(2);
         params.put("id", jobId);
         params.put("now", jobServiceConfiguration.getClock().getCurrentTime());
-        getDbSqlSession().directUpdate("resetExpiredJob", params);
+        getDbSqlSession().update("resetExpiredJob", params);
     }
 
     @Override

diff --git a/...rg/flowable/job/service/impl/persistence/entity/data/impl/MybatisTimerJobDataManager.java b/...rg/flowable/job/service/impl/persistence/entity/data/impl/MybatisTimerJobDataManager.java
@@ -97,7 +97,7 @@ public void resetExpiredJob(String jobId) {
         Map<String, Object> params = new HashMap<>(2);
         params.put("id", jobId);
         params.put("now", jobServiceConfiguration.getClock().getCurrentTime());
-        getDbSqlSession().directUpdate("resetExpiredTimerJob", params);
+        getDbSqlSession().update("resetExpiredTimerJob", params);
     }
 
     @Override

diff --git a/...a/org/flowable/task/service/impl/persistence/entity/data/impl/MybatisTaskDataManager.java b/...a/org/flowable/task/service/impl/persistence/entity/data/impl/MybatisTaskDataManager.java
@@ -150,7 +150,7 @@ public void updateTaskTenantIdForDeployment(String deploymentId, String newTenan
 
     @Override
     public void updateAllTaskRelatedEntityCountFlags(boolean newValue) {
-        getDbSqlSession().directUpdate("updateTaskRelatedEntityCountEnabled", newValue);
+        getDbSqlSession().update("updateTaskRelatedEntityCountEnabled", newValue);
     }
 
     @Override