ResultSet.next() and previous() incremented or decremented the

internal current_row variable regardless of wether they succeeded or
not.  This generated some ArrayIndexOutOfBoundsExceptions when the
errorneous adjustment current_row led to out of range values.

Per report from Fischer Krisztian.

diff --git a/src/interfaces/jdbc/org/postgresql/jdbc1/AbstractJdbc1ResultSet.java b/src/interfaces/jdbc/org/postgresql/jdbc1/AbstractJdbc1ResultSet.java
index b75f0106a00deae41c86093b6bce327ff932430c..5dbb80a6921f5eee196f0567a292c03e566e400a 100644 (file)
--- a/src/interfaces/jdbc/org/postgresql/jdbc1/AbstractJdbc1ResultSet.java
+++ b/src/interfaces/jdbc/org/postgresql/jdbc1/AbstractJdbc1ResultSet.java
@@ -9,7 +9,7 @@
  * Copyright (c) 2003, PostgreSQL Global Development Group
  *
  * IDENTIFICATION
- *       $Header: /cvsroot/pgsql/src/interfaces/jdbc/org/postgresql/jdbc1/Attic/AbstractJdbc1ResultSet.java,v 1.22.2.1 2003/12/12 17:59:08 davec Exp $
+ *       $Header: /cvsroot/pgsql/src/interfaces/jdbc/org/postgresql/jdbc1/Attic/AbstractJdbc1ResultSet.java,v 1.22.2.2 2004/02/03 05:25:36 jurka Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -137,11 +137,13 @@ public abstract class AbstractJdbc1ResultSet implements BaseResultSet
                if (rows == null)
                        throw new PSQLException("postgresql.con.closed", PSQLState.CONNECTION_DOES_NOT_EXIST);
 
-               if (++current_row >= rows.size())
+               if (current_row+1 >= rows.size())
                {
                        String cursorName = statement.getFetchingCursorName();
-                       if (cursorName == null || lastFetchSize == 0 || rows.size() < lastFetchSize)
+                       if (cursorName == null || lastFetchSize == 0 || rows.size() < lastFetchSize) {
+                               current_row = rows.size();
                                return false;  // Not doing a cursor-based fetch or the last fetch was the end of the query
+                       }
  
                        // Use the ref to the statement to get
                        // the details we need to do another cursor
@@ -167,6 +169,8 @@ public abstract class AbstractJdbc1ResultSet implements BaseResultSet
 
                        // Otherwise reset the counter and let it go on...
                        current_row = 0;
+               } else {
+                       current_row++;
                }
 
                this_row = (byte [][])rows.elementAt(current_row);

diff --git a/src/interfaces/jdbc/org/postgresql/jdbc2/AbstractJdbc2ResultSet.java b/src/interfaces/jdbc/org/postgresql/jdbc2/AbstractJdbc2ResultSet.java
index 10c6ad136ab979a2279f445fde109ada8a045c67..a10578cfe92f7384d5a8adbb07b166ede9657c53 100644 (file)
--- a/src/interfaces/jdbc/org/postgresql/jdbc2/AbstractJdbc2ResultSet.java
+++ b/src/interfaces/jdbc/org/postgresql/jdbc2/AbstractJdbc2ResultSet.java
@@ -9,7 +9,7 @@
  * Copyright (c) 2003, PostgreSQL Global Development Group
  *
  * IDENTIFICATION
- *       $Header: /cvsroot/pgsql/src/interfaces/jdbc/org/postgresql/jdbc2/Attic/AbstractJdbc2ResultSet.java,v 1.25.2.2 2003/12/18 03:35:55 davec Exp $
+ *       $Header: /cvsroot/pgsql/src/interfaces/jdbc/org/postgresql/jdbc2/Attic/AbstractJdbc2ResultSet.java,v 1.25.2.3 2004/02/03 05:25:37 jurka Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -490,8 +490,12 @@ public abstract class AbstractJdbc2ResultSet extends org.postgresql.jdbc1.Abstra
 
        public boolean previous() throws SQLException
        {
-               if (--current_row < 0)
+               if (current_row-1 < 0) {
+                       current_row = -1;
                        return false;
+               } else {
+                       current_row--;
+               }
                this_row = (byte[][]) rows.elementAt(current_row);
                rowBuffer = new byte[this_row.length][];
                System.arraycopy(this_row, 0, rowBuffer, 0, this_row.length);

diff --git a/src/interfaces/jdbc/org/postgresql/test/jdbc2/ResultSetTest.java b/src/interfaces/jdbc/org/postgresql/test/jdbc2/ResultSetTest.java
index c09ac49a9825bb42011bf558b28d08a7e63eaf4c..aec118504674158dd0fb3bd4985fde9f67d09065 100644 (file)
--- a/src/interfaces/jdbc/org/postgresql/test/jdbc2/ResultSetTest.java
+++ b/src/interfaces/jdbc/org/postgresql/test/jdbc2/ResultSetTest.java
@@ -4,6 +4,7 @@ import org.postgresql.test.TestUtil;
 import java.sql.Connection;
 import java.sql.ResultSet;
 import java.sql.Statement;
+import java.sql.SQLException;
 
 import junit.framework.TestCase;
 
@@ -285,5 +286,48 @@ public class ResultSetTest extends TestCase
                                fail("Exception expected.");
                }
        }
-       
+
+       public void testZeroRowResultPositioning() throws SQLException
+       {
+               Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
+               ResultSet rs = stmt.executeQuery("SELECT * FROM pg_database WHERE datname='nonexistantdatabase'");
+               assertEquals(rs.previous(),false);
+               assertEquals(rs.previous(),false);
+               assertEquals(rs.next(),false);
+               assertEquals(rs.next(),false);
+               assertEquals(rs.next(),false);
+               assertEquals(rs.next(),false);
+               assertEquals(rs.next(),false);
+               assertEquals(rs.previous(),false);
+               assertEquals(rs.first(),false);
+               assertEquals(rs.last(),false);
+               assertEquals(rs.getRow(),0);
+               assertEquals(rs.absolute(1),false);
+               assertEquals(rs.relative(1),false);
+               assertEquals(rs.isBeforeFirst(),false);
+               assertEquals(rs.isAfterLast(),false);
+               assertEquals(rs.isFirst(),false);
+               assertEquals(rs.isLast(),false);
+               rs.close();
+               stmt.close();
+       }
+
+       public void testRowResultPositioning() throws SQLException
+       {
+               Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
+               // Create a one row result set.
+               ResultSet rs = stmt.executeQuery("SELECT * FROM pg_database WHERE datname='template1'");
+               assertTrue(rs.isBeforeFirst());
+               assertTrue(rs.next());
+               assertTrue(rs.isFirst());
+               assertTrue(rs.isLast());
+               assertTrue(!rs.next());
+               assertTrue(rs.isAfterLast());
+               assertTrue(rs.previous());
+               assertTrue(rs.absolute(1));
+               rs.close();
+               stmt.close();
+       }
+
 }
+