MySQL Blob 对应 Java 类型|极客笔记

MySQL Blob 对应 Java 类型

1. 简介

Blob (Binary Large Object) 是一种可用于存储大量二进制数据的数据类型。MySQL 中的 BLOB 类型可以存储图像、视频、音频等二进制数据。在 Java 中操作 MySQL 数据库时，我们需要了解 MySQL Blob 类型对应的 Java 类型，以便正确地存储和读取 Blob 数据。

本文将详细介绍 MySQL Blob 类型的使用以及 Java 中对应的数据类型。

2. MySQL Blob 类型

2.1 Blob 数据类型

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

TINYBLOB: 最大存储长度为 255 个字节。
BLOB: 最大存储长度为 65,535 个字节。
MEDIUMBLOB: 最大存储长度为 16,777,215 个字节。
LONGBLOB: 最大存储长度为 4,294,967,295 个字节。

2.2 存储 Blob 数据

在数据库中创建一个能够存储 Blob 数据的表时，需要使用 Blob 类型的列。以下是一个示例 SQL 语句：

CREATE TABLE my_table (
    id INT PRIMARY KEY AUTO_INCREMENT,
    data BLOB
);

我们创建了一张名为 my_table 的表，其中包含 id 和 data 两列。id 是主键并自增，data 列用于存储 Blob 数据。

2.3 插入 Blob 数据

为了向表中插入 Blob 数据，我们需要使用二进制流（Byte Stream）来传递数据。以下是一个示例 Java 代码：

import java.io.FileInputStream;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

public class BlobInsertExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/my_database";
        String username = "root";
        String password = "password";

        try {
            Connection connection = DriverManager.getConnection(url, username, password);
            String query = "INSERT INTO my_table (data) VALUES (?)";
            PreparedStatement statement = connection.prepareStatement(query);

            InputStream inputStream = new FileInputStream("image.jpg");
            statement.setBlob(1, inputStream);

            int rowsInserted = statement.executeUpdate();
            if (rowsInserted > 0) {
                System.out.println("Blob data inserted successfully!");
            }

            statement.close();
            connection.close();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

上面的代码演示了如何插入 Blob 数据到 MySQL 数据库中。首先，我们建立了与数据库的连接，并将数据源定义为一个图片文件 “image.jpg”。然后，我们使用 PreparedStatement 来安全地插入数据。插入之后，输出 “Blob data inserted successfully!”。

2.4 读取 Blob 数据

要从 MySQL 数据库中读取 Blob 数据，我们需要使用 ResultSet。以下是一个示例 Java 代码：

import java.io.FileOutputStream;
import java.io.OutputStream;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class BlobReadExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/my_database";
        String username = "root";
        String password = "password";

        try {
            Connection connection = DriverManager.getConnection(url, username, password);
            String query = "SELECT data FROM my_table WHERE id = ?";
            PreparedStatement statement = connection.prepareStatement(query);

            int id = 1;
            statement.setInt(1, id);

            ResultSet resultSet = statement.executeQuery();
            if (resultSet.next()) {
                Blob blob = resultSet.getBlob("data");
                InputStream inputStream = blob.getBinaryStream();

                OutputStream outputStream = new FileOutputStream("image_output.jpg");
                byte[] buffer = new byte[4096];
                int bytesRead = -1;

                while ((bytesRead = inputStream.read(buffer)) != -1) {
                    outputStream.write(buffer, 0, bytesRead);
                }

                inputStream.close();
                outputStream.close();
                System.out.println("Blob data read successfully!");
            }

            statement.close();
            connection.close();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

上面的代码演示了如何从 MySQL 数据库中读取 Blob 数据并将其写入到输出流中。首先，我们建立了与数据库的连接，并通过 id 来选择要读取的 Blob 数据。然后，我们使用 getBlob() 方法获取 Blob 对象，并使用 getBinaryStream() 方法获取二进制流。最后，我们使用输出流将二进制流写入文件 “image_output.jpg”，并输出 “Blob data read successfully!”。