发表于: 2004.12.05 14:44
分类: 工作
出处: http://junsheng.itpub.net/post/860/8559
---------------------------------------------------------------
package blobtest;
import javax.swing.*;
import java.io.*;
import java.sql.*;
//import DriverData;
import oracle.jdbc.driver.*;
import oracle.sql.*;
//import oracle.ord.im.*;
// Package for JDBC classes
import java.sql.Connection;
import java.sql.Clob;
import java.sql.ResultSet;
import java.sql.Blob;
import java.sql.Statement;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import oracle.jdbc.pool.OracleDataSource;
public class ReadAudioFromDB {
Connection conn;
Statement stmt;
ResultSet rs;
int bufferSize;
public ReadAudioFromDB()
throws SQLException, ClassNotFoundException {
String connectString;
Class.forName("oracle.jdbc.driver.OracleDriver");
connectString = "jdbc:oracle:oci8:@";
conn = (OracleConnection)
DriverManager.getConnection(connectString, "blobtest",
"1234");
stmt = conn.createStatement();
}
public void readFromDB() {
String pathname, name;
int amount = 0;
InputStream in = null;
BufferedOutputStream out = null;
JFileChooser chooser = new JFileChooser();
int returnVal = chooser.showOpenDialog(null);
if (returnVal == JFileChooser.APPROVE_OPTION) {
pathname = chooser.getSelectedFile().getAbsolutePath();
name = chooser.getSelectedFile().getName();
chooser = null;
}
else {
System.out.println("没有找到文件！");
System.out.println("程序非正常结束...");
return;
}
try {
rs = stmt.executeQuery(
"select BlobFile from audio where cavern_no='285' and document_id=1");
if (rs.next()) {
Blob blob = rs.getBlob(1);
in = blob.getBinaryStream();
bufferSize = ( (oracle.sql.BLOB) blob).getBufferSize();
out = new BufferedOutputStream(new FileOutputStream(pathname),
(int) bufferSize);
byte[] b = new byte[ (int) bufferSize];
int count = in.read(b, 0, (int) bufferSize);
while (count != -1) {
out.write(b, 0, count);
amount += count;
System.out.println("已经处理了" + amount + "字节.");
count = in.read(b, 0, (int) bufferSize);
}
System.out.println("成功处理完毕字节数:" + amount);
out.close();
out = null;
in.close();
in = null;
}
else {
System.out.println("文档:" + name + "未找到.");
}
}
catch (Exception e) {
e.printStackTrace();
}
finally {
if (out != null) {
try {
out.close();
}
catch (Exception ignored) {}
}
if (in != null) {
try {
in.close();
}
catch (Exception ignored) {}
}
}
}
}
＝＝＝＝＝＝＝
package blobtest;
import javax.swing.*;
import java.io.*;
import java.sql.*;
//import DriverData;
import oracle.jdbc.driver.*;
import oracle.sql.*;
//import oracle.ord.im.*;
// Package for JDBC classes
import java.sql.Connection;
import java.sql.Clob;
import java.sql.ResultSet;
import java.sql.Blob;
import java.sql.Statement;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import oracle.jdbc.pool.OracleDataSource;
public class WriteAudioToDB {
Connection conn;
Statement stmt;
ResultSet rs;
int bufferSize;
public WriteAudioToDB() throws SQLException, ClassNotFoundException {
String connectString;
Class.forName("oracle.jdbc.driver.OracleDriver");
connectString = "jdbc:oracle:oci8:@";
conn = (OracleConnection)
DriverManager.getConnection(connectString, "blobtest",
"1234");
stmt = conn.createStatement();
}
public void sendToDb() {
String pathname, name;
int amount = 0;
OutputStream out = null;
BufferedInputStream in = null;
JFileChooser chooser = new JFileChooser();
int returnVal = chooser.showOpenDialog(null);
if (returnVal == JFileChooser.APPROVE_OPTION) {
pathname = chooser.getSelectedFile().getAbsolutePath();
name = chooser.getSelectedFile().getName();
chooser = null;
}
else {
System.out.println("没有找到文件！");
System.out.println("程序非正常结束...");
return;
}
try {
conn.setAutoCommit(false);
stmt.executeUpdate("insert into document(cavern_no,audio_id,TITLE ,
ARCHITECTURE_ATTR_VAL ,PAINTED_SCULPTURE_ATTR_VAL,
FRESCO_ATTR_VAL,FOKAN_ATTR_VAL,BLOBFILE )
values("+"'285',2,'"+name+"','1111','111101','10101','10001',empty_blob())");
rs = stmt.executeQuery(
"select BlobFile from document where cavern_no='285' and document_id=1");
if (rs.next()) {
Blob blob = rs.getBlob("BlobFile");
out = ( (oracle.sql.BLOB) blob).getBinaryOutputStream();
bufferSize = ( (oracle.sql.BLOB) blob).getBufferSize();
in = new BufferedInputStream(new FileInputStream(pathname), bufferSize);
byte[] b = new byte[bufferSize];
int count = in.read(b, 0, bufferSize);
while (count != -1) {
out.write(b, 0, count);
amount += count;
System.out.println("处理了" + amount + "字节.");
count = in.read(b, 0, bufferSize);
System.out.println("处理了" + amount + "字节,成功.");
}
out.close();
out = null;
in.close();
in = null;
conn.commit();
}
}
catch (Exception e) {
e.printStackTrace();
try {
conn.rollback();
}
catch (Exception ignored) {}
}
finally {
if (out!=null) try{out.close();} catch(Exception igored){}
if (in!=null) try{in.close();} catch(Exception igored){}
}
}
}
re: 用jdbc操作Oracle Blob读写过程 
