Merge initialize partitions

Sednai · Dec 19, 2023 · c06fab3 · c06fab3
1 parent 3eebb91
commit c06fab3
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/RowImpl.java b/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/RowImpl.java
@@ -1241,14 +1241,11 @@ static synchronized public List<PartitionRecord<Long>> initializePartitions(Conn
 		ResultSet resultSet = pSt.executeQuery();
 
 		while (resultSet.next() == true) {
-			PartitionRecord<Long> partitionRecord = new PartitionRecord<Long>(resultSet.getString(1),
-					resultSet.getString(2), resultSet.getString(3), resultSet.getLong(4),
-					(resultSet.getLong(5)) == 0 ? null : resultSet.getLong(5), resultSet.getShort(6), null);
+			PartitionRecord<Long> partitionRecord = new PartitionRecord<Long>(resultSet.getString(1), resultSet.getString(2),
+					resultSet.getString(3), resultSet.getLong(4), (resultSet.getLong(5)) == 0 ? null : resultSet.getLong(5),
+					resultSet.getShort(6), null);
 
 			partitions.add(partitionRecord);
-			//lvl one only
-			if(partitionRecord.getLevel()==1)
-				partitionNames.get().add(resultSet.getString(1));
 		}
 
 		RowImpl.partitions.set(partitions);