Hibernate 批量增删改查操作

       上文介绍Hibernate基本的增删改查,本例将介绍更实用的批量增删改查的操作的实现。本文中增删改查的操作,仅供参考。如果读者需要应用到实际的应用场景需要的话,需要在此基础上扩展与丰富。

【转载使用,请注明出处:http://blog.csdn.net/mahoking
       在学习本例时,需要扩展一下Hibernate中Session的知识。Hibernate中的Session是一级缓存,可以理解为进程级的缓存。在进程运行期间一直存在。Session可以理解为一个可以操作数据库的对象 具体如何操作数据库,Session中有方法, 如果只是单独的Hibernate程序的话. 获得session之后,打开事务,操作数据库,提交(回滚事务),关闭session。就这样完成了操作DB 。
Hibernate中Session的使用:
在Hibernate中session主要是用来操作数据库,Hibernate在操作数据库前需要得到Session的实例,这个类似于jdbc中的Connection。
获得Session的方法如下:

Session session = sessionFactory.openSession();

       通过Session对象可以对数据库进行增删改查的操作,对应的方法分别为:save(),delete(),update(),saveOrUpdate(),load(),get()。在Hibernate 3中,取消了find()方法,必须通过Query或Criteria来进行查询。对于它的几个最基本的方法如save()、delete()、flush()等的学习需要一定的时间。在深入了解这些这些方法前,了解session的缓存机制以及Hibernate中Java对象的状态对我们是很有帮助的。
      在一个Hibernate应用中,Java对象可以处于以下三个状态之一:
      1.临时状态(Transient)。处于这个状态的对象还被没有纳入Hibernate的缓存管理体系,跟任何session都不关联,在数据库中也没有对应的记录。
      2.持久化状态(Persistent)。处于这个状态的对象位于Session的缓存中,并且和数据库中的一条数据记录相对应。
      3.游离状态(Detached)。处于这个状态的对象不再位于Session的缓存中,它与临时对象的最大区别在于,游离对象在数据库中还可能存在一条与它对应的记录。
上述3个状态之间是可以相互转化的,而且我们所说的状态都是针对某一个session实例而言的,比方说,对象A对于session1而言是处于持久化状态的,因为它处于session1的缓存中,但是对于session2而言对象A并不在它的缓存中,因此它是处于游离状态的。

扩展:
Q:
Session中get()和load()方法的区别?
A:

1、get方法会在调用之后立即向数据库发出sql语句(不考虑缓存的情况下),返回持久化对象;而load方法会在调用后返回一个代理对象,该代理对象只保存了实体对象的id,直到使用对象的非主键属性时才会发出sql语句。
2、查询数据库中不存在的数据时,get方法返回null,load方法抛出异常org.hibernate.ObjectNotFoundException。
具体批量增删改查的代码实现:


 

/* =============Session提供的使用HQL语句增删改查的方法============= */
	/**
	 * 批量插入(保存)操作,本例未使用HQL语句 注意:插入数据时:只支持INSERT INTO ... SELECT ...形式,不支持INSERT
	 * INTO ... VALUES ...形式.
	 * 
	 * @param userList
	 */
	public static void insertByHql(List<User> userList) {
		// 获取Session
		Session session = Hibernate4Util.getCurrentSession();
		try {
			// 开启事务
			Transaction transaction = session.beginTransaction();

			User tempUser = null;
			for (int i = 0; i < userList.size(); i++) {
				tempUser = userList.get(i);
				// 保存对象
				session.save(tempUser);
				// 批插入的对象立即写入数据库并释放内存
				if (i % 10 == 0) {
					session.flush();
					session.clear();
				}
			}
			transaction.commit();
		} catch (Exception e) {
			// 打印错误信息
			e.printStackTrace();
			// 出错将回滚事物
			session.getTransaction().rollback();
		} finally {
			// 关闭Session
			Hibernate4Util.closeSession(session);
		}

	}

	/**
	 * 通过HQL语句,实现批量删除 【具体应用需要自行扩展】
	 * 
	 * @param id
	 */
	public static void deleteByHql(int id) {
		String deleteHql = "delete User user where user.id = ?";

		Session session = Hibernate4Util.getCurrentSession();
		Transaction transaction = session.beginTransaction();
		Query deleteQuery = session.createQuery(deleteHql);
		deleteQuery.setParameter(0, id);
		int result = deleteQuery.executeUpdate();
		System.out.println("result = " + result);
		transaction.commit();

		Hibernate4Util.closeSession(session);
	}

	/**
	 * 批量分页查询
	 * 
	 * @param pageNo 页码
	 * @param pageSize 页面记录数据
	 */
	public static void selectByHql(int pageNo, int pageSize) {

		int fistRow = pageSize * pageNo;
		int maxRow = pageSize * (pageNo + 1);
		String selectHql = "from User user";

		Session session = Hibernate4Util.getCurrentSession();
		Transaction transaction = session.beginTransaction();
		Query selectQuery = session.createQuery(selectHql);
		selectQuery.setFirstResult(fistRow);
		selectQuery.setMaxResults(maxRow);
		List<User> userList = selectQuery.list();
		System.out.println(userList.toString());

		Hibernate4Util.closeSession(session);
	}

	/**
	 * 通过HQL语句,批量更新数据
	 */
	public static void updateByHql() {
		String updateHql = "update User user set user.userName =:newName where user.userName=:oldName";

		Session session = Hibernate4Util.getCurrentSession();
		Transaction transaction = session.beginTransaction();
		Query updateQuery = session.createQuery(updateHql);
		updateQuery.setString("newName", "Hoking");
		updateQuery.setString("oldName", "mahc");
		int result = updateQuery.executeUpdate();
		System.out.println("result = " + result);
		transaction.commit();

		Hibernate4Util.closeSession(session);
	}


【转载使用,请注明出处:http://blog.csdn.net/mahoking

 

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。