1
22
23 package com.liferay.portal.upgrade.v5_2_0;
24
25 import com.liferay.portal.kernel.dao.jdbc.DataAccess;
26 import com.liferay.portal.kernel.log.Log;
27 import com.liferay.portal.kernel.log.LogFactoryUtil;
28 import com.liferay.portal.upgrade.UpgradeException;
29 import com.liferay.portal.upgrade.UpgradeProcess;
30
31 import java.sql.Connection;
32 import java.sql.PreparedStatement;
33 import java.sql.ResultSet;
34
35
41 public class UpgradeExpando extends UpgradeProcess {
42
43 public void upgrade() throws UpgradeException {
44 _log.info("Upgrading");
45
46 try {
47 doUpgrade();
48 }
49 catch (Exception e) {
50 throw new UpgradeException(e);
51 }
52 }
53
54 protected void doUpgrade() throws Exception {
55 Connection con = null;
56 PreparedStatement ps = null;
57 ResultSet rs = null;
58
59 try {
60 con = DataAccess.getConnection();
61
62 ps = con.prepareStatement(_GET_COMPANY_IDS);
63
64 rs = ps.executeQuery();
65
66 while (rs.next()) {
67 long companyId = rs.getLong("companyId");
68
69 runSQL("update ExpandoColumn set companyId = " + companyId);
70
71 runSQL("update ExpandoRow set companyId = " + companyId);
72
73 runSQL("update ExpandoTable set companyId = " + companyId);
74
75 runSQL("update ExpandoValue set companyId = " + companyId);
76
77 break;
78 }
79 }
80 finally {
81 DataAccess.cleanUp(con, ps, rs);
82 }
83 }
84
85 private static final String _GET_COMPANY_IDS =
86 "select companyId from Company";
87
88 private static Log _log = LogFactoryUtil.getLog(UpgradeExpando.class);
89
90 }