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, getTableColumnsMap, getTableName, getThreshold, increment, increment, increment, isPortal62TableName, isSkipUpgradeProcess, isSupportsAlterColumnName, isSupportsAlterColumnType, isSupportsStringCaseSensitiveQuery, isSupportsUpdateWithInnerJoin, normalizeName, upgrade, upgrade, upgrade, upgrade, upgradeTable, upgradeTable
protected void copyCompanyTable(Connection sourceConnection, Connection targetConnection, String shardName) throws Exception
Exception
protected void copyControlTable(Connection sourceConnection, Connection targetConnection, String tableName, Object[][] columns, String createSQL) throws Exception
Exception
protected void copyControlTables(List<String> shardNames) throws Exception
Exception
protected void copyControlTables(String shardName) throws Exception
Exception
protected void doUpgrade() throws Exception
doUpgrade
in class com.liferay.portal.kernel.upgrade.UpgradeProcess
Exception
protected void dropTable(Connection connection, String tableName) throws IOException, SQLException
IOException
SQLException
protected List<Long> getCompanyIds(String shardName) throws Exception
Exception
protected List<String> getShardNames() throws Exception
Exception