java读写oracle的blob字段示例
时间:2023-12-22 16:19:00
package com.wanmei.meishu;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
import oracle.sql.BLOB;
public class BlobUtil {
private static BlobUtil bu;
private String env;
public static BlobUtil getInstance(String env) {
bu = new BlobUtil();
bu.env = env;
return bu;
}
/**
* <p>得到数据库链接</p>
* @return
* @throws Exception
*/
private Connection getConnection() throws Exception {
String driver = "oracle.jdbc.driver.OracleDriver";
Class.forName(driver);
String env = this.env;
Properties pro = new Properties();
// 读取classes 目录下的配置文件
pro.load(new FileReader(Class.class.getResource("/config.properties").getFile()));
String host = pro.getProperty(env + ".host");
String database = pro.getProperty(env + ".database");
String username = pro.getProperty(env + ".username");
String password = pro.getProperty(env + ".password");
String port = pro.getProperty(env + ".port");
String url = "jdbc:oracle:thin:@" + host + ":" + port +":" + database;
return DriverManager.getConnection(url, username, password);
}
/**
* <p>传入项目,任务,附件名称,文件路径,写入数据库</p>
* @param projectId
* @param taskId
* @param fileName
* @param file
* @return 返回是否成功
*/
public boolean write(String projectId, String taskId, String fileName, String file) {
Connection conn = null;
ResultSet rs = null;
PreparedStatement ps = null;
BLOB blob = null;
boolean flag = false;
try {
conn = getConnection();
conn.setAutoCommit(false);
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, projectId);
ps.setString(2, taskId);
ps.setString(3, fileName);
ps.executeUpdate();
sql = "SELECT ZZ_IMAGE_BLOB FROM PS_ZP_PRJ_WBS_BLOB WHERE ZP_PRJ_ID = ? AND ZZ_SEQ_NUM = ? AND ZZ_FILE_NAME = ? FOR UPDATE";
ps = conn.prepareStatement(sql);
ps.setString(1, projectId);
ps.setString(2, taskId);
ps.setString(3, fileName);
rs = ps.executeQuery();
if(rs.next()) {
blob = (BLOB) rs.getBlob(1);
}
InputStream in = new FileInputStream(file);
OutputStream out = blob.setBinaryStream(1L);
byte[] buffer = new byte[1024];
int length = -1;
while ((length = in.read(buffer)) != -1){
out.write(buffer, 0, length);
}
in.close();
out.close();
conn.commit();
conn.setAutoCommit(true);
flag = true;
}
catch(Exception e) {
if(conn != null) {
try {
conn.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
}
}
finally {
try {
rs.close();
ps.close();
conn.close();
}
catch(Exception e) {
e.printStackTrace();
}
}
return flag;
}
/**
* <p>根据项目Id,任务Id,文件名读取数据库blob字段文件,写入指定的文件路径</p>
* @param projectId
* @param taskId
* @param fileName
* @param file
* @return 返回是否成功
*/
public boolean read(String projectId, String taskId, String fileName, String file) {
Connection conn = null;
ResultSet rs = null;
PreparedStatement ps = null;
BLOB blob = null;
boolean flag = false;
try {
conn = getConnection();
String sql = "SELECT ZZ_IMAGE_BLOB FROM PS_ZP_PRJ_WBS_BLOB WHERE ZP_PRJ_ID = ? AND ZZ_SEQ_NUM = ? AND ZZ_FILE_NAME = ?";
ps = conn.prepareStatement(sql);
ps.setString(1, projectId);
ps.setString(2, taskId);
ps.setString(3, fileName);
rs = ps.executeQuery();
if(rs.next()) {
blob = (BLOB) rs.getBlob(1);
}
InputStream in = blob.getBinaryStream();
byte[] buf = new byte[1024];
int bytesIn = 0;
FileOutputStream out = new FileOutputStream(file);
while ((bytesIn = in.read(buf, 0, 1024)) != -1) {
out.write(buf, 0, bytesIn);
}
in.close();
out.close();
flag = true;
}
catch(Exception e) {
e.printStackTrace();
}
finally {
try {
rs.close();
ps.close();
conn.close();
}
catch(Exception e) {
e.printStackTrace();
}
}
return flag;
}
public static void main(String[] 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"));
}
}
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
C#最小二乘法拟合曲线成直线的实例
![](https://img.aspxhome.com/file/2023/8/119598_0s.png)
MyBatis通用的10种写法总结大全
Springboot实现高吞吐量异步处理详解(适用于高并发场景)
C# 开发step步骤条控件详解
![](https://img.aspxhome.com/file/2023/0/80040_0s.png)
Android ActionBar搜索功能用法详解
Android 捕获运行时异常详解
Java语言中的文件数据流示例详解
![](https://img.aspxhome.com/file/2023/3/62773_0s.jpg)
Java中的阻塞队列详细介绍
Struts2之Validator验证框架的详细介绍
![](https://img.aspxhome.com/file/2023/9/99739_0s.png)
Java调用Shell命令的方法
java虚拟机中栈的运行知识点总结
spring配置文件解析失败报”cvc-elt.1: 找不到元素 ''beans'' 的声明”异常解决
![](https://img.aspxhome.com/file/2023/9/89639_0s.png)
详解Java读取Jar中资源文件及示例代码
java map转Multipart/form-data类型body实例
基于sharding-jdbc的使用限制
Spring的事务管理你了解吗
![](https://img.aspxhome.com/file/2023/4/88204_0s.png)
java8中:: 用法示例(JDK8双冒号用法)
springboot @Valid注解对嵌套类型的校验功能
![](https://img.aspxhome.com/file/2023/9/77159_0s.png)