如何在java中读取oracle blob

发布网友 发布时间：2022-04-30 20:12

我来回答

共3个回答

懂视网 时间：2022-05-01 00:33

获得数据库连接 Connection con = ConnectionFactory.getConnection(); con.setAutoCommit(false); Statement st = con.createStatement(); //不需要“for update” ResultSet rs = st.executeQuery("select BLOBATTR from TESTBLOB where ID=1"); if (rs.next()) { java.sql.Blob blob = rs.getBlob("BLOBATTR"); InputStream inStream = blob.getBinaryStream(); //data是读出并需要返回的数据，类型是byte[] data = new byte[input.available()]; inStream.read(data); inStream.close(); } inStream.close(); con.commit(); con.close();

 

2、 put

BLOB

java 代码

1. //获得数据库连接 
    Connection con = ConnectionFactory.getConnection(); 
    con.setAutoCommit(false); 
    Statement st = con.createStatement(); 
    //插入一个空对象empty_blob() 
    st.executeUpdate("insert into TESTBLOB (ID, NAME, BLOBATTR) values (1, "thename", empty_blob())"); 
    //锁定数据行进行更新，注意“for update”语句 
    ResultSet rs = st.executeQuery("select BLOBATTR from TESTBLOB where ID=1 for update"); 
    if (rs.next()) 
    { 
    //得到java.sql.Blob对象后强制转换为oracle.sql.BLOB 
    oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob("BLOBATTR"); 
    OutputStream outStream = blob.getBinaryOutputStream(); 
    //data是传入的byte数组，定义：byte[] data 
    outStream.write(data, 0, data.length); 
    } 
    outStream.flush(); 
    outStream.close(); 
    con.commit(); 
    con.close(); 

    

java操作oracle的blob,clob数据

标签：

热心网友 时间：2022-04-30 21:41

整个流程分为四步，连接oracle数据库 -> 读取blob图片字段 -> 对图片进行缩放 ->把图片展示在jsp页面上。

下面进行详细描述：
1. java连接Oracle

注：数据库是Oracle10g版本为10.2.0, 在数据库中，图片字段类型为BLOB。

java中通常使用的是通过jdbc驱动来连接数据库，oracle也不例外，因此必须下载一个Oracle驱动的jdbc需要去网上进行下载,名称为 ojdbc14.jar。

下载地址为:

下载了驱动之后，可以使用驱动里提供的接口进行连接，具体代码如下：

import java.sql.*;

import java.io.*;

import javax.imageio.ImageIO;

import java.awt.image.BufferedImage;

import java.awt.image.AffineTransformOp;

import java.awt.geom.AffineTransform;

public class OracleQueryBean {

private final String oracleDriverName = "oracle.jdbc.driver.OracleDriver";

private Connection myConnection = null;

/*图片表名*/

private String strTabName;

/*图片ID字段名*/

private String strIDName;

/*图片字段名*/

private String strImgName;

/**

* 加载java连接Oracle的jdbc驱动

*/

public OracleQueryBean(){

try{

Class.forName(oracleDriverName);

}catch(ClassNotFoundException ex){

System.out.println("加载jdbc驱动失败,原因:" + ex.getMessage());

}

}

/**

* 获取Oracle连接对象

* @return Connection

*/

public Connection getConnection(){

try{

//用户名+密码; 以下使用的Test就是Oracle里的表空间

//从配置文件中读取数据库信息

GetPara oGetPara = new GetPara();

String strIP = oGetPara.getPara("serverip");

String strPort = oGetPara.getPara("port");

String strDBName = oGetPara.getPara("dbname");

String strUser = oGetPara.getPara("user");

String strPassword = oGetPara.getPara("password");

this.strTabName = oGetPara.getPara("tablename");

this.strIDName = oGetPara.getPara("imgidname");

this.strImgName = oGetPara.getPara("imgname");

String oracleUrlToConnect ="jdbc:oracle:thin:@"+strIP+":"+strPort+":"+strDBName;

this.myConnection = DriverManager.getConnection(oracleUrlToConnect, strUser, strPassword);

}catch(Exception ex){

System.out.println("Can not get connection:" + ex.getMessage());

System.out.println("请检测配置文件中的数据库信息是否正确." );

}

return this.myConnection;

}

}
2. 读取blob字段

在OracleQueryBean类中增加一个函数，来进行读取，具体代码如下：

/**

* 根据图片在数据库中的ID进行读取

* @param strID图片字段ID

* @param w 需要缩到的宽度

* @param h 需要缩到高度

* @return

*/

public byte[] GetImgByteById(String strID, int w, int h){

//System.out.println("Get img data which id is " + nID);

if(myConnection == null)

this.getConnection();

byte[] data = null;

try {

Statement stmt = myConnection.createStatement();

ResultSet myResultSet = stmt.executeQuery("select " + this.strIDName + " from " + this.strTabName + " where " + this.strIDName + "=" + strID);

StringBuffer myStringBuffer = new StringBuffer();

if (myResultSet.next()) {

java.sql.Blob blob = myResultSet.getBlob(this.strImgName);

InputStream inStream = blob.getBinaryStream();

try {

long nLen = blob.length();

int nSize = (int) nLen;

//System.out.println("img data size is :" + nSize);

data = new byte[nSize];

inStream.read(data);

inStream.close();

} catch (IOException e) {

System.out.println("获取图片数据失败,原因:" + e.getMessage());

}

data = ChangeImgSize(data, w, h);

}

System.out.println(myStringBuffer.toString());

myConnection.commit();

myConnection.close();

} catch (SQLException ex) {

System.out.println(ex.getMessage());

}

return data;

}

3. 缩放图片

因为图片的大小可能不一致，但是在页面中输出的大小需要统一，所以需要

在OracleQueryBean类中增加一个函数，来进行缩放，具体代码如下：

/**

* 缩小或放大图片

* @param data 图片的byte数据

* @param w 需要缩到的宽度

* @param h 需要缩到高度

* @return 缩放后的图片的byte数据

*/

private byte[] ChangeImgSize(byte[] data, int nw, int nh){

byte[] newdata = null;

try{

BufferedImage bis = ImageIO.read(new ByteArrayInputStream(data));

int w = bis.getWidth();

int h = bis.getHeight();

double sx = (double) nw / w;

double sy = (double) nh / h;

AffineTransform transform = new AffineTransform();

transform.setToScale(sx, sy);

AffineTransformOp ato = new AffineTransformOp(transform, null);

//原始颜色

BufferedImage bid = new BufferedImage(nw, nh, BufferedImage.TYPE_3BYTE_BGR);

ato.filter(bis, bid);

//转换成byte字节

ByteArrayOutputStream baos = new ByteArrayOutputStream();

ImageIO.write(bid, "jpeg", baos);

newdata = baos.toByteArray();

}catch(IOException e){

e.printStackTrace();

}

return newdata;

}

4. 展示在页面

页面使用OracleQueryBean来根据用户提供的图片id进行查询，在读取并进行缩放后，通过jsp页面进行展示，具体代码如下：

<%@ page language="java" contentType="text/html;;charset=gbk" %>

<jsp:useBean id="OrcleQuery" scope="page" class="HLFtiDemo.OracleQueryBean" />

<%

response.setContentType("image/jpeg");

//图片在数据库中的 ID

String strID = request.getParameter("id");

//要缩略或放大图片的宽度

String strWidth = request.getParameter("w");

//要缩略或放大图片的高度

String strHeight = request.getParameter("h");

byte[] data = null;

if(strID != null){

int nWith = Integer.parseInt(strWidth);

int nHeight = Integer.parseInt(strHeight);

//获取图片的byte数据

data = OrcleQuery.GetImgByteById(strID, nWith, nHeight);

ServletOutputStream op = response.getOutputStream();

op.write(data, 0, data.length);

op.close();

op = null;

response.flushBuffer();

//清除输出流，防止释放时被捕获异常

out.clear();

out = pageContext.pushBody();

}

%>

5. OracleQueryBean查询类的整体代码

OracleQueryBean.java文件代码如下所示：

import java.sql.*;

import java.io.*;

import javax.imageio.ImageIO;

import java.awt.image.BufferedImage;

import java.awt.image.AffineTransformOp;

import java.awt.geom.AffineTransform;

public class OracleQueryBean {

private final String oracleDriverName = "oracle.jdbc.driver.OracleDriver";

private Connection myConnection = null;

/*图片表名*/

private String strTabName;

/*图片ID字段名*/

private String strIDName;

/*图片字段名*/

private String strImgName;

/**

* 加载java连接Oracle的jdbc驱动

*/

public OracleQueryBean(){

try{

Class.forName(oracleDriverName);

}catch(ClassNotFoundException ex){

System.out.println("加载jdbc驱动失败,原因:" + ex.getMessage());

}

}

/**

* 获取Oracle连接对象

* @return Connection

*/

public Connection getConnection(){

try{

//用户名+密码; 以下使用的Test就是Oracle里的表空间

//从配置文件中读取数据库信息

GetPara oGetPara = new GetPara();

这文章确实写的不错，你可以看原文

热心网友 时间：2022-04-30 22:59

byte[] content = null;
java.sql.Blob blob = rs.getBlob("字段名");
if (blob != null){
inStream = blob.getBinaryStream();
bot = new ByteArrayOutputStream();
byte[] b = new byte[1024];
int len = 0;
while ((len = inStream.read(b)) != -1) {
bot.write(b, 0, len);
}
content = bot.toByteArray();
}