Revert "LPD-27779 Update only rows matching ctCollectionId"

This reverts commit 5a3a754.
ctang3 · Aug 28, 2024 · 4a5be03 · 4a5be03
1 parent 60e87e9
commit 4a5be03
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/...src/main/java/com/liferay/journal/internal/upgrade/v3_3_0/StorageLinksUpgradeProcess.java b/...src/main/java/com/liferay/journal/internal/upgrade/v3_3_0/StorageLinksUpgradeProcess.java
@@ -31,7 +31,6 @@ protected void doUpgrade() throws Exception {
 				connection.prepareStatement(
 					StringBundler.concat(
 						"select DDMStructureVersion.structureVersionId, ",
-						"DDMStorageLink.ctCollectionId, ",
 						"DDMStorageLink.storageLinkId from DDMStorageLink ",
 						"inner join DDMStructure on DDMStructure.structureId ",
 						"= DDMStorageLink.structureVersionId inner join ",
@@ -46,13 +45,12 @@ protected void doUpgrade() throws Exception {
 				AutoBatchPreparedStatementUtil.autoBatch(
 					connection,
 					"update DDMStorageLink set structureVersionId = ? where " +
-						"ctCollectionId = ? and storageLinkId = ?");
+						"storageLinkId = ?");
 			ResultSet resultSet = selectPreparedStatement.executeQuery()) {
 
 			while (resultSet.next()) {
 				updatePreparedStatement.setLong(1, resultSet.getLong(1));
 				updatePreparedStatement.setLong(2, resultSet.getLong(2));
-				updatePreparedStatement.setLong(3, resultSet.getLong(3));
 
 				updatePreparedStatement.addBatch();
 			}
@@ -64,7 +62,6 @@ protected void doUpgrade() throws Exception {
 				connection.prepareStatement(
 					StringBundler.concat(
 						"select DDMStructureVersion.structureId, ",
-						"DDMStorageLink.ctCollectionId, ",
 						"DDMStorageLink.storageLinkId from DDMStorageLink ",
 						"inner join DDMStructureVersion on ",
 						"DDMStructureVersion.structureVersionId = ",
@@ -74,13 +71,12 @@ protected void doUpgrade() throws Exception {
 				AutoBatchPreparedStatementUtil.autoBatch(
 					connection,
 					"update DDMStorageLink set structureId = ? where " +
-						"ctCollectionId = ? and storageLinkId = ?");
+						"storageLinkId = ?");
 			ResultSet resultSet = selectPreparedStatement.executeQuery()) {
 
 			while (resultSet.next()) {
 				updatePreparedStatement.setLong(1, resultSet.getLong(1));
 				updatePreparedStatement.setLong(2, resultSet.getLong(2));
-				updatePreparedStatement.setLong(3, resultSet.getLong(3));
 
 				updatePreparedStatement.addBatch();
 			}