public class QueryTerm {
    static ExecutorService es = Executors.newFixedThreadPool(2);
    static CyclicBarrier barrier = new CyclicBarrier(2);
    
    public static void main(String[] args) throws InterruptedException, BrokenBarrierException {
//подготовим долгий селект
        es.execute(blockTable);
        barrier.await();
        Future f = es.submit(queryTask);
        Thread.sleep(1000L);
//...
//где-то в программе произошло некоторое внешнее событие и нам надо отменить:
        f.cancel(true); //не срабатывает!
        
    }
    
    static Runnable blockTable = ()->{
            try(Connection conn = DriverManager.getConnection("jdbc:mysql://mysql-host:3306/test?user=root&password=root");
                Statement stmt = conn.createStatement()){
                stmt.execute("CREATE TABLE IF NOT EXISTS `mytable1` (`a` int(11) NOT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8;");
                stmt.execute("LOCK TABLES mytable1 WRITE");
                stmt.execute("insert ignore into mytable1(a) VALUE("+(int)System.currentTimeMillis()+")");
                barrier.await();
                Thread.sleep(1000000);
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        };

            
    static Runnable queryTask = ()->{
            try(Connection conn = DriverManager.getConnection("jdbc:mysql://mysql-host:3306/test?user=root&password=root");
                Statement stmt = conn.createStatement()){
//на этом селекте мы повисаем на долго, и потом мы захотим его прерывать
                try(ResultSet rs = stmt.executeQuery("select * from mytable1");){
                    
                }
            } catch (Exception ex) {
                System.out.println("Terminated! Ура!!! Получилось!!!");
            }
        };
}

//добавляем в строку коннекта фабрику
Connection conn = DriverManager.getConnection("jdbc:mysql://mysql-host:3306/test?user=root&password=33600&socketFactory=javaapplication3.FineSocketFactory"
....

public class FineSocketFactory implements com.mysql.jdbc.SocketFactory{ 
    Socket s;
    
    @Override
    public Socket afterHandshake() throws SocketException, IOException {
        return s;
    }

    @Override
    public Socket beforeHandshake() throws SocketException, IOException {
        return s;
    }

    @Override
    public Socket connect(String string, int port, Properties prprts) throws SocketException, IOException {
        SocketAddress sa = new InetSocketAddress(string, port);
        SocketChannel sc = SocketChannel.open(sa);
        sc.configureBlocking(true);
        s = sc.socket();
        return s;
    }
}