- 浏览: 524245 次
- 性别:
- 来自: 北京
最新评论
-
johnsontang:
同样碰到这样的问题,修改用户密码后就好了,估计是密码过期了。
oracle RAC ORA-03113 错误解决 -
zhangzijun1984:
赞!很快的了解了python对文件的大部分操作,以及pickl ...
Python文件操作读写文件 -
ZJ133520:
ftp的用户名口令是多少啊?
oracle 9i/10g安装包和PATCH下载地址汇总 -
jspc:
ok yes thanks
UltraEdit 不能复制粘贴 -
maincoolbo:
piaoxue_x 写道嗯,很详细,看看再说……
这 ...
Oracle归档日志删除
设有表:
create table blobimg (id int primary key, contents blob);
一、BLOB入库的专用访问:
1) 最常见于Oracle的JDBC示例中
一般是先通过select ... for update锁定blob列,然后写入blob值,然后提交。要用到特定的Oracle BLOB类。
2) 再厉害一点的,是通过调用DBMS_LOB包中的一些函数来处理,效率好像也不错.
不过,要使用到存储过程,用到专用类OracleCallableStatement。
例:
二、BLOB值读取的通用处理:
这个jdbc标准接口可以直接调用,因此比较简单,如下所示:
三、BLOB值写入的通用处理:
这时要借助于PreparedStatement的动态绑定功能,借用其setObject()方法插入字节流到BLOB字段。
四. CLOB读取的通用处理
当然还可以直接编写BLOB存取的存储过程供JDBC调用,那也非常方便。不过可能要用到外部LOB类型。这将在后边陆续进行介绍。
To be contd.
create table blobimg (id int primary key, contents blob);
一、BLOB入库的专用访问:
1) 最常见于Oracle的JDBC示例中
一般是先通过select ... for update锁定blob列,然后写入blob值,然后提交。要用到特定的Oracle BLOB类。
Class.forName("oracle.jdbc.driver.OracleDriver"); Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:testdb", "test", "test"); //处理事务 con.setAutoCommit(false); Statement st = con.createStatement(); //插入一个空对象 st.executeUpdate("insert into BLOBIMG values(1,empty_blob())"); //用for update方式锁定数据行 ResultSet rs = st.executeQuery( "select contents from BLOBIMG where id=1 for update"); if (rs.next()) { //使用oracle.sql.BLOB类,没办法了,变成专用的了 oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob(1).; //到数据库的输出流 OutputStream outStream = blob.getBinaryOutputStream(); //这里用一个文件模拟输入流 File file = new File("d:\\proxy.txt"); InputStream fin = new FileInputStream(file); //将输入流写到输出流 byte[] b = new byte[blob.getBufferSize()]; int len = 0; while ( (len = fin.read(b)) != -1) { outStream.write(b, 0, len); } //依次关闭 fin.close(); outStream.flush(); outStream.close(); } con.commit(); con.close();
2) 再厉害一点的,是通过调用DBMS_LOB包中的一些函数来处理,效率好像也不错.
不过,要使用到存储过程,用到专用类OracleCallableStatement。
例:
import java.sql.*; import java.io.*; import oracle.jdbc.driver.*; import oracle.sql.*; class TestBlobWriteByDBMS_LOB { public static void main (String args []) throws SQLException , FileNotFoundException, IOException { DriverManager.registerDriver (new oracle.jdbc.driver.OracleDriver()); Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:ora92","scott","tiger"); conn.setAutoCommit(false); Statement stmt = conn.createStatement(); stmt.execute( "delete from demo" ); System.out.println( "deleted from demo" ); stmt.execute( "insert into demo (id,theBlob) values (s_enr.nextval,empty_blob())" ); conn.commit(); System.out.println( "committed" ); ResultSet rset = stmt.executeQuery ("SELECT theBlob FROM demo where id = s_enr.currval FOR UPDATE"); System.out.println( "Executed Query" ); if(rset.next()) { System.out.println( "Fetched row " ); BLOB l_mapBLOB = ((OracleResultSet)rset).getBLOB(1); File binaryFile = new File("e:\\free\\jo.jpg"); FileInputStream instream=new FileInputStream(binaryFile); int chunk = 32000; System.out.println( "Chunk = "+ chunk ); byte[] l_buffer = new byte[chunk]; int l_nread = 0; OracleCallableStatement cstmt = (OracleCallableStatement)conn.prepareCall( "begin dbms_lob.writeappend( :1, :2, :3 ); end;" ); cstmt.registerOutParameter( 1, OracleTypes.BLOB ); while ((l_nread= instream.read(l_buffer)) != -1) { cstmt.setBLOB( 1, l_mapBLOB ); cstmt.setInt( 2, l_nread ); cstmt.setBytes( 3, l_buffer ); cstmt.executeUpdate(); l_mapBLOB = cstmt.getBLOB(1); } instream.close(); conn.commit(); rset.close(); stmt.close(); conn.close(); } } }
二、BLOB值读取的通用处理:
这个jdbc标准接口可以直接调用,因此比较简单,如下所示:
Connection con = ConnectionFactory.getConnection(); con.setAutoCommit(false); Statement st = con.createStatement(); ResultSet rs = st.executeQuery("select contents from BLOBIMG where id=1"); if (rs.next()) { java.sql.Blob blob = rs.getBlob(1); InputStream ins = blob.getBinaryStream(); //输出到文件 File file = new File("d:\\output.txt"); OutputStream fout = new FileOutputStream(file); //下面将BLOB数据写入文件 byte[] b = new byte[1024]; int len = 0; while ( (len = ins.read(b)) != -1) { fout.write(b, 0, len); } //依次关闭 fout.close(); ins.close(); } con.commit(); con.close();
三、BLOB值写入的通用处理:
这时要借助于PreparedStatement的动态绑定功能,借用其setObject()方法插入字节流到BLOB字段。
public void insertFile(File f) throws Exception{ FileInputStream fis=new FileInputStream(f,Connection conn); byte[] buffer=new byte[1024]; data=null; int sept=0;int len=0; while((sept=fis.read(buffer))!=-1){ if(data==null){ len=sept; data=buffer; }else{ byte[] temp; int tempLength; tempLength=len+sept; temp=new byte[tempLength]; System.arraycopy(data,0,temp,0,len); System.arraycopy(buffer,0,temp,len,sept); data=temp; len=tempLength; } if(len!=data.length()){ byte temp=new byte[len]; System.arraycopy(data,0,temp,0,len); data=temp; } } String sql="insert into fileData (filename,blobData) value(?,?)"; PreparedStatement ps=conn.prepareStatement(sql); ps.setString(1,f.getName()); ps.setObject(2,data); ps.executeUpdate(); }
四. CLOB读取的通用处理
public static String getClobString(ResultSet rs, int col) { try { Clob c=resultSet.getClob(2); Reader reader=c.getCharacterStream(): if (reader == null) { return null; } StringBuffer sb = new StringBuffer(); char[] charbuf = new char[4096]; for (int i = reader.read(charbuf); i > 0; i = reader.read(charbuf)) { sb.append(charbuf, 0, i); } return sb.toString(); } catch (Exception e) { return ""; } }
当然还可以直接编写BLOB存取的存储过程供JDBC调用,那也非常方便。不过可能要用到外部LOB类型。这将在后边陆续进行介绍。
To be contd.
发表评论
-
linux redhat5安装jdk
2011-09-20 13:38 18091.安装 我这里下载的是jdk-6u13-linux-i ... -
eclipse 图标的含义,记录一下
2011-02-24 09:52 1985Objects Compilation ... -
在MyEclipse中启动Tomcat访问网页时出现503错误
2011-01-12 14:44 5558MyEclipse中设置好Tomcat的相关选项后, ... -
Tomcat优化方案
2011-01-07 10:33 1797Tomcat优化方案 调优方案分类: 1,外部环境调优 2, ... -
http https 区别
2010-09-20 10:58 1304HTTPS(Secure Hypertext Tran ... -
MyEclipse 的 优化大法
2010-09-13 16:54 983MyEclipse 优化 相信大家在启动MyEc ... -
Eclipse+MyEclipse总是显示quick update的解决办法
2010-09-02 08:34 2549这个问题的解决办法是关闭自动更新 Windows > ... -
Java Applet签名验证
2010-08-19 16:50 3451本系统的客户程序是Java Applet,但它的执行需要读本地 ... -
数据库连接池的好处
2010-08-04 11:37 1166关键字: 数据库 对 ... -
什么是EJB?
2010-05-31 13:45 3055... -
Eclipse 快捷键
2010-05-27 11:41 861Eclipse 快捷键 Ctrl+1 快速修复(最经典的快捷 ... -
MyEclipse总是显示quick update的解决办法
2010-05-27 09:01 254这个问题的解决办法是关闭自动更新 Windows &g ... -
Java中的native关键字浅析(Java Native Interface)
2010-05-21 09:50 6724native关键字用法 native是与C++联合开 ... -
String 与StringBuffer的区别
2010-05-14 14:30 1059:String 与StringBuffer的区 ... -
WebService是什么
2010-04-01 14:23 2215WebService是什么? We ... -
UltraEdit 不能复制粘贴
2010-03-30 15:38 12296UltraEdit 是每天必用的工 ... -
Java面试题xxx
2010-03-17 11:16 5761文章分类:Java编程 一、 ... -
使用Java组件itext 生成pdf介绍
2010-02-23 13:11 1987iText是一个能够快速产生PDF文件的java类库。iTe ... -
Java常碰面试题
2010-01-27 11:53 12301、jsp和servlet的区别、 ... -
java排序
2009-11-18 13:46 1501这个编辑器不错哈 0.排序基类 /** ...
相关推荐
JDBC中操作Blob、Clob等对象 实例详细JDBC中操作Blob、Clob等对象 实例详细JDBC中操作Blob、Clob等对象 实例详细JDBC中操作Blob、Clob等对象 实例详细JDBC中操作Blob、Clob等对象 实例详细JDBC中操作Blob、Clob等...
JDBC中操作Blob、Clob等对象
oracle中的Blob和Clob区别,希望对大家学习有帮助呵
oracle中使用jdbc读写clob字段,很多细节介绍,内容全面。
JDBC读写Oracle的CLOB字段
oracle Blob转换Clob
weblogic下转换oracle 的clob类型经常报转型错误,本例子通过反射解决weblogic.jdbc.wrapper.Clob_oracle_sql_CLOB转型成oracle.sql.CLOB问题
Oracle导出Clob,Blob等大字段工具,自己写的工具,方便大家下载使用
spring 中对大数据的处理,包括clob,blob的数据。比之jdbc下简便很多。
oracle Blob Clob 大数处理 代码 文件上传 下载
BLOB和CLOB的区别以及在ORALCE中的插入和查询操作
简单写的一个小工具,把图片存入oracle中,按clob和blob两种方式存储,并读取图片
前两个例子的Demo 博文链接:https://zhangguanzhong.iteye.com/blog/623489
UTL_RAW.CAST_TO_VARCHAR2
jdbc 操作oracle blob数据jdbc 操作oracle blob数据jdbc 操作oracle blob数据jdbc 操作oracle blob数据jdbc 操作oracle blob数据jdbc 操作oracle blob数据jdbc 操作oracle blob数据jdbc 操作oracle blob数据jdbc ...
Mybatis 处理 CLOB、BLOB 类型数据
NULL 博文链接:https://shihuan830619.iteye.com/blog/1662937
clob和blob在jdbc的应用~~~~~~
使用Hibernate映射Blob,Clob字段,并对这些字段完成存,取功能