Package javax.transaction

Examples of javax.transaction.Synchronization.afterCompletion()

1136
1137
1138
1139
1140
1141
1142
1143
1144
1145
1146
    assertTrue("JTA synchronization registered", synchronization != null);
    Thread thread = new Thread() {

      @Override
      public void run() {
        synchronization.afterCompletion(Status.STATUS_ROLLEDBACK);
      }
    };
    thread.start();
    thread.join();
View Full Code Here
174
175
176
177
178
179
180
181
182
183
184
    assertEquals("content", type.nullSafeGet(rs, new String[] {"column"}, null));
    type.nullSafeSet(ps, "content", 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.beforeCompletion();
    synch.afterCompletion(Status.STATUS_COMMITTED);
    verify(lobCreator).setClobAsString(ps, 1, "content");
  }

  @Test
  public void testClobStringTypeWithJtaSynchronizationAndRollback() throws Exception {
View Full Code Here
191
192
193
194
195
196
197
198
199
200
201
    ClobStringType type = new ClobStringType(lobHandler, tm);
    assertEquals("content", type.nullSafeGet(rs, new String[] {"column"}, null));
    type.nullSafeSet(ps, "content", 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.afterCompletion(Status.STATUS_ROLLEDBACK);

    verify(lobCreator).setClobAsString(ps, 1, "content");
  }

  @Test
View Full Code Here
262
263
264
265
266
267
268
269
270
271
272
    assertEquals(content, type.nullSafeGet(rs, new String[] {"column"}, null));
    type.nullSafeSet(ps, content, 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.beforeCompletion();
    synch.afterCompletion(Status.STATUS_COMMITTED);

    verify(lobCreator).setBlobAsBytes(ps, 1, contentBytes);
  }

  @Test
View Full Code Here
283
284
285
286
287
288
289
290
291
292
293
    BlobStringType type = new BlobStringType(lobHandler, tm);
    assertEquals(content, type.nullSafeGet(rs, new String[] {"column"}, null));
    type.nullSafeSet(ps, content, 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.afterCompletion(Status.STATUS_ROLLEDBACK);
    verify(lobCreator).setBlobAsBytes(ps, 1, contentBytes);
  }

  @Test
  public void testBlobByteArrayType() throws Exception {
View Full Code Here
331
332
333
334
335
336
337
338
339
340
341
    assertEquals(content, type.nullSafeGet(rs, new String[] {"column"}, null));
    type.nullSafeSet(ps, content, 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.beforeCompletion();
    synch.afterCompletion(Status.STATUS_COMMITTED);
    verify(lobCreator).setBlobAsBytes(ps, 1, content);
  }

  @Test
  public void testBlobByteArrayTypeWithJtaSynchronizationAndRollback() throws Exception {
View Full Code Here
350
351
352
353
354
355
356
357
358
359
360
    BlobByteArrayType type = new BlobByteArrayType(lobHandler, tm);
    assertEquals(content, type.nullSafeGet(rs, new String[] {"column"}, null));
    type.nullSafeSet(ps, content, 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.afterCompletion(Status.STATUS_ROLLEDBACK);
    verify(lobCreator).setBlobAsBytes(ps, 1, content);
  }

  @Test
  public void testBlobSerializableType() throws Exception {
View Full Code Here
429
430
431
432
433
434
435
436
437
438
439
    assertEquals("content", type.nullSafeGet(rs, new String[] {"column"}, null));
    type.nullSafeSet(ps, "content", 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.beforeCompletion();
    synch.afterCompletion(Status.STATUS_COMMITTED);
    verify(lobCreator).setBlobAsBytes(ps, 1, baos.toByteArray());
  }

  @Test
  public void testBlobSerializableTypeWithJtaSynchronizationAndRollback() throws Exception {
View Full Code Here
458
459
460
461
462
463
464
465
466
467
468
    assertEquals("content", type.nullSafeGet(rs, new String[] {"column"}, null));
    type.nullSafeSet(ps, "content", 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.afterCompletion(Status.STATUS_ROLLEDBACK);
    verify(lobCreator).setBlobAsBytes(ps, 1, baos.toByteArray());
  }

  @Test
  public void testHbm2JavaStyleInitialization() throws Exception {
View Full Code Here
212
213
214
215
216
217
218
219
220
221
222
      if ( synchronization != null ) {
        //first cleanup
        flushSynch.remove( session );
        log.debug( "flush event causing index update out of transaction" );
        synchronization.beforeCompletion();
        synchronization.afterCompletion( Status.STATUS_COMMITTED );
      }
    }
  }

  /**
 
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.