1
22
23 package com.liferay.portal.upgrade.v4_3_0;
24
25 import com.liferay.portal.model.impl.OrgGroupPermissionImpl;
26 import com.liferay.portal.model.impl.OrgLaborImpl;
27 import com.liferay.portal.model.impl.OrganizationImpl;
28 import com.liferay.portal.upgrade.UpgradeException;
29 import com.liferay.portal.upgrade.UpgradeProcess;
30 import com.liferay.portal.upgrade.util.DefaultPKMapper;
31 import com.liferay.portal.upgrade.util.DefaultUpgradeTableImpl;
32 import com.liferay.portal.upgrade.util.PKUpgradeColumnImpl;
33 import com.liferay.portal.upgrade.util.SwapUpgradeColumnImpl;
34 import com.liferay.portal.upgrade.util.UpgradeColumn;
35 import com.liferay.portal.upgrade.util.UpgradeTable;
36 import com.liferay.portal.upgrade.util.ValueMapper;
37 import com.liferay.portal.upgrade.v4_3_0.util.AvailableMappersUtil;
38 import com.liferay.portal.upgrade.v4_3_0.util.ValueMapperUtil;
39
40 import org.apache.commons.logging.Log;
41 import org.apache.commons.logging.LogFactory;
42
43
49 public class UpgradeOrganization extends UpgradeProcess {
50
51 public void upgrade() throws UpgradeException {
52 _log.info("Upgrading");
53
54 try {
55 doUpgrade();
56 }
57 catch (Exception e) {
58 throw new UpgradeException(e);
59 }
60 }
61
62 protected void doUpgrade() throws Exception {
63
64
66 PKUpgradeColumnImpl upgradePKColumn = new PKUpgradeColumnImpl(
67 "organizationId", true);
68
69 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
70 OrganizationImpl.TABLE_NAME, OrganizationImpl.TABLE_COLUMNS,
71 upgradePKColumn);
72
73 upgradeTable.setCreateSQL(OrganizationImpl.TABLE_SQL_CREATE);
74
75 upgradeTable.updateTable();
76
77 ValueMapper organizationIdMapper = new DefaultPKMapper(
78 upgradePKColumn.getValueMapper());
79
80 AvailableMappersUtil.setOrganizationIdMapper(organizationIdMapper);
81
82 UpgradeColumn upgradeParentOrganizationIdColumn =
83 new SwapUpgradeColumnImpl(
84 "parentOrganizationId", organizationIdMapper);
85
86 upgradeTable = new DefaultUpgradeTableImpl(
87 OrganizationImpl.TABLE_NAME, OrganizationImpl.TABLE_COLUMNS,
88 upgradeParentOrganizationIdColumn);
89
90 upgradeTable.updateTable();
91
92 UpgradeColumn upgradeOrganizationIdColumn = new SwapUpgradeColumnImpl(
93 "organizationId", organizationIdMapper);
94
95
97 upgradeTable = new DefaultUpgradeTableImpl(
98 OrgGroupPermissionImpl.TABLE_NAME,
99 OrgGroupPermissionImpl.TABLE_COLUMNS, upgradeOrganizationIdColumn);
100
101 upgradeTable.setCreateSQL(OrgGroupPermissionImpl.TABLE_SQL_CREATE);
102
103 upgradeTable.updateTable();
104
105
107 upgradePKColumn = new PKUpgradeColumnImpl("orgLaborId", true);
108
109 upgradeTable = new DefaultUpgradeTableImpl(
110 OrgLaborImpl.TABLE_NAME, OrgLaborImpl.TABLE_COLUMNS,
111 upgradePKColumn, upgradeOrganizationIdColumn);
112
113 upgradeTable.setCreateSQL(OrgLaborImpl.TABLE_SQL_CREATE);
114
115 upgradeTable.updateTable();
116
117 ValueMapperUtil.persist(
118 upgradePKColumn.getValueMapper(), "org-labor-id");
119 }
120
121 private static Log _log = LogFactory.getLog(UpgradeOrganization.class);
122
123 }