java代碼如何實(shí)現(xiàn)存取數(shù)據(jù)庫(kù)的blob字段

更新時(shí)間：2025年04月22日 08:39:25 作者：火冠蜂鳥

這篇文章主要介紹了java代碼如何實(shí)現(xiàn)存取數(shù)據(jù)庫(kù)的blob字段問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

一.業(yè)務(wù)

在業(yè)務(wù)中我們被要求將文件或圖片等轉(zhuǎn)成 byte[] 或 InputStream存到數(shù)據(jù)庫(kù)的Blob類型的字段中.

二.Blob類型介紹

在 MySQL 中，Blob 數(shù)據(jù)類型用于存儲(chǔ)二進(jìn)制數(shù)據(jù)。MySQL 提供了四種不同的 Blob 類型：

TINYBLOB: 最大存儲(chǔ)長(zhǎng)度為 255 個(gè)字節(jié)。
BLOB: 最大存儲(chǔ)長(zhǎng)度為 65,535 個(gè)字節(jié)。
MEDIUMBLOB: 最大存儲(chǔ)長(zhǎng)度為 16,777,215 個(gè)字節(jié)。
LONGBLOB: 最大存儲(chǔ)長(zhǎng)度為 4,294,967,295 個(gè)字節(jié)。

三. Blob 對(duì)應(yīng)的 Java 類型

在 Java 中讀取 MySQL Blob 類型時(shí)，通常使用 java.sql.Blob 類型。java.sql.Blob 是一個(gè)接口，它提供了一些方法來操作 Blob 數(shù)據(jù)。

根據(jù) MySQL Blob 類型的不同，我們可以使用不同的 Java 類型來存儲(chǔ) Blob 數(shù)據(jù)。

TINYBLOB 對(duì)應(yīng) byte[] 或 InputStream。
BLOB 對(duì)應(yīng) byte[] 或 InputStream。
MEDIUMBLOB 對(duì)應(yīng) byte[] 或 InputStream。
LONGBLOB 對(duì)應(yīng) byte[] 或 InputStream。

我們可以根據(jù)需要選擇合適的 Java 類型。推薦用InputStream,這樣代碼不用轉(zhuǎn)換來轉(zhuǎn)換去,比較簡(jiǎn)單

四.上存取java代碼

1.建表

2.建實(shí)體類

@Data
public class TTT {
    private String id;
    private String name;
    private  String createTime;
    private byte[] miaoshuByte;
    private InputStream miaoshuInputstream;
}

3.用個(gè)自己寫的工具類

public class FileUtil {
    /**
     * file轉(zhuǎn)byte
     */
    public static byte[] file2byte(File file) throws IOException {
        FileInputStream fis = null;
        ByteArrayOutputStream bos = null;
        try {
            fis = new FileInputStream(file);
            bos = new ByteArrayOutputStream();
            IOUtils.copy(fis, bos);
            byte[] bytes = bos.toByteArray();
            return bytes;
        }finally {
            if (fis != null) {
                fis.close();
            }
            if (bos != null) {
                bos.close();
            }
        }
    }
 
    /**
     * byte 轉(zhuǎn)file
     */
    public static File byte2File(byte[] buf,String fileName) throws IOException {
        FileOutputStream fos = null;
        try {
            fos = new FileOutputStream(fileName);
            fos.write(buf);
            File file = new File(fileName);
            return file;
        } finally {
            if (fos != null) {
                fos.close();
            }
        }
    }
}

4.訪問接口

@RestController
@RequestMapping("order/")
@Slf4j
public class SendHttpWController {
    @Autowired
    private UtimeeMapper utimeeMapper;

    @GetMapping("/aa")
    public String queryById( Integer id) throws IOException {
        TTT ttt = new TTT();
        ttt.setId("30");
        ttt.setName("張三");
        File file = new File("F:\\Desktop\\aa.docx");
        byte[] bytes = FileUtil.file2byte(file);
        ttt.setMiaoshuByte(bytes);
        FileInputStream fileInputStream = new FileInputStream(file);
        ttt.setMiaoshuInputstream(fileInputStream);
        utimeeMapper.insert01(ttt);
        return "嘿嘿額黑8082";
    }
    @GetMapping("/bb")
    public String bb( Integer id) throws IOException {
        TTT ttt = utimeeMapper.select01("30");
        byte[] bytes = ttt.getMiaoshuByte();
        FileUtil.byte2File(bytes,"F:\\Desktop\\cc.docx");
        InputStream inputStream = ttt.getMiaoshuInputstream();
        FileOutputStream outputStream = new FileOutputStream("F:\\Desktop\\dd.docx");
        IOUtils.copy(inputStream, outputStream);//記得添加關(guān)流代碼(本代碼省略了)
        return "嘿嘿額黑8082";
    }

5.輸出成果