HQL 查询使用休眠替换数据库中的现有文件
HQL query to replace an existing file from database using hibernate
我在数据库中有一个现有文件,现在我需要用一个新文件从数据库中替换它。删除现有文件并添加新文件的 HQL 查询是什么?
public void addReplacementFile(UploadReplacementFileBean uploadReplacementFileBean) throws Exception {
SessionFactory sessionFactory = HibernateUtility.createSessionFactory();
Session session = null;
session = sessionFactory.openSession();
session.beginTransaction();
InputStream input = uploadReplacementFileBean.getFileData().getInputStream();
ByteArrayOutputStream output = new ByteArrayOutputStream();
byte[] buffer = new byte[10240];
for (int length = 0; (length = input.read(buffer)) > 0;)
output.write(buffer, 0, length);
try {
output.flush();
String qs="update UploadFileEntity set fileData=? where fileId=?";
Query query=session.createQuery(qs);
query.setParameter(0, output.toByteArray());
query.setParameter(1, uploadReplacementFileBean.getFileId());
query.executeUpdate();
session.getTransaction().commit();
session.close();
}catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
我在数据库中有一个现有文件,现在我需要用一个新文件从数据库中替换它。删除现有文件并添加新文件的 HQL 查询是什么?
public void addReplacementFile(UploadReplacementFileBean uploadReplacementFileBean) throws Exception {
SessionFactory sessionFactory = HibernateUtility.createSessionFactory();
Session session = null;
session = sessionFactory.openSession();
session.beginTransaction();
InputStream input = uploadReplacementFileBean.getFileData().getInputStream();
ByteArrayOutputStream output = new ByteArrayOutputStream();
byte[] buffer = new byte[10240];
for (int length = 0; (length = input.read(buffer)) > 0;)
output.write(buffer, 0, length);
try {
output.flush();
String qs="update UploadFileEntity set fileData=? where fileId=?";
Query query=session.createQuery(qs);
query.setParameter(0, output.toByteArray());
query.setParameter(1, uploadReplacementFileBean.getFileId());
query.executeUpdate();
session.getTransaction().commit();
session.close();
}catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}