31.7. 이진 토토 캔 저장

예 31-8. 이진 데이터 처리JDBC

예를 들어 파일이 포함 된 테이블이 있다고 가정합니다. 이미지의 이름과 이미지를 a에 저장하고 싶습니다.BYTEA열 :

테이블 이미지 생성 (Imgname Text, IMG Bytea);

이미지를 삽입하려면 다음을 사용합니다.

파일 = 새 파일 ( "myimage.gif");
fileInputStream fis = 새로운 fileInputStream (file);
preparedstatement ps = conn.preparestatement ( "이미지 값 (?,?)에 삽입");
ps.SetString (1, file.getName ());
ps.setbinarystream (2, fis, file.length ());
ps.ExecuteUpdate ();
ps.close ();
fis.close ();

여기,setBinaryStream ()스트림에서 열에서 열로 세트 수를 전송합니다. 유형BYTEA. 이것은 또한 그럴 수도 있습니다 사용 완료setBytes ()메소드 이미지의 내용이 이미 A에있는 경우byte [].

이미지를 검색하는 것이 훨씬 쉽습니다. (우리는 사용준비된 상태여기, 그러나진술클래스를 동일하게 사용할 수 있습니다.)

preparedstatement ps = con.preparestatement ( "imgname =?");
ps.SetString (1, "myimage.gif");
resultSet rs = ps.ExecuteQuery ();
if (rs! = null) 
    while (rs.next ()) 
        바이트 [] imgbytes = rs.getBytes (1);
        // 여기에서 데이터를 어떤 방식으로 사용하십시오

    rs.close ();

여기서 바이너리 토토 캔가 A로 검색되었습니다byte []. 당신은를 사용할 수있었습니다입력 스트림대상 대상.

또는 매우 큰 파일을 저장하고 사용하고 싶어BARGEOBJECT API파일을 저장하려면 :

테이블 생성 imagesLo (imgname text, imgoid oid);

이미지를 삽입하려면 다음을 사용합니다.

// 모든 대형 OBJECT API 호출은 트랜잭션 블록 내에 있어야합니다.
conn.setAutocommit (false);

// 대형 객체 관리자가
BARGEOBJECTMANAGER LOBJ = ((org.postgresql.pgconnection) conn) .getLargeObjectapi ();

// 새로운 큰 객체를 만듭니다
int oid = lobj.create (bargeobjectmanager.read | margeobjectmanager.write);

// 쓰기를 위해 큰 물건을 엽니 다
BARGEOBJECT OBJ = LOBJ.OPEN (OID, BARGEOBJECTMANAGER.WRITE);

// 이제 파일을 엽니 다
파일 = 새 파일 ( "myimage.gif");
fileInputStream fis = 새로운 fileInputStream (file);

// 파일에서 큰 개체로 데이터를 복사합니다.
바이트 buf [] = 새로운 바이트 [2048];
int s, tl = 0;
while ((s = fis.read (buf, 0, 2048)) 0) 
    obj.write (buf, 0, s);
    tl += s;

// 큰 개체를 닫습니다
obj.close ();

// 이제 행을 ImagesLo에 삽입하십시오
preparedstatement ps = conn.preparestatement ( "imagesLo 값 (?,?)에 삽입");
ps.SetString (1, file.getName ());
ps.setint (2, oid);
ps.ExecuteUpdate ();
ps.close ();
fis.close ();

큰 개체에서 이미지 검색 :

// 모든 큰 대형 API 호출은 트랜잭션 블록 내에 있어야합니다.
conn.setAutocommit (false);

// 대형 객체 관리자가
BARGEOBJECTMANAGER LOBJ = ((org.postgresql.pgconnection) conn) .getLargeObjectapi ();

preparedstatement ps = con.preparestatement ( "imagelo에서 imgoid를 선택하여 imgname =?");
ps.SetString (1, "myimage.gif");
resultSet rs = ps.ExecuteQuery ();
if (rs! = null) 
    while (rs.next ()) 
        // 읽기를 위해 큰 물체를 엽니 다
        int oid = rs.getint (1);
        bargeobject obj = lobj.open (OID, BARGEOBJECTMANAGER.READ);

        // 데이터를 읽습니다
        바이트 buf [] = 새로운 바이트 [obj.size ()];
        obj.read (buf, 0, obj.size ());
        // 여기에서 읽은 데이터로 무언가를 수행하십시오

        // 객체를 닫습니다
        obj.close ();

    rs.close ();