BLOBデータの迷宮を脱出せよ：ADOを用いたSQL Serverバイナリデータの極限制御
業務アプリケーションの開発において、避けて通れない壁がある。それは「バイナリデータ（BLOB）」の扱いだ。
「画像やPDFをデータベースに保存したい」という要望に対し、安易に「ファイルパスだけを保存してファイルシステムに置く」という設計を選ぶ者がいる。あるいは、逆に「全データを一度にメモリへ読み込む」という、リソースを使い果たす無謀なコードを書く者がいる。
もし君が、数MBを超えるPDFや高解像度の画像を扱うシステムを構築しようとしているなら、後者のやり方は即座に捨てろ。メモリ不足（Out of Memory）によるクラッシュと、SQL Serverの接続タイムアウトという、逃げ場のない地獄が待っている。
本稿では、Access VBAからSQL Serverのバイナリデータを、`GetChunk`および`AppendChunk`メソッドを用いて「ストリーム」として扱う、プロフェッショナルな設計手法を伝授する。
1. なぜDAOではなくADOなのか：アーキテクチャの決定的な差
まず、前提となるアーキテクチャの理解を正そう。Access開発においてDAO（Data Access Objects）は馴染み深い。しかし、SQL Serverをバックエンドとする場合、我々はADO（ActiveX Data Objects）を選択しなければならない。
- DAOの限界: DAOはもともとJet/ACEエンジン（ローカルの.accdb等）に最適化されている。SQL Serverへの接続は可能だが、サーバー側の高度なデータ型や、バイナリデータの効率的なストリーミング操作においては、設計思想そのものが「ローカルファイル」寄りである。
- ADOの優位性: ADOはOLE DBプロバイダーを介してSQL Serverと直接対話する。`GetChunk` / `AppendChunk` という、データを「断片（Chunk）」として分割してやり取りするメソッドは、ADOの真骨頂だ。
大きなデータを一度にメモリに載せるのではなく、「少しずつ読み込み、少しずつ書き込む」。この「ストリーミング」という概念こそが、堅牢なシステムへの第一歩である。
2. 極限の設計思想：Chunking（断片化）のメカニズム
バイナリデータを扱う際、我々はデータを「一つの巨大な塊」として見てはならない。それは「小さなパズルのピースの連続」である。
GetChunk（読み込み）の戦略
`GetChunk`は、フィールドから指定したバイト数分だけデータを切り出す。これをループさせ、データの終端に達するまで繰り返す。これにより、たとえ1GBのファイルであっても、メモリ消費量を数百KBのバッファサイズに抑え込むことができる。
AppendChunk（書き込み）の戦略
書き込み時は、まずフィールドを「更新可能状態」にし、`AppendChunk`によってパズルを組み上げるようにデータを流し込む。
3. 実装：プロダクション・グレードのコード例
以下に、実務でそのまま利用可能な、堅牢なクラスモジュール級のロジックを示す。ここでは、`ADODB.Stream`と組み合わせて、データベースからファイルへ、またはファイルからデータベースへとデータを流し込む手法をとる。
モジュール宣言
参照設定に `Microsoft ActiveX Data Objects x.x Library` が必要である。
Option Explicit
' ==============================================================================
' Module: modBlobHandler
' Description: SQL Server上のBLOBデータをストリーミング処理するための定石
' Author: Chief Architect
' ==============================================================================
Public Const CHUNK_SIZE As Long = 131072 ' 128KB (パフォーマンスとメモリのバランスが最適)
''' <summary>
''' SQL Serverからバイナリデータを抽出し、ローカルファイルに保存する
''' </summary>
''' <param name="conn">接続済みADO Connectionオブジェクト</param>
''' <param name="sql">SELECT文 (バイナリ列を含む)</param>
''' <param name="targetFilePath">保存先のフルパス</param>
Public Sub DownloadBlobToFile(ByRef conn As ADODB.Connection, ByVal sql As String, ByVal targetFilePath As String)
Dim rs As ADODB.Recordset
Dim stream As ADODB.Stream
Dim chunkData() As Byte
Dim chunkSize As Long
On Error GoTo ErrorHandler
' 1. レコードセットの展開
Set rs = New ADODB.Recordset
' CursorLocationをClientに設定することで、サーバーサイドのロックを最小限に抑える
rs.CursorLocation = adUseClient
rs.Open sql, conn, adOpenStatic, adLockReadOnly
If rs.EOF Then
MsgBox "対象データが見つかりません。", vbExclamation
GoTo CleanUp
End If
' 2. ADODB.Streamの準備 (ファイル書き出し用)
Set stream = New ADODB.Stream
stream.Type = adTypeBinary
stream.Open
' 3. GetChunkによるストリーミング読み込み
' Fields(0) は対象のバイナリ列を想定
Do While Not IsNull(rs.Fields(0).Value)
' 指定サイズ分を取得
chunkData = rs.Fields(0).GetChunk(CHUNK_SIZE)
' 取得できたデータが空でないか確認
If (Not Not chunkData) = 0 Then Exit Do
' Streamへ書き込み
stream.Write chunkData
' 次のチャンクへ（GetChunkは内部的にポインタを進める）
' ※注: GetChunkの挙動はプロバイダーに依存するため、
' 実際にはループ内でデータの終端を判定する設計が重要
If LenB(chunkData) < CHUNK_SIZE Then Exit Do
Loop
' 4. ファイルへの物理書き出し
stream.SaveToFile targetFilePath, adSaveCreateOverWrite
MsgBox "ダウンロード完了: " & targetFilePath, vbInformation
CleanUp:
On Error Resume Next
If Not rs Is Nothing Then If rs.State = adStateOpen Then rs.Close
If Not stream Is Nothing Then stream.Close
Set rs = Nothing
Set stream = Nothing
Exit Sub
ErrorHandler:
MsgBox "致命的エラーが発生しました: " & Err.Description, vbCritical
Resume CleanUp
End Sub
''' <summary>
''' ローカルファイルを読み込み、SQL Serverのバイナリ列に保存する
''' </summary>
''' <param name="conn">接続済みADO Connectionオブジェクト</param>
''' <param name="updateSql">UPDATE文 (例: "UPDATE MyTable SET ImageData = ImageData WHERE ID = ?")</param>
''' <param name="sourceFilePath">読み込み元のファイルパス</param>
''' <param name="targetID">更新対象のID</param>
Public Sub UploadFileToBlob(ByRef conn As ADODB.Connection, ByVal updateSql As String, ByVal sourceFilePath As String, ByVal targetID As Long)
Dim rs As ADODB.Recordset
Dim stream As ADODB.Stream
Dim chunkData() As Byte
Dim chunkSize As Long
On Error GoTo ErrorHandler
' トランザクションの開始 (整合性確保のため必須)
conn.BeginTrans
' 1. ファイルをADODB.Streamで読み込む
Set stream = New ADODB.Stream
stream.Type = adTypeBinary
stream.Open
stream.LoadFromFile sourceFilePath
' 2. レコードセットの展開 (更新可能な状態で)
Set rs = New ADODB.Recordset
rs.CursorLocation = adUseClient
' パラメータクエリを利用して対象レコードを特定
' ※実務ではCommandオブジェクトの使用を推奨するが、簡潔さのためここでは直接指定
rs.Open "SELECT ImageData FROM MyTable WHERE ID = " & targetID, conn, adOpenDynamic, adLockOptimistic
If rs.EOF Then
Err.Raise vbObjectError + 513, "UploadFile", "対象レコードが存在しません。"
End If
' 3. AppendChunkによるストリーミング書き込み
' 一旦フィールドをクリアにする（必要に応じて）
rs.Fields(0).Value = Null
' Streamのポインタを先頭に戻す
stream.Position = 0
Do While stream.Position < stream.Size
' ストリームからchunkSize分読み込む
' stream.Readは指定サイズ分をByte配列で返す
chunkData = stream.Read(CHUNK_SIZE)
' データベースへ断片を流し込む
rs.Fields(0).AppendChunk chunkData
Loop
' 4. 変更の確定
rs.Update
conn.CommitTrans
MsgBox "アップロード完了", vbInformation
CleanUp:
On Error Resume Next
If Not rs Is Nothing Then If rs.State = adStateOpen Then rs.Close
If Not stream Is Nothing Then stream.Close
Set rs = Nothing
Set stream = Nothing
Exit Sub
ErrorHandler:
If Not conn Is Nothing Then conn.RollbackTrans
MsgBox "アップロード失敗: " & Err.Description, vbCritical
Resume CleanUp
End Sub4. 失敗しないためのアーキテクチャ・チェックリスト
コードを書くだけでは不十分だ。運用フェーズでシステムを崩壊させないために、以下の3点を設計段階で必ず検討せよ。
① トランザクションの境界線
バイナリデータの書き込みは、通常の文字列データの更新に比べて、ネットワーク帯域とディスクI/Oを長時間占有する。`AppendChunk`のループ中にエラーが発生した場合、中途半端なデータが残ることは許されない。必ず `BeginTrans` と `RollbackTrans` を組み合わせ、「すべて書き込むか、全く書き込まないか」を徹底せよ。
② タイムアウト値の設定
デフォルトの接続タイムアウト設定では、巨大なファイルの転送中に「通信が途切れた」と判断され、エラーを吐くことが多々ある。
conn.CommandTimeout = 60 ' 秒単位。データの大きさに応じて適切に設定せよこの設定を忘れるのは、プロの仕事ではない。
③ CursorLocationの選択
`adUseServer`（サーバーサイドカーソル）は、サーバーのメモリを消費し、ネットワークトラフィックを増大させる。BLOB操作においては、クライアント側にデータをバッファリングする `adUseClient` を選択することで、サーバー負荷を軽減し、操作の安定性を高めるのが定石だ。
結びに代えて
Access VBAは、決して「小規模なツールを作るための言語」ではない。適切なアーキテクチャ、すなわちストリーミングによるリソース管理と厳格なトランザクション管理を組み合わせれば、エンタープライズ級の堅牢なシステムを構築する強力な武器となる。
`GetChunk`と`AppendChunk`を使いこなせ。メモリの波に飲まれることなく、巨大なデータを自在に操る。それが、エンジニアとして一段上のステージへ進むための条件である。
