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
41 import java.sql.Types;
42
43 import java.util.HashMap;
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<Long, ClassPKContainer> classPKContainers =
80 new HashMap<Long, ClassPKContainer>();
81
82 classPKContainers.put(
83 new Long(PortalUtil.getClassNameId(DLFileEntry.class.getName())),
84 new ClassPKContainer(
85 AvailableMappersUtil.getDLFileEntryIdMapper(), false));
86
87 UpgradeColumn upgradeClassPKColumn = new ClassPKUpgradeColumnImpl(
88 classNameIdColumn, classPKContainers);
89
90 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
91 RatingsEntryImpl.TABLE_NAME, RatingsEntryImpl.TABLE_COLUMNS,
92 new PKUpgradeColumnImpl("entryId", false), upgradeUserIdColumn,
93 classNameIdColumn, upgradeClassPKColumn);
94
95 upgradeTable.setCreateSQL(RatingsEntryImpl.TABLE_SQL_CREATE);
96
97 upgradeTable.updateTable();
98
99
101 upgradeTable = new DefaultUpgradeTableImpl(
102 RatingsStatsImpl.TABLE_NAME, RatingsStatsImpl.TABLE_COLUMNS,
103 new PKUpgradeColumnImpl("statsId", false), classNameIdColumn,
104 upgradeClassPKColumn);
105
106 upgradeTable.setCreateSQL(RatingsStatsImpl.TABLE_SQL_CREATE);
107
108 upgradeTable.updateTable();
109 }
110
111 private static Log _log = LogFactory.getLog(UpgradeRatings.class);
112
113 }