春季發送Blob到存儲過程

我試圖發送一個Blob到存儲過程沒有成功。首先，我有一些限制，我。即我無法使用準備好的聲明。其次，我確信存儲過程的工作原理，因爲我已經成功地通過手動調用過程和準備好的語句來嘗試它。如果我執行這一切工作正常：春季發送Blob到存儲過程

PreparedStatement ps = con.prepareStatement("call t1000_adm.Mandamail.manda_mail(?)"); 
file = new File(request.getPathAllegato()); 
InputStream fis = new FileInputStream(file); 
ps.setBinaryStream(1, fis, (int)file.length()); 
ps.execute();

但我被迫使用Spring MVC的與WebSphere應用服務器，我不能直接使用一個事先準備好的聲明。我必須使用javax.sql.DataSource和org.springframework.jdbc.core.namedparam.MapSqlParameterSource。

這是我必須做的：

MapSqlParameterSource paramSource = new MapSqlParameterSource(); 
paramSource.addValue(BLOB_NAME, blob); 
CustomStoredProcedure proc = new CustomStoredProcedure(dataSource, storedProcedure); 
proc.execute(paramSource);

在CustomStoredProcedure，至極延伸org.springframework.jdbc.object.StoredProcedure，我不得不聯想到BLOB_NAME一個Oracle數據類型，以這樣的方式

public CustomStoredProcedure(DataSource dataSource, String sprocName) { 
    super(dataSource, sprocName); 
    declareParameter(new SqlParameter(BLOB_NAME, OracleTypes.BLOB)); 
    compile(); 
}

現在，這裏的問題：

1）如果我試圖創建的DataSource.getConnection（）的Blob對象createBlob（）我收到錯誤：

java.sql.SQLFeatureNotSupportedException: DSRA1300E: Function not implemented: Connection.createBlob

（描述可能不正確，但我有本地化的版本，我翻譯成英文）。

2）如果我試圖創建BLOB.createTemporary Blob對象我收到錯誤

java.lang.ClassCastException: com.ibm.ws.rsadapter.jdbc.WSJdbcConnection incompatible with oracle.jdbc.OracleConnection

3）如果我使用

com.ibm.websphere.rsadapter.WSCallHelper.getNativeConnection(dataSource.getConnection)

我收到編譯錯誤（只螞蟻，與Eclipse我沒有問題）：

error: package com.ibm.websphere.rsadapter not exists 
[javac] import com.ibm.websphere.rsadapter.WSCallHelper

（和以前一樣，我翻譯的錯誤）

4）如果我忽略螞蟻編譯錯誤，並用它無論如何我收到執行錯誤：

[31/05/17 9.52.50:414 CEST] 0000007f SystemErr  R org.springframework.jdbc.UncategorizedSQLException: CallableStatementCallback; uncategorized SQLException for SQL [{call MANDAMAIL.MANDA_MAIL(?)}]; SQL state [99999]; error code [22922]; ORA-22922: valore LOB non esistente 
ORA-06512: a "SYS.DBMS_LOB", line 837 
ORA-06512: a "T1000_ADM.MANDAMAIL", line 190 
ORA-06512: a line 1 
; nested exception is java.sql.SQLException: ORA-22922: valore LOB non esistente 
ORA-06512: a "SYS.DBMS_LOB", line 837 
ORA-06512: a "T1000_ADM.MANDAMAIL", line 190 
ORA-06512: a line 1 

[31/05/17 9.52.50:415 CEST] 0000007f SystemErr  R at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:83) 
[31/05/17 9.52.50:415 CEST] 0000007f SystemErr  R at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:80) 
[31/05/17 9.52.50:416 CEST] 0000007f SystemErr  R at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:80) 
[31/05/17 9.52.50:416 CEST] 0000007f SystemErr  R at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:1030) 
[31/05/17 9.52.50:416 CEST] 0000007f SystemErr  R at org.springframework.jdbc.core.JdbcTemplate.call(JdbcTemplate.java:1064) 
[31/05/17 9.52.50:417 CEST] 0000007f SystemErr  R at org.springframework.jdbc.object.StoredProcedure.execute(StoredProcedure.java:144) 
[31/05/17 9.52.50:417 CEST] 0000007f SystemErr  R at com.bpvn.vieniconnoi.dao.MandaMailStoredProcedure.execute(MandaMailStoredProcedure.java:42)...

行的程序190是DBMS_LOB的第一occurrance。這是存儲過程（在Java代碼中，爲了簡單起見，我刪除了其他參數）。

PROCEDURE manda_mail( destinatario   IN VARCHAR2, 
         cc     IN VARCHAR2, 
         mittente    IN VARCHAR2, 
         oggetto    IN VARCHAR2, 
         corpo     IN VARCHAR2 DEFAULT NULL, 
         nomeAllegato   IN VARCHAR2 DEFAULT NULL, 
         allegato    IN BLOB DEFAULT NULL) 
AS 
    l_mail_conn UTL_SMTP.connection; 
    l_boundary VARCHAR2(50) := '----=*#abc1234321cba#*='; 
    l_step  PLS_INTEGER := 12000; -- make sure you set a multiple of 3 not higher than 24573 
    v_mime VARCHAR2(50) := 'application/pdf'; 
BEGIN 
    l_mail_conn := UTL_SMTP.open_connection(C_SMTP_SERVER, 25); 
    UTL_SMTP.helo(l_mail_conn, C_SMTP_SERVER); 
    UTL_SMTP.mail(l_mail_conn, mittente); 
    UTL_SMTP.rcpt(l_mail_conn, destinatario); 

    UTL_SMTP.open_data(l_mail_conn); 

    UTL_SMTP.write_data(l_mail_conn, 'Date: ' || TO_CHAR(SYSDATE, 'DD-MON-YYYY HH24:MI:SS') || UTL_TCP.crlf); 
    UTL_SMTP.write_data(l_mail_conn, 'To: ' || destinatario || UTL_TCP.crlf); 
    UTL_SMTP.write_data(l_mail_conn, 'From: ' || mittente || UTL_TCP.crlf); 
    UTL_SMTP.write_data(l_mail_conn, 'Subject: ' || oggetto || UTL_TCP.crlf); 
    UTL_SMTP.write_data(l_mail_conn, 'Reply-To: ' || mittente || UTL_TCP.crlf); 
    UTL_SMTP.write_data(l_mail_conn, 'MIME-Version: 1.0' || UTL_TCP.crlf); 
    UTL_SMTP.write_data(l_mail_conn, 'Content-Type: multipart/mixed; boundary="' || l_boundary || '"' || UTL_TCP.crlf || UTL_TCP.crlf); 

    IF corpo IS NOT NULL THEN 
    UTL_SMTP.write_data(l_mail_conn, '--' || l_boundary || UTL_TCP.crlf); 
    UTL_SMTP.write_data(l_mail_conn, 'Content-Type: text/plain; charset="iso-8859-1"' || UTL_TCP.crlf || UTL_TCP.crlf); 

    UTL_SMTP.write_data(l_mail_conn, corpo); 
    UTL_SMTP.write_data(l_mail_conn, UTL_TCP.crlf || UTL_TCP.crlf); 
    END IF; 

    IF nomeAllegato IS NOT NULL THEN 
    UTL_SMTP.write_data(l_mail_conn, '--' || l_boundary || UTL_TCP.crlf); 
    UTL_SMTP.write_data(l_mail_conn, 'Content-Type: ' || v_mime || '; name="' || nomeAllegato || '"' || UTL_TCP.crlf); 
    UTL_SMTP.write_data(l_mail_conn, 'Content-Transfer-Encoding: base64' || UTL_TCP.crlf); 
    UTL_SMTP.write_data(l_mail_conn, 'Content-Disposition: attachment; filename="' || nomeAllegato || '"' || UTL_TCP.crlf || UTL_TCP.crlf); 

    FOR i IN 0 .. TRUNC((DBMS_LOB.getlength(allegato) - 1)/l_step) LOOP 
     UTL_SMTP.write_data(l_mail_conn, UTL_RAW.cast_to_varchar2(UTL_ENCODE.base64_encode(DBMS_LOB.substr(allegato, l_step, i * l_step + 1)))); 
    END LOOP; 

    UTL_SMTP.write_data(l_mail_conn, UTL_TCP.crlf || UTL_TCP.crlf); 
    END IF; 

    UTL_SMTP.write_data(l_mail_conn, '--' || l_boundary || '--' || UTL_TCP.crlf); 
    UTL_SMTP.close_data(l_mail_conn); 

    UTL_SMTP.quit(l_mail_conn); 
END;

爲了得到這個我用這種方式創建blob對象之前寫的代碼：

BLOB blob = BLOB.createTemporary(WSCallHelper.getNativeConnection(dataSource.getConnection()), false, BLOB.DURATION_SESSION); 
FileInputStream is = new FileInputStream(filePath); 
byte[] buffer = new byte[30000000]; 
ByteArrayOutputStream baos = new ByteArrayOutputStream(); 

int bytesRead; 
while ((bytesRead = is.read(buffer)) != -1) { 
    baos.write(buffer, 0, bytesRead); 
} 

blob.setBytes(1, baos.toByteArray());

有什麼建議？

來源

2017-05-31 DeooK

問題解決：我不需要使用Blob對象：我可以在Java端使用簡單的byte []，將它放在paramSource中並使用OracleTypes.BINARY綁定該數組。這是有效的。

來源

2017-06-14 07:59:52 DeooK

春季發送Blob到存儲過程

回答

相關問題