BLOB型へのファイルの登録

ローカルなら簡単にできるんだけど

BLOB型に画像やPDFファイルを登録する方法ですが、LOAD_FILE()って関数があって、通常はこれでBLOB型にファイルパスを入れて突っ込みます。

しかし、残念ながらMySQL Serverのあるインスタンス、つまりローカルにそのファイルが無いといけないという制約(*1)があります。

MySQL :: MySQL 8.0 リファレンスマニュアル :: 12.8 文字列関数および演算子

というわけで、リモートからのBLOB型カラムへのバイナリファイルの格納方法がMySQLのコマンドツールでは出来ません。

（マウントすればローカル扱いになるんですが、MySQL Severのローカルとして見える場所にファイルなんか置きたくないよ！って言う声はあるでしょう）

じゃあ、どうすれば？

そんな場合はプリペアドステートメントを使用すれば可能です。

プリペアドステートメント

MySQL :: MySQL 8.0 リファレンスマニュアル :: 13.5 プリペアドステートメント

MySQL C API client library for C プログラム、MySQL Connector/J for Java プログラム、MySQL Connector/NET for .NET を使用するプログラムなどのクライアントプログラミングインタフェースを介して使用できます。

ってわけで、簡易的なコードを書いてみました。

実行例

package java_mysql;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.Statement;
import java.sql.SQLException;
import java.sql.Blob;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.io.IOException;

public class Test {
    public static String URL = "jdbc:mysql://（ホストorIPアドレス）:（ポート番号）/（データベース名）";
    public static String USER = "（DBユーザー名）";
    public static String PASSWD = "（DBパスワード）";
    public static String TEST_PDF_PATH = "(ファイルパスとファイル名)";
    public static void main(String[] args) {

        Connection conn;
        Statement st;
        PreparedStatement ps1;
        String sql1 = "INSERT INTO t_blob (b) VALUES(?)";
        byte[] data1;
        
        Blob blob;

        try {
            data1 = Files.readAllBytes(Paths.get(TEST_PDF_PATH));
        } catch(IOException ioex) {
            ioex.printStackTrace();
            return;
        }
        
        try {
            conn = DriverManager.getConnection(URL, USER, PASSWD);
            st = conn.createStatement();
    
            st.execute("CREATE TABLE IF NOT EXISTS t_blob (a SERIAL, b LONGBLOB)");
            st.execute("TRUNCATE t_blob");
            blob = conn.createBlob();
            blob.setBytes(1, data1);
            ps1 = conn.prepareStatement(sql1);
            ps1.setBlob(1, blob);
            ps1.executeUpdate();
            ps1.close();
            st.close();
            conn.close();
        } catch (Exception e) {
            if (e instanceof SQLException) {
            System.out.println("SQLState: " + ((SQLException)e).getSQLState());
            System.out.println("SQLErrorCode: " + ((SQLException)e).getErrorCode());
            System.out.println("SQLErrorMsg: " + ((SQLException)e).getMessage());
            }
            e.printStackTrace();
        }
    }

}

おおまかには以下のような流れです。