Mysql資料庫的功能很強大，除了能儲存字元等常見資料以外，它同樣可以儲存圖片等二進位制檔案，本文以儲存照片為例。

一、Mysql儲存二進位制檔案常見報錯有：

1.com.mysql.jdbc.PacketTooBigException: Packet for query is too large問題。

這個問題是由於mysql資料庫查詢和接收包的資料大小有限制，預設是1M，當你存取的二進位制檔案比較大的時候你需要修改Mysql的配置，具體命令如下：

在mysql命令列中執行命令：

（1）首先檢視當前配置。

show VARIABLES like '%max_allowed_packet%';
 

（2）修改最大可接收包大小為20M。 

set global max_allowed_packet = 2*1024*1024*10;

2.data too long for column 'xxx' at row 1問題 

這個問題是由於所儲存的檔案大於你所選擇的二進位制檔案型別的最大長度，以圖片儲存為例一般選擇BLOB型別，但是不同的blob型別有他的長度大小區分，具體如下：

BLOB是個型別系列，包括：TinyBlob、Blob、MediumBlob、LongBlob，這幾個型別之間的唯一區別是在儲存檔案的最大大小上不同。 

　二、下面貼上我寫的資料庫連線，二進位制流的獲取，圖片存入和取出資料庫的工具類，水平有限，有錯誤的地方請大家指正，共同學習。

我的mysql資料庫表photo的設計如下 ：

CREATE TABLE photo
(
  id    INT AUTO_INCREMENT
    PRIMARY KEY,
  name  VARCHAR(20) NOT NULL
  COMMENT '姓名',
  photo LONGBLOB    NOT NULL
  COMMENT '照片'
);
 

1.MysqlUtils工具類，用於資料庫的連線和關閉。

package mydatabase;

import org.junit.Test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

/**
 * @date on 14:48 2018/8/16
 * @author yuyong
 * @describe 用於連線mysql資料庫的工具類
 */
public class MysqlUtils {

    enum Constants{
        /**
         *定義列舉型別放入資料庫連線的常量
         * Constants_Driver 驅動
         * Constants_Url 資料庫路徑
         * Constants_user 使用者名稱
         * Constants_password 密碼
         */
        Constants_Driver("com.mysql.jdbc.Driver"),
        Constants_Url("jdbc:mysql://localhost:3307/test"),
        Constants_user("root"),
        Constants_password("root");

        private String description;
        Constants (String description){
            this.description = description;
        }
        public String getDescription(){
            return description;
        }
    }

    static {
        try {
            Class.forName(Constants.Constants_Driver.getDescription());
            System.out.println("資料庫驅動註冊成功...");
        } catch (ClassNotFoundException e) {
            System.out.println("驅動註冊失敗");
            e.printStackTrace();
        }
    }

    /**
     * 獲取資料庫的連線
     * @return Connection
     */
    public static Connection getConnection(){
        try {
            Connection connection = DriverManager.getConnection(Constants.Constants_Url.getDescription(),
                    Constants.Constants_user.getDescription(),Constants.Constants_password.getDescription());
            System.out.println("資料庫連線成功...");
            return connection;
        } catch (SQLException e) {
            System.out.println("獲取連線失敗");
            e.printStackTrace();
        }
        return null;
    }

    public static boolean closeConnection(Connection connection){
        if (null != connection){
            try {
                connection.close();
                System.out.println("資料庫關閉成功...");
                return true;
            } catch (SQLException e) {
                System.out.println("關閉連線失敗！！");
                e.printStackTrace();
            }
        }
        return false;
    }

    /**
     * Junit測試
     */
    @Test
    public void mysqlUtilsTest(){
        Connection connection = MysqlUtils.getConnection();
        MysqlUtils.closeConnection(connection);
    }

}

2. ReadImageUtils工具類，封裝用於讀取圖片的工具流，用於資料庫儲存圖片。

package mydatabase;

/**
 * @date on 15:15 2018/8/16
 * @author yuyong
 * @describe 封裝用於讀取圖片的工具流，用於資料庫儲存圖片
 */
import java.io.*;

public class ReadImageUtils {

    /**
     * 讀取本地圖片的輸入流
     * @return FileInputStream
     */
    public static FileInputStream getIns(String imagePath){
        try {
            return new FileInputStream(new File(imagePath));
        } catch (FileNotFoundException e) {
            System.out.println("請檢查檔案路徑是否正確");
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 讀取資料庫表中圖片的輸出流
     * @param targetPath 圖片儲存到本地的路徑
     * @return FileOutputStream
     */
    public static FileOutputStream getOuts(String targetPath){
        File file = new File(targetPath);
        String path = targetPath.substring(0,targetPath.lastIndexOf("/"));
        //如果檔案不存在則建立目錄
        if (!file.exists()){
            new File(path).mkdir();
        }

        FileOutputStream fos ;
        try {
             fos = new FileOutputStream(file);
             return fos;
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 讀取資料庫中的圖片二進位制資料寫出目標地址
     * @param in 輸入流
     * @param out 輸出流
     * @return boolean
     */
    public static boolean readBinaryImage(InputStream in, OutputStream out){
        try {
            int len;
            byte[] b = new byte[1000];
            while ((len=in.read(b)) != -1){
                out.write(b,0,len);
            }
            out.flush();
            return true;
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            if (null != out){
                try {
                    out.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != in){
                try {
                    in.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return false;
    }
}

3. ImageSaveAndOut工具類，實現圖片的本地與資料庫傳輸。

package mydatabase;

/**
 * @date on 15:52 2018/8/16
 * @author yuyong
 * @describe 實現圖片的本地與資料庫傳輸！
 */
import org.junit.Test;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class ImageSaveAndOut {


    /**
     * 存入和取出的sql語句
     */
    enum SQL{
        /**
         * SQL_IN 將圖片存入資料庫的sql語句
         * SQL_OUT 將圖片從資料庫取出的sql語句
         */
        SQL_IN("insert into photo (name,photo) values (?,?)"),
        SQL_OUT("select * from photo where id = ?");
        private String sql;
        SQL(String sql){
            this.sql = sql;
        }
        public String getSql(){
            return sql;
        }
    }
    private static PreparedStatement preparedStatement;
    private static ResultSet resultSet;
    private static Connection connection;
    private static InputStream in;
    private static OutputStream out;

    /**
     * 將圖片資源存入資料庫
     * @param imagePath 本地圖片路徑
     * @param name 名稱
     * @return boolean
     */
    public static boolean imageToDatabase(String imagePath,String name){
        try {
            if (null == out){
                in = ReadImageUtils.getIns(imagePath);
            }
            connection = MysqlUtils.getConnection();
            if (null != connection) {
                preparedStatement = connection.prepareStatement(SQL.SQL_IN.getSql());
                //設定sql語句中的佔位符？
                preparedStatement.setString(1,name);
                preparedStatement.setBlob(2,in,in.available());
                int count = preparedStatement.executeUpdate();
                if (count > 0){
                    System.out.println("儲存圖片成功...");
                    return true;
                }else {
                    System.out.println("儲存圖片失敗...");
                    return false;
                }
            }
        }catch (SQLException | IOException e) {
            e.printStackTrace();
        } finally {
            MysqlUtils.closeConnection(connection);
            try {
                if (null != in ){
                    in.close();
                }
                if (null != preparedStatement){
                    preparedStatement.close();
                }
            }catch (IOException e) {
                System.out.println("輸入流關閉失敗...");
                e.printStackTrace();
            } catch (SQLException e) {
                System.out.println("預處理命令關閉失敗...");
                e.printStackTrace();
            }
        }
        return true;
    }

    /**
     * 將資料庫中的圖片讀出儲存到本地
     * @param localPath 本地儲存該圖片的路徑
     * @param id 資料庫中該圖片的id
     * @return boolean
     */
    public static boolean databaseToImage(String localPath, int id){
        try {

            connection = MysqlUtils.getConnection();
            if (null == out){
                out = ReadImageUtils.getOuts(localPath);
            }
            if (null != connection){
                preparedStatement = connection.prepareStatement(SQL.SQL_OUT.getSql());
            }
            preparedStatement.setInt(1,id);
            resultSet = preparedStatement.executeQuery();
            while (resultSet.next()){
                in = resultSet.getBinaryStream("photo");
                ReadImageUtils.readBinaryImage(in,out);
                System.out.println("圖片取出成功...");
            }
            return true;
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            MysqlUtils.closeConnection(connection);
            if (null != resultSet){
                try {
                    resultSet.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (null != preparedStatement){
                try {
                    preparedStatement.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        return false;
    }

    /**
     * Junit 測試
     */
    @Test
    public void imageSaveAndOutTest(){
        //存入
        //ImageSaveAndOut.imageToDatabase("./src/mydatabase/1111.jpg","yuyong");
        //取出
        ImageSaveAndOut.databaseToImage("./1.jpg",3);
    }
}