用户管理与持久化实现-CSDN博客

1、POJO类，即模型类User；（也叫PO类）

<span style="font-size:18px;">package org.hibernate.entity;

public class User implements java.io.Serializable{
	private int id;
	private String name;
	private String password;
	private String type;
	public User(){
		
	}
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getPassword() {
		return password;
	}
	public void setPassword(String password) {
		this.password = password;
	}
	public String getType() {
		return type;
	}
	public void setType(String type) {
		this.type = type;
	}
}</span>

2、映射文件User.hbm.xml

<span style="font-size:18px;"><?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
	"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<!-- 映射文件的根元素 -->
<hibernate-mapping>
	<!-- class元素指定User类映射到user表， -->
	<class name="org.hibernate.entity.User" table="user">
		<!-- 将User类中的id属性映射为表user中的主键USER_ID -->
		<id name="id" type="java.lang.Integer" column="USER_ID" >
			<generator class="increment" /> <!-- 主键生成方式 -->
		</id>
		<!-- 属性映射，User类的name属性，映射到表中NAME列 -->
		<property name="name" type="java.lang.String" column="NAME" length="30"></property>
		<property name="password" type="java.lang.String" column="PASSWORD" length="32"></property>
		<property name="type" type="java.lang.String" column="TYPE" length="20"></property>
	</class>
</hibernate-mapping></span>

3、hibernate.cfg.xml配置文件

<span style="font-size:18px;"><?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/mldn</property>
        <property name="hibernate.connection.password">root</property>
        <property name="hibernate.connection.username">root</property>
        <!-- 配置JDBC内置连接池，这里最大连接数为1 -->
        <property name="connection.pool_size">1</property>
        <!-- 下面是配置数据库方言 -->
        <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
        <!-- 运行时生成的SQL语句，打印到控制台 -->
        <property name="show_sql">true</property>
        <!-- 列出所有映射文件 -->
        <mapping resource="org/hibernate/entity/User.hbm.xml" />
    </session-factory>
</hibernate-configuration>
</span>

4、辅助工具类HibernateUtil.java

以前用JDBC操作数据库时，用过一个DBUtil类，其主要作用；1. 是连接数据库，并对外提供一个已连接的conn 2. 是关闭这个conn，

这里的HibernateUtil也是类似的功能。

<span style="font-size:18px;">package org.hibernate.util;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;
import org.hibernate.HibernateException;

public class HibernateUtil {
	//声明session工厂类对象，要求得是静态的
	private static SessionFactory sessionFactory;
	private static Configuration cfg = null;
	//创建线程局部变量threadLocal集合，用来保存Hibernate的Session。（thread:线程     Local:本地，局部）
	private static final ThreadLocal<Session> threadLocal = new ThreadLocal<Session>();
	
	//使用静态代码块初始化Hibernate
	static{
		try{
			//读取配置文件hibernate.cfg.xml
			cfg = new Configuration().configure();
			//用cfg实例化工厂类对象sessionFactory
			sessionFactory = cfg.buildSessionFactory();
		}catch(Throwable ex){
			throw new ExceptionInInitializerError(ex);
		}
	}
	
	//获取一个Session工厂实例
	public static SessionFactory getSessionFactory(){
		return sessionFactory;
	}
	
	//获取由ThreadLocal对象管理的一个Session实例
	public static Session getSession() throws HibernateException{
		//先从threadLocal集合取出一个session
		Session session = (Session)threadLocal.get();
		//如果取到的session是个空的
		if(session == null ||!session.isOpen()){
			//先检查下工厂是否为空
			if(sessionFactory == null){
				//重建SessionFactory，此方法写在后面
				rebuildSessionFactory();
			}
			//通过SessionFactory生产一个session
			session = (sessionFactory!=null) ? sessionFactory.openSession():null;
			//把生产的session，放到threadLocal中
			threadLocal.set(session);
		}
		return session;
	}
	
	 //关闭Session实例
	public static void closeSession() throws HibernateException {
		//从线程局部变量中拿出之前存入的session
		Session session = (Session) threadLocal.get();
		threadLocal.set(null);
		if(session!=null){
			session.close();
		}
	}
	
	//重建SessionFactory方法
	public static void rebuildSessionFactory(){
		try{
			cfg.configure("/hibernate.cfg.xml");
			sessionFactory = cfg.buildSessionFactory();
		}catch(Exception e){
			System.err.println("Error Creating SessionFactory ");
			e.printStackTrace();
		}
	}
	
	//关闭缓存和连接池的方法
	public static void shutdown(){
		getSessionFactory().close();
	}

}
</span>

5、编写DAO接口，UserDAO

<span style="font-size:18px;">package org.hibernate.dao;
import java.util.List;
import org.hibernate.entity.User;

public interface UserDAO {
	void save(User user); //添加用户
	User findById(int id);  //根据id查找用户
	void delete(User user); //删除用户
	void update(User user); //修改用户信息
}
</span>

6、编写DAO接口实现类，UserDAOImpl

<span style="font-size:18px;">package org.hibernate.dao;
import org.hibernate.entity.User;
import org.hibernate.util.HibernateUtil;
import org.hibernate.Session;
import org.hibernate.Transaction;

public class UserDAOImpl implements UserDAO{
	/**
	 * 增加一个用户
	 */
	public void save(User user){
		Session session = HibernateUtil.getSession(); //工厂生产session对象
		Transaction tx = session.beginTransaction(); //创建Transaction事务对象
		try{
			session.save(user); //使用save()方法将user保存到数据库
			tx.commit(); //提交事务
		}catch(Exception e){
			e.printStackTrace();
			tx.rollback(); //如果出现异常，回滚事务
		}finally{
			HibernateUtil.closeSession(); //关闭session对象，即关闭数据库连接
		}
	}

	/**
	 * 根据id查询一个用户
	 */
	public User findById(int id){
		User user=null;
		Session session=HibernateUtil.getSession();
		Transaction tx = session.beginTransaction();
		try{
			user = (User)session.get(User.class, id);
			tx.commit();
		}catch(Exception e){
			e.printStackTrace();
			tx.rollback();
		}finally{
			HibernateUtil.closeSession();
		}
		return user;
	}
	
	/**
	 * 删除一个用户
	 */
	public void delete(User user){
		Session session = HibernateUtil.getSession();
		Transaction tx = session.beginTransaction();
		try{
			session.delete(user);
			tx.commit();
		}catch(Exception e){
			e.printStackTrace();
			tx.rollback();
		}finally{
			HibernateUtil.closeSession();
		}
	}
	
	/**
	 * 修改用户信息
	 */
	public void update(User user){
		Session session = HibernateUtil.getSession();
		Transaction tx = session.beginTransaction();
		try{
			session.update(user);
			tx.commit();
		}catch(Exception e){
			e.printStackTrace();
			tx.rollback();
		}finally{
			HibernateUtil.closeSession();
		}
	}


}
</span>

7、编写测试类UserTest

这里测试用JUnit，先将JUnit单元测试包引入项目中，项目上右击——Build Path——Configure Build Path，弹出窗中选Libraries标签，Add Library按钮，弹出窗中选JUint——Next ——选JUint4，Finish

在要建测试类的包上右击，New——Other——Java项下——JUint——JUint Test Case——Next——填上相关内容Finish

<span style="font-size:18px;">package org.hibernate.test;
import org.hibernate.dao.UserDAO;
import org.hibernate.dao.UserDAOImpl;
import org.hibernate.entity.User;

import static org.junit.Assert.*;
import org.junit.Before;
import org.junit.Test;

public class UserTest {
	@Before
	public void setUp() throws Exception {
		
	}
	@Test
	public void testSave() {
		UserDAO userdao=new UserDAOImpl();
		try{
			User u=new User();
			u.setId(20);
			u.setName("LiSi");
			u.setPassword("1212");
			u.setType("guest");
			userdao.save(u);
		}catch(Exception e){
			e.printStackTrace();
		}
	}

}
</span>