📄 hibernatejtatransactiontests.java
字号:
sessionControl.reset();
session.getFlushMode();
sessionControl.setReturnValue(FlushMode.AUTO, 1);
session.flush();
sessionControl.setVoidCallable(1);
session.clear();
sessionControl.setVoidCallable(1);
sessionControl.replay();
}
catch (Exception ex) {
ex.printStackTrace();
}
catch (Error err) {
err.printStackTrace();
throw err;
}
}
});
}
});
fail("Should have thrown UnexpectedRollbackException");
}
catch (UnexpectedRollbackException ex) {
// expected
assertEquals(rex, ex.getCause());
}
finally {
TransactionSynchronizationManager.unbindResource(sf);
}
utControl.verify();
sfControl.verify();
sessionControl.verify();
}
public void testJtaTransactionCommitWithWithRequiresNew() throws Exception {
doTestJtaTransactionWithWithRequiresNew(false);
}
public void testJtaTransactionRollbackWithWithRequiresNew() throws Exception {
doTestJtaTransactionWithWithRequiresNew(true);
}
protected void doTestJtaTransactionWithWithRequiresNew(final boolean rollback) throws Exception {
MockControl utControl = MockControl.createControl(UserTransaction.class);
UserTransaction ut = (UserTransaction) utControl.getMock();
MockControl tmControl = MockControl.createControl(TransactionManager.class);
TransactionManager tm = (TransactionManager) tmControl.getMock();
MockControl sfControl = MockControl.createControl(SessionFactory.class);
final SessionFactory sf = (SessionFactory) sfControl.getMock();
MockControl session1Control = MockControl.createControl(Session.class);
final Session session1 = (Session) session1Control.getMock();
MockControl session2Control = MockControl.createControl(Session.class);
final Session session2 = (Session) session2Control.getMock();
ut.getStatus();
utControl.setReturnValue(Status.STATUS_NO_TRANSACTION, 1);
ut.getStatus();
utControl.setReturnValue(Status.STATUS_ACTIVE, 3);
ut.begin();
utControl.setVoidCallable(2);
MockJtaTransaction transaction = new MockJtaTransaction();
tm.suspend();
tmControl.setReturnValue(transaction, 1);
tm.resume(transaction);
tmControl.setVoidCallable(1);
if (rollback) {
ut.rollback();
}
else {
ut.commit();
}
utControl.setVoidCallable(2);
sf.openSession();
sfControl.setReturnValue(session1, 1);
sf.openSession();
sfControl.setReturnValue(session2, 1);
session1.getSessionFactory();
session1Control.setReturnValue(sf, 1);
session2.getSessionFactory();
session2Control.setReturnValue(sf, 1);
session1.isOpen();
session1Control.setReturnValue(true, 1);
session2.isOpen();
session2Control.setReturnValue(true, 1);
session2.getFlushMode();
session2Control.setReturnValue(FlushMode.AUTO, 1);
if (!rollback) {
session1.getFlushMode();
session1Control.setReturnValue(FlushMode.AUTO, 1);
session2.getFlushMode();
session2Control.setReturnValue(FlushMode.AUTO, 1);
session1.flush();
session1Control.setVoidCallable(1);
session2.flush();
session2Control.setVoidCallable(2);
}
session1.close();
session1Control.setReturnValue(null, 1);
session2.close();
session2Control.setReturnValue(null, 1);
utControl.replay();
tmControl.replay();
sfControl.replay();
session1Control.replay();
session2Control.replay();
JtaTransactionManager ptm = new JtaTransactionManager();
ptm.setUserTransaction(ut);
ptm.setTransactionManager(tm);
final TransactionTemplate tt = new TransactionTemplate(ptm);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
try {
tt.execute(new TransactionCallback() {
public Object doInTransaction(TransactionStatus status) {
Session outerSession = SessionFactoryUtils.getSession(sf, false);
assertSame(session1, outerSession);
SessionHolder holder = (SessionHolder) TransactionSynchronizationManager.getResource(sf);
assertTrue("Has thread session", holder != null);
try {
tt.execute(new TransactionCallback() {
public Object doInTransaction(TransactionStatus status) {
Session innerSession = SessionFactoryUtils.getSession(sf, false);
assertSame(session2, innerSession);
HibernateTemplate ht = new HibernateTemplate(sf);
ht.setFlushMode(HibernateTemplate.FLUSH_EAGER);
return ht.executeFind(new HibernateCallback() {
public Object doInHibernate(Session innerSession) throws HibernateException {
if (rollback) {
throw new HibernateException("");
}
return null;
}
});
}
});
return null;
}
finally {
assertTrue("Same thread session as before", outerSession == SessionFactoryUtils.getSession(sf, false));
}
}
});
if (rollback) {
fail("Should have thrown DataAccessException");
}
}
catch (DataAccessException ex) {
if (!rollback) {
throw ex;
}
}
finally {
assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
}
utControl.verify();
tmControl.verify();
sfControl.verify();
session1Control.verify();
session2Control.verify();
}
public void testJtaTransactionCommitWithWithRequiresNewAndJtaTm() throws Exception {
doTestJtaTransactionWithWithRequiresNewAndJtaTm(false);
}
public void testJtaTransactionRollbackWithWithRequiresNewAndJtaTm() throws Exception {
doTestJtaTransactionWithWithRequiresNewAndJtaTm(true);
}
protected void doTestJtaTransactionWithWithRequiresNewAndJtaTm(final boolean rollback) throws Exception {
MockControl utControl = MockControl.createControl(UserTransaction.class);
UserTransaction ut = (UserTransaction) utControl.getMock();
MockControl tmControl = MockControl.createControl(TransactionManager.class);
TransactionManager tm = (TransactionManager) tmControl.getMock();
MockControl tx1Control = MockControl.createControl(javax.transaction.Transaction.class);
javax.transaction.Transaction tx1 = (javax.transaction.Transaction) tx1Control.getMock();
MockControl sfControl = MockControl.createControl(SessionFactoryImplementor.class);
final SessionFactoryImplementor sf = (SessionFactoryImplementor) sfControl.getMock();
MockControl session1Control = MockControl.createControl(Session.class);
final Session session1 = (Session) session1Control.getMock();
MockControl session2Control = MockControl.createControl(Session.class);
final Session session2 = (Session) session2Control.getMock();
MockJtaTransaction transaction1 = new MockJtaTransaction();
MockJtaTransaction transaction2 = new MockJtaTransaction();
ut.getStatus();
utControl.setReturnValue(Status.STATUS_NO_TRANSACTION, 1);
ut.getStatus();
utControl.setReturnValue(Status.STATUS_ACTIVE, 3);
ut.begin();
utControl.setVoidCallable(2);
tm.getStatus();
tmControl.setReturnValue(Status.STATUS_ACTIVE, 2);
tm.getTransaction();
tmControl.setReturnValue(transaction1, 1);
tm.suspend();
tmControl.setReturnValue(tx1, 1);
tm.getTransaction();
tmControl.setReturnValue(transaction2, 1);
tm.resume(tx1);
tmControl.setVoidCallable(1);
if (rollback) {
ut.rollback();
}
else {
ut.commit();
}
utControl.setVoidCallable(2);
sf.getConnectionProvider();
sfControl.setReturnValue(null, 1);
sf.getTransactionManager();
sfControl.setReturnValue(tm, 2);
sf.openSession();
sfControl.setReturnValue(session1, 1);
sf.openSession();
sfControl.setReturnValue(session2, 1);
session1.isOpen();
session1Control.setReturnValue(true, 1);
session2.isOpen();
session2Control.setReturnValue(true, 1);
session2.getFlushMode();
session2Control.setReturnValue(FlushMode.AUTO, 1);
if (!rollback) {
session1.getFlushMode();
session1Control.setReturnValue(FlushMode.AUTO, 1);
session2.getFlushMode();
session2Control.setReturnValue(FlushMode.AUTO, 1);
session1.flush();
session1Control.setVoidCallable(1);
session2.flush();
session2Control.setVoidCallable(2);
}
session1.close();
session1Control.setReturnValue(null, 1);
session2.close();
session2Control.setReturnValue(null, 1);
utControl.replay();
tmControl.replay();
sfControl.replay();
session1Control.replay();
session2Control.replay();
JtaTransactionManager ptm = new JtaTransactionManager();
ptm.setUserTransaction(ut);
ptm.setTransactionManager(tm);
final TransactionTemplate tt = new TransactionTemplate(ptm);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
try {
tt.execute(new TransactionCallback() {
public Object doInTransaction(TransactionStatus status) {
Session outerSession = SessionFactoryUtils.getSession(sf, false);
assertSame(session1, outerSession);
SessionHolder holder = (SessionHolder) TransactionSynchronizationManager.getResource(sf);
assertTrue("Has thread session", holder != null);
try {
tt.execute(new TransactionCallback() {
public Object doInTransaction(TransactionStatus status) {
Session innerSession = SessionFactoryUtils.getSession(sf, false);
assertSame(session2, innerSession);
HibernateTemplate ht = new HibernateTemplate(sf);
ht.setFlushMode(HibernateTemplate.FLUSH_EAGER);
return ht.executeFind(new HibernateCallback() {
public Object doInHibernate(Session innerSession) throws HibernateException {
if (rollback) {
throw new HibernateException("");
}
return null;
}
});
}
});
return null;
}
finally {
assertTrue("Same thread session as before", outerSession == SessionFactoryUtils.getSession(sf, false));
}
}
});
if (rollback) {
fail("Should have thrown DataAccessException");
}
}
catch (DataAccessException ex) {
if (!rollback) {
throw ex;
}
}
finally {
assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
}
utControl.verify();
tmControl.verify();
sfControl.verify();
session1Control.verify();
session2Control.verify();
}
public void testJtaSessionSynchronization() throws Exception {
MockControl tmControl = MockControl.createControl(TransactionManager.class);
TransactionManager tm = (TransactionManager) tmControl.getMock();
MockJtaTransaction transaction = new MockJtaTransaction();
tm.getStatus();
tmControl.setReturnValue(Status.STATUS_ACTIVE, 6);
tm.getTransaction();
tmControl.setReturnValue(transaction, 6);
MockControl sfControl = MockControl.createControl(SessionFactoryImplementor.class);
final SessionFactoryImplementor sf = (SessionFactoryImplementor) sfControl.getMock();
final MockControl sessionControl = MockControl.createControl(Session.class);
final Session session = (Session) sessionControl.getMock();
sf.getConnectionProvider();
sfControl.setReturnValue(null, 1);
sf.openSession();
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -