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.portlet.blogs.model.impl.BlogsCategoryImpl;
36 import com.liferay.portlet.blogs.model.impl.BlogsEntryImpl;
37
38 import java.sql.Types;
39
40 import org.apache.commons.logging.Log;
41 import org.apache.commons.logging.LogFactory;
42
43
50 public class UpgradeBlogs extends UpgradeProcess {
51
52 public void upgrade() throws UpgradeException {
53 _log.info("Upgrading");
54
55 try {
56 doUpgrade();
57 }
58 catch (Exception e) {
59 throw new UpgradeException(e);
60 }
61 }
62
63 protected void doUpgrade() throws Exception {
64
65
67 UpgradeColumn upgradeGroupIdColumn = new SwapUpgradeColumnImpl(
68 "groupId", AvailableMappersUtil.getGroupIdMapper());
69
70 UpgradeColumn upgradeUserIdColumn = new SwapUpgradeColumnImpl(
71 "userId", new Integer(Types.VARCHAR),
72 AvailableMappersUtil.getUserIdMapper());
73
74 PKUpgradeColumnImpl upgradePKColumn = new PKUpgradeColumnImpl(
75 "categoryId", true);
76
77 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
78 BlogsCategoryImpl.TABLE_NAME, BlogsCategoryImpl.TABLE_COLUMNS,
79 upgradePKColumn, upgradeUserIdColumn);
80
81 upgradeTable.setCreateSQL(BlogsCategoryImpl.TABLE_SQL_CREATE);
82
83 upgradeTable.updateTable();
84
85 ValueMapper categoryIdMapper = new DefaultPKMapper(
86 upgradePKColumn.getValueMapper());
87
88 AvailableMappersUtil.setBlogsCategoryIdMapper(categoryIdMapper);
89
90 UpgradeColumn upgradeParentCategoryIdColumn = new SwapUpgradeColumnImpl(
91 "parentCategoryId", categoryIdMapper);
92
93 upgradeTable = new DefaultUpgradeTableImpl(
94 BlogsCategoryImpl.TABLE_NAME, BlogsCategoryImpl.TABLE_COLUMNS,
95 upgradeParentCategoryIdColumn);
96
97 upgradeTable.updateTable();
98
99 UpgradeColumn upgradeCategoryIdColumn = new SwapUpgradeColumnImpl(
100 "categoryId", categoryIdMapper);
101
102
104 upgradePKColumn = new PKUpgradeColumnImpl("entryId", true);
105
106 upgradeTable = new DefaultUpgradeTableImpl(
107 BlogsEntryImpl.TABLE_NAME, BlogsEntryImpl.TABLE_COLUMNS,
108 upgradePKColumn, upgradeGroupIdColumn, upgradeUserIdColumn,
109 upgradeCategoryIdColumn);
110
111 upgradeTable.setCreateSQL(BlogsEntryImpl.TABLE_SQL_CREATE);
112
113 upgradeTable.updateTable();
114
115 ValueMapper entryIdMapper = upgradePKColumn.getValueMapper();
116
117 AvailableMappersUtil.setBlogsEntryIdMapper(entryIdMapper);
118 }
119
120 private static Log _log = LogFactory.getLog(UpgradeBlogs.class);
121
122 }