Package org.springframework.transaction.support

Examples of org.springframework.transaction.support.TransactionTemplate.execute()

48
49
50
51
52
53
54
55
56
57
58
        });
    }

    protected void sendBMessages() {
        TransactionTemplate transaction = getMandatoryBean(TransactionTemplate.class, "transactionTemplate");
        transaction.execute(new TransactionCallbackWithoutResult() {
            protected void doInTransactionWithoutResult(TransactionStatus status) {
                template.sendBody("direct:b", "<hello id='123'>A</hello>");
                template.sendBody("direct:b", "<hello id='125'>C</hello>");
            }
        });
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
    TransactionTemplate tt = new TransactionTemplate(ptm);
    tt.setReadOnly(readOnly);
    assertTrue("JTA synchronizations not active", !TransactionSynchronizationManager.isSynchronizationActive());
    assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));

    Object result = tt.execute(new TransactionCallback() {
      public Object doInTransaction(TransactionStatus status) {
        try {
          assertTrue("JTA synchronizations active", TransactionSynchronizationManager.isSynchronizationActive());
          assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
          HibernateTemplate ht = new HibernateTemplate(sf);
View Full Code Here
224
225
226
227
228
229
230
231
232
233
234
    final List l = new ArrayList();
    l.add("test");
    assertTrue("JTA synchronizations not active", !TransactionSynchronizationManager.isSynchronizationActive());
    assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));

    Object result = tt.execute(new TransactionCallback() {
      public Object doInTransaction(TransactionStatus status) {
        try {
          assertTrue("JTA synchronizations active", TransactionSynchronizationManager.isSynchronizationActive());
          assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
          HibernateTemplate ht = new HibernateTemplate(sf);
View Full Code Here
310
311
312
313
314
315
316
317
318
319
320
    final HibernateException flushEx = new HibernateException("flush failure");
    assertTrue("JTA synchronizations not active", !TransactionSynchronizationManager.isSynchronizationActive());
    assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));

    try {
      tt.execute(new TransactionCallback() {
        public Object doInTransaction(TransactionStatus status) {
          try {
            assertTrue("JTA synchronizations active", TransactionSynchronizationManager.isSynchronizationActive());
            assertTrue("Hasn't thread session", !TransactionSynchronizationManager.hasResource(sf));
            HibernateTemplate ht = new HibernateTemplate(sf);
View Full Code Here
395
396
397
398
399
400
401
402
403
404
405
    TransactionTemplate tt = new TransactionTemplate(ptm);
    final List l = new ArrayList();
    l.add("test");
    assertTrue("JTA synchronizations not active", !TransactionSynchronizationManager.isSynchronizationActive());

    Object result = tt.execute(new TransactionCallback() {
      public Object doInTransaction(TransactionStatus status) {
        try {
          assertTrue("JTA synchronizations active", TransactionSynchronizationManager.isSynchronizationActive());
          HibernateTemplate ht = new HibernateTemplate(sf);
          List htl = ht.executeFind(new HibernateCallback() {
View Full Code Here
516
517
518
519
520
521
522
523
524
525
526
      final List l = new ArrayList();
      l.add("test");
      assertTrue("JTA synchronizations not active", !TransactionSynchronizationManager.isSynchronizationActive());
      assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));

      Object result = tt.execute(new TransactionCallback() {
        public Object doInTransaction(TransactionStatus status) {
          try {
            assertTrue("JTA synchronizations active", TransactionSynchronizationManager.isSynchronizationActive());
            assertTrue("Has thread session", TransactionSynchronizationManager.hasResource(sf));
            HibernateTemplate ht = new HibernateTemplate(sf);
View Full Code Here
612
613
614
615
616
617
618
619
620
621
622
      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 {
View Full Code Here
614
615
616
617
618
619
620
621
622
623
624
      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));
View Full Code Here
754
755
756
757
758
759
760
761
762
763
764
    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) {
          org.hibernate.Session outerSession = SessionFactoryUtils.getSession(sf, false);
          assertSame(session1, outerSession);
          SessionHolder holder = (SessionHolder) TransactionSynchronizationManager.getResource(sf);
          assertTrue("Has thread session", holder != null);
View Full Code Here
761
762
763
764
765
766
767
768
769
770
771
          org.hibernate.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) {
                org.hibernate.Session innerSession = SessionFactoryUtils.getSession(sf, false);
                assertSame(session2, innerSession);
                HibernateTemplate ht = new HibernateTemplate(sf);
                ht.setFlushMode(HibernateTemplate.FLUSH_EAGER);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.