如何使用java从oracle blob中检索zip文件？

// 导入必要的类
import java.io.FileOutputStream;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class RetrieveZipFromOracleBlob {
    public static void main(String[] args) {
        // 数据库连接信息
        String url = "jdbc:oracle:thin:@localhost:1521:xe";
        String username = "your_username";
        String password = "your_password";
        
        // SQL查询语句
        String sql = "SELECT zip_data FROM your_table WHERE id = ?";
        
        // 设置Blob数据的ID
        int id = 1;
        
        try {
            // 建立数据库连接
            Connection connection = DriverManager.getConnection(url, username, password);
            
            // 创建PreparedStatement对象
            PreparedStatement statement = connection.prepareStatement(sql);
            
            // 设置参数
            statement.setInt(1, id);
            
            // 执行查询
            ResultSet resultSet = statement.executeQuery();
            
            // 处理结果集
            if (resultSet.next()) {
                // 获取Blob数据
                InputStream inputStream = resultSet.getBinaryStream("zip_data");
                
                // 创建输出流
                FileOutputStream outputStream = new FileOutputStream("output.zip");
                
                // 读取Blob数据并写入输出流
                byte[] buffer = new byte[1024];
                int length;
                while ((length = inputStream.read(buffer)) != -1) {
                    outputStream.write(buffer, 0, length);
                }
                
                // 关闭流
                inputStream.close();
                outputStream.close();
                
                System.out.println("Zip文件已成功检索并保存到output.zip");
            } else {
                System.out.println("未找到对应的Blob数据");
            }
            
            // 关闭连接
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}