bulletiondaoimpl.java

来自「有简单的网上书店需求及设计流程」· Java 代码 · 共 101 行

package org.wiely.dao.impl;

import java.util.List;

import org.apache.log4j.Logger;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.wiely.dao.BulletionDAO;
import org.wiely.vo.Bulletion;

public class BulletionDAOImpl extends BaseDAO implements BulletionDAO {
	// use log4j.jar to provide logger provices
	static Logger logger = Logger.getLogger(AdminDAOImpl.class);

	@SuppressWarnings("unchecked")
	@Override
	public String showMess() throws Exception {
		Session session = getSession();
		Query query;
		String s;

		String hql = " from Bulletion b ";

		query = session.createQuery(hql);

		List list = query.list();

		if (list.size() != 0) {
			Bulletion b = (Bulletion) list.get(0);
			s = b.getContent();
			session.close();
			return s;
		} else {
			session.close();
			return null;
		}

	}

	@SuppressWarnings("unchecked")
	@Override
	public boolean isMaxScore(int adminid) throws Exception {
		Session session = getSession();
		Query query;
		int i = maxScore();

		String hql = "from Admin a where a.score=" + i + "and a.adminid ="
				+ adminid;
		query = session.createQuery(hql);

		List list = query.list();

		if (list.size() != 0) {
			session.close();
			return true;
		} else {
			session.close();
			return false;
		}

	}

	@SuppressWarnings("unchecked")
	public int maxScore() throws Exception {
		Session session = getSession();
		Query query;

		String hql = "select max(a.score) from Admin as a";
		query = session.createQuery(hql);
		List list = query.list();

		int i = (Integer) list.get(0);
		System.out.print(i);
		session.close();
		return i;
	}

	@SuppressWarnings("unchecked")
	public int queryIdByAdminid(int adminid) throws Exception {
		Session session = getSession();
		Query query;

		String hql = " select  b.bid from Bulletion b where b.adminid = " + adminid;
		query = session.createQuery(hql);
		List list = query.list();
		int i = (Integer) list.get(0);
		session.close();
		return i;
	}

	@Override
	public void updateBulletion(Bulletion bulletion) throws Exception {
		Session session = getSession();
		Transaction tx = session.beginTransaction();
		session.update(bulletion);
		tx.commit();
		session.close();
	}
}