1
19
20 package com.liferay.portal.upgrade.v4_3_0;
21
22 import com.liferay.portal.kernel.log.Log;
23 import com.liferay.portal.kernel.log.LogFactoryUtil;
24 import com.liferay.portal.model.impl.UserIdMapperImpl;
25 import com.liferay.portal.upgrade.UpgradeException;
26 import com.liferay.portal.upgrade.UpgradeProcess;
27 import com.liferay.portal.upgrade.util.DefaultUpgradeTableImpl;
28 import com.liferay.portal.upgrade.util.PKUpgradeColumnImpl;
29 import com.liferay.portal.upgrade.util.SwapUpgradeColumnImpl;
30 import com.liferay.portal.upgrade.util.UpgradeColumn;
31 import com.liferay.portal.upgrade.util.UpgradeTable;
32 import com.liferay.portal.upgrade.v4_3_0.util.AvailableMappersUtil;
33
34 import java.sql.Types;
35
36
42 public class UpgradeUserIdMapper extends UpgradeProcess {
43
44 public void upgrade() throws UpgradeException {
45 _log.info("Upgrading");
46
47 try {
48 doUpgrade();
49 }
50 catch (Exception e) {
51 throw new UpgradeException(e);
52 }
53 }
54
55 protected void doUpgrade() throws Exception {
56
57
59 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
60 "userId", new Integer(Types.VARCHAR),
61 AvailableMappersUtil.getUserIdMapper());
62
63 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
64 UserIdMapperImpl.TABLE_NAME, UserIdMapperImpl.TABLE_COLUMNS,
65 new PKUpgradeColumnImpl("userIdMapperId", false),
66 upgradeUserIdColumn);
67
68 upgradeTable.setCreateSQL(UserIdMapperImpl.TABLE_SQL_CREATE);
69
70 upgradeTable.updateTable();
71 }
72
73 private static Log _log = LogFactoryUtil.getLog(UpgradeUserIdMapper.class);
74
75 }