MySQL 如何使用JDBC将文件插入/存储到MySQL数据库中?

MySQL是一个非常受欢迎的关系型数据库，许多开发人员都在使用它来存储应用程序的数据。有时，我们需要将文件（例如图片、音频、视频、文本文件等）保存到MySQL数据库中。在这篇文章中，我们将探讨如何使用JDBC将文件插入/存储到MySQL数据库中。

阅读更多：MySQL 教程

1. 首先，我们需要在MySQL数据库中创建一个表来存储文件

我们可以使用以下MySQL命令创建一个名为“files”的表：

CREATE TABLE files (
  id INT(10) NOT NULL AUTO_INCREMENT,
  name VARCHAR(100) NOT NULL,
  data LONGBLOB,
  PRIMARY KEY (id)
);

这个表包含三个字段：

id – 自增长的整数类型，用作每个文件的唯一标识符。
name – 存储文件名的字符串类型，不能为NULL。
data – 存储文件内容的二进制类型，可以为NULL。

2. 然后我们需要编写Java代码来将文件插入到MySQL数据库中

我们使用JDBC（Java Database Connectivity）连接到MySQL数据库。下面是一个示例代码，它将文件存储在“files”表中：

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

public class FileInsert {

  public static void main(String[] args) {
    String url = "jdbc:mysql://localhost:3306/test";
    String user = "root";
    String password = "password";

    String fileName = "test.png";
    String filePath = "C:/Users/user/Desktop/";

    try {
      Class.forName("com.mysql.jdbc.Driver");
      Connection con = DriverManager.getConnection(url, user, password);
      String sql = "INSERT INTO files (name,data) values (?, ?)";
      PreparedStatement statement = con.prepareStatement(sql);

      FileInputStream inputStream = new FileInputStream(filePath + fileName);
      statement.setString(1, fileName);
      statement.setBinaryStream(2, inputStream, (int) (inputStream.available()));
      statement.executeUpdate();
      System.out.println("File inserted successfully!");

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

上面的代码包括以下步骤：

定义MySQL数据库的URL，用户名和密码。
定义要插入的文件的名称和在计算机上的路径。
将JDBC驱动程序加载到内存中。
建立MySQL数据库连接。
准备用于将文件插入到“files”表的SQL语句。
使用“java.io.FileInputStream”类打开要插入的文件，并将其作为二进制流传递给SQL查询。
执行SQL语句将文件插入到“files”表中。
关闭数据库连接。

3. 如何从MySQL数据库中检索文件

下面是一个示例代码，它从“files”表中检索文件并将其保存到计算机上的指定文件夹中：

import java.io.FileOutputStream;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class FileRetrieve {

  public static void main(String[] args) {
    String url = "jdbc:mysql://localhost:3306/test";
    String user = "root";
    String password = "password";

    String fileName = "test.png";
    String filePath = "C:/Users/user/Desktop/";

    try {
      Class.forName("com.mysql.jdbc.Driver");
      Connection con = DriverManager.getConnection(url, user, password);
      Statement statement = con.createStatement();
      ResultSet resultSet = statement.executeQuery("SELECT data FROM files WHERE name='" + fileName + "'");
      if (resultSet.next()) {
        InputStream inputStream = resultSet.getBinaryStream("data");
        FileOutputStream outputStream = new FileOutputStream(filePath + fileName);
        byte[] buffer = new byte[1024];
        while (inputStream.read(buffer) > 0) {
          outputStream.write(buffer);
        }
        System.out.println("File retrieved successfully!");
      }
      con.close();
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}

上面的代码包括以下步骤：