从数据库中插入/选择 Blob 的 Hiberate 示例

原文： https://howtodoinjava.com/hibernate/hibernate-example-of-insertselect-blob-from-database/

在先前的 Hiberate 教程中，我们了解了一级缓存，二级缓存和一些映射示例等。这是 Hiberate 相关教程的完整列表。 在本文中，我将举一个使用 hibernate 将 BLOB 数据插入数据库并使用 hibernate 实体从数据库中获取数据的示例。

简而言之，插入和获取 BLOB 数据（例如图像）需要两个步骤：将数据库列类型定义为“BLOB”，并且在实体中具有“字节数组”类型的字段。

让我们举个例子，其中，我将 Windows C 驱动器中的“test.png”图像插入数据库（MySQL）。 然后，我将再次从数据库中读取图像数据并将其存储到其他位置。

Hiberate 实体

请注意，我已将数据字段声明为byte[]。

@Entity
@Table(name = "TBL_IMAGES")
public class ImageWrapper implements Serializable {
    private static final long serialVersionUID = 1L;
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "ID", unique = true, nullable = false)
    private Integer id;
    @Column(name = "IMAGE_NAME", unique = false, nullable = false, length = 100)
    private String imageName;
    @Column(name = "DATA", unique = false, nullable = false, length = 100000)
    private byte[] data;
    //Getters and Setters
}

将 Blob 数据插入数据库

让我们看一下代码：

    Session session = HibernateUtil.getSessionFactory().openSession();
    session.beginTransaction();
    File file = new File("C:\test.png");
    byte[] imageData = new byte[(int) file.length()];
    try {
        FileInputStream fileInputStream = new FileInputStream(file);
        fileInputStream.read(imageData);
        fileInputStream.close();
    } catch (Exception e) {
        e.printStackTrace();
    }
    ImageWrapper image = new ImageWrapper();
    image.setImageName("test.jpeg");
    image.setData(imageData);
    session.save(image);    //Save the data
    session.getTransaction().commit();
    HibernateUtil.shutdown();

执行完上述代码后，您可以验证是否已在数据库中创建表。 并且创建了一个 BLOB 列来保存图像数据。

Hibernate blob 示例

从数据库读取 Blob 数据

这很简单，实际上您不需要执行任何其他操作。 上面的实体定义可以正常工作。

    Session session = HibernateUtil.getSessionFactory().openSession();
    session.beginTransaction();
    ImageWrapper imgNew = (ImageWrapper)session.get(ImageWrapper.class, 1);
    byte[] bAvatar = imgNew.getData();
    try{
        FileOutputStream fos = new FileOutputStream("C:\temp\test.png"); 
        fos.write(bAvatar);
        fos.close();
    }catch(Exception e){
        e.printStackTrace();
    }
    session.getTransaction().commit();
    HibernateUtil.shutdown();

Hiberate 配置

作为参考，这是我在此示例中使用的配置：

hibernate.cfg.xml

<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-configuration PUBLIC
"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
    <session-factory>
        <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
        <property name="hibernate.connection.url">jdbc:mysql://localhost:3306/test</property>
        <property name="hibernate.connection.password">password</property>
        <property name="hibernate.connection.username">root</property>
        <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
        <property name="show_sql">true</property>
        <property name="hibernate.hbm2ddl.auto">create</property>
        <mapping class="hibernate.test.dto.ImageWrapper"></mapping>
    </session-factory>
</hibernate-configuration>

以下也是HibernateUtil.java的代码

HibernateUtil.java

public class HibernateUtil {
    private static final SessionFactory sessionFactory = buildSessionFactory();
    @SuppressWarnings("deprecation")
    private static SessionFactory buildSessionFactory() {
        try {
            // Create the SessionFactory from hibernate.cfg.xml
            return new AnnotationConfiguration().configure(new File
                    ("D:\Latest Setup\eclipse_juno_workspace\hibernate-test-project\hibernate.cgf.xml"))
                    .buildSessionFactory();
        }
        catch (Throwable ex) {
            // Make sure you log the exception, as it might be swallowed
            System.err.println("Initial SessionFactory creation failed." + ex);
            throw new ExceptionInInitializerError(ex);
        }
    }
    public static SessionFactory getSessionFactory() {
        return sessionFactory;
    }
    public static void shutdown() {
        getSessionFactory().close();
    }
}

如果仍然感到麻烦，请下载随附的源代码。

源码下载

祝您学习愉快！