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.upgrade.UpgradeException;
28 import com.liferay.portal.upgrade.UpgradeProcess;
29 import com.liferay.portal.upgrade.util.DefaultUpgradeTableImpl;
30 import com.liferay.portal.upgrade.util.PKUpgradeColumnImpl;
31 import com.liferay.portal.upgrade.util.SwapUpgradeColumnImpl;
32 import com.liferay.portal.upgrade.util.UpgradeColumn;
33 import com.liferay.portal.upgrade.util.UpgradeTable;
34 import com.liferay.portal.upgrade.v4_3_0.util.AvailableMappersUtil;
35 import com.liferay.portal.upgrade.v4_3_0.util.ClassNameIdUpgradeColumnImpl;
36 import com.liferay.portal.upgrade.v4_3_0.util.ClassPKContainer;
37 import com.liferay.portal.upgrade.v4_3_0.util.ClassPKUpgradeColumnImpl;
38 import com.liferay.portal.util.PortalUtil;
39 import com.liferay.portlet.documentlibrary.model.DLFileEntry;
40 import com.liferay.portlet.ratings.model.impl.RatingsEntryImpl;
41 import com.liferay.portlet.ratings.model.impl.RatingsStatsImpl;
42
43 import java.sql.Types;
44
45 import java.util.HashMap;
46 import java.util.Map;
47
48
54 public class UpgradeRatings 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(DLFileEntry.class.getName())),
83 new ClassPKContainer(
84 AvailableMappersUtil.getDLFileEntryIdMapper(), false));
85
86 UpgradeColumn upgradeClassPKColumn = new ClassPKUpgradeColumnImpl(
87 classNameIdColumn, classPKContainers);
88
89 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
90 RatingsEntryImpl.TABLE_NAME, RatingsEntryImpl.TABLE_COLUMNS,
91 new PKUpgradeColumnImpl("entryId", false), upgradeUserIdColumn,
92 classNameIdColumn, upgradeClassPKColumn);
93
94 upgradeTable.setCreateSQL(RatingsEntryImpl.TABLE_SQL_CREATE);
95
96 upgradeTable.updateTable();
97
98
100 upgradeTable = new DefaultUpgradeTableImpl(
101 RatingsStatsImpl.TABLE_NAME, RatingsStatsImpl.TABLE_COLUMNS,
102 new PKUpgradeColumnImpl("statsId", false), classNameIdColumn,
103 upgradeClassPKColumn);
104
105 upgradeTable.setCreateSQL(RatingsStatsImpl.TABLE_SQL_CREATE);
106
107 upgradeTable.updateTable();
108 }
109
110 private static Log _log = LogFactoryUtil.getLog(UpgradeRatings.class);
111
112 }