Skip to content

Commit dcc7840

Browse files
LPD-66162 SF
1 parent 4752cb5 commit dcc7840

File tree

3 files changed

+31
-40
lines changed

3 files changed

+31
-40
lines changed

modules/apps/portal/portal-upgrade-test/src/testIntegration/java/com/liferay/portal/upgrade/data/cleanup/test/DatabaseTableAndColumnCaseDataCleanupPreupgradeProcessTest.java

Lines changed: 25 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -73,20 +73,21 @@ public void tearDown() throws Exception {
7373

7474
@Test
7575
public void testUpgrade() throws Exception {
76-
ServiceComponent serviceComponent =
77-
_serviceComponentLocalService.createServiceComponent(
78-
RandomTestUtil.nextLong());
79-
8076
DBInspector dbInspector = new DBInspector(_connection);
8177

82-
String invalidTableName = "testTABLE";
8378
String invalidColumnName = "testCOLUMN";
79+
String invalidTableName = "testTABLE";
8480

85-
String testTableName = "TestTable";
86-
String testColumnName = "testColumn";
81+
ServiceComponent serviceComponent =
82+
_serviceComponentLocalService.createServiceComponent(
83+
RandomTestUtil.nextLong());
8784

8885
serviceComponent.setMvccVersion(0);
8986
serviceComponent.setBuildNamespace("com.liferay.test.service.impl");
87+
88+
String testColumnName = "testColumn";
89+
String testTableName = "TestTable";
90+
9091
serviceComponent.setData(
9192
StringBundler.concat(
9293
"<![CDATA[create table ", testTableName, " ( \n",
@@ -100,7 +101,22 @@ public void testUpgrade() throws Exception {
100101
getName(),
101102
LoggerTestUtil.INFO)) {
102103

103-
_addTestTable(invalidTableName, invalidColumnName);
104+
DBType dbType = DBManagerUtil.getDBType();
105+
106+
if (dbType == DBType.SQLSERVER) {
107+
DBPartitionUtil.forEachCompanyId(
108+
companyId -> _db.runSQL(
109+
StringBundler.concat(
110+
"create table [", invalidTableName, "] ([",
111+
invalidColumnName, "] LONG)")));
112+
}
113+
else {
114+
DBPartitionUtil.forEachCompanyId(
115+
companyId -> _db.runSQL(
116+
StringBundler.concat(
117+
"create table `", invalidTableName, "` (`",
118+
invalidColumnName, "` LONG)")));
119+
}
104120

105121
upgrade();
106122

@@ -145,36 +161,12 @@ public void testUpgrade() throws Exception {
145161
DBPartitionUtil.forEachCompanyId(
146162
companyId -> _db.runSQL(
147163
"DROP_TABLE_IF_EXISTS(" + invalidTableName + ")"));
148-
149-
DBPartitionUtil.forEachCompanyId(
150-
companyId -> _db.runSQL(
151-
"DROP_TABLE_IF_EXISTS(" + testTableName + "_temp)"));
152-
153164
DBPartitionUtil.forEachCompanyId(
154165
companyId -> _db.runSQL(
155166
"DROP_TABLE_IF_EXISTS(" + testTableName + ")"));
156-
}
157-
}
158-
159-
private void _addTestTable(
160-
String invalidTableName, String invalidColumnName)
161-
throws Exception {
162-
163-
DBType dbType = DBManagerUtil.getDBType();
164-
165-
if (dbType == DBType.SQLSERVER) {
166-
DBPartitionUtil.forEachCompanyId(
167-
companyId -> _db.runSQL(
168-
StringBundler.concat(
169-
"create table [", invalidTableName, "] ([",
170-
invalidColumnName, "] LONG)")));
171-
}
172-
else {
173167
DBPartitionUtil.forEachCompanyId(
174168
companyId -> _db.runSQL(
175-
StringBundler.concat(
176-
"create table `", invalidTableName, "` (`",
177-
invalidColumnName, "` LONG)")));
169+
"DROP_TABLE_IF_EXISTS(" + testTableName + "_temp)"));
178170
}
179171
}
180172

portal-impl/src/com/liferay/portal/upgrade/data/cleanup/DatabaseTableAndColumnCaseDataCleanupPreupgradeProcess.java

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -93,9 +93,8 @@ protected void doUpgrade() throws Exception {
9393
DBResourceUtil.getServiceComponentModuleColumnDefinitionsMap(
9494
connection));
9595

96-
DatabaseMetaData databaseMetaData = connection.getMetaData();
97-
9896
Map<String, Map<String, String>> columnsMap = new TreeMap<>();
97+
DatabaseMetaData databaseMetaData = connection.getMetaData();
9998

10099
for (String tableName : expectedTableNames) {
101100
try (ResultSet resultSet = databaseMetaData.getColumns(
@@ -124,14 +123,14 @@ protected void doUpgrade() throws Exception {
124123
Map<String, String> columnNames = columnsMap.get(tableName);
125124

126125
_validateColumnNamesCasing(
127-
dbInspector, dbInspector.normalizeName(tableName),
128-
columnDefinitions, columnNames);
126+
dbInspector, columnDefinitions, columnNames,
127+
dbInspector.normalizeName(tableName));
129128
}
130129
}
131130

132131
private void _validateColumnNamesCasing(
133-
DBInspector dbInspector, String tableName,
134-
List<String> columnDefinitions, Map<String, String> columnNames)
132+
DBInspector dbInspector, List<String> columnDefinitions,
133+
Map<String, String> columnNames, String tableName)
135134
throws Exception {
136135

137136
if ((columnNames == null) || columnNames.isEmpty()) {
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
version 32.0.0
1+
version 32.1.0

0 commit comments

Comments
 (0)