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