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.UpgradeColumn;
34 import com.liferay.portal.upgrade.util.UpgradeTable;
35 import com.liferay.portal.upgrade.util.ValueMapper;
36 import com.liferay.portal.upgrade.v4_3_0.util.AvailableMappersUtil;
37 import com.liferay.portal.upgrade.v4_3_0.util.IGImageIdUpgradeColumnImpl;
38 import com.liferay.portal.upgrade.v4_3_0.util.IGLargeImageIdUpgradeColumnImpl;
39 import com.liferay.portal.upgrade.v4_3_0.util.IGSmallImageIdUpgradeColumnImpl;
40 import com.liferay.portlet.imagegallery.model.impl.IGFolderImpl;
41 import com.liferay.portlet.imagegallery.model.impl.IGImageImpl;
42
43 import java.sql.Types;
44
45
51 public class UpgradeImageGallery 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 upgradeCompanyIdColumn = new SwapUpgradeColumnImpl(
69 "companyId", new Integer(Types.VARCHAR),
70 AvailableMappersUtil.getCompanyIdMapper());
71
72 UpgradeColumn upgradeGroupIdColumn = new SwapUpgradeColumnImpl(
73 "groupId", AvailableMappersUtil.getGroupIdMapper());
74
75 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
76 "userId", new Integer(Types.VARCHAR),
77 AvailableMappersUtil.getUserIdMapper());
78
79 PKUpgradeColumnImpl upgradePKColumn = new PKUpgradeColumnImpl(
80 "folderId", true);
81
82 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
83 IGFolderImpl.TABLE_NAME, IGFolderImpl.TABLE_COLUMNS,
84 upgradePKColumn, upgradeGroupIdColumn, upgradeUserIdColumn);
85
86 upgradeTable.setCreateSQL(IGFolderImpl.TABLE_SQL_CREATE);
87
88 upgradeTable.updateTable();
89
90 ValueMapper folderIdMapper = new DefaultPKMapper(
91 upgradePKColumn.getValueMapper());
92
93 AvailableMappersUtil.setIGFolderIdMapper(folderIdMapper);
94
95 UpgradeColumn upgradeParentFolderIdColumn = new SwapUpgradeColumnImpl(
96 "parentFolderId", folderIdMapper);
97
98 upgradeTable = new DefaultUpgradeTableImpl(
99 IGFolderImpl.TABLE_NAME, IGFolderImpl.TABLE_COLUMNS,
100 upgradeParentFolderIdColumn);
101
102 upgradeTable.updateTable();
103
104 UpgradeColumn upgradeFolderIdColumn = new SwapUpgradeColumnImpl(
105 "folderId", folderIdMapper);
106
107
109 PKUpgradeColumnImpl upgradeImageIdColumn =
110 new IGImageIdUpgradeColumnImpl(upgradeCompanyIdColumn);
111
112 UpgradeColumn upgradeSmallImageIdColumn =
113 new IGSmallImageIdUpgradeColumnImpl(
114 upgradeCompanyIdColumn, upgradeImageIdColumn,
115 AvailableMappersUtil.getImageIdMapper());
116
117 UpgradeColumn upgradeLargeImageIdColumn =
118 new IGLargeImageIdUpgradeColumnImpl(
119 upgradeCompanyIdColumn, upgradeImageIdColumn,
120 AvailableMappersUtil.getImageIdMapper());
121
122 upgradeTable = new DefaultUpgradeTableImpl(
123 IGImageImpl.TABLE_NAME, IGImageImpl.TABLE_COLUMNS,
124 upgradeCompanyIdColumn, upgradeImageIdColumn, upgradeUserIdColumn,
125 upgradeFolderIdColumn, upgradeSmallImageIdColumn,
126 upgradeLargeImageIdColumn);
127
128 upgradeTable.setCreateSQL(IGImageImpl.TABLE_SQL_CREATE);
129
130 upgradeTable.updateTable();
131
132 ValueMapper imageIdMapper = upgradeImageIdColumn.getValueMapper();
133
134 AvailableMappersUtil.setIGImageIdMapper(imageIdMapper);
135 }
136
137 private static Log _log = LogFactoryUtil.getLog(UpgradeImageGallery.class);
138
139 }