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.DefaultPKMapper;
28 import com.liferay.portal.upgrade.util.DefaultUpgradeTableImpl;
29 import com.liferay.portal.upgrade.util.PKUpgradeColumnImpl;
30 import com.liferay.portal.upgrade.util.SwapUpgradeColumnImpl;
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.portlet.bookmarks.model.impl.BookmarksEntryImpl;
36 import com.liferay.portlet.bookmarks.model.impl.BookmarksFolderImpl;
37
38 import java.sql.Types;
39
40 import org.apache.commons.logging.Log;
41 import org.apache.commons.logging.LogFactory;
42
43
50 public class UpgradeBookmarks extends UpgradeProcess {
51
52 public void upgrade() throws UpgradeException {
53 _log.info("Upgrading");
54
55 try {
56 doUpgrade();
57 }
58 catch (Exception e) {
59 throw new UpgradeException(e);
60 }
61 }
62
63 protected void doUpgrade() throws Exception {
64
65
67 UpgradeColumn upgradeGroupIdColumn = new SwapUpgradeColumnImpl(
68 "groupId", AvailableMappersUtil.getGroupIdMapper());
69
70 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
71 "userId", new Integer(Types.VARCHAR),
72 AvailableMappersUtil.getUserIdMapper());
73
74 PKUpgradeColumnImpl upgradePKColumn = new PKUpgradeColumnImpl(
75 "folderId", true);
76
77 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
78 BookmarksFolderImpl.TABLE_NAME, BookmarksFolderImpl.TABLE_COLUMNS,
79 upgradePKColumn, upgradeGroupIdColumn, upgradeUserIdColumn);
80
81 upgradeTable.setCreateSQL(BookmarksFolderImpl.TABLE_SQL_CREATE);
82
83 upgradeTable.updateTable();
84
85 ValueMapper folderIdMapper = new DefaultPKMapper(
86 upgradePKColumn.getValueMapper());
87
88 AvailableMappersUtil.setBookmarksFolderIdMapper(folderIdMapper);
89
90 UpgradeColumn upgradeParentFolderIdColumn = new SwapUpgradeColumnImpl(
91 "parentFolderId", folderIdMapper);
92
93 upgradeTable = new DefaultUpgradeTableImpl(
94 BookmarksFolderImpl.TABLE_NAME, BookmarksFolderImpl.TABLE_COLUMNS,
95 upgradeParentFolderIdColumn);
96
97 upgradeTable.updateTable();
98
99 UpgradeColumn upgradeFolderIdColumn = new SwapUpgradeColumnImpl(
100 "folderId", folderIdMapper);
101
102
104 upgradePKColumn = new PKUpgradeColumnImpl("entryId", true);
105
106 upgradeTable = new DefaultUpgradeTableImpl(
107 BookmarksEntryImpl.TABLE_NAME, BookmarksEntryImpl.TABLE_COLUMNS,
108 upgradePKColumn, upgradeFolderIdColumn, upgradeUserIdColumn);
109
110 upgradeTable.setCreateSQL(BookmarksEntryImpl.TABLE_SQL_CREATE);
111
112 upgradeTable.updateTable();
113
114 ValueMapper entryIdMapper = upgradePKColumn.getValueMapper();
115
116 AvailableMappersUtil.setBookmarksEntryIdMapper(entryIdMapper);
117 }
118
119 private static Log _log = LogFactory.getLog(UpgradeBookmarks.class);
120
121 }