jpa - 如何通过 EntityManager 从 InputStream 更新 BLOB？

Question

我有一张 table :

mysql> desc documents;
+---------+--------------+------+-----+---------------------+----------------+
| Field   | Type         | Null | Key | Default             | Extra          |
+---------+--------------+------+-----+---------------------+----------------+
| id      | int(11)      | NO   | PRI | NULL                | auto_increment |
| item_id | int(11)      | YES  | MUL | NULL                |                |
| doctype | int(11)      | YES  | MUL | NULL                |                |
| name    | varchar(128) | YES  | MUL | NULL                |                |
| descr   | text         | YES  |     | NULL                |                |
| created | timestamp    | NO   |     | CURRENT_TIMESTAMP   |                |
| changed | timestamp    | NO   |     | 0000-00-00 00:00:00 |                |
| doc     | longblob     | YES  |     | NULL                |                |
+---------+--------------+------+-----+---------------------+----------------+

我已将其映射为Entity，如下所示:

@Entity
@Table(name = "documents", schema = "office_db")
@XmlRootElement
@NamedQueries({
    ...,
    @NamedQuery(name = "Documents.updateDocById", query = "UPDATE Documents d SET d.doc = :document WHERE d.id = :id")
})
public class Documents implements Serializable {

    @Column(name = "name", length = 128)
    private String name;
    @Lob
    @Column(name = "descr", length = 65535)
    private String descr;
    @Lob
    @Column(name = "doc")
    private byte[] doc;
    private static final long serialVersionUID = 1L;
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Basic(optional = false)
    @Column(name = "id")
    private Integer id;
    @Basic(optional = false)
    @Column(name = "created")
    @Temporal(TemporalType.TIMESTAMP)
    private Date created;
    @Basic(optional = false)
    @Column(name = "changed")
    @Temporal(TemporalType.TIMESTAMP)
    private Date changed;
    ...
}

我想用文件的内容更新 LONGBLOB DOC 列。为此，我获得了一个 InputStream 并希望将其与我的 NamedQuery 相关联 - 我天真地尝试了以下操作，期望它失败(当然，它确实失败了) ):

public String updateDocument(Integer id,InputStream is){
    String msg="";
    try{
        Query stmt=em.createNamedQuery("Documents.updateDocById")
                .setParameter("document",is);
        stmt.executeUpdate();
    }
    ...
}

如果我使用了 PreparedStatement，我就可以使用 setBinaryStream 方法，但这真的是正确的方法吗？

Answer 1

所以，回答我自己的问题:JPA 似乎不支持流式处理，至少在 JPA 2.2 之前不支持，根据 What’s new in JPA 2.2 – Stream the result of a Query execution | Vlad Mihalcea's Blog - 看起来它只是用于流式传输查询结果，而不是用于更新 BLOB，这正是我正在寻找的。

看起来又回到了使用PreparedStatement和setBinaryStream()。我还没有尝试过，但基于How to get DataSource or Connection from JPA2 EntityManager in Java EE 6 ，我的策略是:

• 开始交易。
• 从 EntityManager 中提取连接。
• 创建一个PreparedStatement。
• ...
• 提交或回滚事务。

我认为这有点令人讨厌，但你就是这样。