Java 寫入 MySQL BLOB 二進制文件：PreparedStatement 流式寫入、max_allowed_packet 調優、完整讀寫代碼

JDBC 存取 MySQL BLOB/MEDIUMBLOB/LONGBLOB，核心用 PreparedStatement.setBinaryStream() 流式傳輸，避免全量入內存；讀取用 ResultSet.getBlob() + getBytes()。

表結構與類型選擇

寫入代碼

public void saveBinary(String filePath, Connection conn) throws Exception {
    File file = new File(filePath);
    try (InputStream is = new FileInputStream(file);
         PreparedStatement ps = conn.prepareStatement(
             "INSERT INTO bank_voice(name, data) VALUES (?, ?)")) {
        ps.setString(1, file.getName());
        ps.setBinaryStream(2, is, (int) file.length());  // 流式，無需 byte[]
        ps.executeUpdate();
    }
}

讀取代碼

public void getBinary(String name, String destPath, Connection conn) throws Exception {
    try (PreparedStatement ps = conn.prepareStatement("SELECT data FROM bank_voice WHERE name=?");
         FileOutputStream fos = new FileOutputStream(destPath)) {
        ps.setString(1, name);
        try (ResultSet rs = ps.executeQuery()) {
            if (rs.next()) {
                Blob blob = rs.getBlob("data");
                fos.write(blob.getBytes(1, (int) blob.length()));
            }
        }
    }
}

必改配置：max_allowed_packet

# my.ini / my.cnf
[mysqld]
max_allowed_packet = 16M  # 或 64M/256M，≥ 最大文件

修改後 net stop mysql && net start mysql（Windows）或 systemctl restart mysqld（Linux）。

連接字符串同步：jdbc:mysql://localhost:3306/db?maxAllowedPacket=16777216。

常見異常與解決

下載工具類（輔助）

public static File downLoadFile(String urlStr) throws Exception {
    URL url = new URL(urlStr);
    try (InputStream is = url.openStream();
         FileOutputStream fos = new FileOutputStream("D:/temp.bin")) {
        byte[] buf = new byte[8192];
        int len;
        while ((len = is.read(buf)) != -1) fos.write(buf, 0, len);
        return new File("D:/temp.bin");
    }
}

最佳實踐

1. 生產環境**不建議**直接存大文件入庫，改用對象存儲（MinIO/S3）+ 數據庫存元數據（路徑、MD5、大小、業務 ID）。
2. 若必須入庫：表專庫、啟用 innodb_file_per_table、定期 OPTIMIZE TABLE 整理碎片。
3. 連接池 maxLifetime 設短（30min），防止長連接持有大 Blob 導致內存壓力。