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