java利用mysql存储图片

CREATE TABLE images (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(255),
    image_data LONGBLOB
);

import java.io.*;
import java.sql.*;

public class ImageStorage {
    private static final String DB_URL = "jdbc:mysql://localhost:3306/test";
    private static final String USER = "username";
    private static final String PASS = "password";

    public static void main(String[] args) {
        String imagePath = "path/to/your/image.jpg";
        String imageName = "image.jpg";

        try {
            // 存储图片到数据库
            storeImage(imagePath, imageName);

            // 从数据库读取图片
            byte[] imageData = retrieveImage(imageName);
            if (imageData != null) {
                saveImageToFile(imageData, "retrieved_image.jpg");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static void storeImage(String imagePath, String imageName) throws Exception {
        Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
        PreparedStatement pstmt = conn.prepareStatement("INSERT INTO images (name, image_data) VALUES (?, ?)");

        try (FileInputStream fis = new FileInputStream(imagePath)) {
            pstmt.setString(1, imageName);
            pstmt.setBinaryStream(2, fis, (int) new File(imagePath).length());
            pstmt.executeUpdate();
        }

        pstmt.close();
        conn.close();
    }

    private static byte[] retrieveImage(String imageName) throws Exception {
        Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
        PreparedStatement pstmt = conn.prepareStatement("SELECT image_data FROM images WHERE name = ?");
        pstmt.setString(1, imageName);

        ResultSet rs = pstmt.executeQuery();
        byte[] imageData = null;
        if (rs.next()) {
            imageData = rs.getBytes("image_data");
        }

        rs.close();
        pstmt.close();
        conn.close();

        return imageData;
    }

    private static void saveImageToFile(byte[] imageData, String outputImagePath) throws IOException {
        try (FileOutputStream fos = new FileOutputStream(outputImagePath)) {
            fos.write(imageData);
        }
    }
}