eternally full with hope... :: JSP를 이용해서 오라클 BLOB 다루기

'blob'에 해당되는 글 1건

2007/05/31 JSP를 이용해서 오라클 BLOB 다루기 (1)

JSP를 이용해서 오라클 BLOB 다루기
CS&E/Database
2007/05/31 17:41
blob, JSP, oracle
Posted by eternalbleu

JSP를 이용해서 오라클 BLOB 다루기

크리에이티브 커먼즈 라이선스

이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이선스에 따라 이용하실 수 있습니다.

출처 : http://blog.naver.com/iamjun7/

1. JSP 를 이용한 BLOB 저장

-------------------------------------------------------------------------
File    file = (File) param.get("sajin"); // 등록할 File
Blob    emptyBlob = null;
OutputStream    outstream = null;
FileInputStream finstream = null;
ResultSet rs = null;

try{
// EMPTY_BLOB() 처리
sql = "update table set sajin=EMPTY_BLOB() where id=?";
ps = con.prepareStatement(sql);
ps.setString(1, (String)param.get("id"));
if ( ps.executeUpdate() < 0 ) throw new Exception();

// 저장할 sajin Column 가져온다.
sql = "select sajin from table where id=?";
ps = con.prepareStatement(sql);
ps.setString(1, (String)param.get("id"));
rs = ps.executeQuery();
if ( rs.next() ) emptyBlob = rs.getBlob(1);

// db blob output stream
oracle.sql.BLOB bol = (oracle.sql.BLOB) emptyBlob;
outstream = bol.getBinaryOutputStream();
int size = bol.getBufferSize();
// 파일 input stream
finstream = new FileInputStream(file);

// 파일 읽어서 db에 넣기
byte[] buffer = new byte[size];
int length = -1;
while ((length = finstream.read(buffer)) != -1) {
outstream.write(buffer, 0, length);
}
} catch (Exception e){
throw(e);
} finally {
if( rs != null ) rs.close();
if( finstream != null ) finstream.close();
if( outstream != null ) outstream.close();
}

-------------------------------------------------------------------------
즉, 다른 타입처럼 update문이나 insert를 이용하지 않는다.
다시 한번 정리하면, insert할 column을 EMPTY_BLOB()로 초기화
초기화된 column을 select 하여 OutputStream을 통해 file을 DB에 저장한다.

2. JSP 를 이용한 BLOB 브라우저에서 보기

-------------------------------------------------------------------------
package showImage;

import java.io.*;
import javax.servlet.*;
import javax.servlet.http.*;
import java.sql.*;

public class ShowImageServlet extends HttpServlet
{

public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException
{
doPost(request, response);
}

public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException
{

Connection con = null;
ResultSet rs = null;
PreparedStatement ps = null;
InputStream is = null;

// Image를 가져오기위한 키값들
String key1 = request.getParameter("key1"); // Primary key 1
String key2 = request.getParameter("key2"); // Primary key 2

String file_type = null; // Image 파일 타입
String content_type = null; // Image 보여주기위한 Content_type

// Image 가져올 SQL
final String SQL =
" SELECT image_type, image " +
" FROM cu_basic_t " +
" WHERE key1 = '"+key1+"' AND key2 = '"+key2+"' ";

try {
con = UtilDB.getConnection(); // DB 연결
ps = con.prepareStatement(SQL);
rs = ps.executeQuery(); // SQL 실행

// Image 가져오는 부분(content type도 정해준다.)
if (rs!=null && rs.next()){

file_type = rs.getString("image_type");
is = rs.getBinaryStream("image");

if (file_type.toUpperCase().equals("JPG")) file_type = "jpeg";
else if (file_type.toUpperCase().equals("GIF")) file_type = "gif";

content_type = "image/" + file_type; // "image/jpeg"나 "image/gif"
response.setContentType(content_type); // Content Type Set

// Image를 Stream을 통해 out
ServletOutputStream os = response.getOutputStream();
int binaryRead;
while ((binaryRead = is.read()) != -1)
{
os.write(binaryRead);
}

} else {
throw new Exception("사진이 없습니다.");
}
}
catch(ServletException e) {
e.printStackTrace();
throw e;
}catch(IOException e) {
e.printStackTrace();
throw e;
}
catch(Exception e) {
System.out.println("An error occurs : " + e.toString());
e.printStackTrace();
}
finally {
UtilDB.closeConnection(con, ps, rs); // DB 닫아준다.
}
}
}
package showImage;