Examples of javax.sql.PooledConnection.addConnectionEventListener()

javax.sql.PooledConnection.addConnectionEventListener()
Registers the supplied ConnectionEventListener with this PooledConnection. Once registered, the ConnectionEventListener will receive ConnectionEvent events when they occur in the PooledConnection. @param theListener an object which implements the ConnectionEventListener interface.

        throws SQLException {
        PooledConnection connection =
            (userName != null)
                ? poolDataSource.getPooledConnection(userName, password)
                : poolDataSource.getPooledConnection();
        connection.addConnectionEventListener(this);
        return connection;
    }


    /** Closes all existing connections, removes them from the pool. */
    public void dispose() throws SQLException {

View Full Code Here

        
        ConnectionPoolDataSource ds = J2EEDataSource.getConnectionPoolDataSource();


        PooledConnection pc = ds.getPooledConnection();
        //Add a connection event listener to ConnectionPoolDataSource
        pc.addConnectionEventListener(aes12);
        Connection conn = pc.getConnection();
        
        dropTable(conn, "TAB1");


        //No event should have been generated at this point

View Full Code Here

        assertFalse(aes3.didConnectionErrorEventHappen());
        aes3.resetState();
                       
        pc = dsp.getPooledConnection();
        AssertEventCatcher aes2 = new AssertEventCatcher(2);
        pc.addConnectionEventListener(aes2);
        assertConnectionOK(
            expectedValues, "ConnectionPoolDataSource", pc.getConnection());
        //Check if got connection closed event but not connection error event
        assertTrue(aes2.didConnectionClosedEventHappen());
        assertFalse(aes2.didConnectionErrorEventHappen());

View Full Code Here

    this.closeEventCount = 0;


    try {
      pc = this.cpds.getPooledConnection();


      pc.addConnectionEventListener(conListener);


      Connection conn = pc.getConnection();


      Connection connFromStatement = conn.createStatement()
          .getConnection();

View Full Code Here

    final int NB_TESTS = 5;


    try {
      pc = this.cpds.getPooledConnection();


      pc.addConnectionEventListener(conListener);


      for (int i = 0; i < NB_TESTS; i++) {
        Connection conn = pc.getConnection();


        try {

View Full Code Here

    final ConnectionEventListener conListener = new ConnectionListener();
    PooledConnection pc = null;


    pc = this.cpds.getPooledConnection();


    pc.addConnectionEventListener(conListener);


    createTable("testPacketTooLarge", "(field1 LONGBLOB)");


    Connection connFromPool = pc.getConnection();
    PreparedStatement pstmtFromPool = ((ConnectionWrapper) connFromPool)

View Full Code Here

    final int NB_TESTS = 5;


    try {
      pc = this.cpds.getPooledConnection();


      pc.addConnectionEventListener(conListener);


      for (int i = 0; i < NB_TESTS; i++) {
        Connection pConn = pc.getConnection();


        System.out.println("Before connection.close().");

View Full Code Here

        } else {
            pc = _cpds.getPooledConnection(username, password);
        }
        // should we add this object as a listener or the pool.
        // consider the validateObject method in decision
        pc.addConnectionEventListener(this);
        obj = new PooledConnectionAndInfo(pc, username, password);
        pcMap.put(pc, obj);
 
        return obj;
    }

View Full Code Here

            } else {
                pc = _cpds.getPooledConnection(_username, _password);
            }
            // should we add this object as a listener or the pool.
            // consider the validateObject method in decision
            pc.addConnectionEventListener(this);
            obj = new PooledConnectionAndInfo(pc, _username, _password);
            pcMap.put(pc, obj);
        } catch (SQLException e) {
            throw new RuntimeException(e.getMessage());
        }

View Full Code Here

        throws SQLException {
        PooledConnection connection =
            (userName != null)
                ? poolDataSource.getPooledConnection(userName, password)
                : poolDataSource.getPooledConnection();
        connection.addConnectionEventListener(this);
        return connection;
    }


    /** Closes all existing connections, removes them from the pool. */
    public void dispose() throws SQLException {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.