Hibernate实现Oracle BLOB的数据读写(2)

这次采用的是EJB3的配置

测试环境与前次一样：Hibernate3.6.7，Oracle 10g Express，JDK7，Win7

1，数据库脚本

 

create table TUser  (
   ID                   char(32)                        not null,
   name               varchar(10char)                 not null,
   photo               blob,                              --头像
   constraint PK_TUser primary key (ID)
);

 

 2，配置文件，即META-INF/persistence.xml

 

<?xml version="1.0" encoding="UTF-8"?>
<persistence xmlns="http://java.sun.com/xml/ns/persistence"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://java.sun.com/xml/ns/persistence
http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd"
	version="2.0">
	<persistence-unit name="test" transaction-type="RESOURCE_LOCAL">
		<provider>org.hibernate.ejb.HibernatePersistence</provider>
		<properties>
			<property name="javax.persistence.jdbc.driver" value="oracle.jdbc.driver.OracleDriver" />
			<property name="javax.persistence.jdbc.url" value="jdbc:oracle:thin:@localhost:1521:XE" />
			<property name="javax.persistence.jdbc.user" value="tanlan" />
			<property name="javax.persistence.jdbc.password" value="tanlan" />
			<property name="hibernate.show_sql" value="true" />
			<property name="hibernate.dialect" value="org.hibernate.dialect.Oracle10gDialect" />
		</properties>
	</persistence-unit>
</persistence>

 

 3,编写实体类User.java

 

package com.tanlan.hibernate.entity;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.Lob;
import javax.persistence.Table;

import org.hibernate.annotations.GenericGenerator;

@Entity
@Table(name = "TUser")
public class User {
	@Id
	@GenericGenerator(name = "uid", strategy = "uuid")
	@GeneratedValue(generator = "uid")
	private String id;
	@Column
	private String name;
	@Lob
	@Column
	private byte[] photo;
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public byte[] getPhoto() {
		return photo;
	}
	public void setPhoto(byte[] photo) {
		this.photo = photo;
	}
}

 

 4.测试代码

package com.tanlan.hibernate.test;

import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;

import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.EntityTransaction;
import javax.persistence.Persistence;

import com.tanlan.hibernate.entity.User;

public class TestUser {

	public static void main(String[] args) {
		addUser();
		//getUserById();
	}

	private static void addUser() {
		User user = new User();
		user.setName("谭岚");
		File photo = new File("D:\\test.jpg");
		try {
			FileInputStream is = new FileInputStream(photo);
			ByteArrayOutputStream os = new ByteArrayOutputStream();
			byte[] temp = new byte[512];
			int i = 0;
			while ((i = is.read(temp, 0, temp.length)) != -1) {
				os.write(temp, 0, temp.length);
			}
			os.close();
			is.close();
			user.setPhoto(os.toByteArray());
		} catch (Exception e) {
			e.printStackTrace();
		}
		EntityManager em = createEntityManager();
		EntityTransaction transaction = em.getTransaction();
		transaction.begin();
		em.persist(user);
		transaction.commit();
	}

	private static void getUserById() {
		EntityManager em = createEntityManager();
		User user = (User) em.find(User.class,"402881e432aad3340132aad33c210000");
		em.close();
		byte[] photo = user.getPhoto();
		try {
			FileOutputStream os = new FileOutputStream("E:\\333.jpg");
			os.write(photo);
			os.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	private static EntityManager createEntityManager() {
		EntityManagerFactory emf = Persistence.createEntityManagerFactory("test");
		return emf.createEntityManager();
	}

}