Removed retrieval-possibility over pipelined function

pesse · pesse · commit 2f9f4dcc7535 · 2018-03-23T10:32:11.000+01:00
We're always using cursor now because setFetchSize is not working when
using the object-pipelined-function. Instead the internal PL/SQL
fetchSize is used, which is between 50 and 100 - far from immediate as
we want it.
Also easier to maintain.
diff --git a/src/main/java/org/utplsql/api/outputBuffer/AbstractOutputBuffer.java b/src/main/java/org/utplsql/api/outputBuffer/AbstractOutputBuffer.java
@@ -3,7 +3,10 @@
 import org.utplsql.api.reporter.Reporter;
 
 import java.io.PrintStream;
-import java.sql.*;
+import java.sql.CallableStatement;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.function.Consumer;
@@ -62,8 +65,6 @@ public void printAvailable(Connection conn, List<PrintStream> printStreams) thro
         });
     }
 
-    protected abstract PreparedStatement getLinesStatement( Connection conn ) throws SQLException;
-
     protected abstract CallableStatement getLinesCursorStatement( Connection conn ) throws SQLException;
 
     /**
@@ -74,11 +75,13 @@ public void printAvailable(Connection conn, List<PrintStream> printStreams) thro
      */
     public void fetchAvailable(Connection conn, Consumer<String> onLineFetched) throws SQLException {
 
-        try (PreparedStatement pstmt = getLinesStatement(conn)) {
+        try (CallableStatement cstmt = getLinesCursorStatement(conn)) {
+            cstmt.execute();
+            cstmt.setFetchSize(1);
 
-            try (ResultSet resultSet = pstmt.executeQuery() ) {
+            try ( ResultSet resultSet = (ResultSet) cstmt.getObject(1)) {
                 while (resultSet.next())
-                    onLineFetched.accept(resultSet.getString(1));
+                    onLineFetched.accept(resultSet.getString("text"));
             }
         }
     }
diff --git a/src/main/java/org/utplsql/api/outputBuffer/CompatibilityOutputBufferPre310.java b/src/main/java/org/utplsql/api/outputBuffer/CompatibilityOutputBufferPre310.java
@@ -5,7 +5,6 @@
 
 import java.sql.CallableStatement;
 import java.sql.Connection;
-import java.sql.PreparedStatement;
 import java.sql.SQLException;
 
 /** Compatibility Output-Buffer for 3.0.0 - 3.0.4
@@ -18,13 +17,6 @@ class CompatibilityOutputBufferPre310 extends AbstractOutputBuffer {
         super(reporter);
     }
 
-    @Override
-    protected PreparedStatement getLinesStatement(Connection conn) throws SQLException {
-        PreparedStatement pstmt = conn.prepareStatement("SELECT * FROM table(ut_output_buffer.get_lines(?))");
-        pstmt.setString(1, getReporter().getId());
-        return pstmt;
-    }
-
     @Override
     protected CallableStatement getLinesCursorStatement(Connection conn) throws SQLException {
         CallableStatement cstmt = conn.prepareCall("BEGIN ? := ut_output_buffer.get_lines_cursor(?); END;");
diff --git a/src/main/java/org/utplsql/api/outputBuffer/DefaultOutputBuffer.java b/src/main/java/org/utplsql/api/outputBuffer/DefaultOutputBuffer.java
@@ -2,16 +2,12 @@
 
 import oracle.jdbc.OracleCallableStatement;
 import oracle.jdbc.OracleConnection;
-import oracle.jdbc.OraclePreparedStatement;
-import org.utplsql.api.reporter.Reporter;
 import oracle.jdbc.OracleTypes;
+import org.utplsql.api.reporter.Reporter;
 
-import javax.xml.transform.Result;
-import java.io.PrintStream;
-import java.sql.*;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.function.Consumer;
+import java.sql.CallableStatement;
+import java.sql.Connection;
+import java.sql.SQLException;
 
 /**
  * Fetches the lines produced by a reporter.
@@ -29,14 +25,6 @@ class DefaultOutputBuffer extends AbstractOutputBuffer {
         super(reporter);
     }
 
-    @Override
-    protected PreparedStatement getLinesStatement(Connection conn) throws SQLException {
-        OracleConnection oraConn = conn.unwrap(OracleConnection.class);
-        OraclePreparedStatement pstmt = (OraclePreparedStatement)oraConn.prepareStatement("select * from table(?.get_lines())");
-        pstmt.setORAData(1, getReporter());
-        return pstmt;
-    }
-
     @Override
     protected CallableStatement getLinesCursorStatement(Connection conn) throws SQLException {
         OracleConnection oraConn = conn.unwrap(OracleConnection.class);
