项目搭建啥的看我的上一篇文章，我就不多逼逼了，接下来就贴代码了
工具类：
package com.xinzhi.utils; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.cfg.Configuration; public class HibernateUtil { public static SessionFactory sf; static { sf = new Configuration().configure().buildSessionFactory(); } public static Session getSession() { return sf.openSession(); } }
对象序列化是为了反序列化用的，比如将一个对象写入到文件，或者作为流的形式传给第三方，那么这个类必须实现Serializable接口，并且定义一个私有的常量SerializableID，不然就不能从文件中读取对象了，接收方也没法还原这个对象
实际上就是一个ID用到了
package com.xinzhi.dao; import java.io.Serializable; import java.util.List; import com.xinzhi.entity.UserEntity; public interface UserDao { // 增加一个用户 public void saveUser(UserEntity userEntity); // 删除一个用户 public void deleteUser(Serializable id); // 修改一个用户 public void updateUser(UserEntity userEntity); // 查询所有的用户 public List<UserEntity> selectUser(); // 查询指定用户 public UserEntity selectOneUser(Serializable id); // 分页查询 public List<UserEntity> pageSelectUser(int currentPage, int pageCount); }
接下就是上面方法的代码实现：
package com.xinzhi.dao.impl; import java.io.Serializable; import java.util.List; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.Transaction; import com.xinzhi.dao.UserDao; import com.xinzhi.entity.UserEntity; import com.xinzhi.utils.HibernateUtil; public class UserDaoImpl implements UserDao { @Override public void deleteUser(Serializable id) { Session session = null; Transaction beginTransaction = null; try { session = HibernateUtil.getSession(); beginTransaction = session.beginTransaction(); Object object = session.get(UserEntity.class, id); if (object != null) { session.delete(object); } } catch (Exception e) { throw new RuntimeException(e); } finally { beginTransaction.commit(); session.close(); } } @Override public List<UserEntity> pageSelectUser(int currentPage, int pageCount) { Session session = null; Transaction beginTransaction = null; List<UserEntity> list = null; try { session = HibernateUtil.getSession(); beginTransaction = session.beginTransaction(); Query createQuery = session.createQuery("from UserEntity"); createQuery.setFirstResult(currentPage); createQuery.setMaxResults(pageCount); list = createQuery.list(); } catch (Exception e) { throw new RuntimeException(e); } finally { beginTransaction.commit(); session.close(); return list; } } @Override public void saveUser(UserEntity userEntity) { Session session = null; Transaction beginTransaction = null; try { session = HibernateUtil.getSession(); beginTransaction = session.beginTransaction(); session.saveOrUpdate(userEntity); } catch (Exception e) { throw new RuntimeException(e); } finally { beginTransaction.commit(); session.close(); } } @Override public UserEntity selectOneUser(Serializable id) { Session session = null; Transaction beginTransaction = null; UserEntity userEntity = null; try { session = HibernateUtil.getSession(); beginTransaction = session.beginTransaction(); userEntity = (UserEntity) session.get(UserEntity.class, id); } catch (Exception e) { throw new RuntimeException(e); } finally { beginTransaction.commit(); session.close(); return userEntity; } } @Override public List<UserEntity> selectUser() { Session session = null; Transaction transaction = null; List<UserEntity> list = null; try { session = HibernateUtil.getSession(); transaction = session.beginTransaction(); Query query = session.createQuery("from UserEntity "); list = query.list(); } catch (Exception e) { throw new RuntimeException(e); } finally { transaction.commit(); session.close(); return list; } } @Override public void updateUser(UserEntity userEntity) { Session session = null; Transaction beginTransaction = null; try { session = HibernateUtil.getSession(); beginTransaction = session.beginTransaction(); session.update(userEntity); } catch (Exception e) { throw new RuntimeException(e); } finally { beginTransaction.commit(); session.close(); } } }
接下来是User的实体类
package com.xinzhi.entity; public class UserEntity { private int id; private String username; private String pwd; public int getId() { return id; } public void setId(int id) { this.id = id; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public String getPwd() { return pwd; } public void setPwd(String pwd) { this.pwd = pwd; } @Override public String toString() { return "UserEntity [id=" + id + ", pwd=" + pwd + ", username=" + username + "]"; } }
接下来是对impl中的所有方法进行测试：
package com.xinzhi.test; import java.util.List; import org.junit.Test; import com.xinzhi.dao.impl.UserDaoImpl; import com.xinzhi.entity.UserEntity; public class TestUser { @Test public void testDelete() throws Exception { UserDaoImpl userDaoImpl = new UserDaoImpl(); userDaoImpl.deleteUser(2); } @Test public void testSelectAll() throws Exception { UserDaoImpl userDaoImpl = new UserDaoImpl(); List<UserEntity> selectUser = userDaoImpl.selectUser(); System.out.println(selectUser); } @Test public void testSelectLimit() throws Exception { UserDaoImpl userDaoImpl = new UserDaoImpl(); List<UserEntity> selectUser = userDaoImpl.pageSelectUser(0, 3); System.out.println(selectUser); } @Test public void testSelectOneUser() throws Exception { UserDaoImpl userDaoImpl = new UserDaoImpl(); UserEntity selectOneUser = userDaoImpl.selectOneUser(3); System.out.println(selectOneUser); } @Test public void testUpdateUser() throws Exception { UserDaoImpl userDaoImpl = new UserDaoImpl(); UserEntity userEntity = new UserEntity(); userEntity.setId(10); userEntity.setPwd("2113"); userEntity.setUsername("shaoxin"); userDaoImpl.updateUser(userEntity); System.out.println(userDaoImpl.selectOneUser(10)); } @Test public void testSaveUser() throws Exception { UserDaoImpl userDaoImpl = new UserDaoImpl(); UserEntity userEntity = new UserEntity(); userEntity.setUsername("shaoxin"); userEntity.setPwd("2113"); userDaoImpl.saveUser(userEntity); System.out.println(userDaoImpl.selectOneUser(11)); } }
接下来是文件配置文件名固定用UserEntity.hbm.xml
<?xml version="1.0"?> <!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN" "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd"> <hibernate-mapping package="com.xinzhi.entity"> <class name="UserEntity" table="user"><!-- 这里是主键，name是你实体类中的主键名称 ， column是你数据库中字段的主键 --><id name="id" column="id"> <generator class="native"/> </id><!-- 下面的分别是实体类中的属性对应数据库中的字段 --><property name="username" column="username"></property> <property name="pwd" column="pwd"></property> </class> </hibernate-mapping>
接下来是Hibernate的配置文件：
<!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd"> <hibernate-configuration> <session-factory> <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property> <property name="hibernate.connection.username">root</property> <property name="hibernate.connection.password">123456</property> <property name="hibernate.connection.url">jdbc:mysql://localhost:3306/webproject</property><!-- 反正下面这段话我直接跑去hibernate.dialect包下复制文件路径的时候gg了要指定特定的方言 --><property name="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</property> <property name="hibernate.show_sql">true</property> <property name=""></property> <!-- 如果不加下面这句话，引入你自己写的配置文件，你将会很绝望 --><mapping resource="com/xinzhi/entity/UserEntity.hbm.xml"/> </session-factory> </hibernate-configuration>