BLOB 사용 예제

2008년 12월 31일
 |  댓글 없음

저장하기

 

package BLOB;
import java.io.*;
import java.sql.*;
import java.util.*;
public class Exam_07 {
public static void main(String[] args) throws IOException {
try {
Class.forName(“oracle.jdbc.driver.OracleDriver”);
System.out.println(“드라이버 검색 성공”);
}catch(ClassNotFoundException e) {
System.err.println(“error = ” + e);
System.exit(1);
}
Connection conn = null;
PreparedStatement pstmt = null;
String url = “jdbc:oracle:thin:@localhost:1521:kyu”;
String id = “scott”;
String pass = “tiger”;
String query = null;
try {
conn = DriverManager.getConnection(url, id, pass);
}catch(SQLException e) {
System.err.println(“sql error = ” + e);
System.exit(1); // 비정상 종료시 사용되는 함수이다.
}

Scanner sc = new Scanner(System.in);
System.out.print(“업로드 할 파일 = “);
String filename = sc.next();
File f = new File(filename);
if(!f.exists()) {
System.out.println(“파일이 존재 하지 않습니다.”);
System.exit(1);
}

ByteArrayOutputStream bos = new ByteArrayOutputStream();
FileInputStream fis = new FileInputStream(f);
while(true) {
int x = fis.read();
if(x == -1) break;
bos.write(x);
}
fis.close();
bos.close();
ByteArrayInputStream bis = new ByteArrayInputStream(bos.toByteArray());

query = “insert into filetable values (1, ?, ?)”;
try {
pstmt = conn.prepareStatement(query);
pstmt.setString(1, f.getName());
pstmt.setBinaryStream(2, bis, bos.size());
pstmt.executeUpdate();
System.out.println(“업로드 성공!”);
pstmt.close();
conn.close();
}catch(SQLException e) {
System.err.println(“sql error = ” + e);
}
}
}

 

 

불러오기

 

package BLOB;

import java.io.*;
import java.util.*;
import java.sql.*;
public class Exam_08 {
public static void main(String[] ar) throws IOException {
try {
Class.forName(“oracle.jdbc.driver.OracleDriver”);
System.out.println(“드라이버 검색 성공”);
}catch(ClassNotFoundException e) {
System.err.println(“error = ” + e);
System.exit(1);
}
Connection conn = null;
PreparedStatement pstmt = null;
String url = “jdbc:oracle:thin:@localhost:1521:kyu”;
String id = “scott”;
String pass = “tiger”;
String query = null;
try {
conn = DriverManager.getConnection(url, id, pass);
}catch(SQLException e) {
System.err.println(“sql error = ” + e);
System.exit(1); // 비정상 종료시 사용되는 함수이다.
}

Scanner sc = new Scanner(System.in);
System.out.print(“다운로드 할 번호 = “);
int num = sc.nextInt();

query = “select * from filetable where num = ?”;
try {
pstmt = conn.prepareStatement(query);
pstmt.setInt(1, num);
ResultSet rs = pstmt.executeQuery();
if(rs.next()) {
String filename = rs.getString(“filename”);
System.out.println(“파일명 : ” + filename);
Blob blob = rs.getBlob(“filedata”);
InputStream is = blob.getBinaryStream();
while(true) {
int x = is.read();
if(x == -1) break;
System.out.print((char)x);
}
is.close();
}
else {
System.out.println(“찾는 번호는 없습니다.”);
}
rs.close();
pstmt.close();
conn.close();
}catch(SQLException e) {
System.err.println(“sql error = ” + e);
}
}
}

테이블 스크립트

 

CREATE TABLE filetable
(
    num          NUMBER,
    filename    VARCHAR2(20),
    filedata      BLOB
)

 

 

* blob으로 저장시 한가지 문제점이 발생
  java.sql.SQLException: ORA-01460: 요구된 변환은 실행될 수 없습니다. 
 – 오라클 드라이버 버전이 맞지 않아서 생긴 오류
 – ojdbc14.jar –> ojdbc14_g.jar 로 변경

 

태그: ,