Examples of javax.sql.StatementEvent

javax.sql.StatementEvent
A StatementEvent is sent to all StatementEventListeners which were registered with a PooledConnection. This occurs when the driver determines that a PreparedStatement that is associated with the PooledConnection has been closed or the driver determines is invalid.
@since 1.6

     * @param statement PreparedStatement
     * @param sqle      SQLException
     */
    public void onStatementErrorOccurred(PreparedStatement statement,SQLException sqle) {
        if (!statementEventListeners.isEmpty()){
            StatementEvent event = new StatementEvent(this,statement,sqle);
            for (StatementEventListener l : statementEventListeners) {
                l.statementErrorOccurred(event);
            }
        }
    }

View Full Code Here

    fireConnectionFatalError(e);
  }


  protected StatementEvent createStatementEvent(PreparedStatement ps, SQLException sqle) {
    if (sqle == null)
      return new StatementEvent(this, ps);
    else
      return new StatementEvent(this, ps, sqle);
  }

View Full Code Here


  /**
   * Used to fire a statement closed event to all listeners.
   */
  void fireStatementClosed(PreparedStatement ps) {
    StatementEvent evt = null;
    // Copy the listener list so the listener can remove itself during this method call
    StatementEventListener[] local = (StatementEventListener[]) statementListeners.toArray(new StatementEventListener[statementListeners.size()]);
    for (int i = 0; i < local.length; i++) {
      StatementEventListener listener = local[i];
      if (evt == null) {

View Full Code Here


  /**
   * Used to fire a statement error event to all listeners.
   */
  void fireStatementError(PreparedStatement ps, SQLException se) {
    StatementEvent evt = null;
    // Copy the listener list so the listener can remove itself during this method call
    StatementEventListener[] local = (StatementEventListener[]) statementListeners.toArray(new StatementEventListener[statementListeners.size()]);
    for (int i = 0; i < local.length; i++) {
      StatementEventListener listener = local[i];
      if (evt == null) {

View Full Code Here

     * @param statement The PreparedStatement that was closed
     *
     */
    public void onStatementClose(PreparedStatement statement) {
        if (!statementEventListeners.isEmpty()) {
            StatementEvent event = new StatementEvent(this,statement);
            for (StatementEventListener l : statementEventListeners) {
                l.statementClosed(event);
            }
        }
    }

View Full Code Here

     *
     */
    public void onStatementErrorOccurred(PreparedStatement statement,
                                         SQLException sqle) {
        if (!statementEventListeners.isEmpty()) {
            StatementEvent event = new StatementEvent(this,statement,sqle);
            for (StatementEventListener l : statementEventListeners) {
                l.statementErrorOccurred(event);
            }
        }
    }

View Full Code Here

     * corresponding events occurs
     * @param statement The PreparedStatement that was closed
     */
    public void onStatementClose(PreparedStatement statement) {
        if (!statementEventListeners.isEmpty()) {
            StatementEvent event = new StatementEvent(this,statement);
            for (StatementEventListener l : statementEventListeners) {
                l.statementClosed(event);
            }
        }
    }

View Full Code Here

     *
     */
    public void onStatementErrorOccurred(PreparedStatement statement,
                    SQLException sqle) {
        if (!statementEventListeners.isEmpty()) {
            StatementEvent event = new StatementEvent(this,statement,sqle);
            for (StatementEventListener l : statementEventListeners) {
                l.statementErrorOccurred(event);
            }
        }
    }

View Full Code Here

    /**
     * @tests {@link javax.sql.StatementEvent#StatementEvent(PooledConnection, java.sql.PreparedStatement)}
     */
    public void testStatementEventPooledConnectionPreparedStatementSQLException() {
        SQLException e = new SQLException();
        StatementEvent st2 = new StatementEvent(pc, null, e);
        assertNotNull(st2);


        assertEquals(e, st2.getSQLException());
    }

View Full Code Here

     */
    public void testStatementEventPooledConnectionPreparedStatement() {
        assertNotNull(st);


        try {
            new StatementEvent(null, null);
            fail("should throw IllegalArgumentException");
        } catch (IllegalArgumentException e) {
            // expected
        }
    }

View Full Code Here

0 1 2 3 4

TOP

Related Classes of javax.sql.StatementEvent

com.impossibl.postgres.jdbc.PGPooledConnection

com.mysql.jdbc.jdbc2.optional.JDBC4PreparedStatementWrapper

net.sf.hajdbc.sql.pool.AbstractPooledConnectionProxyFactory$StatementEventListenerFilter

org.apache.derby.client.ClientPooledConnection

org.apache.derby.client.ClientPooledConnection40

org.apache.derby.client.ClientXAConnection40

org.apache.derby.jdbc.EmbedPooledConnection

org.apache.derby.jdbc.EmbedPooledConnection40

org.apache.derby.jdbc.EmbedXAConnection40

org.apache.hadoop.hbase.jdbc.impl.ConnectionImpl

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.