Как написать java.sql.Blob для объекта JPA?

У меня есть объект JPA с java.sql.Blob:

@Entity
public class LargeData {

  @Lob
  private java.sql.Blob data;

  //getters/setters
}

Как создать экземпляр этого объекта? Я хочу установить Blob с помощью метода setData(), но как получить Blob из JPA? java.sql.Blob - это только интерфейс, существуют разные реализации для разных баз данных, поэтому я предполагаю, что JPA должна дать мне правильную реализацию. Как это получить?

Ответы

Ответ 1

Использовать массив байтов:

@Lob
@Column(length=100000)
private byte[] data;

Если вы хотите использовать потоки, создайте blob с помощью Hibernate.createBlob(..)

Ответ 2

используйте поток файлов. Тем не менее, это, по-видимому, имеет различные сложности, в зависимости от вашей базы данных, драйвера и реализации JPA. Я построил общее решение, которое было медленным и не удалось с большими файлами, а затем обнаружило решение, зависящее от Hibernate, которое работало с Oracle 11.2.0.4

Я использую Spring Data/JPA, но проблема кажется вокруг Hibernate, а не Spring.

Hibernate:

private void testLoadFile() throws SQLException, IOException {


  File f = new File("//C:/tmp/6mb_file.wmv");
  BufferedInputStream fstream = new BufferedInputStream(new FileInputStream(f));

  Session session = entityManager.unwrap(Session.class);
  Blob blob = Hibernate.getLobCreator(session).createBlob(fstream, f.length());

  FileBLOBEntity file = new FileBLOBEntity();

  file.setName("//C:/tmp/6mb_file.wmv");
  file.setTheData(blob);
  blobRepository.saveAndFlush(file);
}

Общий Spring/JPA:

private void testLoadFile() throws SQLException, IOException {

  File f = new File("//C:/tmp/6mb_file.wmv");
  BufferedInputStream fstream = new BufferedInputStream(new FileInputStream(f));

  Blob blob = connection.getConnection().createBlob();
  BufferedOutputStream bstream = new  BufferedOutputStream(blob.setBinaryStream(1));
  // stream copy runs a high-speed upload across the network
  StreamUtils.copy(fstream, bstream);

  FileBLOBEntity file = new FileBLOBEntity();

  file.setName("//C:/tmp/6mb_file.wmv");
  file.setTheData(blob);
  // save runs a low-speed download across the network.  this is where
  // Spring does the SQL insert.  For a large file, I get an OutOfMemory exception here.
  blobRepository.saveAndFlush(file);
}

и для извлечения:

public void unloadFile() throws SQLException, IOException {

  File f = new File("//C:/tmp/6mb_file.wmv" + "_fromDb");

  FileOutputStream fstream = new FileOutputStream(f);

  FileBLOBEntity file = blobRepository.findByName("//C:/tmp/6mb_file.wmv");
  Blob data = file.getTheData();

  InputStream bstream = data.getBinaryStream();
  StreamUtils.copy(bstream, fstream);

}