001
014
015 package com.liferay.portal.upgrade.v4_3_0;
016
017 import com.liferay.portal.kernel.upgrade.UpgradeProcess;
018 import com.liferay.portal.kernel.upgrade.util.DefaultPKMapper;
019 import com.liferay.portal.kernel.upgrade.util.SwapUpgradeColumnImpl;
020 import com.liferay.portal.kernel.upgrade.util.TempUpgradeColumnImpl;
021 import com.liferay.portal.kernel.upgrade.util.UpgradeColumn;
022 import com.liferay.portal.kernel.upgrade.util.UpgradeTable;
023 import com.liferay.portal.kernel.upgrade.util.UpgradeTableFactoryUtil;
024 import com.liferay.portal.kernel.upgrade.util.ValueMapper;
025 import com.liferay.portal.upgrade.util.PKUpgradeColumnImpl;
026 import com.liferay.portal.upgrade.v4_3_0.util.AccountTable;
027 import com.liferay.portal.upgrade.v4_3_0.util.AvailableMappersUtil;
028 import com.liferay.portal.upgrade.v4_3_0.util.ContactTable;
029 import com.liferay.portal.upgrade.v4_3_0.util.CyrusUserTable;
030 import com.liferay.portal.upgrade.v4_3_0.util.CyrusVirtualTable;
031 import com.liferay.portal.upgrade.v4_3_0.util.PasswordTrackerTable;
032 import com.liferay.portal.upgrade.v4_3_0.util.UserPortraitIdUpgradeColumnImpl;
033 import com.liferay.portal.upgrade.v4_3_0.util.UserTable;
034
035 import java.sql.Types;
036
037
042 public class UpgradeUser extends UpgradeProcess {
043
044 protected void doUpgrade() throws Exception {
045
046
047
048 PKUpgradeColumnImpl upgradePKColumn =
049 new PKUpgradeColumnImpl("userId", new Integer(Types.VARCHAR), true);
050
051 UpgradeColumn upgradeCompanyIdColumn = new TempUpgradeColumnImpl(
052 "companyId", new Integer(Types.VARCHAR));
053
054 UpgradeColumn upgradeContactIdColumn = new TempUpgradeColumnImpl(
055 "contactId", new Integer(Types.VARCHAR));
056
057 UpgradeColumn upgradeUserPortraitIdColumn =
058 new UserPortraitIdUpgradeColumnImpl(
059 upgradePKColumn, AvailableMappersUtil.getImageIdMapper());
060
061 UpgradeTable upgradeTable = UpgradeTableFactoryUtil.getUpgradeTable(
062 UserTable.TABLE_NAME, UserTable.TABLE_COLUMNS, upgradePKColumn,
063 upgradeCompanyIdColumn, upgradeContactIdColumn,
064 upgradeUserPortraitIdColumn);
065
066 upgradeTable.updateTable();
067
068 ValueMapper userIdMapper = new DefaultPKMapper(
069 upgradePKColumn.getValueMapper());
070
071 AvailableMappersUtil.setUserIdMapper(userIdMapper);
072
073 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
074 "userId", new Integer(Types.VARCHAR), userIdMapper);
075
076
077
078 upgradeTable = UpgradeTableFactoryUtil.getUpgradeTable(
079 AccountTable.TABLE_NAME, AccountTable.TABLE_COLUMNS,
080 upgradeUserIdColumn);
081
082 upgradeTable.setCreateSQL(AccountTable.TABLE_SQL_CREATE);
083
084 upgradeTable.updateTable();
085
086
087
088 UpgradeColumn upgradeAccountIdColumn = new TempUpgradeColumnImpl(
089 "accountId", new Integer(Types.VARCHAR));
090
091 UpgradeColumn upgradeParentContactIdColumn = new TempUpgradeColumnImpl(
092 "parentContactId", new Integer(Types.VARCHAR));
093
094 UpgradeColumn upgradePrefixIdColumn = new TempUpgradeColumnImpl(
095 "prefixId", new Integer(Types.VARCHAR));
096
097 UpgradeColumn upgradeSuffixIdColumn = new TempUpgradeColumnImpl(
098 "suffixId", new Integer(Types.VARCHAR));
099
100 upgradeTable = UpgradeTableFactoryUtil.getUpgradeTable(
101 ContactTable.TABLE_NAME, ContactTable.TABLE_COLUMNS,
102 upgradeContactIdColumn, upgradeCompanyIdColumn, upgradeUserIdColumn,
103 upgradeAccountIdColumn, upgradeParentContactIdColumn,
104 upgradePrefixIdColumn, upgradeSuffixIdColumn);
105
106 upgradeTable.updateTable();
107
108
109
110 upgradeTable = UpgradeTableFactoryUtil.getUpgradeTable(
111 CyrusUserTable.TABLE_NAME, CyrusUserTable.TABLE_COLUMNS,
112 upgradeUserIdColumn);
113
114 upgradeTable.updateTable();
115
116
117
118 upgradeTable = UpgradeTableFactoryUtil.getUpgradeTable(
119 CyrusVirtualTable.TABLE_NAME, CyrusVirtualTable.TABLE_COLUMNS,
120 upgradeUserIdColumn);
121
122 upgradeTable.updateTable();
123
124
125
126 upgradeTable = UpgradeTableFactoryUtil.getUpgradeTable(
127 PasswordTrackerTable.TABLE_NAME, PasswordTrackerTable.TABLE_COLUMNS,
128 new PKUpgradeColumnImpl("passwordTrackerId", false),
129 upgradeUserIdColumn);
130
131 upgradeTable.setCreateSQL(PasswordTrackerTable.TABLE_SQL_CREATE);
132
133 upgradeTable.updateTable();
134 }
135
136 }