1
19
20 package com.liferay.portal.upgrade.v4_3_0;
21
22 import com.liferay.portal.kernel.log.Log;
23 import com.liferay.portal.kernel.log.LogFactoryUtil;
24 import com.liferay.portal.upgrade.UpgradeException;
25 import com.liferay.portal.upgrade.UpgradeProcess;
26 import com.liferay.portal.upgrade.util.DefaultPKMapper;
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.DLFileEntryIdUpgradeColumnImpl;
36 import com.liferay.portlet.documentlibrary.model.impl.DLFileEntryImpl;
37 import com.liferay.portlet.documentlibrary.model.impl.DLFileRankImpl;
38 import com.liferay.portlet.documentlibrary.model.impl.DLFileShortcutImpl;
39 import com.liferay.portlet.documentlibrary.model.impl.DLFileVersionImpl;
40 import com.liferay.portlet.documentlibrary.model.impl.DLFolderImpl;
41
42 import java.sql.Types;
43
44
50 public class UpgradeDocumentLibrary 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 upgradeCompanyIdColumn = new SwapUpgradeColumnImpl(
68 "companyId", new Integer(Types.VARCHAR),
69 AvailableMappersUtil.getCompanyIdMapper());
70
71 UpgradeColumn upgradeGroupIdColumn = new SwapUpgradeColumnImpl(
72 "groupId", AvailableMappersUtil.getGroupIdMapper());
73
74 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
75 "userId", new Integer(Types.VARCHAR),
76 AvailableMappersUtil.getUserIdMapper());
77
78 PKUpgradeColumnImpl upgradePKColumn = new PKUpgradeColumnImpl(
79 "folderId", true);
80
81 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
82 DLFolderImpl.TABLE_NAME, DLFolderImpl.TABLE_COLUMNS,
83 upgradePKColumn, upgradeGroupIdColumn, upgradeUserIdColumn);
84
85 upgradeTable.setCreateSQL(DLFolderImpl.TABLE_SQL_CREATE);
86
87 upgradeTable.updateTable();
88
89 ValueMapper folderIdMapper = new DefaultPKMapper(
90 upgradePKColumn.getValueMapper());
91
92 AvailableMappersUtil.setDLFolderIdMapper(folderIdMapper);
93
94 UpgradeColumn upgradeParentFolderIdColumn = new SwapUpgradeColumnImpl(
95 "parentFolderId", folderIdMapper);
96
97 upgradeTable = new DefaultUpgradeTableImpl(
98 DLFolderImpl.TABLE_NAME, DLFolderImpl.TABLE_COLUMNS,
99 upgradeParentFolderIdColumn);
100
101 upgradeTable.updateTable();
102
103 UpgradeColumn upgradeFolderIdColumn = new SwapUpgradeColumnImpl(
104 "folderId", folderIdMapper);
105
106 UpgradeColumn upgradeToFolderIdColumn = new SwapUpgradeColumnImpl(
107 "toFolderId", folderIdMapper);
108
109
111 UpgradeColumn upgradeNameColumn = new TempUpgradeColumnImpl("name");
112
113 PKUpgradeColumnImpl fileEntryIdColumn =
114 new DLFileEntryIdUpgradeColumnImpl(
115 upgradeCompanyIdColumn, upgradeFolderIdColumn,
116 upgradeNameColumn);
117
118 UpgradeColumn upgradeVersionUserIdColumn = new SwapUpgradeColumnImpl(
119 "versionUserId", new Integer(Types.VARCHAR),
120 AvailableMappersUtil.getUserIdMapper());
121
122 upgradeTable = new DefaultUpgradeTableImpl(
123 DLFileEntryImpl.TABLE_NAME, DLFileEntryImpl.TABLE_COLUMNS,
124 upgradeCompanyIdColumn, upgradeFolderIdColumn, upgradeNameColumn,
125 fileEntryIdColumn, upgradeUserIdColumn, upgradeVersionUserIdColumn);
126
127 upgradeTable.setCreateSQL(DLFileEntryImpl.TABLE_SQL_CREATE);
128
129 upgradeTable.updateTable();
130
131 ValueMapper fileEntryIdMapper = fileEntryIdColumn.getValueMapper();
132
133 AvailableMappersUtil.setDLFileEntryIdMapper(fileEntryIdMapper);
134
135
137 upgradeTable = new DefaultUpgradeTableImpl(
138 DLFileRankImpl.TABLE_NAME, DLFileRankImpl.TABLE_COLUMNS,
139 new PKUpgradeColumnImpl("fileRankId", false),
140 upgradeUserIdColumn, upgradeFolderIdColumn);
141
142 upgradeTable.setCreateSQL(DLFileRankImpl.TABLE_SQL_CREATE);
143
144 upgradeTable.updateTable();
145
146
148 upgradePKColumn = new PKUpgradeColumnImpl("fileShortcutId", true);
149
150 upgradeTable = new DefaultUpgradeTableImpl(
151 DLFileShortcutImpl.TABLE_NAME, DLFileShortcutImpl.TABLE_COLUMNS,
152 upgradePKColumn, upgradeUserIdColumn, upgradeFolderIdColumn,
153 upgradeToFolderIdColumn);
154
155 upgradeTable.setCreateSQL(DLFileShortcutImpl.TABLE_SQL_CREATE);
156
157 upgradeTable.updateTable();
158
159 ValueMapper fileShortcutIdMapper = upgradePKColumn.getValueMapper();
160
161 AvailableMappersUtil.setDLFileShortcutIdMapper(fileShortcutIdMapper);
162
163
165 upgradeTable = new DefaultUpgradeTableImpl(
166 DLFileVersionImpl.TABLE_NAME, DLFileVersionImpl.TABLE_COLUMNS,
167 new PKUpgradeColumnImpl("fileVersionId", false),
168 upgradeUserIdColumn, upgradeFolderIdColumn);
169
170 upgradeTable.setCreateSQL(DLFileVersionImpl.TABLE_SQL_CREATE);
171
172 upgradeTable.updateTable();
173 }
174
175 private static Log _log =
176 LogFactoryUtil.getLog(UpgradeDocumentLibrary.class);
177
178 }