Attachment 26553 Details for Bug 50660 – proposed interceptor

proposed interceptor

ValidationQueryInterceptor.java (text/x-java), 1.56 KB, created by Daniel Mikusa on 2011-01-26 12:48:21 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Daniel Mikusa

Created: 2011-01-26 12:48:21 UTC

Size: 1.56 KB

patch

obsolete

>package org.apache.tomcat.jdbc.pool.interceptor;
>
>import java.sql.Connection;
>import java.sql.Statement;
>
>import org.apache.juli.logging.Log;
>import org.apache.juli.logging.LogFactory;
>import org.apache.tomcat.jdbc.pool.ConnectionPool;
>import org.apache.tomcat.jdbc.pool.JdbcInterceptor;
>import org.apache.tomcat.jdbc.pool.PooledConnection;
>
>public class ValidationQueryInterceptor extends JdbcInterceptor {
>	//logger
>    private static final Log log = LogFactory.getLog(ValidationQueryInterceptor.class);
>    
>	@Override
>	public void reset(ConnectionPool parent, PooledConnection con) {
>		// NOOP
>	}
>	
>	@Override
>	public void poolStarted(ConnectionPool pool) {
>        String query = pool.getPoolProperties().getValidationQuery();
>        if (query != null) {
>	        Connection connection = null;
>	        Statement stmt = null;
>	        try {
>	        	connection = pool.getConnection();
>	            stmt = connection.createStatement();
>	            stmt.execute(query);
>	            stmt.close();
>	            connection.close();
>	            if (log.isDebugEnabled())
>	    			log.debug("validationQuery is OK");
>	        } catch (Exception ex) {
>	            if (log.isErrorEnabled())
>	                log.error("validationQuery has failed: ", ex);
>	        	if (stmt!=null)
>	        		try { stmt.close();} catch (Exception ignore) {/*NOOP*/}
>	    		if (connection!=null)
>	        		try { connection.close();} catch (Exception ignore) {/*NOOP*/}
>	        }
>        } else {
>        	if (log.isDebugEnabled())
>        		log.debug("validationQuery not specified, test skipped");
>        }
>    }
>}

Actions: View

Attachments on bug 50660: 26553