java 将文件存入数据库的方法有哪些呢

综合百科 2025年11月21日 16:04 237 admin

Java中将文件存入数据库的多种方法

在Java开发中,有时需要将文件数据存储到数据库中，这一需求在很多应用场景中都非常重要，例如备份系统、日志记录系统等，本文将介绍几种常见的方法，帮助你实现将文件存入数据库的功能。

二进制大对象（BLOB）字段

最常见的方法是使用数据库中的BLOB（Binary Large Object）字段，大多数关系型数据库如MySQL、PostgreSQL和Oracle都支持BLOB字段，可以存储大量二进制数据。

java 将文件存入数据库的方法有哪些呢

步骤如下：

创建表时添加BLOB字段：

  CREATE TABLE files (
      id INT PRIMARY KEY,
      file_name VARCHAR(255),
      file_data BLOB
  );

使用JDBC将文件存入数据库：

  import java.sql.*;
  import java.io.*;
  public class BlobExample {
      public static void main(String[] args) {
          Connection connection = null;
          try {
              // 加载数据库驱动
              Class.forName("com.mysql.cj.jdbc.Driver");
              // 建立连接
              connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "password");
              // 创建PreparedStatement
              String sql = "INSERT INTO files (file_name, file_data) VALUES (?, ?)";
              PreparedStatement pstmt = connection.prepareStatement(sql);
              pstmt.setString(1, "example.txt");
              FileInputStream fis = new FileInputStream("example.txt");
              pstmt.setBlob(2, fis);
              pstmt.executeUpdate();
              fis.close();
          } catch (Exception e) {
              e.printStackTrace();
          } finally {
              if (connection != null) {
                  try {
                      connection.close();
                  } catch (SQLException e) {
                      e.printStackTrace();
                  }
              }
          }
      }
  }

从数据库读取文件：

  import java.sql.*;
  import java.io.*;
  public class ReadBlobExample {
      public static void main(String[] args) {
          Connection connection = null;
          try {
              // 加载数据库驱动
              Class.forName("com.mysql.cj.jdbc.Driver");
              // 建立连接
              connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "password");
              // 创建PreparedStatement
              String sql = "SELECT * FROM files WHERE id = ?";
              PreparedStatement pstmt = connection.prepareStatement(sql);
              pstmt.setInt(1, 1);
              ResultSet rs = pstmt.executeQuery();
              if (rs.next()) {
                  Blob blob = rs.getBlob("file_data");
                  InputStream is = blob.getBinaryStream();
                  OutputStream os = new FileOutputStream("output.txt");
                  byte[] buffer = new byte[1024];
                  int bytesRead;
                  while ((bytesRead = is.read(buffer)) != -1) {
                      os.write(buffer, 0, bytesRead);
                  }
                  is.close();
                  os.close();
              }
          } catch (Exception e) {
              e.printStackTrace();
          } finally {
              if (connection != null) {
                  try {
                      connection.close();
                  } catch (SQLException e) {
                      e.printStackTrace();
                  }
              }
          }
      }
  }

使用字节数组（byte array）字段

另一种方法是将文件内容读入字节数组,然后存储到数据库的字节数组字段中，这种方法适用于存储较小的文件。

步骤如下：

java 将文件存入数据库的方法有哪些呢

创建表时添加字节数组字段：

  CREATE TABLE files (
      id INT PRIMARY KEY,
      file_name VARCHAR(255),
      file_data VARBINARY(MAX)
  );

使用JDBC将文件存入数据库：

  import java.sql.*;
  import java.io.*;
  public class VarbinaryExample {
      public static void main(String[] args) {
          Connection connection = null;
          try {
              // 加载数据库驱动
              Class.forName("com.mysql.cj.jdbc.Driver");
              // 建立连接
              connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "password");
              // 创建PreparedStatement
              String sql = "INSERT INTO files (file_name, file_data) VALUES (?, ?)";
              PreparedStatement pstmt = connection.prepareStatement(sql);
              pstmt.setString(1, "example.txt");
              FileInputStream fis = new FileInputStream("example.txt");
              byte[] fileBytes = new byte[fis.available()];
              fis.read(fileBytes);
              pstmt.setBytes(2, fileBytes);
              pstmt.executeUpdate();
              fis.close();
          } catch (Exception e) {
              e.printStackTrace();
          } finally {
              if (connection != null) {
                  try {
                      connection.close();
                  } catch (SQLException e) {
                      e.printStackTrace();
                  }
              }
          }
      }
  }

从数据库读取文件：

  import java.sql.*;
  import java.io.*;
  public class ReadVarbinaryExample {
      public static void main(String[] args) {
          Connection connection = null;
          try {
              // 加载数据库驱动
              Class.forName("com.mysql.cj.jdbc.Driver");
              // 建立连接
              connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "password");
              // 创建PreparedStatement
              String sql = "SELECT * FROM files WHERE id = ?";
              PreparedStatement pstmt = connection.prepareStatement(sql);
              pstmt.setInt(1, 1);
              ResultSet rs = pstmt.executeQuery();
              if (rs.next()) {
                  byte[] fileBytes = rs.getBytes("file_data");
                  InputStream is = new ByteArrayInputStream(fileBytes);
                  OutputStream os = new FileOutputStream("output.txt");
                  byte[] buffer = new byte[1024];
                  int bytesRead;
                  while ((bytesRead = is.read(buffer)) != -1) {
                      os.write(buffer, 0, bytesRead);
                  }
                  is.close();
                  os.close();
              }
          } catch (Exception e) {
              e.printStackTrace();
          } finally {
              if (connection != null) {
                  try {
                      connection.close();
                  } catch (SQLException e) {
                      e.printStackTrace();
                  }
              }
          }
      }
  }

使用文件流（File Stream）字段

有些数据库支持直接存储文件流,这样可以避免将文件内容读入内存，这种方法的使用较为有限，且依赖于具体的数据库实现。

步骤如下：

创建表时添加文件流字段：

  CREATE TABLE files (
      id INT PRIMARY KEY,
      file_name VARCHAR(255),
      file_data VARCHAR(MAX) FOR FILE STUFFONLY
  );

使用JDBC将文件存入数据库：

  import java.sql.*;
  import java.io.*;
  public class FileStreamExample {
      public static void main(String[] args) {
          Connection connection = null;
          try {
              // 加载数据库驱动
              Class.forName("com.mysql.cj.jdbc.Driver");
              // 建立连接
              connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "password");
              // 创建PreparedStatement
              String sql = "INSERT INTO files (file_name, file_data) VALUES (?, ?)";
              PreparedStatement pstmt = connection.prepareStatement(sql);
              pstmt.setString(1, "example.txt");
              FileInputStream fis = new FileInputStream("example.txt");
              pstmt.setAsciiStream(2, fis);
              pstmt.executeUpdate();
              fis.close();
          } catch (Exception e) {
              e.printStackTrace();
          } finally {
              if (connection != null) {
                  try {
                      connection.close();
                  } catch (SQLException e) {
                      e.printStackTrace();
                  }
              }
          }
      }
  }

从数据库读取文件：

  import java.sql.*;
  import java.io.*;
  public class ReadFileStreamExample {
      public static void main(String[] args) {
          Connection connection = null;
          try {
              // 加载数据库驱动
              Class.forName("com.mysql.cj.jdbc.Driver");
              // 建立连接
              connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "password");
              // 创建PreparedStatement
              String sql = "SELECT * FROM files WHERE id = ?";
              PreparedStatement pstmt = connection.prepareStatement(sql);
              pstmt.setInt(1, 1);
              ResultSet rs = pstmt.executeQuery();
              if (rs.next()) {
                  InputStream is = rs.getAsciiStream("file_data");
                  OutputStream os = new FileOutputStream("output.txt");
                  byte[] buffer = new byte[1024];
                  int bytesRead;
                  while ((bytesRead = is.read(buffer)) != -1) {
                      os.write(buffer, 0, bytesRead);
                  }
                  is.close();
                  os.close();
              }
          } catch (Exception e) {
              e.printStackTrace();
          } finally {
              if (connection != null) {
                  try {
                      connection.close();
                  } catch (SQLException e) {
                      e.printStackTrace();
                  }
              }
          }
      }

标签：文件存储