日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

以下的文章主要是對(duì)Oracle數(shù)據(jù)庫(kù)中BLOB字段的存取問(wèn)題的介紹，我在經(jīng)常會(huì)碰到Oracle數(shù)據(jù)庫(kù)中BLOB字段的存取這一問(wèn)題，需求是將一個(gè)文件或者文件流存儲(chǔ)到Oracle數(shù)據(jù)庫(kù)里，Oracle8提供了Blob和Clob用來(lái)存儲(chǔ)二進(jìn)制大對(duì)象數(shù)據(jù)。

勃利網(wǎng)站建設(shè)公司成都創(chuàng)新互聯(lián)公司,勃利網(wǎng)站設(shè)計(jì)制作，有大型網(wǎng)站制作公司豐富經(jīng)驗(yàn)。已為勃利上1000家提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\外貿(mào)網(wǎng)站建設(shè)要多少錢，請(qǐng)找那個(gè)售后服務(wù)好的勃利做網(wǎng)站的公司定做！

可是它和Java.sql.里面的Blob不兼容，經(jīng)常導(dǎo)致Blob字段無(wú)法鎖定或者操作失敗，總之我總結(jié)了一些經(jīng)驗(yàn)大家共享。

首先建立測(cè)試數(shù)據(jù)表

 
 
 

  
  
  
drop table filelist;  
  
  
  
commit;  
  
  
  
CREATE TABLE SYSTEM.FILELIST (  
  
  
  
"FILENAME" VARCHAR2(50) NOT NULL,  
  
  
  
"FILESIZE" NUMBER(20) NULL,  
  
  
  
"FILEBODY" BLOB NULL,  
  
  
  
PRIMARY KEY("FILENAME"), UNIQUE("FILENAME")) ;  
  
  
  
commit;  
 
 
 

 

測(cè)試過(guò)程，首先將硬盤(pán)文件讀入Oracle數(shù)據(jù)庫(kù)，然后再讀出到硬盤(pán)的另一個(gè)新文件里，原碼如下：

 
 
 

  
  
  
import java.io.*;  
  
  
  
import java.util.*;  
  
  
  
import java.sql.*;  
  
  
  
import oracle.sql.*;  
  
  
  
import oracle.jdbc.driver.*;  
  
  
  
import java.text.*;  
  
  
  
public class test  
  
  
  
{  
  
  
  
public static void main(String args[]) throws java.io.IOException,java.sql.SQLException  
  
  
  
{  
  
  
  
dbBean db1=new dbBean();  
  
  
  
/**  
 
 
 

 

*這里是我的數(shù)據(jù)聯(lián)接Bean

*大家可以用自己的連接Bean

 
 
 

  
  
  
*/  
  
  
  
byte a[]=null;  
 
 
 

 

**將測(cè)試文件test.doc讀入此字節(jié)數(shù)組

 
 
 

  
  
  
java.io.FileInputStream fin=null;  
  
  
  
java.io.FileOutputStream fout=null;  
  
  
  
oracle.jdbc.OracleResultSet ors=null；  
 
 
 

 

**這里rs一定要用Oracle數(shù)據(jù)庫(kù)提供的

 
 
 

  
  
  
oracle.jdbc.driver.OraclePreparedStatement opst=null; 
 
 
 

**PreparedStatement用

Oracle提供的

 
 
 

  
  
  
try  
  
  
  
{  
  
  
  
java.io.File f1=new java.io.File("c:/temp/test.doc");  
  
  
  
java.io.File f2=new java.io.File("c:/temp/testout.doc");  
 
 
 

**從BLOB讀出的信息寫(xiě)

//入該文件，和源文件對(duì)比測(cè)試用

 
 
 

  
  
  
fin=new java.io.FileInputStream(f1);  
  
  
  
fout=new java.io.FileOutputStream(f2);  
 
 
 

 

int flength=(int)f1.length();//**讀入文件的字節(jié)長(zhǎng)度

 
 
 

  
  
  
System.out.println("file length::"+flength);  
  
  
  
a=new byte[flength];  
  
  
  
int i=0;int itotal=0;  
 
 
 

 

/**將文件讀入字節(jié)數(shù)組

 
 
 

  
  
  
for (;itotal
  
  
  
{  
  
  
  
i=fin.read(a,itotal,flength-itotal);  
  
  
  
}  
  
  
  
fin.close();  
  
  
  
System.out.println("read itotal::"+itotal);  
 
 
 

 

/**注意Oracle數(shù)據(jù)庫(kù)的 BLOB一定要用EMPTY_BLOB()初始化

 
 
 

  
  
  
String mysql="insert into filelist (FileName,FileSize,FileBody) values (?,?,EMPTY_BLOB())";  
  
  
  
opst=(oracle.jdbc.driver.OraclePreparedStatement)db1.conn.prepareStatement(mysql);  
  
  
  
opst.setString(1,"wordtemplate");  
  
  
  
opst.setInt (2,flength);  
  
  
  
opst.executeUpdate();  
  
  
  
opst.clearParameters();  
 
 
 

 

/**插入其它數(shù)據(jù)后，定位BLOB字段

 
 
 

  
  
  
mysql="select filebody from filelist where filename=?";  
  
  
  
opst=(oracle.jdbc.driver.OraclePreparedStatement)db1.conn.prepareStatement(mysql);  
  
  
  
opst.setString(1,"wordtemplate");  
  
  
  
ors=(oracle.jdbc.OracleResultSet)opst.executeQuery();  
  
  
  
if (ors.next())  
  
  
  
{  
 
 
 

 

oracle.sql.BLOB blob=ors.getBLOB(1);/**得到BLOB字段

int j=blob.putBytes(1,a);/**將字節(jié)數(shù)組寫(xiě)入BLOB字段

 
 
 

  
  
  
System.out.println("j:"+j);  
  
  
  
db1.conn.commit();  
  
  
  
ors.close();  
  
  
  
}  
  
  
  
System.out.println("insert into ok");  
 
 
 

 

byte b[]=null;/**保存從BLOB讀出的字節(jié)

 
 
 

  
  
  
opst.clearParameters();  
  
  
  
mysql="select filebody from filelist where filename=?";  
  
  
  
opst=(oracle.jdbc.driver.OraclePreparedStatement)db1.conn.prepareStatement(mysql);  
  
  
  
opst.setString(1,"wordtemplate");  
  
  
  
ors=(oracle.jdbc.OracleResultSet)opst.executeQuery();  
  
  
  
if (ors.next())  
  
  
  
{  
  
  
  
oracle.sql.BLOB blob2=ors.getBLOB(1);  
  
  
  
System.out.println("blob2 length:"+blob2.length());  
 
 
 

 

b=blob2.getBytes(1,flength);/**從BLOB取出字節(jié)流數(shù)據(jù)

 
 
 

  
  
  
System.out.println("b length::"+b.length);  
  
  
  
db1.conn.commit();  
  
  
  
}  
  
  
  
ors.close();  
 
 
 

 

/**將從BLOB讀出的字節(jié)寫(xiě)入文件

 
 
 

  
  
  
fout.write(b,0,b.length);  
  
  
  
fout.close();  
  
  
  
System.out.println("write itotal::"+b.length);  
  
  
  
}  
  
  
  
catch(Exception e)  
  
  
  
{  
  
  
  
System.out.println("errror :"+e.toString() );  
  
  
  
e.printStackTrace();  
  
  
  
}  
  
  
  
finally  
 
 
 

 

{ /**關(guān)閉所有數(shù)據(jù)聯(lián)接

 
 
 

  
  
  
stmt.close();  
  
  
  
db1.closeConn();  
  
  
  
}  
  
  
  
}  
  
  
  
}  
 
 
 

 

編譯運(yùn)行在TomCat下調(diào)試通過(guò)。

需要注意的是Blob存取的過(guò)程，一般先存入和BLOB相關(guān)的控制數(shù)據(jù)，如文件的名字，然后查詢定位BLOB字段，利用Oracle數(shù)據(jù)庫(kù)Blob提供的方法：

 
 
 

  
  
  
public int putBytes(long pos,byte bytes[])  
  
  
  
public byte[] getBytes(long pos,byte bytes[])  
 
 
 

 

或者利用

 
 
 

  
  
  
public OutputStream getBinaryOutputStream() throws SQLException  
  
  
  
public InputStream getBinaryStream() throws SQLException  
 
 
 

 

因?yàn)槔幂斎胼敵隽骺倸w還是利用到字節(jié)數(shù)組緩沖流，所以就不舉例子了。

網(wǎng)頁(yè)名稱：Oracle數(shù)據(jù)庫(kù)中BLOB字段的存取問(wèn)題
網(wǎng)頁(yè)路徑：http://m.5511xx.com/article/dhghcii.html