Statement timeout not working on broken connections with active queries

Below is the Java code used to duplicate the error.  You need to sever your network connection once you see the output "set statement_timeout = ...".

 

Thanks, Brendan

 

 

import java.sql.*;

 

public class TestStatementTimeout {

 

    private static final String URL = "jdbc:postgresql://hostname/db_name";
    private static final String DB_USER = "user";
    private static final String DB_PASSWORD = "password";
    private static final int STMT_TIMEOUT = 15 * 1000;
 
    public static void main(String[] args) throws Exception {
        String sql = "SELECT * FROM table_with_many_rows"; 
        try {
     System.out.println("Connecting to " + URL);
          Class.forName("org.postgresql.Driver");
          Connection conn = java.sql.DriverManager.getConnection(URL, DB_USER, DB_PASSWORD);
  
          Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
          stmt.execute("set statement_timeout = " + STMT_TIMEOUT);
          System.out.println("set statement_timeout = " + STMT_TIMEOUT);
          ResultSet rs=stmt.executeQuery(sql);
          System.out.println("executed query");

 

          while (rs.next())
          {
             System.out.print("column 1 = " + rs.getInt(1) + "\015");
          }

 

          System.out.println("Closing Connection");
          rs.close(); stmt.close();
          conn.close();
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }
}