package cn.com.blogonline;

import java.util.List;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;

public class DbOperate {

	/**
	 * 根據用戶名得到Blog對象
	 */
	public Blog getBlog(String userId) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		Blog blog = null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			Query query = session.createQuery("from Blog where username=:userId");
			query.setParameter("userId", userId);
			List list = query.list();
			if (!list.isEmpty())
				blog = (Blog) list.get(0);
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		session.close();
		return blog;
	}

	/**
	 * 根據ID得到Blog對象
	 */
	public Blog getBlog(int Id) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		Blog blog = null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			Query query = session.createQuery("from Blog where id=" + Id);
			List list = query.list();
			if (!list.isEmpty())
				blog = (Blog) list.get(0);
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		session.close();
		return blog;
	}


	/**
	 * 得到熱點Blog對象集
	 */
	public List getBlogs(int showCount) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		List list=null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			Query query = session.createQuery("from Blog order by visitcount desc");
			if (showCount>0){
				query.setMaxResults(showCount);								//記錄集最大個數
			}
			list = query.list(); //從數據庫取出數據，并自動封裝到List集合中
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		HibernateUtil.closeSession();
		return list; 
	}

	/**
	 * 得到匹配Blog對象集
	 */
	public List getMatchBlogs(String key) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		List list=null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			Query query = session.createQuery("from Blog where subject like '%" + key + "%'");
			list = query.list(); //從數據庫取出數據，并自動封裝到List集合中
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		HibernateUtil.closeSession();
		return list; 
	}

	/**
	 * 根據ID得到Sort對象
	 */
	public Sort getSort(int Id) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		Sort sort = null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			Query query = session.createQuery("from Sort where id=" + Id);
			List list = query.list();
			if (!list.isEmpty())
				sort = (Sort) list.get(0);
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		session.close();
		return sort;
	}

	/**
	 * 根據ID得到Links對象
	 */
	public Links getLink(int Id) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		Links link = null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			Query query = session.createQuery("from Links where id=" + Id);
			List list = query.list();
			if (!list.isEmpty())
				link = (Links) list.get(0);
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		session.close();
		return link;
	}

	/**
	 * 得到指定文章對象
	 */
	public Article getArticle(int articleid) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		Article article = null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
		//	創建查詢對象
			Query query = session.createQuery("from Article where id=" + articleid);
			List list = query.list();
			if (!list.isEmpty())
				article = (Article) list.get(0);
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		session.close();
		return article;
	}

	/**
	 * 得到匹配Article對象集
	 */
	public List getMatchArticles(String key) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		List list=null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			Query query = session.createQuery("from Article where title like '%" + key + "%'");
			list = query.list(); //從數據庫取出數據，并自動封裝到List集合中
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		HibernateUtil.closeSession();
		return list; 
	}

	/**
	 * 得到最新文章對象集
	 */
	public List getArticles(int showCount) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		List list=null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			Query query = session.createQuery("from Article order by pubtime desc");
			if (showCount>0){
				query.setMaxResults(showCount);								//記錄集最大個數
			}
			list = query.list(); //從數據庫取出數據，并自動封裝到List集合中
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		HibernateUtil.closeSession();
		return list; 
	}

	/**
	 * 得到指定博客最新文章對象集
	 */
	public List getBlogArticles(int blogid,int sortid) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		List list=null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			String strSql = "from Article  where blogid=" + blogid;//創建一個查詢語句,查詢指定類別產品;
			if (sortid>0){
				strSql = strSql + " and sortid=" + sortid ;								//記錄集最大個數
			}
			strSql = strSql + " order by pubtime desc" ;								//記錄集最大個數
			Query query = session.createQuery(strSql);
			list = query.list(); //從數據庫取出數據，并自動封裝到List集合中
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		HibernateUtil.closeSession();
		return list; 
	}

	/**
	 * 得到指定博客文章分類對象集
	 */
	public List getBlogSorts(int blogid) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		List list=null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			String strSql = "from Sort where blogid=" + blogid;//創建一個查詢語句,查詢指定類別產品;
			Query query = session.createQuery(strSql);
			list = query.list(); //從數據庫取出數據，并自動封裝到List集合中
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		HibernateUtil.closeSession();
		return list; 
	}

	/**
	 * 得到指定博客超級鏈接對象集
	 */
	public List getBlogLinks(int blogid) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		List list=null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			String strSql = "from Links where blogid=" + blogid;//創建一個查詢語句,查詢指定類別產品;
			Query query = session.createQuery(strSql);
			list = query.list(); //從數據庫取出數據，并自動封裝到List集合中
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		HibernateUtil.closeSession();
		return list; 
	}

	/**
	 * 得到指定文章回復對象集
	 */
	public List getFeedBacks(int articleid) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		List list=null;
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
//			創建查詢對象
			String strSql = "from FeedBack  where articleid=" + articleid
						+ " order by pubtime desc" ;					//創建一個查詢語句,查詢指定類別產品;			
			Query query = session.createQuery(strSql);
			list = query.list(); //從數據庫取出數據，并自動封裝到List集合中
			tx.commit();
		} catch (HibernateException e) {
			if (tx != null)
				tx.rollback();
			throw e;
		}
		HibernateUtil.closeSession();
		return list; 
	}

	/**
	 * 插入實體對象所對應的記錄
	 */
	public void save(Object obj) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		if (obj != null) {
			Transaction tx = null;
			try {
				tx = session.beginTransaction();
				session.save(obj);
				tx.commit();
			} catch (HibernateException e) {
				if (tx != null)
						tx.rollback();
				throw e;
			}
		}
		session.close();
	}

	/**
	 * 修改實體對象所對應的記錄
	 */
	public void update(Object obj) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		
		if (obj != null) {
			Transaction tx = null;
			try {
				tx = session.beginTransaction();
				session.update(obj);
				tx.commit();
			} catch (HibernateException e) {
				if (tx != null)
						tx.rollback();
				throw e;
			}
		}
		session.close();
	}
	
	/**
	 * 刪除對象所對應的記錄
	 */
	public void delete(Object obj) throws HibernateException {
		Session session = HibernateUtil.currentSession();
		if (obj != null) {
			Transaction tx = null;
			try {
				tx = session.beginTransaction();
				session.delete(obj);
				tx.commit();
			} catch (HibernateException e) {
				if (tx != null)
						tx.rollback();
				throw e;
			}
		}
		session.close();
	}
}