package com.accp;
import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.OutputStream;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.swing.JFileChooser;
import oracle.jdbc.driver.OracleConnection;
public class MyTest {
Connection conn;
Statement stmt;
ResultSet rs;
int bufferSize;
public static void main(String[] args) {
MyTest test = new MyTest();
try {
test.writeAudioToDB();
test.sendToDb();
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
public void writeAudioToDB() throws SQLException, ClassNotFoundException {
String connectString;
Class.forName("oracle.jdbc.driver.OracleDriver");
connectString = "jdbc:oracle:thin:sky/sky@localhost:1521:orcl";
conn = (OracleConnection) DriverManager.getConnection(connectString,
"sky", "sky");
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 originalfile values('2001','mp3',empty_blob())");
rs = stmt
.executeQuery("select FILECONTENT from originalfile where FILECODE='2001'");
if (rs.next()) {
Blob blob = rs.getBlob("FILECONTENT");
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) {
}
}
}
}
oracle_java_blob.rar （7个子文件） 
oracle_java_blob 
.project 392B bin com accp MyTest.class 4KB MyTest2.class 3KB src com accp MyTest2.java 3KB MyTest.java 3KB .classpath 288B lib 
classes12.jar 1.14MB资源评论
asia19872014-03-27还没看呢，不知道是否是自己想要的
