1
22
23 package com.liferay.portal.upgrade.v4_3_0;
24
25 import com.liferay.portal.upgrade.UpgradeProcess;
26 import com.liferay.portal.upgrade.util.DefaultUpgradeTableImpl;
27 import com.liferay.portal.upgrade.util.PKUpgradeColumnImpl;
28 import com.liferay.portal.upgrade.util.SwapUpgradeColumnImpl;
29 import com.liferay.portal.upgrade.util.UpgradeColumn;
30 import com.liferay.portal.upgrade.util.UpgradeTable;
31 import com.liferay.portal.upgrade.v4_3_0.util.AvailableMappersUtil;
32 import com.liferay.portal.upgrade.v4_3_0.util.ClassNameIdUpgradeColumnImpl;
33 import com.liferay.portal.upgrade.v4_3_0.util.ClassPKContainer;
34 import com.liferay.portal.upgrade.v4_3_0.util.ClassPKUpgradeColumnImpl;
35 import com.liferay.portal.upgrade.v4_3_0.util.SubscriptionTable;
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
50 public class UpgradeSubscription extends UpgradeProcess {
51
52 protected void doUpgrade() throws Exception {
53
54
56 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
57 "userId", new Integer(Types.VARCHAR),
58 AvailableMappersUtil.getUserIdMapper());
59
60 ClassNameIdUpgradeColumnImpl classNameIdColumn =
61 new ClassNameIdUpgradeColumnImpl();
62
63 Map<Long, ClassPKContainer> classPKContainers =
64 new HashMap<Long, ClassPKContainer>();
65
66 classPKContainers.put(
67 new Long(PortalUtil.getClassNameId(MBCategory.class.getName())),
68 new ClassPKContainer(
69 AvailableMappersUtil.getMBCategoryIdMapper(), true));
70
71 UpgradeColumn upgradeClassPKColumn = new ClassPKUpgradeColumnImpl(
72 classNameIdColumn, classPKContainers);
73
74 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
75 SubscriptionTable.TABLE_NAME, SubscriptionTable.TABLE_COLUMNS,
76 new PKUpgradeColumnImpl("subscriptionId", false),
77 upgradeUserIdColumn, classNameIdColumn, upgradeClassPKColumn);
78
79 upgradeTable.setCreateSQL(SubscriptionTable.TABLE_SQL_CREATE);
80
81 upgradeTable.updateTable();
82 }
83
84 }