Hibernate对于用户表增删该查的实现

偏执的太偏执、 2022-07-21 00:26 128阅读 0赞

1、使用的Hibernate的版本

[hibernate-distribution-3.6.0.Final][]

2、引入的jar文件

**hibernate3.jar核心  \+  required 必须引入的(6个) +  jpa 目录  \+数据库驱动包**

3、对象以及对象的映射文件\*.hbm.xml的编写

1、User.java

public class User {
    	private int id;
    	private int age;
    	private String name;
            // setter  getter
    }

2、User.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.hibernate.entity">
    
    	<class name="User" table="user">
    
    		
    		<id name="id" column="id">
    			
    			<generator class="native" />
    		</id>
    
    		
    		<property name="name" column="name"></property>
    		<property name="age" column="age"></property>
    
    	</class>
    
    </hibernate-mapping>

4、主配置文件hibernate.cfg.xml 的编写

<!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.url">
    			jdbc:mysql:///hibernate
    		</property>
    		<property name="hibernate.connection.username">root</property>
    		<property name="hibernate.connection.password">1234</property>
    		
    		<property name="hibernate.dialect">
    			org.hibernate.dialect.MySQL5Dialect
    		</property>
    
    
    		
    		
    		<property name="hibernate.show_sql">true</property>
    		
    		<property name="hibernate.format_sql">true</property>
    		
    		<property name="hibernate.hbm2ddl.auto">update</property>
    
    		
    
    		<mapping resource="com/hibernate/entity/User.hbm.xml" />
    	</session-factory>
    </hibernate-configuration>

5、IUserDao,java接口的定义

public interface IUserDao {
    	// 查找用户
    	public User findById(int id);
    
    	// 增加用户
    	public void addUser(User user);
    
    	// 修改用户
    	public void updateUser(User user);
    
    	// 删除用户
    	public void deleteUser(int id);
    
    	// 查询所有的用户
    	public List<User> getAll();
    
    	// 分页查询用户
    	public List<User> getAll(int start, int size);
    
    	//
    
    }

6、UserdaoImpl.java对于IUserDao,java接口的实现

public class UserdaoImpl implements IUserDao {
    
    	@Override
    	public User findById(int id) {
    		Session session = null;
    		Transaction tx = null;
    		try {
    			// 获取Session
    			session = HibernateUtils.openSession();
    			// 开启事务
    			tx = session.beginTransaction();
    			// 主键查询
    			return (User) session.get(User.class, id);
    		} catch (Exception e) {
    			// 进行事务的回滚
    			tx.rollback();
    			throw new RuntimeException(e);
    		} finally {
    			// 进行事务的提交
    			tx.commit();
    			// 关闭session
    			session.close();
    		}
    	}
    
    	@Override
    	public void addUser(User user) {
    		Session session = null;
    		Transaction tx = null;
    		try {
    			// 获取Session
    			session = HibernateUtils.openSession();
    			// 开启事务
    			tx = session.beginTransaction();
    			// 用户的保存
    			session.save(user);
    		} catch (Exception e) {
    			// 进行事务的回滚
    			tx.rollback();
    			throw new RuntimeException(e);
    		} finally {
    			// 进行事务的提交
    			tx.commit();
    			// 关闭session
    			session.close();
    		}
    	}
    
    	@Override
    	public void updateUser(User user) {
    		Session session = null;
    		Transaction tx = null;
    		try {
    			// 获取Session
    			session = HibernateUtils.openSession();
    			// 开启事务
    			tx = session.beginTransaction();
    			// 用户的更新
    			session.update(user);
    		} catch (Exception e) {
    			// 进行事务的回滚
    			tx.rollback();
    			throw new RuntimeException(e);
    		} finally {
    			// 进行事务的提交
    			tx.commit();
    			// 关闭session
    			session.close();
    		}
    	}
    
    	@Override
    	public void deleteUser(int id) {
    		Session session = null;
    		Transaction tx = null;
    		try {
    			session = HibernateUtils.openSession();
    			tx = session.beginTransaction();
    			// 先根据id查询对象，再判断删除
    			User obj = (User) session.get(User.class, id);
    			if (obj != null) {
    				session.delete(obj);
    			}
    		} catch (Exception e) {
    			// 进行事务的回滚
    			tx.rollback();
    			throw new RuntimeException(e);
    		} finally {
    			// 进行事务的提交
    			tx.commit();
    			// 关闭session
    			session.close();
    		}
    	}
    
    	@Override
    	public List<User> getAll() {
    		Session session = null;
    		Transaction tx = null;
    		try {
    			session = HibernateUtils.openSession();
    			tx = session.beginTransaction();
    			Query q = session.createQuery("from User");
    			List<User> list = q.list();
    			return list;
    		} catch (Exception e) {
    			// 进行事务的回滚
    			tx.rollback();
    			throw new RuntimeException(e);
    		} finally {
    			// 进行事务的提交
    			tx.commit();
    			// 关闭session
    			session.close();
    		}
    	}
    
    	@Override
    	public List<User> getAll(int start, int size) {
    		Session session = null;
    		Transaction tx = null;
    		try {
    			session = HibernateUtils.openSession();
    			tx = session.beginTransaction();
    			Query q = session.createQuery("from User");
    			// 设置分页参数
    			q.setFirstResult(start); // 查询的其实行
    			q.setMaxResults(size); // 查询返回的行数
    
    			List<User> list = q.list();
    			return list;
    		} catch (Exception e) {
    			// 进行事务的回滚
    			tx.rollback();
    			throw new RuntimeException(e);
    		} finally {
    			// 进行事务的提交
    			tx.commit();
    			// 关闭session
    			session.close();
    		}
    	}
    
    }

6、HibernateUtils.java

public class HibernateUtils {
    	private final static SessionFactory FACTORY = buildSessionFactory();
    
    	private static SessionFactory buildSessionFactory() {
    		// 默认在classpath下，寻找hibernate.cfg.xml的配置文件
    		Configuration cfg = new Configuration().configure();
    		return cfg.buildSessionFactory();
    	}
    
    	public static SessionFactory getSessionFactory() {
    		return FACTORY;
    	}
    
    	public static Session openSession() {
    		return FACTORY.openSession();
    	}
    
    	public static void closeSession(Session session) {
    		if (session != null)
    			session.close();
    	}
    
    	public static void main(String[] args) {
    		System.out.println(HibernateUtils.FACTORY);
    	}
    }

7、项目源码的下载

[1、用到的数据库mysql文件的下载][1_mysql]

[2、用到的mysql数据库，可视化工具的下载][2_mysql]

[3、项目代码的下载][3]

[hibernate-distribution-3.6.0.Final]: http://pan.baidu.com/s/1dFE1VFV
[1_mysql]: http://pan.baidu.com/s/1skFPlVJ
[2_mysql]: http://pan.baidu.com/s/1nuMcYkL
[3]: http://pan.baidu.com/s/1nuEB0cp