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.SubscriptionImpl;
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 import com.liferay.portal.upgrade.v4_3_0.util.ClassNameIdUpgradeColumnImpl;
34 import com.liferay.portal.upgrade.v4_3_0.util.ClassPKContainer;
35 import com.liferay.portal.upgrade.v4_3_0.util.ClassPKUpgradeColumnImpl;
36 import com.liferay.portal.util.PortalUtil;
37 import com.liferay.portlet.messageboards.model.MBCategory;
38
39 import java.sql.Types;
40
41 import java.util.HashMap;
42 import java.util.Map;
43
44
51 public class UpgradeSubscription extends UpgradeProcess {
52
53 public void upgrade() throws UpgradeException {
54 _log.info("Upgrading");
55
56 try {
57 doUpgrade();
58 }
59 catch (Exception e) {
60 throw new UpgradeException(e);
61 }
62 }
63
64 protected void doUpgrade() throws Exception {
65
66
68 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
69 "userId", new Integer(Types.VARCHAR),
70 AvailableMappersUtil.getUserIdMapper());
71
72 ClassNameIdUpgradeColumnImpl classNameIdColumn =
73 new ClassNameIdUpgradeColumnImpl();
74
75 Map<Long, ClassPKContainer> classPKContainers =
76 new HashMap<Long, ClassPKContainer>();
77
78 classPKContainers.put(
79 new Long(PortalUtil.getClassNameId(MBCategory.class.getName())),
80 new ClassPKContainer(
81 AvailableMappersUtil.getMBCategoryIdMapper(), true));
82
83 UpgradeColumn upgradeClassPKColumn = new ClassPKUpgradeColumnImpl(
84 classNameIdColumn, classPKContainers);
85
86 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
87 SubscriptionImpl.TABLE_NAME, SubscriptionImpl.TABLE_COLUMNS,
88 new PKUpgradeColumnImpl("subscriptionId", false),
89 upgradeUserIdColumn, classNameIdColumn, upgradeClassPKColumn);
90
91 upgradeTable.setCreateSQL(SubscriptionImpl.TABLE_SQL_CREATE);
92
93 upgradeTable.updateTable();
94 }
95
96 private static Log _log = LogFactoryUtil.getLog(UpgradeSubscription.class);
97
98 }