java代码如何实现存取数据库的blob字段

薄如秋水

一.业务

在业务中我们被要求将文件或图片等转成

1. byte[]

复制代码

或

1. InputStream

复制代码

存到数据库的

1. Blob

复制代码

类型的字段中.

二.Blob类型介绍

在 MySQL 中，Blob 数据类型用于存储二进制数据。MySQL 提供了四种不同的 Blob 类型：

• 1. TINYBLOB

  复制代码
  : 最大存储长度为 255 个字节。
• 1. BLOB

  复制代码
  : 最大存储长度为 65,535 个字节。
• 1. MEDIUMBLOB

  复制代码
  : 最大存储长度为 16,777,215 个字节。
• 1. LONGBLOB

  复制代码
  : 最大存储长度为 4,294,967,295 个字节。

三. Blob 对应的 Java 类型

在 Java 中读取 MySQL Blob 类型时，通常使用

1. java.sql.Blob

复制代码

类型。

1. java.sql.Blob

复制代码

是一个接口，它提供了一些方法来操作 Blob 数据。

根据 MySQL Blob 类型的不同，我们可以使用不同的 Java 类型来存储 Blob 数据。

• TINYBLOB 对应
  1. byte[]

  复制代码
  或
  1. InputStream

  复制代码
  。
• BLOB 对应
  1. byte[]

  复制代码
  或
  1. InputStream

  复制代码
  。
• MEDIUMBLOB 对应
  1. byte[]

  复制代码
  或
  1. InputStream

  复制代码
  。
• LONGBLOB 对应
  1. byte[]

  复制代码
  或
  1. InputStream

  复制代码
  。

我们可以根据需要选择合适的 Java 类型。推荐用

1. InputStream

复制代码

,这样代码不用转换来转换去,比较简单

四.上存取java代码

1.建表

2.建实体类

1. @Data
2. public class TTT {
3. private String id;
4. private String name;
5. private String createTime;
6. private byte[] miaoshuByte;
7. private InputStream miaoshuInputstream;
8. }

复制代码

3.用个自己写的工具类

1. public class FileUtil {
2. /**
3. * file转byte
4. */
5. public static byte[] file2byte(File file) throws IOException {
6. FileInputStream fis = null;
7. ByteArrayOutputStream bos = null;
8. try {
9. fis = new FileInputStream(file);
10. bos = new ByteArrayOutputStream();
11. IOUtils.copy(fis, bos);
12. byte[] bytes = bos.toByteArray();
13. return bytes;
14. }finally {
15. if (fis != null) {
16. fis.close();
17. }
18. if (bos != null) {
19. bos.close();
20. }
21. }
22. }
24. /**
25. * byte 转file
26. */
27. public static File byte2File(byte[] buf,String fileName) throws IOException {
28. FileOutputStream fos = null;
29. try {
30. fos = new FileOutputStream(fileName);
31. fos.write(buf);
32. File file = new File(fileName);
33. return file;
34. } finally {
35. if (fos != null) {
36. fos.close();
37. }
38. }
39. }
40. }

复制代码

4.访问接口

1. @RestController
2. @RequestMapping("order/")
3. @Slf4j
4. public class SendHttpWController {
5. @Autowired
6. private UtimeeMapper utimeeMapper;
8. @GetMapping("/aa")
9. public String queryById( Integer id) throws IOException {
10. TTT ttt = new TTT();
11. ttt.setId("30");
12. ttt.setName("张三");
13. File file = new File("F:\\Desktop\\aa.docx");
14. byte[] bytes = FileUtil.file2byte(file);
15. ttt.setMiaoshuByte(bytes);
16. FileInputStream fileInputStream = new FileInputStream(file);
17. ttt.setMiaoshuInputstream(fileInputStream);
18. utimeeMapper.insert01(ttt);
19. return "嘿嘿额黑8082";
20. }
21. @GetMapping("/bb")
22. public String bb( Integer id) throws IOException {
23. TTT ttt = utimeeMapper.select01("30");
24. byte[] bytes = ttt.getMiaoshuByte();
25. FileUtil.byte2File(bytes,"F:\\Desktop\\cc.docx");
26. InputStream inputStream = ttt.getMiaoshuInputstream();
27. FileOutputStream outputStream = new FileOutputStream("F:\\Desktop\\dd.docx");
28. IOUtils.copy(inputStream, outputStream);//记得添加关流代码(本代码省略了)
29. return "嘿嘿额黑8082";
30. }

复制代码

5.输出成果

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持晓枫资讯。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！