protected class BaseUpgradeCompanyId.TableUpdater
extends java.lang.Object
implements java.util.concurrent.Callable<java.lang.Void>
| Constructor and Description |
|---|
TableUpdater(java.lang.String tableName,
java.lang.String foreignTableName,
java.lang.String foreignColumnName) |
TableUpdater(java.lang.String tableName,
java.lang.String columnName,
java.lang.String[][] foreignNamesArray) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.Void |
call() |
protected java.util.List<java.lang.Long> |
getCompanyIds(java.sql.Connection connection) |
protected java.lang.String |
getSelectSQL(java.sql.Connection connection,
java.lang.String foreignTableName,
java.lang.String foreignColumnName) |
java.lang.String |
getTableName() |
protected java.lang.String |
getUpdateSQL(java.sql.Connection connection,
java.lang.String foreignTableName,
java.lang.String foreignColumnName) |
protected java.lang.String |
getUpdateSQL(java.lang.String selectSQL) |
void |
setCreateCompanyIdColumn(boolean createCompanyIdColumn) |
void |
update(java.sql.Connection connection) |
public TableUpdater(java.lang.String tableName,
java.lang.String foreignTableName,
java.lang.String foreignColumnName)
public TableUpdater(java.lang.String tableName,
java.lang.String columnName,
java.lang.String[][] foreignNamesArray)
public final java.lang.Void call()
throws java.lang.Exception
call in interface java.util.concurrent.Callable<java.lang.Void>java.lang.Exceptionpublic java.lang.String getTableName()
public void setCreateCompanyIdColumn(boolean createCompanyIdColumn)
public void update(java.sql.Connection connection)
throws java.io.IOException,
java.sql.SQLException
java.io.IOExceptionjava.sql.SQLExceptionprotected java.util.List<java.lang.Long> getCompanyIds(java.sql.Connection connection)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.String getSelectSQL(java.sql.Connection connection,
java.lang.String foreignTableName,
java.lang.String foreignColumnName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.String getUpdateSQL(java.sql.Connection connection,
java.lang.String foreignTableName,
java.lang.String foreignColumnName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.String getUpdateSQL(java.lang.String selectSQL)