📄 toplinkjtatransactiontests.java
字号:
// sfControl.replay();
// sessionControl.replay();
//
// TransactionSynchronizationManager.bindResource(sf, new SessionHolder(session));
// try {
// JtaTransactionManager ptm = new JtaTransactionManager(ut);
// final TransactionTemplate tt = new TransactionTemplate(ptm);
// assertTrue("JTA synchronizations not active", !TransactionSynchronizationManager.isSynchronizationActive());
// assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));
//
// tt.execute(new TransactionCallbackWithoutResult() {
// public void doInTransactionWithoutResult(TransactionStatus status) {
// tt.execute(new TransactionCallbackWithoutResult() {
// public void doInTransactionWithoutResult(TransactionStatus status) {
// status.setRollbackOnly();
// try {
// assertTrue("JTA synchronizations active", TransactionSynchronizationManager.isSynchronizationActive());
// assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));
// HibernateTemplate ht = new HibernateTemplate(sf);
// ht.setExposeNativeSession(true);
// for (int i = 0; i < 5; i++) {
// ht.execute(new HibernateCallback() {
// public Object doInHibernate(Session sess) {
// assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));
// assertEquals(session, sess);
// return null;
// }
// });
// assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));
// }
// sessionControl.verify();
// sessionControl.reset();
// session.clear();
// sessionControl.setVoidCallable(1);
// sessionControl.replay();
// }
// catch (Error err) {
// err.printStackTrace();
// throw err;
// }
// }
// });
// }
// });
//
// assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));
// assertTrue("JTA synchronizations not active", !TransactionSynchronizationManager.isSynchronizationActive());
// }
// finally {
// TransactionSynchronizationManager.unbindResource(sf);
// }
//
// utControl.verify();
// sfControl.verify();
// sessionControl.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();
// sfControl.setReturnValue(session, 1);
// sf.getTransactionManager();
// sfControl.setReturnValue(tm, 6);
// session.getFlushMode();
// sessionControl.setReturnValue(FlushMode.AUTO, 1);
// session.flush();
// sessionControl.setVoidCallable(1);
// session.close();
// sessionControl.setReturnValue(null, 1);
//
// tmControl.replay();
// sfControl.replay();
// sessionControl.replay();
//
// assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
// HibernateTemplate ht = new HibernateTemplate(sf);
// ht.setExposeNativeSession(true);
// for (int i = 0; i < 5; i++) {
// ht.executeFind(new HibernateCallback() {
// public Object doInHibernate(Session sess) {
// assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));
// assertEquals(session, sess);
// return null;
// }
// });
// }
//
// Synchronization synchronization = transaction.getSynchronization();
// assertTrue("JTA synchronization registered", synchronization != null);
// synchronization.beforeCompletion();
// synchronization.afterCompletion(Status.STATUS_COMMITTED);
//
// assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
// assertTrue("JTA synchronizations not active", !TransactionSynchronizationManager.isSynchronizationActive());
//
// tmControl.verify();
// sfControl.verify();
// sessionControl.verify();
// }
//
// public void testJtaSessionSynchronizationWithRollback() 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);
//
// final HibernateException flushEx = new HibernateException("flush failure");
// 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();
// sfControl.setReturnValue(session, 1);
// sf.getTransactionManager();
// sfControl.setReturnValue(tm, 6);
// session.close();
// sessionControl.setReturnValue(null, 1);
//
// tmControl.replay();
// sfControl.replay();
// sessionControl.replay();
//
// assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
// HibernateTemplate ht = new HibernateTemplate(sf);
// ht.setExposeNativeSession(true);
// for (int i = 0; i < 5; i++) {
// ht.executeFind(new HibernateCallback() {
// public Object doInHibernate(Session sess) {
// assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));
// assertEquals(session, sess);
// return null;
// }
// });
// }
//
// Synchronization synchronization = transaction.getSynchronization();
// assertTrue("JTA synchronization registered", synchronization != null);
// synchronization.afterCompletion(Status.STATUS_ROLLEDBACK);
//
// assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
// assertTrue("JTA synchronizations not active", !TransactionSynchronizationManager.isSynchronizationActive());
//
// tmControl.verify();
// sfControl.verify();
// sessionControl.verify();
// }
//
// public void testJtaSessionSynchronizationWithFlushFailure() 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);
// tm.setRollbackOnly();
// tmControl.setVoidCallable(1);
//
// final HibernateException flushEx = new HibernateException("flush failure");
// 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();
// sfControl.setReturnValue(session, 1);
// sf.getTransactionManager();
// sfControl.setReturnValue(tm, 6);
// session.getFlushMode();
// sessionControl.setReturnValue(FlushMode.AUTO, 1);
// session.flush();
// sessionControl.setThrowable(flushEx, 1);
// session.close();
// sessionControl.setReturnValue(null, 1);
//
// tmControl.replay();
// sfControl.replay();
// sessionControl.replay();
//
// assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
// HibernateTemplate ht = new HibernateTemplate(sf);
// ht.setExposeNativeSession(true);
// for (int i = 0; i < 5; i++) {
// ht.executeFind(new HibernateCallback() {
// public Object doInHibernate(Session sess) {
// assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));
// assertEquals(session, sess);
// return null;
// }
// });
// }
//
// Synchronization synchronization = transaction.getSynchronization();
// assertTrue("JTA synchronization registered", synchronization != null);
// synchronization.beforeCompletion();
// synchronization.afterCompletion(Status.STATUS_COMMITTED);
//
// assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
// assertTrue("JTA synchronizations not active", !TransactionSynchronizationManager.isSynchronizationActive());
//
// tmControl.verify();
// sfControl.verify();
// sessionControl.verify();
// }
//
// public void testJtaSessionSynchronizationWithSuspendedTransaction() throws Exception {
// MockControl tmControl = MockControl.createControl(TransactionManager.class);
// TransactionManager tm = (TransactionManager) tmControl.getMock();
// MockJtaTransaction transaction1 = new MockJtaTransaction();
// MockJtaTransaction transaction2 = new MockJtaTransaction();
// tm.getStatus();
// tmControl.setReturnValue(Status.STATUS_ACTIVE, 5);
// tm.getTransaction();
// tmControl.setReturnValue(transaction1, 2);
// tm.getTransaction();
// tmControl.setReturnValue(transaction2, 3);
//
// MockControl sfControl = MockControl.createControl(SessionFactoryImplementor.class);
// final SessionFactoryImplementor sf = (SessionFactoryImplementor) sfControl.getMock();
// final MockControl session1Control = MockControl.createControl(Session.class);
// final Session session1 = (Session) session1Control.getMock();
// final MockControl session2Control = MockControl.createControl(Session.class);
// final Session session2 = (Session) session2Control.getMock();
// sf.getConnectionProvider();
// sfControl.setReturnValue(null, 1);
// sf.openSession();
// sfControl.setReturnValue(session1, 1);
// sf.openSession();
// sfControl.setReturnValue(session2, 1);
// sf.getTransactionManager();
// sfControl.setReturnValue(tm, 5);
// session1.getFlushMode();
// session1Control.setReturnValue(FlushMode.AUTO, 1);
// session2.getFlushMode();
// session2Control.setReturnValue(FlushMode.AUTO, 1);
// session1.flush();
// session1Control.setVoidCallable(1);
// session2.flush();
// session2Control.setVoidCallable(1);
// session1.close();
// session1Control.setReturnValue(null, 1);
// session2.close();
// session2Control.setReturnValue(null, 1);
//
// tmControl.replay();
// sfControl.replay();
// session1Control.replay();
// session2Control.replay();
//
// assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
// HibernateTemplate ht = new HibernateTemplate(sf);
// ht.setExposeNativeSession(true);
// ht.executeFind(new HibernateCallback() {
// public Object doInHibernate(Session sess) {
// assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));
// assertEquals(session1, sess);
// return null;
// }
// });
// ht.executeFind(new HibernateCallback() {
// public Object doInHibernate(Session sess) {
// assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));
// assertEquals(session2, sess);
// return null;
// }
// });
//
// Synchronization synchronization2 = transaction2.getSynchronization();
// assertTrue("JTA synchronization registered", synchronization2 != null);
// synchronization2.beforeCompletion();
// synchronization2.afterCompletion(Status.STATUS_COMMITTED);
//
// Synchronization synchronization1 = transaction1.getSynchronization();
// assertTrue("JTA synchronization registered", synchronization1 != null);
// synchronization1.beforeCompletion();
// synchronization1.afterCompletion(Status.STATUS_COMMITTED);
//
// assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
// assertTrue("JTA synchronizations not active", !TransactionSynchronizationManager.isSynchronizationActive());
//
// tmControl.verify();
// sfControl.verify();
// session1Control.verify();
// session2Control.verify();
// }
//
// public void testJtaSessionSynchronizationWithNonSessionFactoryImplementor() throws Exception {
// MockControl tmControl = MockControl.createControl(TransactionManager.class);
// TransactionManager tm = (TransactionManager) tmControl.getMock();
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -