复制代码代码如下：
com.wanmei.meishu 包；
导入 java.io.FileInputStream;
导入 java.io.FileOutputStream;
导入 java.io.FileReader;
导入 java.io.InputStream;
导入 java.io.OutputStream;
导入java.sql.Connection；
导入 java.sql.DriverManager;
导入 java.sql.PreparedStatement;
导入java.sql.ResultSet；
导入java.sql.SQLException；
导入java.util.Properties；
导入 oracle.sql.BLOB；
公共类 BlobUtil {
私有静态 BlobUtil bu；
私有字符串环境；
公共静态 BlobUtil getInstance(String env) {
bu = new BlobUtil();
bu.env = env;
返回卜；
}
/**
* <p>获取数据库链接</p>
* @返回
* @抛出异常
*/
私有连接 getConnection() 抛出异常 {
字符串驱动程序=“oracle.jdbc.driver.OracleDriver”;
Class.forName(驱动程序);
字符串 env = this.env;
属性 pro = 新属性();
// 读取classes目录下的配置文件
pro.load(new FileReader(Class.class.getResource("/config.properties").getFile()));
String host = pro.getProperty(env + ".host");
字符串数据库 = pro.getProperty(env + ".database");
String username = pro.getProperty(env + ".username");
字符串密码 = pro.getProperty(env + ".password");
String port = pro.getProperty(env + ".port");
String url = "jdbc:oracle:thin:@" + 主机 + ":" + 端口 +":" + 数据库;
return DriverManager.getConnection(url, 用户名, 密码);
}
/**
* <p>创建项目，任务，附件名称，文件路径，读取数据库</p>
* @param 项目ID
* @param 任务ID
* @param 文件名
* @param 文件
* @return 返回是否成功
*/
公共布尔写入（字符串项目ID，字符串任务ID，字符串文件名，字符串文件）{
连接 conn = null;
结果集 rs = null;
准备语句 ps = null;
BLOB 斑点 = null;
布尔标志= false；
尝试 {
conn = getConnection();
conn.setAutoCommit(假);
String sql = "INSERT INTO PS_ZP_PRJ_WBS_BLOB BLB(ZP_PRJ_ID, ZZ_SEQ_NUM, ZZ_FILE_NAME, ZZ_IMAGE_BLOB) VALUES(?, ? ,? ,empty_blob())";
ps = conn.prepareStatement(sql);
ps.setString(1, 项目Id);
ps.setString(2, 任务Id);
ps.setString(3, 文件名);
ps.executeUpdate();
sql = "从 PS_ZP_PRJ_WBS_BLOB 中选择 ZZ_IMAGE_BLOB，其中 ZP_PRJ_ID = ? AND ZZ_SEQ_NUM = ? AND ZZ_FILE_NAME = ? 用于更新";
ps = conn.prepareStatement(sql);
ps.setString(1, 项目Id);
ps.setString(2, 任务Id);
ps.setString(3, 文件名);
rs = ps.executeQuery();
if(rs.next()) {
blob = (BLOB) rs.getBlob(1);
}
输入流 = new FileInputStream(文件);
OutputStream out = blob.setBinaryStream(1L);
字节[]缓冲区=新字节[1024]；
整数长度=-1；
while ((长度 = in.read(buffer)) != -1){
out.write(缓冲区, 0, 长度);
}
附寄（）;
关闭();
conn.commit();
conn.setAutoCommit(true);
标志=真；
}
捕获（异常e）{
如果（conn！=空）{
尝试 {
conn.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
}
}
最后 {
尝试 {
rs.close();
ps.close();
conn.close();
}
捕获（异常e）{
e.printStackTrace();
}
}
返回标志；
}
/**
* <p>根据项目Id，任务Id，文件名读取数据库blob字段文件，读取指定的文件路径</p>
* @param 项目ID
* @param 任务ID
* @param 文件名
* @param 文件
* @return 返回是否成功
*/
公共布尔读取（字符串项目ID，字符串任务ID，字符串文件名，字符串文件）{
连接 conn = null;
结果集 rs = null;
准备语句 ps = null;
BLOB 斑点 = null;
布尔标志= false；
尝试 {
conn = getConnection();
String sql = "从 PS_ZP_PRJ_WBS_BLOB 中选择 ZZ_IMAGE_BLOB，其中 ZP_PRJ_ID = ? AND ZZ_SEQ_NUM = ? AND ZZ_FILE_NAME = ?";
ps = conn.prepareStatement(sql);
ps.setString(1, 项目Id);
ps.setString(2, 任务Id);
ps.setString(3, 文件名);
rs = ps.executeQuery();
if(rs.next()) {
blob = (BLOB) rs.getBlob(1);
}
输入流= blob.getBinaryStream();
字节[] buf = 新字节[1024];
int 字节 = 0;
FileOutputStream out = new FileOutputStream(文件);
while ((bytesIn = in.read(buf, 0, 1024)) != -1) {
out.write(buf, 0, bytesIn);
}
附寄（）;
关闭();
标志=真；
}
捕获（异常e）{
e.printStackTrace();
}
最后 {
尝试 {
rs.close();
ps.close();
conn.close();
}
捕获（异常e）{
e.printStackTrace();
}
}
返回标志；
}
公共静态无效主（字符串[] args）{
BlobUtil bu = BlobUtil.getInstance("MSDEV");
System.out.println(bu.write("CB", "001", "image1", "D://61e44b02jw1dw4xbp2zo6j.jpg"));
System.out.println(bu.read("CB", "001", "image1", "D://2.jpg"));
}
}