dbms_output

Author: clagomess

README.md

@@ -17,6 +17,7 @@ CREATE OR REPLACE PROCEDURE HELLO_WORLD (
 ) IS
 BEGIN
     HTP.PRINT('Hello World');
+    DBMS_OUTPUT.PUT_LINE('Test DBMS_OUTPUT');
 END;
 ```
 

src/main/java/com/github/clagomess/modplsql/jdbc/Database.java

@@ -10,26 +10,25 @@
 public class Database {
     public static ConfigDto configDto;
     private static Connection conn;
+    private static Statement stmt;
 
     public static void init(ConfigDto dto) throws SQLException {
         configDto = dto;
         conn = DriverManager.getConnection(dto.getDbUrl(), dto.getDbUser(), dto.getDbPass());
+        stmt = conn.createStatement();
 
-        // inicia OWA
-        owaInit();
-    }
-
-    private static void owaInit() throws SQLException {
-        Statement stmt = conn.createStatement();
-        stmt.executeQuery("declare\n" +
+        // init OWA
+        stmt.executeUpdate("declare\n" +
                 "    nm  owa.vc_arr;\n" +
                 "    vl  owa.vc_arr;\n" +
                 "begin\n" +
                 "    nm(1) := 'SERVER_PORT';\n" +
-                "    vl(1) := '80';\n" +
+                "    vl(1) := '8000';\n" +
                 "    owa.init_cgi_env( 1, nm, vl );\n" +
                 "end;");
-        stmt.close();
+
+        // init DBMS
+        stmt.executeUpdate("begin dbms_output.enable(); end;");
     }
 
     public static String runPl(String plName, Map<String, String> param) throws SQLException {
@@ -64,19 +63,26 @@ public static String runPl(String plName, Map<String, String> param) throws SQLE
 
         log.info("QUERY:\n{}", sql.toString());
 
-        Statement stmt = conn.createStatement();
-        stmt.executeQuery(sql.toString());
+        stmt.executeUpdate(sql.toString());
 
         log.info("GET RESULT");
         return getResult();
     }
 
     private static String getResult() throws SQLException {
         StringBuilder result = new StringBuilder();
-        String buff;
 
-        while ((buff = getChunkResult()) != null){
-            result.append(buff);
+        try {
+            // get buffer
+            String buff;
+
+            while ((buff = getChunkResult()) != null) {
+                result.append(buff);
+            }
+        }catch (SQLException e){
+            log.error(e.getMessage());
+        }finally {
+            printDbmsOutput();
         }
 
         return result.toString();
@@ -104,9 +110,30 @@ private static String getChunkResult() throws SQLException {
         cs.setInt(1, 127);
         cs.registerOutParameter(2, Types.VARCHAR);
         cs.registerOutParameter(3, Types.BIGINT);
+        cs.execute();
+
+        String result = cs.getString(2);
+
+        cs.close();
 
+        return result;
+    }
+
+    private static void printDbmsOutput() throws SQLException {
+        String query = "declare\n" +
+                "  num integer := 1000;\n" +
+                "begin\n" +
+                "  dbms_output.get_lines(?, num);\n" +
+                "end;";
+        CallableStatement cs = conn.prepareCall(query);
+        cs.registerOutParameter(1, Types.ARRAY, "DBMSOUTPUT_LINESARRAY");
         cs.execute();
 
-        return cs.getString(2);
+        String[] listLog = (String[]) cs.getArray(1).getArray();
+        cs.close();
+
+        for(String item : listLog){
+            log.info("DBMSOUTPUT: {}", item);
+        }
     }
 }

src/main/resources/log4j.xml

@@ -6,7 +6,7 @@
     <appender name="console" class="org.apache.log4j.ConsoleAppender">
         <param name="Target" value="System.out" />
         <layout class="org.apache.log4j.PatternLayout">
-            <param name="ConversionPattern" value="%d{yyyy-MM-dd HH:mm:ss} %-5p %c:%L - %m%n" />
+            <param name="ConversionPattern" value="%-5p %d{yyyy-MM-dd HH:mm:ss} - %m%n" />
         </layout>
     </appender>