使用 JDBC 从 dbms_output.get_lines 获取输出

问题描述 投票:0回答:1

如何在 Java 应用程序中使用 JDBC

 获取 Oracle 
dbms_output.get_lines 的输出,而不在数据库中创建额外的对象

java sql oracle jdbc plsql
1个回答
30
投票

我也在这里写过关于这个问题的博客。这是一个片段,说明了如何做到这一点:

try (CallableStatement call = c.prepareCall(
    "declare "
  + "  num integer := 1000;" // Adapt this as needed
  + "begin "

  // You have to enable buffering any server output that you may want to fetch
  + "  dbms_output.enable();"

  // This might as well be a call to third-party stored procedures, etc., whose
  // output you want to capture
  + "  dbms_output.put_line('abc');"
  + "  dbms_output.put_line('hello');"
  + "  dbms_output.put_line('so cool');"

  // This is again your call here to capture the output up until now.
  // The below fetching the PL/SQL TABLE type into a SQL cursor works with Oracle 12c.
  // In an 11g version, you'd need an auxiliary SQL TABLE type
  + "  dbms_output.get_lines(?, num);"

  // Don't forget this or the buffer will overflow eventually
  + "  dbms_output.disable();"
  + "end;"
)) {
    call.registerOutParameter(1, Types.ARRAY, "DBMSOUTPUT_LINESARRAY");
    call.execute();

    Array array = null;
    try {
        array = call.getArray(1);
        System.out.println(Arrays.asList((Object[]) array.getArray()));
    }
    finally {
        if (array != null)
            array.free();
    }
}

上面会打印:

[abc, hello, so cool, null]

请注意,

ENABLE
/
DISABLE
设置是一个连接范围的设置,因此您也可以通过多个 JDBC 语句执行此操作:

try (Connection c = DriverManager.getConnection(url, properties);
     Statement s = c.createStatement()) {

    try {
        s.executeUpdate("begin dbms_output.enable(); end;");
        s.executeUpdate("begin dbms_output.put_line('abc'); end;");
        s.executeUpdate("begin dbms_output.put_line('hello'); end;");
        s.executeUpdate("begin dbms_output.put_line('so cool'); end;");

        try (CallableStatement call = c.prepareCall(
            "declare "
          + "  num integer := 1000;"
          + "begin "
          + "  dbms_output.get_lines(?, num);"
          + "end;"
        )) {
            call.registerOutParameter(1, Types.ARRAY, "DBMSOUTPUT_LINESARRAY");
            call.execute();
    
            Array array = null;
            try {
                array = call.getArray(1);
                System.out.println(Arrays.asList((Object[]) array.getArray()));
            }
            finally {
                if (array != null)
                    array.free();
            }
        }
    }
    finally {
        s.executeUpdate("begin dbms_output.disable(); end;");
    }
}

还要注意,这将最多获取 1000 行的固定大小。如果您需要更多行,您可能需要在 PL/SQL 中循环或轮询数据库。

使用 jOOQ 来做到这一点

请注意,如果您是 jOOQ 用户,您可以在查询时自动获取服务器输出:

DSLContext ctx = DSL.using(c, 
    new Settings().withFetchServerOutputSize(10));

然后你应该看到一些

DEBUG
FetchServerOutputListener
的日志输出,例如

DEBUG [LoggerListener           ] Executing query : begin my_procedure(1, 2); end;
DEBUG [FetchServerOutputListener] <output here>       

除了上面的

DEBUG
日志外,您还会在
ExecuteContext::serverOutput

中获得信息

链接的博文中也提到了这一点

关于调用
DBMS_OUTPUT.GET_LINE
的注释

以前,有一个现已删除的答案建议单独调用

DBMS_OUTPUT.GET_LINE
,一次返回一行。我已经对方法进行了基准测试,将其与
DBMS_OUTPUT.GET_LINES
进行了比较,差异非常大——从 JDBC 调用时最多慢 30 倍(即使从 PL/SQL 调用过程时并没有太大的区别)。

所以,使用

DBMS_OUTPUT.GET_LINES
的批量数据传输方法绝对值得。这是基准测试的链接:

https://blog.jooq.org/the-cost-of-jdbc-server-roundtrips/

© www.soinside.com 2019 - 2024. All rights reserved.