Package org.alfresco.repo.domain.schema.script

Class MySQLDeleteNotExistsExecutor

java.lang.Object

org.alfresco.repo.domain.schema.script.DeleteNotExistsExecutor

org.alfresco.repo.domain.schema.script.MySQLDeleteNotExistsExecutor

All Implemented Interfaces:

StatementExecutor

public class MySQLDeleteNotExistsExecutor
extends DeleteNotExistsExecutor

Extends DeleteNotExistsExecutor to cope with MySQL specific fetch size limitation and restrictions.

Field Summary

Fields inherited from class org.alfresco.repo.domain.schema.script.DeleteNotExistsExecutor

batchSize, connection, deleteBatchSize, deletedCount, PROPERTY_BATCH_SIZE, PROPERTY_DELETE_BATCH_SIZE, PROPERTY_READ_ONLY, PROPERTY_TIMEOUT_SECONDS, readOnly, startTime

Constructor Summary

Constructors

Constructor	Description
MySQLDeleteNotExistsExecutor(Connection connection, String sql, int line, File scriptFile, Properties globalProperties, DataSource dataSource)

Method Summary

Modifier and Type	Method	Description
protected void	process(Pair<String,String>[] tableColumn, Long[] tableUpperLimits, String[] optionalWhereClauses)
protected Long	processPrimaryTableResultSet(PreparedStatement primaryPrepStmt, PreparedStatement[] secondaryPrepStmts, PreparedStatement deletePrepStmt, Set<Long> deleteIds, String primaryTableName, String primaryColumnName, Pair<String,String>[] tableColumn)

Methods inherited from class org.alfresco.repo.domain.schema.script.DeleteNotExistsExecutor

checkProperties, closeQuietly, closeQuietly, closeQuietly, closeQuietly, createPreparedDeleteStatement, createPreparedSelectStatement, deleteFromPrimaryTable, execute, getColumnValueById, getSecondaryIds, getSecondaryResultSets, isLess, isTimeoutExceeded

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MySQLDeleteNotExistsExecutor

public MySQLDeleteNotExistsExecutor(Connection connection,
                                    String sql,
                                    int line,
                                    File scriptFile,
                                    Properties globalProperties,
                                    DataSource dataSource)

Method Detail

process

protected void process(Pair<String,String>[] tableColumn,
                       Long[] tableUpperLimits,
                       String[] optionalWhereClauses)
                throws SQLException

Overrides:

process in class DeleteNotExistsExecutor

Throws:

SQLException

processPrimaryTableResultSet

protected Long processPrimaryTableResultSet(PreparedStatement primaryPrepStmt,
                                            PreparedStatement[] secondaryPrepStmts,
                                            PreparedStatement deletePrepStmt,
                                            Set<Long> deleteIds,
                                            String primaryTableName,
                                            String primaryColumnName,
                                            Pair<String,String>[] tableColumn)
                                     throws SQLException

Overrides:

processPrimaryTableResultSet in class DeleteNotExistsExecutor

Throws:

SQLException