第一个Hibernate兑现CRUD
第一个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