JDBC+Hibernate将Blob数据写入Oracle

2016-01-29 12:55 18 1 收藏

JDBC+Hibernate将Blob数据写入Oracle,JDBC+Hibernate将Blob数据写入Oracle

【 tulaoshi.com - Java 】

  Oracle的Blob字段比较特殊,他比long字段的性能要好很多,可以用来保存例如图片之类的二进制数据。

  写入Blob字段和写入其它类型字段的方式非常不同,因为Blob自身有一个cursor,你必须使用cursor对blob进行操作,因而你在写入Blob之前,必须获得cursor才能进行写入,那么如何获得Blob的cursor呢?

  这需要你先插入一个empty的blob,这将创建一个blob的cursor,然后你再把这个empty的blob的cursor用select查询出来,这样通过两步操作,你就获得了blob的cursor,可以真正的写入blob数据了。

  看下面的JDBC的demo,把oraclejdbc.jar这个二进制文件写入数据库表javatest的content字段(这是一个blob型字段)

  import java.sql.*;
  import java.io.*;
  import oracle.sql.*;
  public class WriteBlob {

  public static void main(String[] args) {

  try {
  DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
  Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl","fankai","fankai");
  conn.setAutoCommit(false);

  BLOB blob = null;

  PreparedStatement pstmt = conn.prepareStatement("insert into javatest(name,content) values(?,empty_blob())");
  pstmt.setString(1,"fankai");
  pstmt.executeUpdate();
  pstmt.close();

  pstmt = conn.prepareStatement("select content from javatest where name= ? for update");
  pstmt.setString(1,"fankai");
  ResultSet rset = pstmt.executeQuery();
  if (rset.next()) blob = (BLOB) rset.getBlob(1);

  String fileName = "oraclejdbc.jar";
  File f = new File(fileName);
  FileInputStream fin = new FileInputStream(f);
  System.out.println("file size = " + fin.available());

  pstmt = conn.prepareStatement("update javatest set content=? where name=?");

  OutputStream out = blob.getBinaryOutputStream();

  int count = -1, total = 0;
  byte[] data = new byte[(int)fin.available()];
  fin.read(data);
  out.write(data);
  /*
  byte[] data = new byte[blob.getBufferSize()]; 另一种实现方法,节省内存
  while ((count = fin.read(data)) != -1) {
   total += count;
   out.write(data, 0, count);
  }
  */

  fin.close();
  out.close();

  pstmt.setBlob(1,blob);
  pstmt.setString(2,"fankai");

  pstmt.executeUpdate();
  pstmt.close();

  conn.commit();
  conn.close();
  } catch (SQLException e) {
    System.err.println(e.getMessage());
  e.printStackTrace();
  } catch (IOException e) {
  System.err.println(e.getMessage());
  }
  }

  }

  仔细看上例,分三步:

  1、插入空blob

  into javatest(name,content) values(?,empty_blob());

  2、获得blob的cursor

  select content from javatest where name= ? for update;

  注意!!!必须加for update,这将锁定该行,直至该行被修改完毕,保证不产生并发冲突。

  3、update javatest set content=? where name=

  用cursor往数据库写数据

  这里面还有一点要提醒大家:

  JDK1.3带的JDBC2.0规范是不完善的,只有读Blob的接口,而没有写Blob的接口,JDK1.4带的JDBC3.0加入了写Blob的接口。你可以使用JDBC3.0的接口,也可以直接使用Oracle的JDBC的API,我在上例中使用了Oracle的JDBC的API。

  另外要注意的是:

  java.sql.Blob

  oracle.sql.BLOB

  注意看blob的大小写,是不一样的。写程序的时候不要搞混了。

  下面看看用Hibernate怎么写,原理是一样的,也要分三步,但是代码简单很多

  这是Cat对象定义

  package com.fankai;

  import java.sql.Blob;

  public class Cat {
  private String id;
  private String name;
  private char sex;
  private float weight;
  private Blob image;
  public Cat() { }

  public String getId() { return id; }
  public void setId(String id) { this.id = id; }

  public String

来源:http://www.tulaoshi.com/n/20160129/1488089.html

延伸阅读
标签: Web开发
代码如下: Usertable user=null; Session session=HibernateSessionFactory.getSession(); String sql="from Usertable as user where user.username=?"; Query q=session.createQuery(sql); q.setString(0,username); List l=q.list(); Iterator ite=l.iterator(); if(ite.hasNext()){ user=(Usertable)ite.next(); } return user;...
    在Oracle 9i中可以方便的把数据导出为文件,或者从文件导入。通过Oracle的管理服务器(Oracle Management Server,OMS)可以方便的实现,整个操作过程中有很多地方需要解释说明,但是完整的指导资料不多。各大论坛上很多所谓的高手,对该主题的回答往往是,高手是不用OMS的,用exp/impl吧。如果你执意追问,他多半会告诉你...
第一种:使用JDBC的ACCESS驱动程序:在http://industry.java.sun.com/products/jdbc/drivers下载ACCESS的JDBC驱动程序。 第二种:使用JDBC-ODBC桥访问: Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); conn = DriverManager.getConnection("jdbc:odbc:dbaccess"); 第三种:直接访问ACCESS数据库,不使用JDBC-ODBC桥: Class.forNam...
标签: Java JAVA基础
在 struts+ hibernate 这种结构中,是不应该把Hibernate产生的PO直接传递给JSP的,不管他是Iterator,还是List,这是一个设计错误。 我来谈谈在J2EE架构中各层的数据表示方法: Web层的数据表示是FormBean,数据来源于HTML Form POST 业务层的数据表示是VO 持久层的数据表示是PO,其数据来源于数据库,...
标签: PHP
  来源:奥索网 桌面中心(二)数据库写入 作者:elong 一、以下是数据库的写入的html程序,你可以加入密码功能。把密码做成变量发入下面那个写入的php程序。这样就实现了密码保护了: <html <head <title数据库</title <meta http-equiv="Content-Type" content="text/html; charset=gb2312" &...

经验教程

550

收藏

95

精华推荐

微博分享 QQ分享 QQ空间 手机页面 收藏网站 回到头部