java - 如何使用 Hibernate 选择 block 中的 BLOB 并写入文件？

Question

我需要选择 Blob 数据并将其写入磁盘上的文件。我需要使用从 Blob 获取的二进制流来执行此操作，但我遇到了 OutOfMemoryError，并且找不到解决方法。

实体类:

@Entity
@Table(name = "Table1")
public class AttachmentData implements Serializable
{
    // member variables
    @Column(name = "CONTENT")
    @Lob
    private Blob content;
    // getters, setters
}

实现类:

EntityManagerFactory emf = Persistence.createEntityManagerFactory("default");
EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
et.begin();
Session session = (Session) em.getDelegate(); // hibernate session
attachmentData = (AttachmentData) session.get(AttachmentData.class, new Long(1000));
InputStream is = attachmentData.getContent().getBinaryStream();
FileOutputStream fos = new FileOutputStream(new File("D:\\MyFile.wmv"));
BufferedOutputStream bos = new BufferedOutputStream(fos);
byte buf[] = new byte[2048];
int len;
while ((len = is.read(buf)) > 0)
{
    bos.write(buf, 0, len);
    bos.flush();
}

使用 Hibernate 4.2.1 和 JPA 1。

Answer 1

以下是我如何让它工作:

Session session = (Session) em.getDelegate(); // hibernate session
session.doWork(new Work()
{
    @Override
    public void execute(Connection connection) throws SQLException
    {
        try
        {
            String QUERY_STATEMENT = "SELECT * FROM Table1 WHERE ID= ?";
            PreparedStatement preparedStatement = connection.prepareStatement(QUERY_STATEMENT);
            preparedStatement.setLong(1, new Long(123123));
            ResultSet rs = preparedStatement.executeQuery();

            while (rs.next())
            {
                String fileName = rs.getString("FILE_NAME");
                FileOutputStream outStream = new FileOutputStream(location + fileName);
                InputStream inStream = rs.getBinaryStream("CONTENT");
                try
                {
                    IOUtils.copy(inStream, outStream);
                }
                catch (Exception exc)
                {
                    exc.printStackTrace();
                }
                finally
                {
                    IOUtils.closeQuietly(outStream);
                    IOUtils.closeQuietly(inStream);
                }
            }
        }
        catch (Exception exc)
        {
            exc.printStackTrace();
        }
    }
});

问题在于 MSSQL 驱动程序将整个数据加载到 byte[] 中，而不是为我提供流。我正在使用 Oracle 和 MSSQL 数据库。这为两者提供了通用解决方案。