1
22
23 package com.liferay.portal.upgrade.v4_3_0;
24
25 import com.liferay.portal.model.impl.SubscriptionImpl;
26 import com.liferay.portal.upgrade.UpgradeException;
27 import com.liferay.portal.upgrade.UpgradeProcess;
28 import com.liferay.portal.upgrade.util.DefaultUpgradeTableImpl;
29 import com.liferay.portal.upgrade.util.PKUpgradeColumnImpl;
30 import com.liferay.portal.upgrade.util.SwapUpgradeColumnImpl;
31 import com.liferay.portal.upgrade.util.UpgradeColumn;
32 import com.liferay.portal.upgrade.util.UpgradeTable;
33 import com.liferay.portal.upgrade.v4_3_0.util.AvailableMappersUtil;
34 import com.liferay.portal.upgrade.v4_3_0.util.ClassNameIdUpgradeColumnImpl;
35 import com.liferay.portal.upgrade.v4_3_0.util.ClassPKContainer;
36 import com.liferay.portal.upgrade.v4_3_0.util.ClassPKUpgradeColumnImpl;
37 import com.liferay.portal.util.PortalUtil;
38 import com.liferay.portlet.messageboards.model.MBCategory;
39 import com.liferay.util.CollectionFactory;
40
41 import java.sql.Types;
42
43 import java.util.Map;
44
45 import org.apache.commons.logging.Log;
46 import org.apache.commons.logging.LogFactory;
47
48
55 public class UpgradeSubscription extends UpgradeProcess {
56
57 public void upgrade() throws UpgradeException {
58 _log.info("Upgrading");
59
60 try {
61 doUpgrade();
62 }
63 catch (Exception e) {
64 throw new UpgradeException(e);
65 }
66 }
67
68 protected void doUpgrade() throws Exception {
69
70
72 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
73 "userId", new Integer(Types.VARCHAR),
74 AvailableMappersUtil.getUserIdMapper());
75
76 ClassNameIdUpgradeColumnImpl classNameIdColumn =
77 new ClassNameIdUpgradeColumnImpl();
78
79 Map classPKContainers = CollectionFactory.getHashMap();
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 = LogFactory.getLog(UpgradeSubscription.class);
100
101 }