From Gossip@Openhome

Java Gossip: 將檔案存入資料庫

如果將要檔案寫入資料庫,您可以在欄位上使用BLOB或CLOB資料型態BLOB全名Binary Large Object,用於儲存大量的二進位資料,CLOB全名Character Large Object,用於儲存大量的文字資料。

在JDBC中也提供了Blob與Clob兩個類別分別代表BLOB與CLOB資料,您可以使用PreparedStatement的setBinaryStream()、 setObject()、setAsciiStream()、setUnicodeStream()等方法來代替,例如我們可以如下取得一個檔案,並將之存入資料庫中:
// 取得檔案
File file = new File("./logo_phpbb.jpg");
int length = (int) file.length();
InputStream fin = new FileInputStream(file);
 
// 填入資料庫
PreparedStatement pstmt = conn.prepareStatement(
                       "INSERT INTO files VALUES(?, ?)");

pstmt.setString(1, "米小國Logo");
pstmt.setBinaryStream (2, fin, length);

pstmt.executeUpdate();
pstmt.clearParameters();
pstmt.close();
fin.close();
 

如果要從資料庫中取得BLOB或CLOB資料,您可以如下進行:
Blob blob = result.getBlob(2);  // 取得BLOB
Clob clob = result.getClob(2)  // 取得CLOB 
 

Blob擁有getBinaryStream()、getBytes()等方法,可以取得二進位串流或byte等資料,同樣的,Clob擁有getCharacterStream()、getSubString()等方法,可以取得字元串流或子字串等資料,您可以查看API文件來獲得更詳細的訊息。

下面這個程式示範基本的檔案存入資料庫並取出另存新檔:

  • BLOBCLOBDemo.java
package onlyfun.caterpillar;
 
import java.io.*;
import java.sql.*;

public class BLOBCLOBDemo {
public static void main(String[] args) {
String driver = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://localhost:3306/upload?" +
"useUnicode=true&characterEncoding=Big5";

String user = "caterpillar";
String password = "123456";

try {
Class.forName(driver);

Connection conn = null;
PreparedStatement pstmt = null;

try {
conn = DriverManager.getConnection(
url, user, password);

// 取得檔案
File file = new File("./logo_phpbb.jpg");
int length = (int) file.length();
InputStream fin = new FileInputStream(file);

// 填入資料庫
pstmt = conn.prepareStatement(
"INSERT INTO files VALUES(?, ?)");
pstmt.setString(1, "米小國Logo");
pstmt.setBinaryStream (2, fin, length);
pstmt.executeUpdate();
pstmt.clearParameters();

fin.close();
}
catch(SQLException e) {
e.printStackTrace();
}
catch(IOException e) {
e.printStackTrace();
}
finally {
if(pstmt != null) {
try {
pstmt.close();
}
catch(SQLException e) {
e.printStackTrace();
}
}
}

Statement stmt = null;

try {
// 從資料庫取出檔案
stmt = conn.createStatement();
ResultSet result = stmt.executeQuery(
"SELECT * FROM files");
result.next();
String description = result.getString(1);
Blob blob = result.getBlob(2);

// 寫入檔案
System.out.println("檔案描述:" + description);
FileOutputStream fout =
new FileOutputStream("./logo_phpbb_2.jpg");
fout.write(blob.getBytes(1, (int)blob.length()));
fout.flush();
fout.close();
}
catch(SQLException e) {
e.printStackTrace();
}
catch(IOException e) {
e.printStackTrace();
}
finally {
if(stmt != null) {
try {
stmt.close();
}
catch(SQLException e) {
e.printStackTrace();
}
}
if(conn != null) {
try {
conn.close();
}
catch(SQLException e) {
e.printStackTrace();
}
}
}
}
catch(ClassNotFoundException e) {
System.out.println("找不到驅動程式");
e.printStackTrace();
}
}
}

您還可以參考 串流資料型別  中有關於BLOB的處理。