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();
        }
    }
}