Package org.springframework.jca.cci.core

Examples of org.springframework.jca.cci.core.CciTemplate.execute()

422
423
424
425
426
427
428
429
430
431
432
    given(generator.createRecord(recordFactory)).willReturn(record);
    given(interaction.execute(interactionSpec, record)).willReturn(resultset);
    given(extractor.extractData(resultset)).willReturn(new Object());

    CciTemplate ct = new CciTemplate(connectionFactory);
    ct.execute(interactionSpec, generator, extractor);

    verify(extractor).extractData(resultset);
    verify(resultset).close();
    verify(interaction).close();
    verify(connection).close();
View Full Code Here
442
443
444
445
446
447
448
449
450
451
452
    given(connectionFactory.getConnection()).willReturn(connection);
    given(connectionCallback.doInConnection(connection, connectionFactory)).willReturn(new Object());

    CciTemplate ct = new CciTemplate(connectionFactory);
    ct.execute(connectionCallback);

    verify(connectionCallback).doInConnection(connection, connectionFactory);
    verify(connection).close();
  }
View Full Code Here
462
463
464
465
466
467
468
469
470
471
472
    given(connectionFactory.getConnection()).willReturn(connection);
    given(connection.createInteraction()).willReturn(interaction);
    given(interactionCallback.doInInteraction(interaction,connectionFactory)).willReturn(new Object());

    CciTemplate ct = new CciTemplate(connectionFactory);
    ct.execute(interactionCallback);

    verify(interactionCallback).doInInteraction(interaction,connectionFactory);
    verify(interaction).close();
    verify(connection).close();
  }
View Full Code Here
487
488
489
490
491
492
493
494
495
496
497
    given(connection.createInteraction()).willReturn(interaction);
    given(interaction.execute(interactionSpec, inputOutputRecord, inputOutputRecord)).willReturn(true);

    CciTemplate ct = new CciTemplate(connectionFactory);
    ct.setOutputRecordCreator(creator);
    ct.execute(interactionSpec, inputOutputRecord, inputOutputRecord);

    verify(interaction).execute(interactionSpec, inputOutputRecord, inputOutputRecord);
    verify(interaction).close();
    verify(connection).close();
  }
View Full Code Here
507
508
509
510
511
512
513
514
515
516
517
    given(connectionFactory.getConnection()).willReturn(connection);
    given(connection.createInteraction()).willReturn(interaction);
    given(interaction.execute(interactionSpec, inputOutputRecord, inputOutputRecord)).willReturn(true);

    CciTemplate ct = new CciTemplate(connectionFactory);
    ct.execute(interactionSpec, inputOutputRecord, inputOutputRecord);

    verify(interaction).execute(interactionSpec, inputOutputRecord, inputOutputRecord);
    verify(interaction).close();
    verify(connection).close();
  }
View Full Code Here
527
528
529
530
531
532
533
534
535
536
537
    given(connectionFactory.getConnection()).willReturn(connection);
    given(connection.createInteraction()).willReturn(interaction);
    given(interaction.execute(interactionSpec, inputOutputRecord)).willReturn(null);

    CciTemplate ct = new CciTemplate(connectionFactory);
    Record tmpOutputRecord = ct.execute(interactionSpec,
        inputOutputRecord);
    assertNull(tmpOutputRecord);

    verify(interaction).execute(interactionSpec, inputOutputRecord);
    verify(interaction).close();
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
    tt.execute(new TransactionCallbackWithoutResult() {
      @Override
      protected void doInTransactionWithoutResult(TransactionStatus status) {
        assertTrue("Has thread connection", TransactionSynchronizationManager.hasResource(connectionFactory));
        CciTemplate ct = new CciTemplate(connectionFactory);
        ct.execute(interactionSpec, record, record);
      }
    });

    verify(localTransaction).begin();
    verify(interaction).close();
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
      tt.execute(new TransactionCallback<Void>() {
        @Override
        public Void doInTransaction(TransactionStatus status) {
          assertTrue("Has thread connection", TransactionSynchronizationManager.hasResource(connectionFactory));
          CciTemplate ct = new CciTemplate(connectionFactory);
          ct.execute(interactionSpec, record, record);
          throw new DataRetrievalFailureException("error");
        }
      });
    }
    catch (Exception ex) {
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.