在 java 存储过程中创建 java.sql.blob 实例

Question

这是我第一次在stackoverflow上发帖， 我需要编写一个 java 存储过程来创建一个 excel 文件并返回一个包含文件数据（以字节为单位）的 blob。

我的pl/sql函数如下形式

function test_create_excel(i_username IN varchar2) return BLOB
   AS LANGUAGE JAVA NAME 'NTO.Excel.ExcelFunctions.PushToExcel( java.lang.String ) return java.sql.Blob';

我的Java方法如下

public static java.sql.Blob TestPushToExcel(String username) throws IOException, SQLException{
        //create excel file, read content to byte array and set to a blob
    }

我的问题是我找不到任何方法来创建 java.sql.Blob 的实例，以便我可以使用 blob.setBinaryStream(..) 方法来写入文件数据字节数组。

我尝试使用 SerialBlob 实现，但会导致以下 oracle 错误

ORA-00932：不一致的数据类型：预期返回值是 可转换为 Oracle 类型的用户定义 Java 类的实例 得到一个无法转换的对象

有没有人遇到过这个问题，如果有，您可以分享一下您是如何解决的。

在此先感谢您。

编辑 JAVA

public static oracle.sql.BLOB getBlob(byte[] data) throws SQLException, IOException{
        oracle.jdbc.OracleConnection conn = (oracle.jdbc.OracleConnection)new OracleDriver().defaultConnection();

        oracle.sql.BLOB retBlob = oracle.sql.BLOB.createTemporary(conn, true, oracle.sql.BLOB.DURATION_SESSION);

        java.io.OutputStream outStr = retBlob.setBinaryStream(0);
        outStr.write(data);
        outStr.flush();

        return retBlob;
  }


public static ExcelFileStore PushToExcel(String userId) throws IOException, SQLException{

        ExcelFileStore fileStore = new ExcelFileStore();        
        fileStore.NU_USERID = userId;
        fileStore.CreatedTime = new java.sql.Date(new Date().getTime());
        fileStore.Last_Updated = new java.sql.Date(new Date().getTime());        
        fileStore.FileSize = fileData.length;
        fileStore.FileData = getBlob(fileData);        
        return fileStore;
    }

PL/SQL

 function test_create_excel(i_username IN varchar2) return EXCELFILESTORE    AS LANGUAGE JAVA NAME 'NTO.Excel.ExcelFunctions.PushToExcel( java.lang.String, ) return OracleObjects.ExcelFileStore';

OracleObject.ExcelfileStore是实现java.sql.SqlData的类，EXCELFILESTORE是oracle中的UDT。

我使用 'sys.dbms_java.loadjava' 加载了参考 jar 和为我的代码创建的 jar

我希望你能理解我的问题，因为我对 pl/sql 编程很陌生

Answer 1

我错了。它可以完成。我花了一段时间才让它工作，但最后，这是一个工作示例：

Java 类

import oracle.jdbc.driver.*;

public class TestBlob {
  public static oracle.sql.BLOB getBlob(String username) throws Exception {
    oracle.jdbc.OracleConnection conn = 
      (oracle.jdbc.OracleConnection)new OracleDriver().defaultConnection();

    oracle.sql.BLOB retBlob =
      oracle.sql.BLOB.createTemporary(conn,
                                      true,
                                      oracle.sql.BLOB.DURATION_SESSION);

    java.io.OutputStream outStr = retBlob.setBinaryStream(0);
    outStr.write(username.getBytes());
    outStr.flush();

    return retBlob;
  }
}

如您所见，我使用oracle.sql.BLOB 作为结果。我使用BLOB 类的静态createTemporary 方法创建它，指定它应该在会话期间创建（oracle.sql.BLOB.DURATION_SESSION 参数）。

然后，我获取OutputStream 并写入数据。需要冲洗。

数据库端

create or replace FUNCTION getBlobWrp (username IN VARCHAR2) RETURN BLOB
  AS LANGUAGE JAVA NAME
              'TestBlob.getBlob(java.lang.String) return oracle.sql.BLOB';

测试：

DECLARE
  l_blob BLOB;
BEGIN
  l_blob := getBlobWrp('test');

  dbms_output.put_line(UTL_RAW.CAST_TO_VARCHAR2(l_blob));
END;

输出：

测试

（上一个答案）

我认为您应该在您的test_create_excel 函数中有一个IN OUT BLOB 参数（将其更改为一个过程），并在您的Java 存储方法中对该参数进行操作。这种方法我见过一次。

在调用test_create_excel之前，你应该创建一个BLOB对象：

DECLARE
  l_blob BLOB;
BEGIN
  DBMS_LOB.createtemporary(l_blob, TRUE);
  test_create_excel('username', l_blob);
END;

编辑

我认为您尝试做的事情是不可能的。但是，您可以将上述代码包装在另一个函数中。这有点乱，但是你会有一个返回 blob 的函数：

CREATE OR REPLACE FUNCTION get_excel_blob(p_username VARCHAR2) RETURN BLOB
AS
  l_blob BLOB;
BEGIN
  DBMS_LOB.createtemporary(l_blob, TRUE);
  test_create_excel(p_username, l_blob);
  RETURN l_blob;
END;