У меня есть объект JPA с java.sql.Blob:
@Entity
public class LargeData {
@Lob
private java.sql.Blob data;
//getters/setters
}
Как создать экземпляр этой сущности? Я хочу установить Blob методом setData(), но как получить Blob из JPA? java.sql.Blob - это только интерфейс, для разных баз данных существуют разные реализации, поэтому я предполагаю, что JPA должен дать мне правильную реализацию. Как его получить?
Используйте массив байтов:
@Lob
@Column(length=100000)
private byte[] data;
Если вы хотите использовать потоки, создайте большой двоичный объект с помощью Hibernate.createBlob(..)
length. Я также использую java nio для чтения из файла: myEntity.data = Files.readAllBytes(myPath).
- person Julien Kronegg; 27.12.2018
использовать файловый поток. Однако это может иметь различные сложности, в зависимости от вашей базы данных, драйвера и реализации JPA. Я построил универсальное решение, которое было медленным и не работало с большими файлами, затем нашел решение для Hibernate, которое работало с Oracle 11.2.0.4.
Я использую Spring Data/JPA, но проблема, похоже, связана с Hibernate, а не с Spring.
Спящий режим:
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);
}
