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.portal.upgrade.v4_3_0.util.IGImageIdUpgradeColumnImpl;
36 import com.liferay.portal.upgrade.v4_3_0.util.IGLargeImageIdUpgradeColumnImpl;
37 import com.liferay.portal.upgrade.v4_3_0.util.IGSmallImageIdUpgradeColumnImpl;
38 import com.liferay.portlet.imagegallery.model.impl.IGFolderImpl;
39 import com.liferay.portlet.imagegallery.model.impl.IGImageImpl;
40
41 import java.sql.Types;
42
43 import org.apache.commons.logging.Log;
44 import org.apache.commons.logging.LogFactory;
45
46
52 public class UpgradeImageGallery extends UpgradeProcess {
53
54 public void upgrade() throws UpgradeException {
55 _log.info("Upgrading");
56
57 try {
58 doUpgrade();
59 }
60 catch (Exception e) {
61 throw new UpgradeException(e);
62 }
63 }
64
65 protected void doUpgrade() throws Exception {
66
67
69 UpgradeColumn upgradeCompanyIdColumn = new SwapUpgradeColumnImpl(
70 "companyId", new Integer(Types.VARCHAR),
71 AvailableMappersUtil.getCompanyIdMapper());
72
73 UpgradeColumn upgradeGroupIdColumn = new SwapUpgradeColumnImpl(
74 "groupId", AvailableMappersUtil.getGroupIdMapper());
75
76 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
77 "userId", new Integer(Types.VARCHAR),
78 AvailableMappersUtil.getUserIdMapper());
79
80 PKUpgradeColumnImpl upgradePKColumn = new PKUpgradeColumnImpl(
81 "folderId", true);
82
83 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
84 IGFolderImpl.TABLE_NAME, IGFolderImpl.TABLE_COLUMNS,
85 upgradePKColumn, upgradeGroupIdColumn, upgradeUserIdColumn);
86
87 upgradeTable.setCreateSQL(IGFolderImpl.TABLE_SQL_CREATE);
88
89 upgradeTable.updateTable();
90
91 ValueMapper folderIdMapper = new DefaultPKMapper(
92 upgradePKColumn.getValueMapper());
93
94 AvailableMappersUtil.setIGFolderIdMapper(folderIdMapper);
95
96 UpgradeColumn upgradeParentFolderIdColumn = new SwapUpgradeColumnImpl(
97 "parentFolderId", folderIdMapper);
98
99 upgradeTable = new DefaultUpgradeTableImpl(
100 IGFolderImpl.TABLE_NAME, IGFolderImpl.TABLE_COLUMNS,
101 upgradeParentFolderIdColumn);
102
103 upgradeTable.updateTable();
104
105 UpgradeColumn upgradeFolderIdColumn = new SwapUpgradeColumnImpl(
106 "folderId", folderIdMapper);
107
108
110 PKUpgradeColumnImpl upgradeImageIdColumn =
111 new IGImageIdUpgradeColumnImpl(upgradeCompanyIdColumn);
112
113 UpgradeColumn upgradeSmallImageIdColumn =
114 new IGSmallImageIdUpgradeColumnImpl(
115 upgradeCompanyIdColumn, upgradeImageIdColumn,
116 AvailableMappersUtil.getImageIdMapper());
117
118 UpgradeColumn upgradeLargeImageIdColumn =
119 new IGLargeImageIdUpgradeColumnImpl(
120 upgradeCompanyIdColumn, upgradeImageIdColumn,
121 AvailableMappersUtil.getImageIdMapper());
122
123 upgradeTable = new DefaultUpgradeTableImpl(
124 IGImageImpl.TABLE_NAME, IGImageImpl.TABLE_COLUMNS,
125 upgradeCompanyIdColumn, upgradeImageIdColumn, upgradeUserIdColumn,
126 upgradeFolderIdColumn, upgradeSmallImageIdColumn,
127 upgradeLargeImageIdColumn);
128
129 upgradeTable.setCreateSQL(IGImageImpl.TABLE_SQL_CREATE);
130
131 upgradeTable.updateTable();
132
133 ValueMapper imageIdMapper = upgradeImageIdColumn.getValueMapper();
134
135 AvailableMappersUtil.setIGImageIdMapper(imageIdMapper);
136 }
137
138 private static Log _log = LogFactory.getLog(UpgradeImageGallery.class);
139
140 }