例 7.1. JDBCによるバイナリデータ処理

例として、画像ファイル名を持つテーブルがあり、画像をbytea型の列として格納したいものと仮定します。

CREATE TABLE images (imgname text, img bytea);

画像を挿入するには、以下のように使います。

File file = new File("myimage.gif");
FileInputStream fis = new FileInputStream(file);
PreparedStatement ps = conn.prepareStatement("INSERT INTO images VALUES (?, ?)");
ps.setString(1, file.getName());
ps.setBinaryStream(2, fis, (int)file.length());
ps.executeUpdate();
ps.close();
fis.close();

ここでは、setBinaryStream()は、ストリームからバイト列の集合をbytea型の列に転送します。 これはまた、画像の内容がすでにbyte[]内にあれば、setBytes()メソッドを使用して行うこともできます。

画像の取り出しはいっそう簡単です。 （ここではPreparedStatementを使用していますが、Statementクラスも同様に使用することができます。）

PreparedStatement ps = conn.prepareStatement("SELECT img FROM images WHERE imgname = ?");
ps.setString(1, "myimage.gif");
ResultSet rs = ps.executeQuery();
while (rs.next()) {
    byte[] imgBytes = rs.getBytes(1);

    // ここでデータを何らかの形で使用します。
}
rs.close();
ps.close();

これにより、バイナリデータがbyte[]として取り出されました。 代わりにInputStreamオブジェクトを使用することもできます。

この他に、非常に巨大なファイルを格納する場合には LargeObject APIを使用してそのファイルを格納したいでしょう。

CREATE TABLE imageslo (imgname text, imgoid oid);

画像を挿入するには以下のように使用します。

// すべてのLargeObject APIはトランザクションブロック内で呼び出さなければなりません。
conn.setAutoCommit(false);


// 操作を行うためのラージオブジェクトマネージャを入手します。
LargeObjectManager lobj = ((org.postgresql.PGConnection)conn).getLargeObjectAPI();


// 新しいラージオブジェクトを作成します。
long oid = lobj.createLO(LargeObjectManager.READ | LargeObjectManager.WRITE);


// 書き込み用にラージオブジェクトを開きます。
LargeObject obj = lobj.open(oid, LargeObjectManager.WRITE);


// ここでファイルを開きます。
File file = new File("myimage.gif");
FileInputStream fis = new FileInputStream(file);


// ファイルからラージオブジェクトにデータをコピーします。
byte buf[] = new byte[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("INSERT INTO imageslo VALUES (?, ?)");
ps.setString(1, file.getName());
ps.setLong(2, oid);
ps.executeUpdate();
ps.close();
fis.close();


// 最後にトランザクションをコミットします。
conn.commit();

ラージオブジェクトから画像を取り出します。

// すべてのLargeObject APIはトランザクションブロック内で呼び出さなければなりません。
conn.setAutoCommit(false);


// 操作を行うためのラージオブジェクトマネージャを入手します。
LargeObjectManager lobj = ((org.postgresql.PGConnection)conn).getLargeObjectAPI();

PreparedStatement ps = conn.prepareStatement("SELECT imgoid FROM imageslo WHERE imgname = ?");
ps.setString(1, "myimage.gif");
ResultSet rs = ps.executeQuery();
while (rs.next()) {

    // 読み込み用にラージオブジェクトを開きます。
    long oid = rs.getLong(1);
    LargeObject obj = lobj.open(oid, LargeObjectManager.READ);


    // データを読み込みます。
    byte buf[] = new byte[obj.size()];
    obj.read(buf, 0, obj.size());

    // ここで読み込んだデータを使用して何らかの処理を行います。


    // オブジェクトを閉じます。
    obj.close();
}
rs.close();
ps.close();


// 最後にトランザクションをコミットします。
conn.commit();