高分请教tomcat5＋oracle9存取blob的源码~~，急，路过的朋友帮忙顶一下

Question

GOOGLE: oracle JDBC blob 大把。

Answer 1

楼上的兄弟，大把的都试过了，不是这个错就是那个错！很多方法里的这句“oracle.sql.BLOB blob=ors.getBLOB(1);/**得到BLOB字段 ”我这边会报错，晕了....，不知道是不是oracle的包不对，我用的是oracle9安装自带的class12.jar~~

Answer 2

Oracle的Blob字段比较特殊，他比long字段的性能要好很多，可以用来保存例如图片之类的二进制数据。 
　　写入Blob字段和写入其它类型字段的方式非常不同，因为Blob自身有一个cursor，你必须使用cursor对blob进行操作，因而你在写入Blob之前，必须获得cursor才能进行写入，那么如何获得Blob的cursor呢？
　　这需要你先插入一个empty的blob，这将创建一个blob的cursor，然后你再把这个empty的blob的cursor用select查询出来，这样通过两步操作，你就获得了blob的cursor，可以真正的写入blob数据了。
　　看下面的JDBC的demo，把oraclejdbc.jar这个二进制文件写入数据库表javatest的content字段(这是一个blob型字段)
import java.sql.*;
import java.io.*;
import oracle.sql.*;
public class WriteBlob {
public static void main(String[] args) {
try {
DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl","fankai","fankai");
conn.setAutoCommit(false);
BLOB blob = null;
PreparedStatement pstmt = conn.prepareStatement("insert into javatest(name,content) values(?,empty_blob())");
pstmt.setString(1,"fankai");
pstmt.executeUpdate();
pstmt.close();
pstmt = conn.prepareStatement("select content from javatest where name= ? for update");
pstmt.setString(1,"fankai");
ResultSet rset = pstmt.executeQuery();
if (rset.next()) blob = (BLOB) rset.getBlob(1);
    String fileName = "oraclejdbc.jar";
    File f = new File(fileName);
    FileInputStream fin = new FileInputStream(f);
    System.out.println("file size = " + fin.available());
    pstmt = conn.prepareStatement("update javatest set content=? where name=?");
    OutputStream out = blob.getBinaryOutputStream();
    int count = -1, total = 0;
    byte[] data = new byte[(int)fin.available()];
/*
byte[] data = new byte[blob.getBufferSize()]; 另一种实现方法,节省内存
while ((count = fin.read(data)) != -1) {
total += count;
out.write(data, 0, count);
}
*/
fin.close();
out.close();
pstmt.setBlob(1,blob);
pstmt.setString(2,"fankai");
pstmt.executeUpdate();
pstmt.close();
conn.commit();
conn.close();
} catch (SQLException e) {
System.err.println(e.getMessage());
e.printStackTrace();
} catch (IOException e) {
System.err.println(e.getMessage());
}}
}

Answer 3

hooligan000112003你好，我试了你的方法，如果我数据库改用tomcat连接池的方式，则blob = (BLOB) rset.getBlob(1);报ClassCast..错误。直接copy你的代码则没这个错，但保存小文件时数据库里存进去了但blob字段是空的，如果文件超过1m则保存时间超长（超过半小时），且最后没有保存成功（没有报错，但数据库里没有记录），不知道这是怎么回事，肯请指教，谢谢！