Skip to content

Commit 49a2602

Browse files
committed
HHH-19336 - Proper implementation for JPA extended locking scope
HHH-19459 - LockScope, FollowOnLocking
1 parent b6560ed commit 49a2602

File tree

2 files changed

+10
-25
lines changed

2 files changed

+10
-25
lines changed

hibernate-core/src/main/java/org/hibernate/id/enhanced/TableGenerator.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,6 @@
5959
import static org.hibernate.id.enhanced.OptimizerFactory.determineImplicitOptimizerName;
6060
import static org.hibernate.internal.util.StringHelper.isEmpty;
6161
import static org.hibernate.internal.util.StringHelper.isNotEmpty;
62-
import static org.hibernate.internal.util.StringHelper.qualify;
6362
import static org.hibernate.internal.util.config.ConfigurationHelper.getBoolean;
6463
import static org.hibernate.internal.util.config.ConfigurationHelper.getInt;
6564
import static org.hibernate.internal.util.config.ConfigurationHelper.getString;
@@ -492,11 +491,10 @@ protected int determineIncrementSize(Properties params) {
492491

493492
protected String buildSelectQuery(String formattedPhysicalTableName, SqlStringGenerationContext context) {
494493
final LockOptions lockOptions = new LockOptions( LockMode.PESSIMISTIC_WRITE );
495-
final String alias = "tbl";
496494
final SimpleSelect select = new SimpleSelect( context.getDialect() )
497-
.addColumn( qualify( alias, valueColumnName ) )
498-
.setTableName( formattedPhysicalTableName, alias )
499-
.addRestriction( qualify( alias, segmentColumnName ) )
495+
.addColumn( valueColumnName )
496+
.setTableName( formattedPhysicalTableName )
497+
.addRestriction( segmentColumnName )
500498
.setLockOptions( lockOptions );
501499
return select.toStatementString();
502500
}

hibernate-core/src/main/java/org/hibernate/sql/SimpleSelect.java

Lines changed: 7 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -4,23 +4,22 @@
44
*/
55
package org.hibernate.sql;
66

7-
import java.util.ArrayList;
8-
import java.util.HashMap;
9-
import java.util.HashSet;
10-
import java.util.List;
11-
import java.util.Map;
12-
import java.util.Set;
13-
147
import org.hibernate.Internal;
158
import org.hibernate.LockMode;
169
import org.hibernate.LockOptions;
1710
import org.hibernate.dialect.Dialect;
1811
import org.hibernate.engine.jdbc.spi.JdbcServices;
1912
import org.hibernate.engine.spi.SessionFactoryImplementor;
20-
import org.hibernate.internal.util.StringHelper;
2113
import org.hibernate.sql.ast.internal.ParameterMarkerStrategyStandard;
2214
import org.hibernate.sql.ast.spi.ParameterMarkerStrategy;
2315

16+
import java.util.ArrayList;
17+
import java.util.HashMap;
18+
import java.util.HashSet;
19+
import java.util.List;
20+
import java.util.Map;
21+
import java.util.Set;
22+
2423
/**
2524
* A SQL {@code SELECT} statement with no table joins.
2625
*
@@ -29,7 +28,6 @@
2928
@Internal
3029
public class SimpleSelect implements RestrictionRenderingContext {
3130
protected String tableName;
32-
protected String tableAlias;
3331
protected String orderBy;
3432
protected String comment;
3533

@@ -67,15 +65,7 @@ public String makeParameterMarker() {
6765
* Sets the name of the table we are selecting from
6866
*/
6967
public SimpleSelect setTableName(String tableName) {
70-
return setTableName( tableName, null );
71-
}
72-
73-
/**
74-
* Sets the name of the table we are selecting from
75-
*/
76-
public SimpleSelect setTableName(String tableName, String tableAlias) {
7768
this.tableName = tableName;
78-
this.tableAlias = tableAlias;
7969
return this;
8070
}
8171

@@ -225,9 +215,6 @@ private void applySelectClause(StringBuilder buf) {
225215

226216
private void applyFromClause(StringBuilder buf) {
227217
buf.append( " from " ).append( dialect.appendLockHint( lockOptions, tableName ) );
228-
if ( StringHelper.isNotEmpty( tableAlias ) ) {
229-
buf.append( " as " ).append( tableAlias );
230-
}
231218
}
232219

233220
private void applyWhereClause(StringBuilder buf) {

0 commit comments

Comments
 (0)