Go语言视频零基础入门到精通

admin

有时候，我们需要将文件以二进制流的形式存入数据库中，比如oracle表中有一个字段为files，字段类型为blob。如果编写存储过程，传入blob参数或者文件的路径进行处理似乎有些难度，处理起来也麻烦。由于项目使用到了spring，所以使用spring的jdbc作新增和更新操作。
例如：oracle表t_customer_health_document表中有名为files，类型为blob的字段，需要保存一张图片。
首先，创建一个工具类以获取spring的上下文，如下：
package com.zhangjie.test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class TaskInit {
private static ApplicationContext context = null;
/**
* 单例 ApplicationContext
*  用于获取Spring容器中beans
* @return ApplicationContext
* @see
*/
public static ApplicationContext getInstance() {
if (context == null) {
context = new ClassPathXmlApplicationContext(new String[] {
"applicationContext.xml"});
}
return context;
}
}
然后，使用jdbc操作来将文件保存到files字段中，如下：
package com.zhangjie.test;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import oracle.sql.BLOB;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceUtils;
import org.springframework.jdbc.support.JdbcUtils;
public class UpdateFiles {
public static Boolean updateFiles(String id, String filepath) {
Boolean result = false;
JdbcTemplate jdbcTemplate = (JdbcTemplate) TaskInit.getInstance()
.getBean("jdbcTemplate");;
Connection con = null;
PreparedStatement pstmt = null;
ResultSet rset = null;
try {
con = DataSourceUtils.getConnection(jdbcTemplate.getDataSource());
con.setAutoCommit(false);
BLOB blob = null;
pstmt = con
.prepareStatement("update t_customer_health_document set files=empty_blob() where id=?");
pstmt.setString(1, id);
pstmt.executeUpdate();
pstmt.close();
pstmt = con
.prepareStatement("select files from t_customer_health_document where id= ? for update");
pstmt.setString(1, id);
rset = pstmt.executeQuery();
if (rset.next())
blob = (BLOB) rset.getBlob(1);
File f = new File(filepath);
FileInputStream fin = new FileInputStream(f);
pstmt = con
.prepareStatement("update t_customer_health_document set files=? where id=?");
OutputStream out = blob.getBinaryOutputStream();
byte[] data = new byte[(int) fin.available()];
fin.read(data);
out.write(data);
fin.close();
out.close();
pstmt.setBlob(1, blob);
pstmt.setString(2, id);
pstmt.executeUpdate();
pstmt.close();
con.commit();
con.close();
result = true;
} catch (SQLException e) {
e.printStackTrace();
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
JdbcUtils.closeResultSet(rset);
JdbcUtils.closeStatement(pstmt);
DataSourceUtils
.releaseConnection(con, jdbcTemplate.getDataSource());
}
return result;
}
public static void main(String[] args) {
boolean is = updateFiles("D6256CEBFEF76A03E040A8C057E005B3", "D:\\web deployment assembly.jpg");
System.out.println(is);
}
}

吴会

谢谢楼主总结的非常好啊。