Package org.springframework.transaction.support

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

637
638
639
640
641
642
643
644
645
646
647
        });

        assertTrue(TransactionSynchronizationManager.hasResource(factory));
        TransactionTemplate tt2 = new TransactionTemplate(transactionManager);
        tt2.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
        return tt2.execute(new TransactionCallback() {
          public Object doInTransaction(TransactionStatus status) {
            return template.execute(new JpaCallback() {
              public Object doInJpa(EntityManager em2) {
                em2.flush();
                return l;
View Full Code Here
470
471
472
473
474
475
476
477
478
479
480
  public void testReadExclusive() {
   
    TransactionTemplate transactionTemplate =
      new TransactionTemplate(transactionManager);
   
    transactionTemplate.execute(
        new TransactionCallback() {
          public Object doInTransaction(TransactionStatus ts) {
            Employee employee =  employeeDao.readExclusive(testEmployees.get(0).getId());
            AssertJUnit.assertNotNull("Employee for id=1 not read.", employee);
            return null;
View Full Code Here
524
525
526
527
528
529
530
531
532
533
534
   
  @Test (groups="createsObjectInDB")
    public void testStoreMultiple() {
        employeeDao.flushAndClear();
      TransactionTemplate xTemplate = new TransactionTemplate(transactionManager);
      xTemplate.execute(new TransactionCallback() {
   
      public Object doInTransaction(TransactionStatus arg0) {
            List<Employee> employees =Arrays.asList(
                new Employee[] {
                    new Employee("StoreMultipleOne", "Hightower"),
View Full Code Here
12
13
14
15
16
17
18
19
20
21
22
    return new String[] { "org/jencks/samples/outbound/jencks-genericjmsra.xml" };
  }

  protected void checkIfMessageExist(final String sentMessage) {
    TransactionTemplate tt = new TransactionTemplate(getTransactionManager());
    tt.execute(new TransactionCallback() {
      public Object doInTransaction(TransactionStatus status) {
        JmsTemplate template=new JmsTemplate(getConnectionFactory());
        template.setReceiveTimeout(10);
        String receivedMessage=(String)template.receiveAndConvert(getQueue());
        assertEquals(sentMessage,receivedMessage);
View Full Code Here
25
26
27
28
29
30
31
32
33
34
35
    });
  }

  protected void checkIfMessageNotExist() {
    TransactionTemplate tt = new TransactionTemplate(getTransactionManager());
    tt.execute(new TransactionCallback() {
      public Object doInTransaction(TransactionStatus status) {
        JmsTemplate template=new JmsTemplate(getConnectionFactory());
        template.setReceiveTimeout(10);
        String receivedMessage=null;
        receivedMessage=(String)template.receiveAndConvert(getQueue());
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
    // set behavior
    txTemplate.setPropagationBehavior(DefaultTransactionDefinition.PROPAGATION_REQUIRES_NEW);
    final String noCommentSql[] = removeCommentsAndSemicolons(connectionModel.getSchema(), sql);
    try {
      // run the code in a transaction
      txTemplate.execute(new TransactionCallbackWithoutResult() {
        public void doInTransactionWithoutResult(TransactionStatus status) {
          jt.batchUpdate(noCommentSql);
        }
      });
    } catch (DataAccessException e) {
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
        TransactionTemplate transactionTemplate = new TransactionTemplate();
        transactionTemplate.setTransactionManager(new JpaTransactionManager(jpaTemplate.getEntityManagerFactory()));
        transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);

        transactionTemplate.execute(new TransactionCallback() {
            public Object doInTransaction(TransactionStatus arg0) {
                List list = jpaTemplate.find(SELECT_ALL_STRING);
                for (Object item : list) {
                    jpaTemplate.remove(item);
                }
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
        TransactionTemplate transactionTemplate = new TransactionTemplate();
        transactionTemplate.setTransactionManager(new JpaTransactionManager(jpaTemplate.getEntityManagerFactory()));
        transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);

        transactionTemplate.execute(new TransactionCallback() {
            public Object doInTransaction(TransactionStatus arg0) {
                List list = jpaTemplate.find(SELECT_ALL_STRING);
                for (Object item : list) {
                    jpaTemplate.remove(item);
                }
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
        TransactionTemplate transactionTemplate = new TransactionTemplate();
        transactionTemplate.setTransactionManager(new JpaTransactionManager(jpaTemplate.getEntityManagerFactory()));
        transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);

        transactionTemplate.execute(new TransactionCallback() {
            public Object doInTransaction(TransactionStatus arg0) {
                List list = jpaTemplate.find(SELECT_ALL_STRING);
                for (Object item : list) {
                    jpaTemplate.remove(item);
                }
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
        TransactionTemplate transactionTemplate = new TransactionTemplate();
        transactionTemplate.setTransactionManager(new JpaTransactionManager(jpaTemplate.getEntityManagerFactory()));
        transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);

        transactionTemplate.execute(new TransactionCallback() {
            public Object doInTransaction(TransactionStatus arg0) {
                List list = jpaTemplate.find(SELECT_ALL_STRING);
                for (Object item : list) {
                    jpaTemplate.remove(item);
                }
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.