package org.mariadb.jdbc;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import org.junit.Test;

public class ResultSetCloseTest extends BaseTest {

    @Test

    public void testAutomaticCloseResultSet_CONJ90() throws SQLException {

        Statement statement = connection.createStatement();

        statement.execute("drop table if exists resultset_close_test");

        statement.execute("create table resultset_close_test (id int not null primary key auto_increment, data CHAR)");

        statement.execute("insert into resultset_close_test values(null, 'A')");

        statement.close();

        //I don't know if it a lack of feature, but the row fetch size for ResulSet must be set to

        //Integer.MIN_VALUE to be able to force streaming of ResultSets

        statement = connection.createStatement();

        statement.setFetchSize(Integer.MIN_VALUE);  

        ResultSet resultSet1 = statement.executeQuery("SELECT * FROM resultset_close_test");

        resultSet1.next();

        resultSet1.previous();

        /* 

         * This will trigger the error message

         *   There is an open result set on the current connection, which must be closed prior to executing a query

         */

        ResultSet resultSet2 = statement.executeQuery("SELECT * FROM resultset_close_test");

        statement.close();

    }

}