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.RatingsEntryTable;
36 import com.liferay.portal.upgrade.v4_3_0.util.RatingsStatsTable;
37 import com.liferay.portal.util.PortalUtil;
38 import com.liferay.portlet.documentlibrary.model.DLFileEntry;
39
40 import java.sql.Types;
41
42 import java.util.HashMap;
43 import java.util.Map;
44
45
50 public class UpgradeRatings 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(DLFileEntry.class.getName())),
68 new ClassPKContainer(
69 AvailableMappersUtil.getDLFileEntryIdMapper(), false));
70
71 UpgradeColumn upgradeClassPKColumn = new ClassPKUpgradeColumnImpl(
72 classNameIdColumn, classPKContainers);
73
74 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
75 RatingsEntryTable.TABLE_NAME, RatingsEntryTable.TABLE_COLUMNS,
76 new PKUpgradeColumnImpl("entryId", false), upgradeUserIdColumn,
77 classNameIdColumn, upgradeClassPKColumn);
78
79 upgradeTable.setCreateSQL(RatingsEntryTable.TABLE_SQL_CREATE);
80
81 upgradeTable.updateTable();
82
83
85 upgradeTable = new DefaultUpgradeTableImpl(
86 RatingsStatsTable.TABLE_NAME, RatingsStatsTable.TABLE_COLUMNS,
87 new PKUpgradeColumnImpl("statsId", false), classNameIdColumn,
88 upgradeClassPKColumn);
89
90 upgradeTable.setCreateSQL(RatingsStatsTable.TABLE_SQL_CREATE);
91
92 upgradeTable.updateTable();
93 }
94
95 }