Hibernate
/
hibernate-orm
mirror of https://github.com/hibernate/hibernate-orm
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

HHH-2879 Cache naturalId -> entityId sql on init

This commit is contained in:
edalquist 2011-10-06 15:18:33 -05:00 committed by Steve Ebersole
parent eecee618c6
commit 8de0f76df1
1 changed files with 51 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

90
hibernate-core/src/main/java/org/hibernate/persister/entity/AbstractEntityPersister.java
View File

@ -222,6 +222,8 @@ public abstract class AbstractEntityPersister
private final Map loaders = new HashMap(); private final Map loaders = new HashMap();
// SQL strings // SQL strings
private String sqlEntityIdByNaturalIdString;
private String sqlVersionSelectString; private String sqlVersionSelectString;
private String sqlSnapshotSelectString; private String sqlSnapshotSelectString;
private String sqlLazySelectString; private String sqlLazySelectString;
@ -3387,6 +3389,8 @@ public abstract class AbstractEntityPersister
sqlInsertGeneratedValuesSelectString); sqlInsertGeneratedValuesSelectString);
if (sqlUpdateGeneratedValuesSelectString != null) LOG.debugf("Update-generated property select: %s", if (sqlUpdateGeneratedValuesSelectString != null) LOG.debugf("Update-generated property select: %s",
sqlUpdateGeneratedValuesSelectString); sqlUpdateGeneratedValuesSelectString);
if (sqlEntityIdByNaturalIdString != null) LOG.debugf("Id by Natural Id: %s",
sqlEntityIdByNaturalIdString);
} }
} }
@ -3589,6 +3593,10 @@ public abstract class AbstractEntityPersister
sqlIdentityInsertString = null; sqlIdentityInsertString = null;
} }
if (hasNaturalIdentifier()) {
sqlEntityIdByNaturalIdString = generateEntityIdByNaturalIdSql();
}
logStaticSQL(); logStaticSQL();
} }
@ -4506,49 +4514,14 @@ public abstract class AbstractEntityPersister
if (LOG.isTraceEnabled()) LOG.trace("Getting entity id for natural-id for: " if (LOG.isTraceEnabled()) LOG.trace("Getting entity id for natural-id for: "
+ MessageHelper.infoString(this, naturalIdParameters, getFactory())); + MessageHelper.infoString(this, naturalIdParameters, getFactory()));
///////////////////////////////////////////////////////////////////////
// TODO : look at perhaps caching this...
Select select = new Select( getFactory().getDialect() );
if ( getFactory().getSettings().isCommentsEnabled() ) {
select.setComment( "get current natural-id->entity-id state " + getEntityName() );
}
final String rootAlias = getRootAlias();
select.setSelectClause( identifierSelectFragment(rootAlias, "") );
select.setFromClause( fromTableFragment( rootAlias ) + fromJoinFragment( rootAlias, true, false ) );
final StringBuilder whereClause = new StringBuilder();
final int[] propertyTableNumbers = getPropertyTableNumbers();
final int[] naturalIdPropertyIndexes = this.getNaturalIdentifierProperties();
for (int propIdx = 0; propIdx < naturalIdPropertyIndexes.length; propIdx++) {
if (propIdx > 0) {
whereClause.append(" and ");
}
final int naturalIdIdx = naturalIdPropertyIndexes[propIdx];
final String tableAlias = generateTableAlias( rootAlias, propertyTableNumbers[naturalIdIdx] );
final String[] propertyColumnNames = getPropertyColumnNames(naturalIdIdx);
final String[] aliasedPropertyColumns = StringHelper.qualify( rootAlias, propertyColumnNames );
whereClause.append( StringHelper.join( "=? and ", aliasedPropertyColumns ) ).append( "=?" );
}
whereClause.append( whereJoinFragment( getRootAlias(), true, false ) );
String sql = select.setOuterJoins( "", "" )
.setWhereClause( whereClause.toString() )
.toStatementString();
///////////////////////////////////////////////////////////////////////
try { try {
PreparedStatement ps = session.getTransactionCoordinator() PreparedStatement ps = session.getTransactionCoordinator()
.getJdbcCoordinator() .getJdbcCoordinator()
.getStatementPreparer() .getStatementPreparer()
.prepareStatement( sql ); .prepareStatement( sqlEntityIdByNaturalIdString );
try { try {
int positions = 1; int positions = 1;
final int[] naturalIdPropertyIndexes = this.getNaturalIdentifierProperties();
for (int propIdx = 0; propIdx < naturalIdPropertyIndexes.length; propIdx++) { for (int propIdx = 0; propIdx < naturalIdPropertyIndexes.length; propIdx++) {
final int naturalIdIdx = naturalIdPropertyIndexes[propIdx]; final int naturalIdIdx = naturalIdPropertyIndexes[propIdx];
@ -4583,12 +4556,51 @@ public abstract class AbstractEntityPersister
catch ( SQLException e ) { catch ( SQLException e ) {
throw getFactory().getSQLExceptionHelper().convert( throw getFactory().getSQLExceptionHelper().convert(
e, e,
"could not retrieve snapshot: " + MessageHelper.infoString( this, naturalIdParameters, getFactory() ), "could not retrieve entity id: " + MessageHelper.infoString( this, naturalIdParameters, getFactory() ),
sql sqlEntityIdByNaturalIdString
); );
} }
} }
/**
* @return
*/
private String generateEntityIdByNaturalIdSql() {
Select select = new Select( getFactory().getDialect() );
if ( getFactory().getSettings().isCommentsEnabled() ) {
select.setComment( "get current natural-id->entity-id state " + getEntityName() );
}
final String rootAlias = getRootAlias();
select.setSelectClause( identifierSelectFragment(rootAlias, "") );
select.setFromClause( fromTableFragment( rootAlias ) + fromJoinFragment( rootAlias, true, false ) );
final StringBuilder whereClause = new StringBuilder();
final int[] propertyTableNumbers = getPropertyTableNumbers();
final int[] naturalIdPropertyIndexes = this.getNaturalIdentifierProperties();
for (int propIdx = 0; propIdx < naturalIdPropertyIndexes.length; propIdx++) {
if (propIdx > 0) {
whereClause.append(" and ");
}
final int naturalIdIdx = naturalIdPropertyIndexes[propIdx];
final String tableAlias = generateTableAlias( rootAlias, propertyTableNumbers[naturalIdIdx] );
final String[] propertyColumnNames = getPropertyColumnNames(naturalIdIdx);
final String[] aliasedPropertyColumns = StringHelper.qualify( rootAlias, propertyColumnNames );
whereClause.append( StringHelper.join( "=? and ", aliasedPropertyColumns ) ).append( "=?" );
}
whereClause.append( whereJoinFragment( getRootAlias(), true, false ) );
String sql = select.setOuterJoins( "", "" )
.setWhereClause( whereClause.toString() )
.toStatementString();
return sql;
}
protected String concretePropertySelectFragmentSansLeadingComma(String alias, boolean[] include) { protected String concretePropertySelectFragmentSansLeadingComma(String alias, boolean[] include) {
String concretePropertySelectFragment = concretePropertySelectFragment( alias, include ); String concretePropertySelectFragment = concretePropertySelectFragment( alias, include );
int firstComma = concretePropertySelectFragment.indexOf( ", " ); int firstComma = concretePropertySelectFragment.indexOf( ", " );