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.ShoppingCartItemIdUpgradeColumnImpl;
36 import com.liferay.portal.upgrade.v4_3_0.util.ShoppingCartItemIdsUpgradeColumnImpl;
37 import com.liferay.portal.upgrade.v4_3_0.util.ShoppingCouponLimitCategoriesUpgradeColumnImpl;
38 import com.liferay.portlet.shopping.model.impl.ShoppingCartImpl;
39 import com.liferay.portlet.shopping.model.impl.ShoppingCategoryImpl;
40 import com.liferay.portlet.shopping.model.impl.ShoppingCouponImpl;
41 import com.liferay.portlet.shopping.model.impl.ShoppingItemFieldImpl;
42 import com.liferay.portlet.shopping.model.impl.ShoppingItemImpl;
43 import com.liferay.portlet.shopping.model.impl.ShoppingItemPriceImpl;
44 import com.liferay.portlet.shopping.model.impl.ShoppingOrderImpl;
45 import com.liferay.portlet.shopping.model.impl.ShoppingOrderItemImpl;
46
47 import java.sql.Types;
48
49 import org.apache.commons.logging.Log;
50 import org.apache.commons.logging.LogFactory;
51
52
58 public class UpgradeShopping extends UpgradeProcess {
59
60 public void upgrade() throws UpgradeException {
61 _log.info("Upgrading");
62
63 try {
64 doUpgrade();
65 }
66 catch (Exception e) {
67 throw new UpgradeException(e);
68 }
69 }
70
71 protected void doUpgrade() throws Exception {
72
73
75 UpgradeColumn upgradeGroupIdColumn = new SwapUpgradeColumnImpl(
76 "groupId", AvailableMappersUtil.getGroupIdMapper());
77
78 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
79 "userId", new Integer(Types.VARCHAR),
80 AvailableMappersUtil.getUserIdMapper());
81
82 PKUpgradeColumnImpl upgradePKColumn = new PKUpgradeColumnImpl(
83 "categoryId", true);
84
85 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
86 ShoppingCategoryImpl.TABLE_NAME, ShoppingCategoryImpl.TABLE_COLUMNS,
87 upgradePKColumn, upgradeGroupIdColumn, upgradeUserIdColumn);
88
89 upgradeTable.setCreateSQL(ShoppingCategoryImpl.TABLE_SQL_CREATE);
90
91 upgradeTable.updateTable();
92
93 ValueMapper categoryIdMapper = new DefaultPKMapper(
94 upgradePKColumn.getValueMapper());
95
96 AvailableMappersUtil.setShoppingCategoryIdMapper(categoryIdMapper);
97
98 UpgradeColumn upgradeParentCategoryIdColumn = new SwapUpgradeColumnImpl(
99 "parentCategoryId", categoryIdMapper);
100
101 upgradeTable = new DefaultUpgradeTableImpl(
102 ShoppingCategoryImpl.TABLE_NAME, ShoppingCategoryImpl.TABLE_COLUMNS,
103 upgradeParentCategoryIdColumn);
104
105 upgradeTable.updateTable();
106
107 UpgradeColumn upgradeCategoryIdColumn = new SwapUpgradeColumnImpl(
108 "categoryId", categoryIdMapper);
109
110
112 upgradePKColumn = new PKUpgradeColumnImpl("itemId", true);
113
114 upgradeTable = new DefaultUpgradeTableImpl(
115 ShoppingItemImpl.TABLE_NAME, ShoppingItemImpl.TABLE_COLUMNS,
116 upgradePKColumn, upgradeCategoryIdColumn, upgradeUserIdColumn);
117
118 upgradeTable.setCreateSQL(ShoppingItemImpl.TABLE_SQL_CREATE);
119
120 upgradeTable.updateTable();
121
122 ValueMapper itemIdMapper = upgradePKColumn.getValueMapper();
123
124 AvailableMappersUtil.setShoppingItemIdMapper(itemIdMapper);
125
126 UpgradeColumn upgradeItemIdColumn = new SwapUpgradeColumnImpl(
127 "itemId", itemIdMapper);
128
129
131 upgradeTable = new DefaultUpgradeTableImpl(
132 ShoppingItemFieldImpl.TABLE_NAME,
133 ShoppingItemFieldImpl.TABLE_COLUMNS,
134 new PKUpgradeColumnImpl("itemFieldId", false), upgradeItemIdColumn);
135
136 upgradeTable.setCreateSQL(ShoppingItemFieldImpl.TABLE_SQL_CREATE);
137
138 upgradeTable.updateTable();
139
140
142 upgradeTable = new DefaultUpgradeTableImpl(
143 ShoppingItemPriceImpl.TABLE_NAME,
144 ShoppingItemPriceImpl.TABLE_COLUMNS,
145 new PKUpgradeColumnImpl("itemPriceId", false), upgradeItemIdColumn);
146
147 upgradeTable.setCreateSQL(ShoppingItemPriceImpl.TABLE_SQL_CREATE);
148
149 upgradeTable.updateTable();
150
151
153 upgradePKColumn = new PKUpgradeColumnImpl(
154 "orderId", new Integer(Types.VARCHAR), true);
155
156 upgradeTable = new DefaultUpgradeTableImpl(
157 ShoppingOrderImpl.TABLE_NAME, ShoppingOrderImpl.TABLE_COLUMNS,
158 upgradePKColumn, upgradeGroupIdColumn, upgradeUserIdColumn);
159
160 upgradeTable.setCreateSQL(ShoppingOrderImpl.TABLE_SQL_CREATE);
161
162 upgradeTable.updateTable();
163
164 ValueMapper orderIdMapper = upgradePKColumn.getValueMapper();
165
166 UpgradeColumn upgradeOrderIdColumn = new SwapUpgradeColumnImpl(
167 "orderId", new Integer(Types.VARCHAR), orderIdMapper);
168
169
171 UpgradeColumn upgradeCartItemIdColumn =
172 new ShoppingCartItemIdUpgradeColumnImpl(itemIdMapper);
173
174 upgradeTable = new DefaultUpgradeTableImpl(
175 ShoppingOrderItemImpl.TABLE_NAME,
176 ShoppingOrderItemImpl.TABLE_COLUMNS,
177 new PKUpgradeColumnImpl("orderItemId", false),
178 upgradeOrderIdColumn, upgradeCartItemIdColumn);
179
180 upgradeTable.setCreateSQL(ShoppingOrderItemImpl.TABLE_SQL_CREATE);
181
182 upgradeTable.updateTable();
183
184
186 UpgradeColumn upgradeItemIdsColumn =
187 new ShoppingCartItemIdsUpgradeColumnImpl(itemIdMapper);
188
189 upgradeTable = new DefaultUpgradeTableImpl(
190 ShoppingCartImpl.TABLE_NAME, ShoppingCartImpl.TABLE_COLUMNS,
191 new PKUpgradeColumnImpl(
192 "cartId", new Integer(Types.VARCHAR), false),
193 upgradeGroupIdColumn, upgradeUserIdColumn, upgradeItemIdsColumn);
194
195 upgradeTable.setCreateSQL(ShoppingCartImpl.TABLE_SQL_CREATE);
196
197 upgradeTable.updateTable();
198
199
201 UpgradeColumn upgradeLimitCategoriesColumn =
202 new ShoppingCouponLimitCategoriesUpgradeColumnImpl(
203 categoryIdMapper);
204
205 upgradeTable = new DefaultUpgradeTableImpl(
206 ShoppingCouponImpl.TABLE_NAME, ShoppingCouponImpl.TABLE_COLUMNS,
207 new PKUpgradeColumnImpl(
208 "couponId", new Integer(Types.VARCHAR), false),
209 upgradeGroupIdColumn, upgradeUserIdColumn,
210 upgradeLimitCategoriesColumn);
211
212 upgradeTable.setCreateSQL(ShoppingCouponImpl.TABLE_SQL_CREATE);
213
214 upgradeTable.updateTable();
215 }
216
217 private static Log _log = LogFactory.getLog(UpgradeShopping.class);
218
219 }