DoubleRight The past of the world Blog's

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

从数据库中插入/选择 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 example

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();
    }
}

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

源码下载

祝您学习愉快！

搜索