Author: jolee Date: 2014-04-23 13:49:06 -0400 (Wed, 23 Apr 2014) New Revision: 4635 Modified: branches/7.7.x/test-integration/common/src/test/java/org/teiid/transport/TestODBCSocketTransport.java Log: TEIID-2931: Perform equi-join full outer joins in a streaming manner Modified: branches/7.7.x/test-integration/common/src/test/java/org/teiid/transport/TestODBCSocketTransport.java =================================================================== --- branches/7.7.x/test-integration/common/src/test/java/org/teiid/transport/TestODBCSocketTransport.java 2014-04-23 17:48:59 UTC (rev 4634) +++ branches/7.7.x/test-integration/common/src/test/java/org/teiid/transport/TestODBCSocketTransport.java 2014-04-23 17:49:06 UTC (rev 4635) @@ -318,27 +318,28 @@ ResultSet rs = stmt.executeQuery("begin;declare \"foo\" cursor for select * from pg_proc;fetch 10 in \"foo\"; close \"foo\""); rs.next(); } + +// Introduces too many upstream dependencies, manual test against patched server needed. +// @Test public void testScrollCursor() throws Exception { +// Statement stmt = conn.createStatement(); +// //ExtendedQueryExectutorImpl.simplePortal = "foo"; +// try { +// assertFalse(stmt.execute("declare \"foo\" insensitive scroll cursor for select * from pg_proc;")); +// assertFalse(stmt.execute("move 5 in \"foo\"")); +// stmt.execute("fetch 10 in \"foo\""); +// ResultSet rs = stmt.getResultSet(); +// int rowCount = 0; +// while (rs.next()) { +// rowCount++; +// } +// assertEquals(6, rowCount); +// stmt.execute("close \"foo\""); +// } finally { +// // ExtendedQueryExectutorImpl.simplePortal = null; +// } +// +// } - @Test public void testScrollCursor() throws Exception { - Statement stmt = conn.createStatement(); - ExtendedQueryExectutorImpl.simplePortal = "foo"; - try { - assertFalse(stmt.execute("declare \"foo\" insensitive scroll cursor for select * from pg_proc;")); - assertFalse(stmt.execute("move 5 in \"foo\"")); - stmt.execute("fetch 10 in \"foo\""); - ResultSet rs = stmt.getResultSet(); - int rowCount = 0; - while (rs.next()) { - rowCount++; - } - assertEquals(6, rowCount); - stmt.execute("close \"foo\""); - } finally { - ExtendedQueryExectutorImpl.simplePortal = null; - } - - } - @Test public void testPgProcedure() throws Exception { Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery("select has_function_privilege(100, 'foo')");