第一个Hibernate实现CRUD

0.创建webapp 带入hibernate包。

1.新建domain类：(com.zchen.user.domain)

package com.zchen.user.domain;

import java.util.Date;

public class User {
	
	private int id;
	private String name;
	private Date birthday;
	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 Date getBirthday() {
		return birthday;
	}
	public void setBirthday(Date birthday) {
		this.birthday = birthday;
	}
	

}

 

2.配置映射文件user.hbm.xml(com.zchen.user.domain)

<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping SYSTEM
  "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
  
<hibernate-mapping package="com.zchen.user.domain">
	<class name="User" table="`user`">
	  	<id name="id" column="`id`">
		  <generator class="native">
		  </generator>
	  	</id>
	  	<property name="name" unique="true"/>
	  	<property name="birthday"/>
	</class>
	
</hibernate-mapping>

 

3.在src目录下创建hibernate.cfg.xml文件

<!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="dialect">org.hibernate.dialect.MySQLDialect</property>
		<property name="connection.driver_class">com.mysql.jdbc.Driver</property>
		<property name="connection.url">jdbc:mysql:///user</property>
		<property name="connection.username">root</property>
		<property name="connection.password">mysqladmin</property>
		<property name="show_sql">true</property>
		<property name="hbm2ddl.auto">create</property>
		<mapping resource="com/zchen/user/domain/User.hbm.xml"/>
	</session-factory>
</hibernate-configuration>

 4.新建UserDao接口定义CRUD方法

package com.zchen.user.dao;

import com.zchen.user.domain.User;

public interface UserDao {

	public void saveUser(User user);
	public User findUserByName(String name);
	public User findUserById(int id);
	public void updateUser(User user);
	public void removeUser(User user);
}

 5.创建hibernate工具类得到session对象

package com.zchen.user.dao;

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

public final class HibernateUtil {
	
	private static SessionFactory sessionFactory;
	private HibernateUtil(){}
	static{
		Configuration cfg = new Configuration();
		cfg.configure();
		//cfg.setProperty(propertyName, value)
		sessionFactory = cfg.buildSessionFactory();
	}
	public static SessionFactory getSessionFactory() {
		return sessionFactory;
	}
	public static Session getSession(){
		return sessionFactory.openSession();
	}
	

}

 6.定义UserDaoHibernateImpl类实现UserDao接口

package com.zchen.user.dao.impl;
import org.hibernate.Criteria;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.criterion.Restrictions;

import com.zchen.user.dao.HibernateUtil;
import com.zchen.user.dao.UserDao;
import com.zchen.user.domain.User;

public class UserDaoHibernateImpl implements UserDao {

	public User findUserById(int id) {
		Session session = null;
		User user = null;
		try {
			session = HibernateUtil.getSession();
			user = (User)session.get(User.class,id);
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			if(session != null){
				session.close();
			}
		}
		return user;
	}

	public User findUserByName(String name) {
	/*	String hql="from User as user where user.name=:n";
		Query q = session.createQuery(hql);
		q.setString("n",name);
		User user = (User)q.uniqueResult();
	*/
		Session session = null;
		User user = null;
		try {
			session = HibernateUtil.getSession();
			Criteria c = session.createCriteria(User.class);
			c.add(Restrictions.eq("name", name));
			user = (User)c.uniqueResult();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			if(session != null){
				session.close();
			}
		}
		return user;
	}

	public void removeUser(User user) {
		Session session = null;
		Transaction tx = null;
		try {
			session = HibernateUtil.getSession();
			tx = session.beginTransaction();
		//可以传id 然后用user.setId(id);再将user作为变量delete（user）
			session.delete(user);
			tx.commit();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			if(session != null){
				session.close();
			}
		}
	}

	public void saveUser(User user) {
		Session session = null;
		Transaction tx = null;
		try {
			session = HibernateUtil.getSession();
			tx = session.beginTransaction();
					session.save(user);
			tx.commit();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			if(session != null){
				session.close();
			}
		}

	}

	public void updateUser(User user) {
		Session session = null;
		Transaction tx = null;
		try {
			 session = HibernateUtil.getSession();
			 tx = session.beginTransaction();
			 session.update(user);
			tx.commit();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			if(session != null){
				session.close();
			}
		}
	}

}

 测试：

package test;

import java.util.Date;

import com.zchen.user.dao.UserDao;
import com.zchen.user.dao.impl.UserDaoHibernateImpl;
import com.zchen.user.domain.User;

public class DaoTest {
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		UserDao dao = new UserDaoHibernateImpl();
		User user = new User();
		user.setName("admin");
		user.setBirthday(new Date());
		System.out.println("11111");
		dao.saveUser(user);
		
		user.setName("zchen");
		System.out.println("22222");
		dao.updateUser(user);
		
		User u = dao.findUserByName(user.getName());
		System.out.println("33333");
		dao.removeUser(u);

	}

}

 

评论

1 楼 rochou 2012-08-24