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型字段)
java代码:
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()];
fin.read(data);
out.write(data);
/*
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());
}
}
}
仔细看上例，分三步：
1、插入空blob
into javatest(name,content) values(?,empty_blob());
2、获得blob的cursor
select content from javatest where name= ? for update;
注意！！！必须加for update，这将锁定该行，直至该行被修改完毕，保证不产生并发冲突。
3、update javatest set content=? where name=
用cursor往数据库写数据
这里面还有一点要提醒大家：
jdk1.3带的jdbc2.0规范是不完善的，只有读blob的接口，而没有写blob的接口，jdk1.4带的jdbc3.0加入了写blob的接口。你可以使用jdbc3.0的接口，也可以直接使用oracle的jdbc的api，我在上例中使用了oracle的jdbc的api。
另外要注意的是：
java.sql.blob
oracle.sql.blob
注意看blob的大小写，是不一样的。写程序的时候不要搞混了。
下面看看用hibernate怎么写，原理是一样的，也要分三步，但是代码简单很多
这是cat对象定义
java代码:
package com.fankai;
import java.sql.blob;
public class cat {
private string id;
private string name;
private char sex;
private float weight;
private blob image;
public cat() { }
public string getid() { return id; }
public void setid(string id) { this.id = id; }
public string getname() { return name; }
public void setname(string name) { this.name = name; }
public char getsex() { return sex; }
public void setsex(char sex) { this.sex = sex; }
public float getweight() { return weight; }
public void setweight(float weight) { this.weight = weight; }
public blob getimage() { return image; }
public void setimage(blob image) { this.image = image;}
}
这是cat.hbm.xml
java代码:
下面是完整的用hibernate写入blob的例子，相比jdbc，已经简单轻松多了，也不用写那些oracle特殊的sql了：
java代码:
package com.fankai;
import java.sql.blob;
import net.sf.hibernate.*;
import oracle.sql.*;
import java.io.*;
public class testcathibernate {
public static void testblob() {
session s = null;
byte[] buffer = new byte[1];
buffer[0] = 1;
try {
sessionfactory sf = hibernatesessionfactory.getsessionfactory();
s = sf.opensession();
transaction tx = s.begintransaction();
cat c = new cat();
c.setname("robbin");
c.setimage(hibernate.createblob(buffer));
s.save(c);
s.flush();
s.refresh(c, lockmode.upgrade);
blob blob = (blob) c.getimage();
outputstream out = blob.getbinaryoutputstream();
string filename = "oraclejdbc.jar";
file f = new file(filename);
fileinputstream fin = new fileinputstream(f);
int count = -1, total = 0;
byte[] data = new byte[(int)fin.available()];
fin.read(data);
out.write(data);
fin.close();
out.close();
s.flush();
tx.commit();
} catch (exception e) {
system.out.println(e.getmessage());
} finally {
if (s != null)
try {
s.close();
} catch (exception e) {}
}
}
}
闽公网安备 35060202000074号