1
22
23 package com.liferay.portal.upgrade.v4_3_0;
24
25 import com.liferay.portal.kernel.log.Log;
26 import com.liferay.portal.kernel.log.LogFactoryUtil;
27 import com.liferay.portal.upgrade.UpgradeException;
28 import com.liferay.portal.upgrade.UpgradeProcess;
29 import com.liferay.portal.upgrade.util.DefaultPKMapper;
30 import com.liferay.portal.upgrade.util.DefaultUpgradeTableImpl;
31 import com.liferay.portal.upgrade.util.PKUpgradeColumnImpl;
32 import com.liferay.portal.upgrade.util.SwapUpgradeColumnImpl;
33 import com.liferay.portal.upgrade.util.TempUpgradeColumnImpl;
34 import com.liferay.portal.upgrade.util.UpgradeColumn;
35 import com.liferay.portal.upgrade.util.UpgradeTable;
36 import com.liferay.portal.upgrade.util.ValueMapper;
37 import com.liferay.portal.upgrade.v4_3_0.util.AvailableMappersUtil;
38 import com.liferay.portal.upgrade.v4_3_0.util.DLFileEntryIdUpgradeColumnImpl;
39 import com.liferay.portlet.documentlibrary.model.impl.DLFileEntryImpl;
40 import com.liferay.portlet.documentlibrary.model.impl.DLFileRankImpl;
41 import com.liferay.portlet.documentlibrary.model.impl.DLFileShortcutImpl;
42 import com.liferay.portlet.documentlibrary.model.impl.DLFileVersionImpl;
43 import com.liferay.portlet.documentlibrary.model.impl.DLFolderImpl;
44
45 import java.sql.Types;
46
47
53 public class UpgradeDocumentLibrary extends UpgradeProcess {
54
55 public void upgrade() throws UpgradeException {
56 _log.info("Upgrading");
57
58 try {
59 doUpgrade();
60 }
61 catch (Exception e) {
62 throw new UpgradeException(e);
63 }
64 }
65
66 protected void doUpgrade() throws Exception {
67
68
70 UpgradeColumn upgradeCompanyIdColumn = new SwapUpgradeColumnImpl(
71 "companyId", new Integer(Types.VARCHAR),
72 AvailableMappersUtil.getCompanyIdMapper());
73
74 UpgradeColumn upgradeGroupIdColumn = new SwapUpgradeColumnImpl(
75 "groupId", AvailableMappersUtil.getGroupIdMapper());
76
77 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
78 "userId", new Integer(Types.VARCHAR),
79 AvailableMappersUtil.getUserIdMapper());
80
81 PKUpgradeColumnImpl upgradePKColumn = new PKUpgradeColumnImpl(
82 "folderId", true);
83
84 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
85 DLFolderImpl.TABLE_NAME, DLFolderImpl.TABLE_COLUMNS,
86 upgradePKColumn, upgradeGroupIdColumn, upgradeUserIdColumn);
87
88 upgradeTable.setCreateSQL(DLFolderImpl.TABLE_SQL_CREATE);
89
90 upgradeTable.updateTable();
91
92 ValueMapper folderIdMapper = new DefaultPKMapper(
93 upgradePKColumn.getValueMapper());
94
95 AvailableMappersUtil.setDLFolderIdMapper(folderIdMapper);
96
97 UpgradeColumn upgradeParentFolderIdColumn = new SwapUpgradeColumnImpl(
98 "parentFolderId", folderIdMapper);
99
100 upgradeTable = new DefaultUpgradeTableImpl(
101 DLFolderImpl.TABLE_NAME, DLFolderImpl.TABLE_COLUMNS,
102 upgradeParentFolderIdColumn);
103
104 upgradeTable.updateTable();
105
106 UpgradeColumn upgradeFolderIdColumn = new SwapUpgradeColumnImpl(
107 "folderId", folderIdMapper);
108
109 UpgradeColumn upgradeToFolderIdColumn = new SwapUpgradeColumnImpl(
110 "toFolderId", folderIdMapper);
111
112
114 UpgradeColumn upgradeNameColumn = new TempUpgradeColumnImpl("name");
115
116 PKUpgradeColumnImpl fileEntryIdColumn =
117 new DLFileEntryIdUpgradeColumnImpl(
118 upgradeCompanyIdColumn, upgradeFolderIdColumn,
119 upgradeNameColumn);
120
121 UpgradeColumn upgradeVersionUserIdColumn = new SwapUpgradeColumnImpl(
122 "versionUserId", new Integer(Types.VARCHAR),
123 AvailableMappersUtil.getUserIdMapper());
124
125 upgradeTable = new DefaultUpgradeTableImpl(
126 DLFileEntryImpl.TABLE_NAME, DLFileEntryImpl.TABLE_COLUMNS,
127 upgradeCompanyIdColumn, upgradeFolderIdColumn, upgradeNameColumn,
128 fileEntryIdColumn, upgradeUserIdColumn, upgradeVersionUserIdColumn);
129
130 upgradeTable.setCreateSQL(DLFileEntryImpl.TABLE_SQL_CREATE);
131
132 upgradeTable.updateTable();
133
134 ValueMapper fileEntryIdMapper = fileEntryIdColumn.getValueMapper();
135
136 AvailableMappersUtil.setDLFileEntryIdMapper(fileEntryIdMapper);
137
138
140 upgradeTable = new DefaultUpgradeTableImpl(
141 DLFileRankImpl.TABLE_NAME, DLFileRankImpl.TABLE_COLUMNS,
142 new PKUpgradeColumnImpl("fileRankId", false),
143 upgradeUserIdColumn, upgradeFolderIdColumn);
144
145 upgradeTable.setCreateSQL(DLFileRankImpl.TABLE_SQL_CREATE);
146
147 upgradeTable.updateTable();
148
149
151 upgradePKColumn = new PKUpgradeColumnImpl("fileShortcutId", true);
152
153 upgradeTable = new DefaultUpgradeTableImpl(
154 DLFileShortcutImpl.TABLE_NAME, DLFileShortcutImpl.TABLE_COLUMNS,
155 upgradePKColumn, upgradeUserIdColumn, upgradeFolderIdColumn,
156 upgradeToFolderIdColumn);
157
158 upgradeTable.setCreateSQL(DLFileShortcutImpl.TABLE_SQL_CREATE);
159
160 upgradeTable.updateTable();
161
162 ValueMapper fileShortcutIdMapper = upgradePKColumn.getValueMapper();
163
164 AvailableMappersUtil.setDLFileShortcutIdMapper(fileShortcutIdMapper);
165
166
168 upgradeTable = new DefaultUpgradeTableImpl(
169 DLFileVersionImpl.TABLE_NAME, DLFileVersionImpl.TABLE_COLUMNS,
170 new PKUpgradeColumnImpl("fileVersionId", false),
171 upgradeUserIdColumn, upgradeFolderIdColumn);
172
173 upgradeTable.setCreateSQL(DLFileVersionImpl.TABLE_SQL_CREATE);
174
175 upgradeTable.updateTable();
176 }
177
178 private static Log _log =
179 LogFactoryUtil.getLog(UpgradeDocumentLibrary.class);
180
181 }