org.springframework.cloud.dataflow.server.db.migration

Class DropColumnSqlCommands

java.lang.Object

org.springframework.cloud.dataflow.common.flyway.SqlCommand

org.springframework.cloud.dataflow.server.db.migration.DropColumnSqlCommands

public class DropColumnSqlCommands
extends org.springframework.cloud.dataflow.common.flyway.SqlCommand

Utility class that can be used in future to drop columns. This checks for the existence of the column before dropping.

Author:

Corneil du Plessis

Constructor Summary

Constructors

Constructor and Description
DropColumnSqlCommands(String... columnName)

Method Summary

Modifier and Type	Method and Description
boolean	canHandleInJdbcTemplate()
protected void	dropColumn(JdbcTemplate jdbcTemplate, Connection connection, String name)
void	handle(JdbcTemplate jdbcTemplate, Connection connection)
protected boolean	hasColumn(Connection connection, String schemaName, String tableName, String columnName)

Methods inherited from class org.springframework.cloud.dataflow.common.flyway.SqlCommand

from, from, getCommand, getSuppressedErrorCodes

Methods inherited from class java.lang.Object

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

Constructor Detail

DropColumnSqlCommands

public DropColumnSqlCommands(String... columnName)

Method Detail

handle

public void handle(JdbcTemplate jdbcTemplate,
                   Connection connection)

Overrides:

handle in class org.springframework.cloud.dataflow.common.flyway.SqlCommand

canHandleInJdbcTemplate

public boolean canHandleInJdbcTemplate()

Overrides:

canHandleInJdbcTemplate in class org.springframework.cloud.dataflow.common.flyway.SqlCommand

dropColumn

protected void dropColumn(JdbcTemplate jdbcTemplate,
                          Connection connection,
                          String name)
                   throws SQLException

Throws:

SQLException

hasColumn

protected boolean hasColumn(Connection connection,
                            String schemaName,
                            String tableName,
                            String columnName)
                     throws SQLException

Throws:

SQLException