JDBC を使用して Oracle データベースに Java ソース オブジェクトを作成しようとしています。
作成したいソースは次のとおりです。
create or replace and resolve java source named "BlobIO" as package dbjava;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.io.*;
public class BlobIO {
/**
* Stores a blob into a local file (or even UNC-path)
* @param blob The blob locator that should be stored in a file
* @param filename The filename to write to
* @param bufferSize The buffer size for data transfer
* @return 1 if successful, 0 if failed
*/
public static int blobToFile(java.sql.Blob blob, String filename, int bufferSize)
{
OutputStream os = null;
InputStream is = null;
boolean fail = true;
try {
is = blob.getBinaryStream();
os = new FileOutputStream(filename);
int amountRead = 0;
byte[] buffer = new byte[bufferSize];
while ((amountRead = is.read(buffer, 0, buffer.length)) != -1) {
os.write(buffer, 0, amountRead);
}
is.close();
os.flush();
os.close();
fail = false;
} catch (IOException ex) {
new File(filename).delete();
System.err.println("Could not store blob to file.");
System.err.println("File : " + filename);
System.err.println("Reason : " + ex.getClass().getName() + " : " + ex.getMessage());
fail = true;
} catch (SQLException ex) {
new File(filename).delete();
System.err.println("Could not store blob to file.");
System.err.println("File : " + filename);
System.err.println("Reason : " + ex.getClass().getName() + " : " + ex.getMessage());
fail = true;
} finally {
try {is.close();} catch (Exception ex) {}
try {os.flush();} catch (Exception ex) {}
try {os.close();} catch (Exception ex) {}
}
return fail? 0:1;
}
/**
* Stores a blob into a local file (or even UNC-path)
* @param query The query that should select ONLY the blob field
* @param filename The filename to write to
* @param bufferSize The buffer size for data transfer
* @return 1 if successful, 0 if failed
*/
public static int blobToFile(String query, String filename, int bufferSize) {
try {
Connection conn = DriverManager.getConnection("jdbc:default:connection:");
Statement stmt = conn.createStatement();
ResultSet rset = stmt.executeQuery(query);
InputStream is;
if (rset.next())
{
int ret = blobToFile(rset.getBlob(1), filename, bufferSize);
if (rset.next())
{
new File(filename).delete();
System.err.println("Could not store blob to file.");
System.err.println("Blob query : " + query);
System.err.println("File : " + filename);
System.err.println("Reason : too many rows");
rset.close();
stmt.close();
return 0;
} else {
rset.close();
stmt.close();
return ret;
}
} else {
System.err.println("Could not store blob to file.");
System.err.println("Blob query : " + query);
System.err.println("File : " + filename);
System.err.println("Reason : no records retrieved by query");
rset.close();
stmt.close();
return 0;
}
} catch (Exception e) {
System.err.println(e.getMessage());
return 0;
}
}
}
/
CallableStatementexecute メソッドを使用してみerror: "Missing IN/OUT parameters"
ましたが、通常のStatementオブジェクトで execute メソッドを使用しようとすると、次のエラーが表示されます。
Non supported SQL92 token at position: 262"
誰が私が間違っているのか知っていますか? グーグルでも何も見つからないようです。
編集:これは、スクリプトを実行しようとするために使用するコードです (文字列sqlには上記のスクリプトが含まれており、変数connはConnectionオブジェクトです。
CallableStatement stat = conn.prepareCall(sql);
stat.setEscapeProcessing(false);
stat.execute();
ステートメントだけで試してみると、次のようになります。
Statement stat = conn.createStatement();
stat.execute(sql);