mybatis的BLOB存储与读取

简单介绍一下背景环境，web开发避免不了照片附件之类的东东，原先是存到硬盘的文件下，存储读取都比较方便。现在公司弄了个硬件负载均衡，6台服务器，当用户登录的时候会随机分配到其中的一台机器上，6台机器安装的相同的server，session不共享。访问的同一个oracle11.2g，这样的话，原先的附件就可能不好使了，必须保证6台机器共享文件，想想直接放到数据库里吧，将来再做个本地缓存之类的。ok背景就到这里。

第一步，没做过大字段的存取，网上查资料，N多资料，总体来说有用的不多，但也要硬着头皮找，开始看mybatis和数据库的字段对照表，bytes[]对应的是blob字段，于是在pojo类中的content设置类型为byte[],mapper.xml中设置了resultMap，字段content设置<result property="content" column="content" jdbcType="BLOB" typeHandler="com.ibatis.sqlmap.engine.type.BlobTypeHandlerCallback"/>

结果总是报”ora-01461“的错误，网上查询了一下，基本意思就是超出长度了。但是明明是大字段，图片大小也就是70k，不可能超出长度

1）人为把byte定义一个长度 byte[0] = 1,继续插入数据库，成功！但是这不符合我的需求，这哪是大字段

2）继续网上搜索，说是用byte[]这种形式传的话，1000-2000之间的字节会报‘ora-01461’的错误，网上有给出编写oracleLobHandler的做法，不过他用的是hibernate，大字段是clob，处于懒人目的直接忽略

3）终于找到一篇有用的文章，我的大体里程也是按照他的方法来的http://www.360doc.com/content/06/0913/13/6272_206215.shtml，总结一下里面提到的

1》pojo类中不能使用byte[],也不能使用BLOB，这两种鄙人也都用过确实无效，使用Object

2》mapper.mxl中的resultMap把typeHandler去掉，我也怀疑自带的这个类型处理器不是很好使，不能将blob转换成byte[]等，这里建议有时间的同学可以自己写一个再试试，感觉应该是能成功的，不然换成Object强制类型转换估计也没戏。

3》oracle存大数据的时候，要先插入一个empty_blob()占位符，占到blob字段，其次在查询出来这个大字段用流的方式写入。

4》在进行流读取的时候，发现blob.getBinaryOutputStream();已经过时了,于是改成了推荐的blob.setBinaryStream(0);发现总是提示"无效的参数...",经查看发现是oracle驱动的问题，当时的环境是oracle11.2g+ojdbc6.jar+jdk1.6,查看setBinaryStream这个api说适用于jdbc3.0，按理说都应该满足了，经替换发现，ojdbc6，ojdbc5都出问题，换成支持1.4jdk的ojdbc14.jar不会出问题，但是驱动越高，效率越高，bug越少，所以一直用的过时的方法。

下面把我存储和读取的主要代码附上：

pojo类：

[html] view plaincopy在CODE上查看代码片派生到我的代码片

public class Attachment {

private String id;

private String group;//分类的id，包括消息附件、照片等

private String name;

private String type;

private String size;

private String author;

private Object content;

public Object getContent() {

return content;

}

public void setContent(Object content) {

this.content = content;

}

public String getId() {

return id;

}

public void setId(String id) {

this.id = id;

}

public String getGroup() {

return group;

}

public void setGroup(String group) {

this.group = group;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

public String getType() {

return type;

}

public void setType(String type) {

this.type = type;

}

public String getSize() {

return size;

}

public void setSize(String size) {

this.size = size;

}

public String getAuthor() {

return author;

}

public void setAuthor(String author) {

this.author = author;

}

}

[html] view plaincopy在CODE上查看代码片派生到我的代码片

map.xml中的resultMap和sql:

[java] view plaincopy在CODE上查看代码片派生到我的代码片

<resultMap id="attachmentResultMap" type="attachment">

<result property="id" column="id"/>

<result property="group" column="groupId"/>

<result property="name" column="fileName" />

<result property="type" column="fileType" />

<result property="size" column="fileSize" />

<result property="author" column="author" />

<result property="content" column="content" jdbcType="BLOB" />

</resultMap>

<insert id="insertAttachment" parameterType="attachment">

insert into bop_attachment (id,filename,filetype,filesize,author,content,groupid)

values(#{id},#{name},#{type},#{size},#{author},empty_blob(),#{group})

</insert>

service层存储的主要方法：

[java] view plaincopy在CODE上查看代码片派生到我的代码片

@Override

public void insertAttachment(Attachment attachment,File file)

throws AttachmentServiceException {

attachmentDao.insertAttachment(attachment);

Attachment att = attachmentDao.queryAttachmentById(attachment.getId());

BLOB content = (BLOB)att.getContent();

FileInputStream fis = null;

OutputStream ops = null;

try {

ops = content.getBinaryOutputStream();//暂时使用这个废弃的方法

//ops = content.setBinaryStream(0);//ojdbc14支持,ojdbc6,5都不支持

fis = new FileInputStream(file);

byte[] data = null;

data = FileCopyUtils.copyToByteArray(fis);

ops.write(data);

} catch (Exception e) {

e.printStackTrace();

} finally {

try {

if(fis!=null){

fis.close();

}

if(ops!=null){

ops.close();

}

} catch (IOException e) {

e.printStackTrace();

}

}

}

用于图片展示的servlet层：

[java] view plaincopy在CODE上查看代码片派生到我的代码片

AttachmentService as = (AttachmentService) SpringUtils.getContext().getBean("AttachmentService");

Attachment attachment = null;

try {

attachment = as.queryAttachmentById(attachmentId);

} catch (AttachmentServiceException ae) {

logger.error(ae);

throw new ServletException(ae);

}

//String realPath = rootDir + attachment.getName();

response.setContentType(attachment.getType());

response.setContentLength(Integer.parseInt(attachment.getSize()));

response.setHeader("Content-Disposition", "attachment; filename="

+ java.net.URLEncoder.encode(attachment.getName(), "UTF-8")

+ ';');

InputStream in = null;

BLOB content = (BLOB)attachment.getContent();

try {

in=content.getBinaryStream();

} catch (SQLException e) {

e.printStackTrace();

}

BufferedOutputStream bos = new BufferedOutputStream(response.getOutputStream());

int n;

while ((n=in.read())!=-1){

bos.write(n);

}

bos.flush();

bos.close();

in.close();

转载自：http://blog.csdn.net/bluesky5219/article/details/36427789