Javaのjavax.sql.rowset.serialを徹底解説！シリアライズ可能なSQLデータ型の実装ガイド

java.sql.Blobは、画像や音声ファイルなどのバイナリラージオブジェクト（BLOB）を扱うためのインターフェースです。SerialBlobは、このBlobオブジェクトをシリアライズ可能な形式に変換します。

コンストラクタは主に2種類あります。

• SerialBlob(byte[] b): バイト配列から直接SerialBlobインスタンスを生成します。
• SerialBlob(Blob blob): 既存のBlobオブジェクトからインスタンスを生成します。この場合、コンストラクタ内部でBlobからデータを読み出し、自身のバイト配列にコピーします。

サンプルコード：

import java.sql.Blob;
import javax.sql.rowset.serial.SerialBlob;
import java.sql.SQLException;
import java.util.Arrays;
public class SerialBlobExample { public static void main(String[] args) { try { // 元となるバイナリデータ（例：文字列をバイト配列に変換） byte[] originalBytes = "This is a binary data example.".getBytes(); // 1. バイト配列からSerialBlobを生成 SerialBlob blobFromBytes = new SerialBlob(originalBytes); System.out.println("blobFromBytesの長さ: " + blobFromBytes.length()); // データの読み出し byte[] retrievedBytes = blobFromBytes.getBytes(1, (int) blobFromBytes.length()); System.out.println("読み出したデータ: " + new String(retrievedBytes)); // 2. 既存のBlobオブジェクトからSerialBlobを生成するシナリオ（ここではダミーのBlobを使用） // 実際にはResultSet.getBlob()などから取得したBlobオブジェクトを渡す Blob sourceBlob = new SerialBlob(originalBytes); // ダミーとして作成 SerialBlob blobFromBlob = new SerialBlob(sourceBlob); System.out.println("blobFromBlobの長さ: " + blobFromBlob.length()); // 比較 System.out.println("内容は同じか: " + Arrays.equals( blobFromBytes.getBytes(1, (int) blobFromBytes.length()), blobFromBlob.getBytes(1, (int) blobFromBlob.length()) )); // オブジェクトを解放 blobFromBytes.free(); blobFromBlob.free(); } catch (SQLException e) { e.printStackTrace(); } }
} 

java.sql.Clobは、長文のテキストデータなどのキャラクタラージオブジェクト（CLOB）を扱います。SerialClobは、これをシリアライズ可能な形式に変換します。

コンストラクタは主に2種類です。

• SerialClob(char[] ch): 文字配列から直接SerialClobインスタンスを生成します。
• SerialClob(Clob clob): 既存のClobオブジェクトからインスタンスを生成します。

サンプルコード：

import java.sql.Clob;
import javax.sql.rowset.serial.SerialClob;
import java.sql.SQLException;
public class SerialClobExample { public static void main(String[] args) { try { // 元となるテキストデータ String originalText = "これは長文のテキストデータです。SerialClobによってシリアライズされます。"; char[] originalChars = originalText.toCharArray(); // 1. 文字配列からSerialClobを生成 SerialClob clobFromChars = new SerialClob(originalChars); System.out.println("clobFromCharsの長さ: " + clobFromChars.length()); // データの読み出し (部分文字列) String subString = clobFromChars.getSubString(1, 10); System.out.println("読み出した部分文字列: " + subString); // 2. 既存のClobオブジェクトからSerialClobを生成するシナリオ（ダミーを使用） Clob sourceClob = new SerialClob(originalChars); SerialClob clobFromClob = new SerialClob(sourceClob); System.out.println("clobFromClobの長さ: " + clobFromClob.length()); System.out.println("内容は同じか: " + clobFromClob.getSubString(1, (int)clobFromClob.length()).equals(originalText) ); // オブジェクトを解放 clobFromChars.free(); clobFromClob.free(); } catch (SQLException e) { e.printStackTrace(); } }
} 

java.sql.Arrayは、データベースの配列型をJavaで表現するためのインターフェースです。SerialArrayは、このArrayオブジェクトをシリアライズ可能にします。

SerialArrayのコンストラクタは、java.sql.Arrayオブジェクトを受け取ります。コンストラクタ内で、配列の要素とベースタイプ（配列要素の型）を読み込み、内部に保持します。

サンプルコード：

java.sql.Arrayのインスタンス化は通常JDBCドライバが行うため、ここではインスタンス化済みのArrayオブジェクトが存在する前提でSerialArrayを作成する部分を示します。

import javax.sql.rowset.serial.SerialArray;
import java.sql.Array;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
public class SerialArrayExample { // ダミーのArray実装クラス static class MockArray implements Array { private final Object[] elements; private final int baseType; public MockArray(Object[] elements, int baseType) { this.elements = elements; this.baseType = baseType; } @Override public String getBaseTypeName() throws SQLException { if (baseType == Types.VARCHAR) return "VARCHAR"; if (baseType == Types.INTEGER) return "INTEGER"; return "UNKNOWN"; } @Override public int getBaseType() throws SQLException { return baseType; } @Override public Object getArray() throws SQLException { return elements; } // ... その他のメソッドは省略 ... @Override public Object getArray(java.util.Map<String, Class<?>> map) throws SQLException { return null; } @Override public Object getArray(long index, int count) throws SQLException { return null; } @Override public Object getArray(long index, int count, java.util.Map<String, Class<?>> map) throws SQLException { return null; } @Override public ResultSet getResultSet() throws SQLException { return null; } @Override public ResultSet getResultSet(java.util.Map<String, Class<?>> map) throws SQLException { return null; } @Override public ResultSet getResultSet(long index, int count) throws SQLException { return null; } @Override public ResultSet getResultSet(long index, int count, java.util.Map<String, Class<?>> map) throws SQLException { return null; } @Override public void free() throws SQLException {} } public static void main(String[] args) { try { // DBから取得したと仮定するArrayオブジェクト String[] strElements = {"apple", "banana", "cherry"}; Array sourceArray = new MockArray(strElements, Types.VARCHAR); // ArrayオブジェクトからSerialArrayを生成 SerialArray serialArray = new SerialArray(sourceArray); // シリアライズされた配列データの取得 Object[] retrievedElements = (Object[]) serialArray.getArray(); System.out.println("シリアル化された配列の要素数: " + retrievedElements.length); for (Object element : retrievedElements) { System.out.println("- " + element); } System.out.println("ベースタイプ名: " + serialArray.getBaseTypeName()); System.out.println("ベースタイプ (int): " + serialArray.getBaseType()); // オブジェクトを解放 serialArray.free(); } catch (SQLException e) { e.printStackTrace(); } }
}