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	closeQuietly(Connection connection)
protected void	closeQuietly(Connection[] connections)
protected void	process(Pair<String,String>[] tableColumn, Long[] tableUpperLimits, String[] optionalWhereClauses)

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

checkProperties, closeQuietly, closeQuietly, closeQuietly, closeQuietly, createPreparedDeleteStatement, createPreparedSelectStatement, deleteFromPrimaryTable, execute, isTimeoutExceeded, processPrimaryTableResultSet

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

closeQuietly

protected void closeQuietly(Connection connection)

closeQuietly

protected void closeQuietly(Connection[] connections)