useraccountdao.java

基于Struts的网络商店源码。使用Hibernate技术

package com.sush.webstore.store.data.dao.hibernate;

import org.hibernate.Query;
import org.hibernate.Session;

import com.sush.webstore.store.data.dao.IUserAccountDAO;
import com.sush.webstore.store.data.dao.hibernate.util.HibernateUtil;
import com.sush.webstore.store.domain.IUserAccount;
import com.sush.webstore.store.domain.beans.UserAccount;

public class UserAccountDAO implements IUserAccountDAO {

	/*
	 * @param account @return
	 */
	public boolean addUserAccount(IUserAccount account) {

		if (account == null)
			return false;

		Session session = HibernateUtil.getSessionFactory().getCurrentSession();
		try {
			session.beginTransaction();
			session.save(account);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			session.getTransaction().commit();
		}
		return true;
	}

	/*
	 * @param id @return
	 */
	public IUserAccount getUserAccount(long id) {

		Session session = HibernateUtil.getSessionFactory().getCurrentSession();
		IUserAccount account = null;

		try {
			session.beginTransaction();
			account = (IUserAccount) session.get(UserAccount.class, id);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			session.getTransaction().commit();
		}
		return account;
	}

	/*
	 * @param userName @param pwd @return
	 */
	public IUserAccount getUserAccount(String userName, String pwd) {

		Session session = HibernateUtil.getSessionFactory().getCurrentSession();
		IUserAccount account = null;

		try {
			session.beginTransaction();

			Query query = session.createQuery("from UserAccount as account "
					+ "where account.userName = ? and account.password = ?");
			query.setString(0, userName);
			query.setString(1, pwd);

			account = (IUserAccount) query.uniqueResult();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			session.getTransaction().commit();
		}
		return account;
	}

	/*
	 * @param userName @return
	 */
	public IUserAccount getUserAccount(String userName) {

		Session session = HibernateUtil.getSessionFactory().getCurrentSession();
		IUserAccount account = null;

		try {
			session.beginTransaction();

			Query query = session.createQuery("from UserAccount as account "
					+ "where account.userName = ?");
			query.setString(0, userName);

			account = (IUserAccount) query.uniqueResult();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			session.getTransaction().commit();
		}
		return account;
	}

	/*
	 * @param account @return
	 */
	public boolean removeUserAccount(IUserAccount account) {

		if (account == null)
			return false;

		Session session = HibernateUtil.getSessionFactory().getCurrentSession();

		try {
			session.beginTransaction();
			session.delete(account);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			session.getTransaction().commit();
		}
		return true;
	}

	/*
	 * @param account @return
	 */
	public boolean updateUserAccount(IUserAccount account) {

		if (account == null)
			return false;

		Session session = HibernateUtil.getSessionFactory().getCurrentSession();

		try {
			session.beginTransaction();
			session.update(account);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			session.getTransaction().commit();
		}
		return true;
	}

}