1
22
23 package com.liferay.portal.upgrade.v4_3_0;
24
25 import com.liferay.portal.upgrade.UpgradeProcess;
26 import com.liferay.portal.upgrade.util.DefaultPKMapper;
27 import com.liferay.portal.upgrade.util.DefaultUpgradeTableImpl;
28 import com.liferay.portal.upgrade.util.PKUpgradeColumnImpl;
29 import com.liferay.portal.upgrade.util.SwapUpgradeColumnImpl;
30 import com.liferay.portal.upgrade.util.UpgradeColumn;
31 import com.liferay.portal.upgrade.util.UpgradeTable;
32 import com.liferay.portal.upgrade.util.ValueMapper;
33 import com.liferay.portal.upgrade.v4_3_0.util.AvailableMappersUtil;
34 import com.liferay.portal.upgrade.v4_3_0.util.OrgGroupPermissionTable;
35 import com.liferay.portal.upgrade.v4_3_0.util.OrgLaborTable;
36 import com.liferay.portal.upgrade.v4_3_0.util.OrganizationTable;
37 import com.liferay.portal.upgrade.v4_3_0.util.ValueMapperUtil;
38
39
44 public class UpgradeOrganization extends UpgradeProcess {
45
46 protected void doUpgrade() throws Exception {
47
48
50 PKUpgradeColumnImpl upgradePKColumn = new PKUpgradeColumnImpl(
51 "organizationId", true);
52
53 UpgradeTable upgradeTable = new DefaultUpgradeTableImpl(
54 OrganizationTable.TABLE_NAME, OrganizationTable.TABLE_COLUMNS,
55 upgradePKColumn);
56
57 upgradeTable.setCreateSQL(OrganizationTable.TABLE_SQL_CREATE);
58
59 upgradeTable.updateTable();
60
61 ValueMapper organizationIdMapper = new DefaultPKMapper(
62 upgradePKColumn.getValueMapper());
63
64 AvailableMappersUtil.setOrganizationIdMapper(organizationIdMapper);
65
66 UpgradeColumn upgradeParentOrganizationIdColumn =
67 new SwapUpgradeColumnImpl(
68 "parentOrganizationId", organizationIdMapper);
69
70 upgradeTable = new DefaultUpgradeTableImpl(
71 OrganizationTable.TABLE_NAME, OrganizationTable.TABLE_COLUMNS,
72 upgradeParentOrganizationIdColumn);
73
74 upgradeTable.updateTable();
75
76 UpgradeColumn upgradeOrganizationIdColumn = new SwapUpgradeColumnImpl(
77 "organizationId", organizationIdMapper);
78
79
81 upgradeTable = new DefaultUpgradeTableImpl(
82 OrgGroupPermissionTable.TABLE_NAME,
83 OrgGroupPermissionTable.TABLE_COLUMNS, upgradeOrganizationIdColumn);
84
85 upgradeTable.setCreateSQL(OrgGroupPermissionTable.TABLE_SQL_CREATE);
86
87 upgradeTable.updateTable();
88
89
91 upgradePKColumn = new PKUpgradeColumnImpl("orgLaborId", true);
92
93 upgradeTable = new DefaultUpgradeTableImpl(
94 OrgLaborTable.TABLE_NAME, OrgLaborTable.TABLE_COLUMNS,
95 upgradePKColumn, upgradeOrganizationIdColumn);
96
97 upgradeTable.setCreateSQL(OrgLaborTable.TABLE_SQL_CREATE);
98
99 upgradeTable.updateTable();
100
101 ValueMapperUtil.persist(
102 upgradePKColumn.getValueMapper(), "org-labor-id");
103 }
104
105 }