inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-07-31 17:39:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

ACS-1600 : Error when running propTablesCleanupJob on an env with 100 million records in alf_prop_value (#473)

Browse Source 
- commit changes to db anytime `deleteBatchSize` of deleted data is reached
This commit is contained in:
Denis Ungureanu
2021-05-21 14:26:01 +03:00
committed by GitHub
parent 5092bf8a89
commit 00b0b21668
2 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
repository/src/main/java/org/alfresco/repo/domain/schema/script/DeleteNotExistsExecutor.java
View File

@@ -220,7 +220,6 @@ public class DeleteNotExistsExecutor implements StatementExecutor
{ {
// Process batch // Process batch
primaryId = processPrimaryTableResultSet(primaryPrepStmt, secondaryPrepStmts, deletePrepStmt, deleteIds, primaryTableName, primaryColumnName, tableColumn); primaryId = processPrimaryTableResultSet(primaryPrepStmt, secondaryPrepStmts, deletePrepStmt, deleteIds, primaryTableName, primaryColumnName, tableColumn);
connection.commit();
if (primaryId == null) if (primaryId == null)
{ {
@@ -299,6 +298,7 @@ public class DeleteNotExistsExecutor implements StatementExecutor
if (deleteIds.size() == deleteBatchSize) if (deleteIds.size() == deleteBatchSize)
{ {
deleteFromPrimaryTable(deletePrepStmt, deleteIds, primaryTableName); deleteFromPrimaryTable(deletePrepStmt, deleteIds, primaryTableName);
connection.commit();
} }
if (!resultSet.next()) if (!resultSet.next())

1
repository/src/main/java/org/alfresco/repo/domain/schema/script/MySQLDeleteNotExistsExecutor.java
View File

@@ -126,7 +126,6 @@ public class MySQLDeleteNotExistsExecutor extends DeleteNotExistsExecutor
{ {
// Process batch // Process batch
primaryId = processPrimaryTableResultSet(primaryPrepStmt, secondaryPrepStmts, deletePrepStmt, deleteIds, primaryTableName, primaryColumnName, tableColumn); primaryId = processPrimaryTableResultSet(primaryPrepStmt, secondaryPrepStmts, deletePrepStmt, deleteIds, primaryTableName, primaryColumnName, tableColumn);
connection.commit();
if (primaryId == null) if (primaryId == null)
{ {