public class UpgradeSharding
extends com.liferay.portal.kernel.upgrade.UpgradeProcess
com.liferay.portal.kernel.upgrade.UpgradeProcess.Alterable, com.liferay.portal.kernel.upgrade.UpgradeProcess.AlterColumnName, com.liferay.portal.kernel.upgrade.UpgradeProcess.AlterColumnType, com.liferay.portal.kernel.upgrade.UpgradeProcess.AlterTableAddColumn, com.liferay.portal.kernel.upgrade.UpgradeProcess.AlterTableDropColumn| Constructor and Description |
|---|
UpgradeSharding() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
copyCompanyTable(Connection sourceConnection,
Connection targetConnection,
String shardName) |
protected void |
copyControlTable(Connection sourceConnection,
Connection targetConnection,
String tableName,
Object[][] columns,
String createSQL) |
protected void |
copyControlTables(List<String> shardNames) |
protected void |
copyControlTables(String shardName) |
protected void |
doUpgrade() |
protected void |
dropTable(Connection connection,
String tableName) |
protected List<Long> |
getCompanyIds(String shardName) |
protected List<String> |
getShardNames() |
alter, clearIndexesCache, getIndexesSQL, getThreshold, increment, increment, increment, isSupportsAlterColumnName, isSupportsAlterColumnType, isSupportsStringCaseSensitiveQuery, isSupportsUpdateWithInnerJoin, normalizeName, upgrade, upgrade, upgrade, upgrade, upgradeTable, upgradeTableprotected void copyCompanyTable(Connection sourceConnection, Connection targetConnection, String shardName) throws Exception
Exceptionprotected void copyControlTable(Connection sourceConnection, Connection targetConnection, String tableName, Object[][] columns, String createSQL) throws Exception
Exceptionprotected void copyControlTables(List<String> shardNames) throws Exception
Exceptionprotected void copyControlTables(String shardName) throws Exception
Exceptionprotected void doUpgrade()
throws Exception
doUpgrade in class com.liferay.portal.kernel.upgrade.UpgradeProcessExceptionprotected void dropTable(Connection connection, String tableName) throws IOException, SQLException
IOExceptionSQLExceptionprotected List<Long> getCompanyIds(String shardName) throws Exception
Exception