[teiid-commits] teiid SVN: r4635 - branches/7.7.x/test-integration/common/src/test/java/org/teiid/transport.

[teiid-commits at lists.jboss.org]

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')");