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.TempUpgradeColumnImpl;
31 import com.liferay.portal.upgrade.util.UpgradeColumn;
32 import com.liferay.portal.upgrade.util.UpgradeTable;
33 import com.liferay.portal.upgrade.util.ValueMapper;
34 import com.liferay.portal.upgrade.v4_3_0.util.AvailableMappersUtil;
35 import com.liferay.portal.upgrade.v4_3_0.util.WikiPageIdUpgradeColumnImpl;
36 import com.liferay.portal.upgrade.v4_3_0.util.WikiPageResourcePrimKeyUpgradeColumnImpl;
37 import com.liferay.portlet.wiki.model.impl.WikiNodeImpl;
38 import com.liferay.portlet.wiki.model.impl.WikiPageImpl;
39
40 import java.sql.Types;
41
42 import org.apache.commons.logging.Log;
43 import org.apache.commons.logging.LogFactory;
44
45
51 public class UpgradeWiki extends UpgradeProcess {
52
53 public void upgrade() throws UpgradeException {
54 _log.info("Upgrading");
55
56 try {
57 doUpgrade();
58 }
59 catch (Exception e) {
60 throw new UpgradeException(e);
61 }
62 }
63
64 protected void doUpgrade() throws Exception {
65
66
68 UpgradeColumn upgradeGroupIdColumn = new SwapUpgradeColumnImpl(
69 "groupId", AvailableMappersUtil.getGroupIdMapper());
70
71 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
72 "userId", new Integer(Types.VARCHAR),
73 AvailableMappersUtil.getUserIdMapper());
74
75 PKUpgradeColumnImpl upgradePKColumn = new PKUpgradeColumnImpl(
76 "nodeId", true);
77
78 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
79 WikiNodeImpl.TABLE_NAME, WikiNodeImpl.TABLE_COLUMNS,
80 upgradePKColumn, upgradeGroupIdColumn, upgradeUserIdColumn);
81
82 upgradeTable.setCreateSQL(WikiNodeImpl.TABLE_SQL_CREATE);
83
84 upgradeTable.updateTable();
85
86 ValueMapper nodeIdMapper = upgradePKColumn.getValueMapper();
87
88 AvailableMappersUtil.setWikiNodeIdMapper(nodeIdMapper);
89
90 UpgradeColumn upgradeNodeIdColumn = new SwapUpgradeColumnImpl(
91 "nodeId", nodeIdMapper);
92
93
95 UpgradeColumn upgradeTitleColumn = new TempUpgradeColumnImpl("title");
96
97 WikiPageIdUpgradeColumnImpl upgradePageIdColumn =
98 new WikiPageIdUpgradeColumnImpl(
99 upgradeNodeIdColumn, upgradeTitleColumn);
100
101 UpgradeColumn upgradePageResourcePrimKeyColumn =
102 new WikiPageResourcePrimKeyUpgradeColumnImpl(
103 upgradePageIdColumn);
104
105 upgradeTable = new DefaultUpgradeTableImpl(
106 WikiPageImpl.TABLE_NAME, WikiPageImpl.TABLE_COLUMNS,
107 upgradeNodeIdColumn, upgradeTitleColumn, upgradePageIdColumn,
108 upgradePageResourcePrimKeyColumn, upgradeUserIdColumn);
109
110 upgradeTable.setCreateSQL(WikiPageImpl.TABLE_SQL_CREATE);
111
112 upgradeTable.updateTable();
113
114 ValueMapper pageIdMapper = upgradePageIdColumn.getValueMapper();
115
116 AvailableMappersUtil.setWikiPageIdMapper(pageIdMapper);
117 }
118
119 private static Log _log = LogFactory.getLog(UpgradeWiki.class);
120
121 }