Use bulk update where possible

filiphr · May 14, 2024 · 59caf4d · 59caf4d
1 parent 042d0ce
commit 59caf4d
Show file tree

Hide file tree

Showing 18 changed files with 32 additions and 32 deletions.
diff --git a/...lowable/app/engine/impl/persistence/entity/data/impl/MybatisAppDefinitionDataManager.java b/...lowable/app/engine/impl/persistence/entity/data/impl/MybatisAppDefinitionDataManager.java
@@ -114,7 +114,7 @@ public void updateAppDefinitionTenantIdForDeployment(String deploymentId, String
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateAppDefinitionTenantIdForDeploymentId", params);
+        getDbSqlSession().update("updateAppDefinitionTenantIdForDeploymentId", params);
     }
 
     @Override

diff --git a/...wable/cmmn/engine/impl/persistence/entity/data/impl/MybatisCaseDefinitionDataManager.java b/...wable/cmmn/engine/impl/persistence/entity/data/impl/MybatisCaseDefinitionDataManager.java
@@ -133,7 +133,7 @@ public void updateCaseDefinitionTenantIdForDeployment(String deploymentId, Strin
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateCaseDefinitionTenantIdForDeploymentId", params);
+        getDbSqlSession().update("updateCaseDefinitionTenantIdForDeploymentId", params);
     }
 
     @Override

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/...org/flowable/dmn/engine/impl/persistence/entity/data/impl/MybatisDecisionDataManager.java b/...org/flowable/dmn/engine/impl/persistence/entity/data/impl/MybatisDecisionDataManager.java
@@ -154,7 +154,7 @@ public void updateDecisionTenantIdForDeployment(String deploymentId, String newT
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateDecisionTenantIdForDeploymentId", params);
+        getDbSqlSession().update("updateDecisionTenantIdForDeploymentId", params);
     }
 
 }
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/...flowable-engine-common/src/main/java/org/flowable/common/engine/impl/db/DbSqlSession.java b/...flowable-engine-common/src/main/java/org/flowable/common/engine/impl/db/DbSqlSession.java
@@ -581,7 +581,7 @@ protected void flushUpdates() {
 
         // Unlike bulk deletes, bulk updates are executed before the regular updates.
         // The reason for that, is due to the fact that regular updates might change something that would lead to an invalid bulk update.
-        
+
         if (!bulkUpdateOperations.isEmpty()) {
             bulkUpdateOperations.forEach(this::flushBulkUpdate);
         }

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
@@ -295,7 +295,7 @@ public void updateExecutionTenantIdForDeployment(String deploymentId, String new
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateExecutionTenantIdForDeployment", params);
+        getDbSqlSession().update("updateExecutionTenantIdForDeployment", params);
     }
 
     @Override
@@ -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/...lowable/engine/impl/persistence/entity/data/impl/MybatisProcessDefinitionDataManager.java b/...lowable/engine/impl/persistence/entity/data/impl/MybatisProcessDefinitionDataManager.java
@@ -168,15 +168,15 @@ public void updateProcessDefinitionTenantIdForDeployment(String deploymentId, St
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateProcessDefinitionTenantIdForDeploymentId", params);
+        getDbSqlSession().update("updateProcessDefinitionTenantIdForDeploymentId", params);
     }
 
     @Override
     public void updateProcessDefinitionVersionForProcessDefinitionId(String processDefinitionId, int version) {
         HashMap<String, Object> params = new HashMap<>();
         params.put("processDefinitionId", processDefinitionId);
         params.put("version", version);
-        getDbSqlSession().directUpdate("updateProcessDefinitionVersionForProcessDefinitionId", params);
+        getDbSqlSession().update("updateProcessDefinitionVersionForProcessDefinitionId", params);
     }
 
     protected void setSafeInValueLists(ProcessDefinitionQueryImpl processDefinitionQuery) {

diff --git a/.../eventregistry/impl/persistence/entity/data/impl/MybatisChannelDefinitionDataManager.java b/.../eventregistry/impl/persistence/entity/data/impl/MybatisChannelDefinitionDataManager.java
@@ -151,7 +151,7 @@ public void updateChannelDefinitionTenantIdForDeployment(String deploymentId, St
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateChannelDefinitionTenantIdForDeploymentId", params);
+        getDbSqlSession().update("updateChannelDefinitionTenantIdForDeploymentId", params);
     }
 
     @Override
@@ -160,6 +160,6 @@ public void updateChannelDefinitionTypeAndImplementation(String channelDefinitio
         params.put("id", channelDefinitionId);
         params.put("type", type);
         params.put("implementation", implementation);
-        getDbSqlSession().directUpdate("updateChannelDefinitionTypeAndImplementationById", params);
+        getDbSqlSession().update("updateChannelDefinitionTypeAndImplementationById", params);
     }
 }
diff --git a/...le/eventregistry/impl/persistence/entity/data/impl/MybatisEventDefinitionDataManager.java b/...le/eventregistry/impl/persistence/entity/data/impl/MybatisEventDefinitionDataManager.java
@@ -154,7 +154,7 @@ public void updateEventDefinitionTenantIdForDeployment(String deploymentId, Stri
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateEventDefinitionTenantIdForDeploymentId", params);
+        getDbSqlSession().update("updateEventDefinitionTenantIdForDeploymentId", params);
     }
 
 }
diff --git a/...iption/service/impl/persistence/entity/data/impl/MybatisEventSubscriptionDataManager.java b/...iption/service/impl/persistence/entity/data/impl/MybatisEventSubscriptionDataManager.java
@@ -318,7 +318,7 @@ public void updateEventSubscriptionTenantId(String oldTenantId, String newTenant
         Map<String, String> params = new HashMap<>();
         params.put("oldTenantId", oldTenantId);
         params.put("newTenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateTenantIdOfEventSubscriptions", params);
+        getDbSqlSession().update("updateTenantIdOfEventSubscriptions", params);
     }
 
     @Override
@@ -333,7 +333,7 @@ public void updateEventSubscriptionProcessDefinitionId(String oldProcessDefiniti
         if (StringUtils.isNotBlank(configuration)) {
             params.put("configuration", configuration);
         }
-        getDbSqlSession().directUpdate("updateManualProcessStartEventSubscriptionWithProcessDefinitionId", params);
+        getDbSqlSession().update("updateManualProcessStartEventSubscriptionWithProcessDefinitionId", params);
     }
 
     @Override
@@ -346,7 +346,7 @@ public void updateEventSubscriptionScopeDefinitionId(String oldScopeDefinitionId
         if (StringUtils.isNotBlank(configuration)) {
             params.put("configuration", configuration);
         }
-        getDbSqlSession().directUpdate("updateManualScopeStartEventSubscriptionWithScopeDefinitionId", params);
+        getDbSqlSession().update("updateManualScopeStartEventSubscriptionWithScopeDefinitionId", params);
     }
 
     @Override
@@ -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/...owable/job/service/impl/persistence/entity/data/impl/MybatisDeadLetterJobDataManager.java b/...owable/job/service/impl/persistence/entity/data/impl/MybatisDeadLetterJobDataManager.java
@@ -93,7 +93,7 @@ public void updateJobTenantIdForDeployment(String deploymentId, String newTenant
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateDeadLetterJobTenantIdForDeployment", params);
+        getDbSqlSession().update("updateDeadLetterJobTenantIdForDeployment", params);
     }
 
     @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
@@ -118,7 +118,7 @@ public void updateJobTenantIdForDeployment(String deploymentId, String newTenant
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateExternalWorkerJobTenantIdForDeployment", params);
+        getDbSqlSession().update("updateExternalWorkerJobTenantIdForDeployment", params);
     }
 
     @Override
@@ -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
@@ -101,7 +101,7 @@ public void updateJobTenantIdForDeployment(String deploymentId, String newTenant
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateHistoryJobTenantIdForDeployment", params);
+        getDbSqlSession().update("updateHistoryJobTenantIdForDeployment", params);
     }
 
     @Override
@@ -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
@@ -123,7 +123,7 @@ public void updateJobTenantIdForDeployment(String deploymentId, String newTenant
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateJobTenantIdForDeployment", params);
+        getDbSqlSession().update("updateJobTenantIdForDeployment", params);
     }
 
     @Override
@@ -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/...lowable/job/service/impl/persistence/entity/data/impl/MybatisSuspendedJobDataManager.java b/...lowable/job/service/impl/persistence/entity/data/impl/MybatisSuspendedJobDataManager.java
@@ -93,7 +93,7 @@ public void updateJobTenantIdForDeployment(String deploymentId, String newTenant
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateSuspendedJobTenantIdForDeployment", params);
+        getDbSqlSession().update("updateSuspendedJobTenantIdForDeployment", 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
@@ -176,7 +176,7 @@ public void updateJobTenantIdForDeployment(String deploymentId, String newTenant
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateTimerJobTenantIdForDeployment", params);
+        getDbSqlSession().update("updateTimerJobTenantIdForDeployment", 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
@@ -145,12 +145,12 @@ public void updateTaskTenantIdForDeployment(String deploymentId, String newTenan
         HashMap<String, Object> params = new HashMap<>();
         params.put("deploymentId", deploymentId);
         params.put("tenantId", newTenantId);
-        getDbSqlSession().directUpdate("updateTaskTenantIdForDeployment", params);
+        getDbSqlSession().update("updateTaskTenantIdForDeployment", params);
     }
 
     @Override
     public void updateAllTaskRelatedEntityCountFlags(boolean newValue) {
-        getDbSqlSession().directUpdate("updateTaskRelatedEntityCountEnabled", newValue);
+        getDbSqlSession().update("updateTaskRelatedEntityCountEnabled", newValue);
     }
 
     @Override