Skip to content

Instantly share code, notes, and snippets.

@mgodave
Last active October 7, 2015 06:28
Show Gist options
  • Save mgodave/3120153 to your computer and use it in GitHub Desktop.
Save mgodave/3120153 to your computer and use it in GitHub Desktop.
/**
* Copyright 2013 David Rusek <dave.rusek@gmail.com>
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
**/
import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.ListeningExecutorService;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.AsyncQueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.concurrent.Future;
public class ListenableAsyncQueryRunner extends AsyncQueryRunner {
public ListenableAsyncQueryRunner(ListeningExecutorService executor) {
super(executor);
}
public ListenableAsyncQueryRunner(ListeningExecutorService executor, QueryRunner qr) {
super(executor, qr);
}
@Override
public ListenableFuture<int[]> batch(Connection conn, String sql, Object[][] params) throws SQLException {
return (ListenableFuture<int[]>) super.batch(conn, sql, params);
}
@Override
public ListenableFuture<int[]> batch(String sql, Object[][] params) throws SQLException {
return (ListenableFuture<int[]>) super.batch(sql, params);
}
@Override
public <T> ListenableFuture<T> query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException {
return (ListenableFuture<T>) super.query(conn, sql, rsh, params);
}
@Override
public <T> ListenableFuture<T> query(Connection conn, String sql, ResultSetHandler<T> rsh) throws SQLException {
return (ListenableFuture<T>) super.query(conn, sql, rsh);
}
@Override
public <T> ListenableFuture<T> query(String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException {
return (ListenableFuture<T>) super.query(sql, rsh, params);
}
@Override
public <T> ListenableFuture<T> query(String sql, ResultSetHandler<T> rsh) throws SQLException {
return (ListenableFuture<T>) super.query(sql, rsh);
}
@Override
public ListenableFuture<Integer> update(Connection conn, String sql) throws SQLException {
return (ListenableFuture<Integer>) super.update(conn, sql);
}
@Override
public ListenableFuture<Integer> update(Connection conn, String sql, Object param) throws SQLException {
return (ListenableFuture<Integer>) super.update(conn, sql, param);
}
@Override
public ListenableFuture<Integer> update(Connection conn, String sql, Object... params) throws SQLException {
return (ListenableFuture<Integer>) super.update(conn, sql, params);
}
@Override
public ListenableFuture<Integer> update(String sql) throws SQLException {
return (ListenableFuture<Integer>) super.update(sql);
}
@Override
public ListenableFuture<Integer> update(String sql, Object param) throws SQLException {
return (ListenableFuture<Integer>) super.update(sql, param);
}
@Override
public ListenableFuture<Integer> update(String sql, Object... params) throws SQLException {
return (ListenableFuture<Integer>) super.update(sql, params);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment