LPD-41532 search-experiences-service: Change SXPBlueprintUpgradeProce…

…ss class to use AutoBatchPreparedStatementUtil https://liferay.atlassian.net/browse/LPD-41532
rotty3000 · Nov 11, 2024 · f4cf85a · f4cf85a
1 parent a4724f0
commit f4cf85a
Showing 1 changed file with 18 additions and 11 deletions.
diff --git a/...va/com/liferay/search/experiences/internal/upgrade/v3_0_0/SXPBlueprintUpgradeProcess.java b/...va/com/liferay/search/experiences/internal/upgrade/v3_0_0/SXPBlueprintUpgradeProcess.java
@@ -7,6 +7,7 @@
 
 import com.liferay.petra.string.StringBundler;
 import com.liferay.petra.string.StringPool;
+import com.liferay.portal.kernel.dao.jdbc.AutoBatchPreparedStatementUtil;
 import com.liferay.portal.kernel.json.JSONArray;
 import com.liferay.portal.kernel.json.JSONFactoryUtil;
 import com.liferay.portal.kernel.json.JSONObject;
@@ -125,9 +126,11 @@ private void _upgradeLowLevelSearchOptionsPortlets() throws Exception {
 			PreparedStatement preparedStatement2 = connection.prepareStatement(
 				"select externalReferenceCode from SXPBlueprint where " +
 					"sxpBlueprintId = ?");
-			PreparedStatement preparedStatement3 = connection.prepareStatement(
-				"update PortletPreferenceValue set smallValue = ? where " +
-					"portletPreferencesId = ? and name = 'attributes'")) {
+			PreparedStatement preparedStatement3 =
+				AutoBatchPreparedStatementUtil.concurrentAutoBatch(
+					connection,
+					"update PortletPreferenceValue set smallValue = ? where " +
+						"portletPreferencesId = ? and name = 'attributes'")) {
 
 			while (resultSet1.next()) {
 				String smallValue = resultSet1.getString("smallValue");
@@ -173,10 +176,12 @@ private void _upgradeSearchBarPortlets() throws Exception {
 			PreparedStatement preparedStatement2 = connection.prepareStatement(
 				"select externalReferenceCode from SXPBlueprint where " +
 					"sxpBlueprintId = ?");
-			PreparedStatement preparedStatement3 = connection.prepareStatement(
-				"update PortletPreferenceValue set largeValue = ? where " +
-					"portletPreferencesId = ? and name = " +
-						"'suggestionsContributorConfigurations'")) {
+			PreparedStatement preparedStatement3 =
+				AutoBatchPreparedStatementUtil.concurrentAutoBatch(
+					connection,
+					"update PortletPreferenceValue set largeValue = ? where " +
+						"portletPreferencesId = ? and name = " +
+							"'suggestionsContributorConfigurations'")) {
 
 			while (resultSet1.next()) {
 				String largeValue = resultSet1.getString("largeValue");
@@ -231,10 +236,12 @@ private void _upgradeSXPBlueprintOptionsPortlets() {
 			PreparedStatement preparedStatement2 = connection.prepareStatement(
 				"select externalReferenceCode from SXPBlueprint where " +
 					"sxpBlueprintId = ?");
-			PreparedStatement preparedStatement3 = connection.prepareStatement(
-				"update PortletPreferenceValue set name = ?, smallValue = ? " +
-					"where portletPreferencesId = ? and name = " +
-						"'sxpBlueprintId'")) {
+			PreparedStatement preparedStatement3 =
+				AutoBatchPreparedStatementUtil.concurrentAutoBatch(
+					connection,
+					"update PortletPreferenceValue set name = ?, smallValue " +
+						"= ? where portletPreferencesId = ? and name = " +
+							"'sxpBlueprintId'")) {
 
 			while (resultSet1.next()) {
 				preparedStatement2.setLong(1, resultSet1.getLong("smallValue"));