1
22
23 package com.liferay.portal.upgrade.v4_3_0;
24
25 import com.liferay.portal.upgrade.UpgradeException;
26 import com.liferay.portal.upgrade.UpgradeProcess;
27 import com.liferay.portal.upgrade.util.DefaultUpgradeTableImpl;
28 import com.liferay.portal.upgrade.util.PKUpgradeColumnImpl;
29 import com.liferay.portal.upgrade.util.SwapUpgradeColumnImpl;
30 import com.liferay.portal.upgrade.util.UpgradeColumn;
31 import com.liferay.portal.upgrade.util.UpgradeTable;
32 import com.liferay.portal.upgrade.v4_3_0.util.AvailableMappersUtil;
33 import com.liferay.portal.upgrade.v4_3_0.util.ClassNameIdUpgradeColumnImpl;
34 import com.liferay.portal.upgrade.v4_3_0.util.ClassPKContainer;
35 import com.liferay.portal.upgrade.v4_3_0.util.ClassPKUpgradeColumnImpl;
36 import com.liferay.portal.util.PortalUtil;
37 import com.liferay.portlet.documentlibrary.model.DLFileEntry;
38 import com.liferay.portlet.ratings.model.impl.RatingsEntryImpl;
39 import com.liferay.portlet.ratings.model.impl.RatingsStatsImpl;
40 import com.liferay.util.CollectionFactory;
41
42 import java.sql.Types;
43
44 import java.util.Map;
45
46 import org.apache.commons.logging.Log;
47 import org.apache.commons.logging.LogFactory;
48
49
55 public class UpgradeRatings 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(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 = LogFactory.getLog(UpgradeRatings.class);
111
112 }