HHH-9451 Propagating entity entry extra state when using identity id generation strategy
This commit is contained in:
parent
7a247e114e
commit
4bbf4cd1db
|
@ -39,6 +39,7 @@ import org.hibernate.engine.internal.ForeignKeys;
|
||||||
import org.hibernate.engine.internal.Versioning;
|
import org.hibernate.engine.internal.Versioning;
|
||||||
import org.hibernate.engine.spi.CascadingAction;
|
import org.hibernate.engine.spi.CascadingAction;
|
||||||
import org.hibernate.engine.spi.EntityEntry;
|
import org.hibernate.engine.spi.EntityEntry;
|
||||||
|
import org.hibernate.engine.spi.EntityEntryExtraState;
|
||||||
import org.hibernate.engine.spi.EntityKey;
|
import org.hibernate.engine.spi.EntityKey;
|
||||||
import org.hibernate.engine.spi.SessionImplementor;
|
import org.hibernate.engine.spi.SessionImplementor;
|
||||||
import org.hibernate.engine.spi.Status;
|
import org.hibernate.engine.spi.Status;
|
||||||
|
@ -248,7 +249,7 @@ public abstract class AbstractSaveEventListener extends AbstractReassociateEvent
|
||||||
// Put a placeholder in entries, so we don't recurse back and try to save() the
|
// Put a placeholder in entries, so we don't recurse back and try to save() the
|
||||||
// same object again. QUESTION: should this be done before onSave() is called?
|
// same object again. QUESTION: should this be done before onSave() is called?
|
||||||
// likewise, should it be done before onUpdate()?
|
// likewise, should it be done before onUpdate()?
|
||||||
source.getPersistenceContext().addEntry(
|
EntityEntry original = source.getPersistenceContext().addEntry(
|
||||||
entity,
|
entity,
|
||||||
Status.SAVING,
|
Status.SAVING,
|
||||||
null,
|
null,
|
||||||
|
@ -306,6 +307,15 @@ public abstract class AbstractSaveEventListener extends AbstractReassociateEvent
|
||||||
|
|
||||||
markInterceptorDirty( entity, persister, source );
|
markInterceptorDirty( entity, persister, source );
|
||||||
|
|
||||||
|
EntityEntry newEntry = source.getPersistenceContext().getEntry( entity );
|
||||||
|
|
||||||
|
if ( newEntry != original ) {
|
||||||
|
EntityEntryExtraState extraState = newEntry.getExtraState( EntityEntryExtraState.class );
|
||||||
|
if ( extraState == null ) {
|
||||||
|
newEntry.addExtraState( original.getExtraState( EntityEntryExtraState.class ) );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
return id;
|
return id;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -0,0 +1,119 @@
|
||||||
|
/*
|
||||||
|
* Hibernate OGM, Domain model persistence for NoSQL datastores
|
||||||
|
*
|
||||||
|
* License: GNU Lesser General Public License (LGPL), version 2.1 or later
|
||||||
|
* See the lgpl.txt file in the root directory or <http://www.gnu.org/licenses/lgpl-2.1.html>.
|
||||||
|
*/
|
||||||
|
package org.hibernate.engine.spi;
|
||||||
|
|
||||||
|
import static org.junit.Assert.assertEquals;
|
||||||
|
import static org.junit.Assert.assertNotNull;
|
||||||
|
|
||||||
|
import javax.persistence.Entity;
|
||||||
|
import javax.persistence.GeneratedValue;
|
||||||
|
import javax.persistence.GenerationType;
|
||||||
|
import javax.persistence.Id;
|
||||||
|
|
||||||
|
import org.hibernate.Session;
|
||||||
|
import org.hibernate.internal.SessionImpl;
|
||||||
|
import org.hibernate.testing.TestForIssue;
|
||||||
|
import org.hibernate.testing.junit4.BaseCoreFunctionalTestCase;
|
||||||
|
import org.junit.Test;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Test for making sure that any set entity entry extra state is propagated from temporary to final entity entries.
|
||||||
|
*
|
||||||
|
* @author Gunnar Morling
|
||||||
|
*/
|
||||||
|
public class ExtraStateTest extends BaseCoreFunctionalTestCase {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Storing it as a field so it can be accessed from the entity setter.
|
||||||
|
*/
|
||||||
|
private Session session;
|
||||||
|
|
||||||
|
@Test
|
||||||
|
@TestForIssue(jiraKey = "HHH-9451")
|
||||||
|
public void shouldMaintainExtraStateWhenUsingIdentityIdGenerationStrategy() {
|
||||||
|
session = openSession();
|
||||||
|
session.getTransaction().begin();
|
||||||
|
|
||||||
|
ChineseTakeawayRestaurant mrKim = new ChineseTakeawayRestaurant();
|
||||||
|
mrKim.setGobelinStars( 3 );
|
||||||
|
|
||||||
|
// As a side-effect, the id setter will populate the test extra state
|
||||||
|
session.persist( mrKim );
|
||||||
|
|
||||||
|
session.getTransaction().commit();
|
||||||
|
|
||||||
|
TestExtraState extraState = getEntityEntry( mrKim ).getExtraState( TestExtraState.class );
|
||||||
|
assertNotNull( "Test extra state was not propagated from temporary to final entity entry", extraState );
|
||||||
|
assertEquals( 311, extraState.getValue() );
|
||||||
|
|
||||||
|
session.close();
|
||||||
|
}
|
||||||
|
|
||||||
|
private EntityEntry getEntityEntry(Object object) {
|
||||||
|
return ( (SessionImpl) session ).getPersistenceContext().getEntry( object );
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected Class<?>[] getAnnotatedClasses() {
|
||||||
|
return new Class<?>[] { ChineseTakeawayRestaurant.class };
|
||||||
|
}
|
||||||
|
|
||||||
|
@Entity
|
||||||
|
public class ChineseTakeawayRestaurant {
|
||||||
|
|
||||||
|
private long id;
|
||||||
|
private int gobelinStars;
|
||||||
|
|
||||||
|
public ChineseTakeawayRestaurant() {
|
||||||
|
}
|
||||||
|
|
||||||
|
@Id
|
||||||
|
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||||
|
public long getId() {
|
||||||
|
return id;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sets the test extra state as a side effect
|
||||||
|
*/
|
||||||
|
public void setId(long id) {
|
||||||
|
getEntityEntry( this ).addExtraState( new TestExtraState( 311 ) );
|
||||||
|
this.id = id;
|
||||||
|
}
|
||||||
|
|
||||||
|
public int getGobelinStars() {
|
||||||
|
return gobelinStars;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setGobelinStars(int gobelinStars) {
|
||||||
|
this.gobelinStars = gobelinStars;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private static class TestExtraState implements EntityEntryExtraState {
|
||||||
|
|
||||||
|
private final long value;
|
||||||
|
|
||||||
|
public TestExtraState(long value) {
|
||||||
|
this.value = value;
|
||||||
|
}
|
||||||
|
|
||||||
|
public long getValue() {
|
||||||
|
return value;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void addExtraState(EntityEntryExtraState extraState) {
|
||||||
|
throw new UnsupportedOperationException();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public <T extends EntityEntryExtraState> T getExtraState(Class<T> extraStateType) {
|
||||||
|
throw new UnsupportedOperationException();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue