Package javax.sql

Examples of javax.sql.XAConnection.addConnectionEventListener()

346
347
348
349
350
351
352
353
354
355
356
    // when switching between global transactions and local
    // and setting connection state.
    // some of this is already tested in simpleDataSource and checkDataSource
    // but I want to make sure I cover all situations. (djd)
    xac = dsx.getXAConnection();
    xac.addConnectionEventListener(new EventCatcher(6));
    xar = xac.getXAResource();
    xid = new cdsXid(1, (byte) 93, (byte) 103);

    // series 1 - Single connection object
    Connection cs1 = xac.getConnection();
View Full Code Here
498
499
500
501
502
503
504
505
506
507
508
    checkLocks(cs1);
    cs1.commit();

    // attach the XA transaction to another connection and see what happens
    XAConnection xac2 = dsx.getXAConnection();
    xac2.addConnectionEventListener(new EventCatcher(5));
    XAResource xar2 = xac2.getXAResource();

    xar2.start(xid, XAResource.TMJOIN);
    Connection cs2 = xac2.getConnection();
View Full Code Here
531
532
533
534
535
536
537
538
539
540
541
    xac2.close();

    // allow close on already closed XAConnection
    xac2.close();
    xac2.addConnectionEventListener(null);
    xac2.removeConnectionEventListener(null);

    // test methods against a closed XAConnection and its resource
    try {
      xac2.getXAResource();
View Full Code Here
300
301
302
303
304
305
306
307
308
309
310
        // checks currently only implemented for embedded
        if (usingEmbedded())
        {
            SecurityCheck.assertSourceSecurity(xac, "javax.sql.XAConnection");
        }
        xac.addConnectionEventListener(new AssertEventCatcher(3));
        assertConnectionOK(
            expectedValues, "XADataSource", xac.getConnection());

        pc = dsp.getPooledConnection();
        pc.addConnectionEventListener(new AssertEventCatcher(2));
View Full Code Here
311
312
313
314
315
316
317
318
319
320
321
        assertConnectionOK(
            expectedValues, "ConnectionPoolDataSource", pc.getConnection());

        // test "local" XAConnections
        xac = dsx.getXAConnection();
        xac.addConnectionEventListener(new AssertEventCatcher(4));
        assertConnectionOK(
            expectedValues, "XADataSource", xac.getConnection());
        assertConnectionOK(
            expectedValues, "XADataSource", xac.getConnection());
        xac.close();
View Full Code Here
320
321
322
323
324
325
326
327
328
329
330
            expectedValues, "XADataSource", xac.getConnection());
        xac.close();

        // test "global" XAConnections
        xac = dsx.getXAConnection();
        xac.addConnectionEventListener(new AssertEventCatcher(5));
        XAResource xar = xac.getXAResource();
        // checks currently only implemented for embedded
        if (usingEmbedded())
        {
           SecurityCheck.assertSourceSecurity(
View Full Code Here
454
455
456
457
458
459
460
461
462
463
464
        // some of this may be tested elsewhere too.

        XADataSource dsx = J2EEDataSource.getXADataSource();
        JDBCDataSource.setBeanProperty(dsx, "DatabaseName", dbName);
        XAConnection xac = dsx.getXAConnection();
        xac.addConnectionEventListener(new AssertEventCatcher(6));
        XAResource xar = xac.getXAResource();
        Xid xid = new cdsXid(1, (byte) 93, (byte) 103);

        // series 1 - Single connection object
        Connection cs1 = xac.getConnection();
View Full Code Here
765
766
767
768
769
770
771
772
773
774
775
            ResultSet.HOLD_CURSORS_OVER_COMMIT};

        XADataSource dsx = J2EEDataSource.getXADataSource();
        JDBCDataSource.setBeanProperty(dsx, "DatabaseName", dbName);
        XAConnection xac = dsx.getXAConnection();
        xac.addConnectionEventListener(new AssertEventCatcher(6));
        XAResource xar = xac.getXAResource();
        Xid xid = new cdsXid(1, (byte) 103, (byte) 119);

        // now check re-use of *Statement objects across local/global
        // connections.
View Full Code Here
856
857
858
859
860
861
862
863
864
865
866
        assertLocks(new int[] {14,14}, cs1);
        cs1.commit();

        // attach the XA transaction to another connection and see what happens
        XAConnection xac2 = dsx.getXAConnection();
        xac2.addConnectionEventListener(new AssertEventCatcher(5));
        XAResource xar2 = xac2.getXAResource();

        xar2.start(xid, XAResource.TMJOIN);
        Connection cs2 = xac2.getConnection();
View Full Code Here
893
894
895
896
897
898
899
900
901
902
903
        xar2.end(xid, XAResource.TMSUCCESS);
        xac2.close();

        // allow close on already closed XAConnection
        xac2.close();
        xac2.addConnectionEventListener(null);
        xac2.removeConnectionEventListener(null);

        // test methods against a closed XAConnection and its resource
        try {
            xac2.getXAResource();
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.