8.6. バイナリデータの格納

Example 8-4. バイナリデータの例

例として、画像のファイル名を持つテーブルがあり、また、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, file.length());
ps.executeUpdate();
ps.close();
fis.close();

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

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

PreparedStatement ps = con.prepareStatement("SELECT img FROM images WHERE imgname=?");
ps.setString(1, "myimage.gif");
ResultSet rs = ps.executeQuery();
if (rs != null) {
    while(rs.next()) {
        byte[] imgBytes = rs.getBytes(1);
        // use the stream in some way here
    }
    rs.close();
}
ps.close();

ここで、バイナリデータは byte[] として取り出されました。InputStream を使用しても可能です。

他の方法として、非常に巨大なファイルを格納するために、 LargeObject API を使用してファイルに格納することを考えます。

CREATE TABLE imagesLO (imgname text, imgOID OID);

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

// 全ての LargeObject API の呼び出しはトランザクション内部でなければなりません。
conn.setAutoCommit(false);

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

// 新規にラージオブジェクトを作成します。
int oid = lobj.create(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.setInt(2, oid);
ps.executeUpdate();
ps.close();
fis.close();

ラージオブジェクトから画像を取り出すには、以下のようにします。

// 全ての LargeObject API の呼び出しはトランザクション内部でなければなりません。
conn.setAutoCommit(false);

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

PreparedStatement ps = con.prepareStatement("SELECT imgOID FROM imagesLO WHERE imgname=?");
ps.setString(1, "myimage.gif");
ResultSet rs = ps.executeQuery();
if (rs != null) {
    while(rs.next()) {
	//open the large object for reading
	int oid = rs.getInt(1);
	LargeObject obj = lobj.open(oid, LargeObjectManager.READ);

	//read the data
	byte buf[] = new byte[obj.size()];
	obj.read(buf, 0, obj.size());
	//do something with the data read here

	// Close the object
	obj.close();
    }
    rs.close();
}
ps.close();