hibernateDAOimpl

/*******************************************************************************
  ******************************************************************************/

import java.util.List;
import java.util.Iterator;
import java.sql.Connection;
import javax.sql.DataSource;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.criterion.DetachedCriteria;
import org.springframework.dao.DataAccessException;
import org.springframework.orm.hibernate3.HibernateCallback;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.insigma.common.util.InsigmaException;
import com.opensource.log.NewLogger;

import java.sql.SQLException;
import java.sql.Statement;

public class HibernateDaoImpl extends HibernateDaoSupport implements
  HibernateBaseDao {
 /** 注入的数据源 **/
 protected DataSource dataSource;

 public void setDataSource(DataSource dataSource) {
  this.dataSource = dataSource;
 }

 public DataSource getDataSource() {
  return this.dataSource;
 }

 public HibernateDaoImpl() {
 }

 /**
  * 存储对象
  */
 public void save(Object obj) throws InsigmaException {
  save(new Object[] { obj });
 }

 /**
  * 存储对象数组
  */
 public void save(Object[] obj) throws InsigmaException {
  for (int i = 0; i < obj.length; i++) {
   if (obj[i] == null)
    throw new InsigmaException("存储对象出错,对象为空!\n");
   getHibernateTemplate().save(obj[i]);
  }
  getHibernateTemplate().flush();
 }

 /**
  * 批量存储对象
  */
 public void save(List obj) throws InsigmaException {
  for (int i = 0; i < obj.size(); i++) {
   if (obj.get(i) == null)
    throw new InsigmaException("批量存储对象出错,对象为空!\n");
   getHibernateTemplate().save(obj.get(i));
  }
  getHibernateTemplate().flush();

 }

 /**
  * 批量更新对象
  */
 public void update(List obj) throws InsigmaException {
  for (int i = 0; i < obj.size(); i++) {
   if (obj.get(i) == null)
    throw new InsigmaException("更新对象出错,对象为空!\n");
   getHibernateTemplate().saveOrUpdate(obj.get(i));

  }
  getHibernateTemplate().flush();
 }

 /**
  * 更新对象数组
  */
 public void update(Object[] obj) throws InsigmaException {
  for (int i = 0; i < obj.length; i++) {
   if (obj[i] == null)
    throw new InsigmaException("更新对象出错,对象为空!\n");
   getHibernateTemplate().update(obj[i]);
  }
  getHibernateTemplate().flush();
 }

 /**
  * 更新对象
  */
 public void update(Object obj) throws InsigmaException {
  update(new Object[] { obj });
 }

 /**
  * 执行预处理HQL，如update tab1 set name=?,value=? where id=12
  * 则list的对象为"zhang","qing"
  */
 public void exeHQL(String hql, List list) throws InsigmaException {
  Session ses = getSession();
  try {
   Query query = ses.createQuery(hql);
   Object obj = null;
   for (int i = 0; i < list.size(); i++) {
    obj = list.get(i);
    query.setParameter(i, obj);
   }
   query.executeUpdate();
  } catch (Exception e) {
   NewLogger.getInstance().writeError("执行预处理HQL出错!\n"+e.getMessage(), e);
   throw new InsigmaException(e.getMessage(), e);
  } finally {
   releaseSession(ses);
  }

 }

 /**
  * 执行批量事务，先存储，后更新/删除
  */
 public void exeHQL(Object obj, List list) throws InsigmaException {
  if (obj != null)
   save(obj);
  exeHQL(list);
 }

 /**
  * 先存储对象数据，再执行更新或删除，批量事务执行
  */
 public void exeHQL(Object[] obj, List list) throws InsigmaException {
  if (obj != null)
   save(obj);
  exeHQL(list);
 }

 /**
  * 执行更新或删除HQL语句
  */
 public void exeHQL(String hql) throws InsigmaException {
  Session ses = getSession();
//  try {
   Query query = ses.createQuery(hql);
   query.executeUpdate();
//  } catch (Exception e) {
//   NewLogger.getInstance().writeError("执行更新或删除HQL语句出错!\n"+e.getMessage(), e);
//   throw new InsigmaException(e.getMessage(), e);
//  }
//  finally {
//   releaseSession(ses);
//  }

 }

 /**
  * 执行更新或删除HQL语句
  */
 public void exeHQL(List hql) throws InsigmaException {
  Session ses = getSession();
//  try {
   String sql;
   for (Iterator<String> it = hql.iterator(); it.hasNext();) {
    sql = it.next();
    NewLogger.getInstance().writeDebug(sql);
    Query qr = ses.createQuery(sql);
    qr.executeUpdate();
   }
//  } catch (Exception e) {
//   NewLogger.getInstance().writeError("批量更新或删除出错!"+e.getMessage(), e);
//   throw new InsigmaException(e.getMessage(), e);
//  } finally {
//   releaseSession(ses);
//  }

 }

 /**
  * 查询HQL语句
  */
 public List findObjs(String HQL) throws InsigmaException {
  List list = null;
//  try {
   list = getHibernateTemplate().find(HQL);
//  } catch (DataAccessException e) {
//   NewLogger.getInstance().writeError("查询HQL出错!\n" + e.getMessage(), e);
//   throw new InsigmaException(e.getMessage(), e);
//  }
  return list;

 }

 /**
  * 预编译查询HQL
  */
 public List findObjs(String hql, Object[]prams) throws InsigmaException {
  List reList = null;
//  try {
   reList = getHibernateTemplate().find(hql, prams);
//  } catch (DataAccessException e) {
//   NewLogger.getInstance().writeError("预编译查询HQL出错!\n" + e.getMessage(), e);
//   throw new InsigmaException(e.getMessage(), e);
//  }
  return reList;

 }

 /*
  * 分页查询HQL
  *
  * @
  *
  * @see com.insigma.common.dao.HibernateBaseDao#findObjs(java.lang.String,
  * int, int)
  */
 /**
  * 分页查询HQL
  *
  * @param hql
  *            hql语句
  * @param pageFirst
  *            第几页
  * @param pageRow
  *            每页多少行
  */
 public List findObjs(String hql, int pageFirst, int pageRow)
   throws InsigmaException {
  List list = null;
  Session ses = getSession();
//  try {
   Query qr = ses.createQuery(hql);
   qr.setReadOnly(true);
   qr.setFirstResult((pageFirst - 1) * pageRow);
   qr.setMaxResults(pageRow);
   list = qr.list();
//  } catch (DataAccessException e) {
//   e.printStackTrace();
//   throw new InsigmaException("分页查询出错!\n" + e.getMessage(), e);
//  }
//
//  finally {
//   releaseSession(ses);
//  }
  return list;

 }

 /**
  * 存储并执行HQL
  */
 public void saveObjAndExeHql(List hql, List obj) throws InsigmaException {
  String sql;
  Session ses = getSession();
//  try {
   for (Iterator it = hql.iterator(); it.hasNext();) {
    sql = (String) it.next();
    Query qr = ses.createQuery(sql);
    qr.executeUpdate();
   }
   Object object;
   for (Iterator it = obj.iterator(); it.hasNext();) {
    object = it.next();
    getSession().save(object);
   }
//  } catch (Exception e) {
//   e.printStackTrace();
//   throw new InsigmaException("存储并执行HQL时出错!\n" + e.getMessage(), e);
//  }

//  finally {
//   releaseSession(ses);
//  }

 }

 /**
  * 查询共计记录数
  */
 public int getMaxRow(final String hql) throws InsigmaException {
  int maxRow = (Integer)getHibernateTemplate().execute(new HibernateCallback(){
    public Object doInHibernate(Session session)
      throws HibernateException, SQLException {
     Query qr = getSession().createQuery(hql);
     List list = qr.list();
     int maxRow = 0;
     if (list.size() > 0) {
      String s = String.valueOf(list.get(0));
      if ((s == null) || (s.equals("")))
       s = "0";
      maxRow = Integer.parseInt(s);// ((Integer)
      
     }
     return new Integer(maxRow);
    }
   });
  return maxRow;

 }

 /**
  * 得到数据源连接
  */
 public Connection getConnection() throws InsigmaException {
  Connection con = null;
//  try {
   con = getSession().connection();
//  } catch (Exception e) {
//   e.printStackTrace();
//   throw new InsigmaException("得到数据源连接时出错!\n" + e.getMessage(), e);
//  }
  return con;

 }

 /**
  * 关闭数据源连接
  */
 public void closeConnection() throws InsigmaException {
  Connection con = null;
  try {
   con = getDataSource().getConnection();
   if (con != null) {
    con.close();
   }
  } catch (SQLException e) {
//   e.printStackTrace();
   throw new InsigmaException("关闭数据源连接时出错!\n" + e.getMessage(), e);
  }

 }

 /**
  * 得到Hibernate的Session
  *
  * @return Session
  */
 public Session getHSession() throws InsigmaException {
  Session s = getHibernateTemplate().getSessionFactory().openSession();
  return s;
 }

 /**
  * 关闭Hibernate的Session
  *
  * @param s
  *            Session
  * @throws InsigmaException
  */
 public void closeHSession(Session s) throws InsigmaException {
  if (s != null) {
   s.close();
  }
 }

 /**
  * 关闭输入的连接
  */
 public void closeConnection(Connection conn) throws InsigmaException {

  try {

   if (conn != null) {
    conn.close();
   }
  } catch (SQLException e) {
//   e.printStackTrace();
   throw new InsigmaException("关闭连接时出错!\n" + e.getMessage(), e);
  }

 }

 /**
  * 执行存储过程
  *
  * @param proc
  *            如：
  */
 public void runProc(String proc) throws InsigmaException {
  Connection conn = null;
  Statement st = null;
  Session ses = getSession();
  try {
   conn = ses.connection();
   st = conn.createStatement();
   st.execute("{call " + proc + "}");
  } catch (Exception e) {
//   e.printStackTrace();
   throw new InsigmaException("执行存储过程时出错!\n" + e.getMessage(), e);
  } finally {
   try {
    if (st != null) {
     st.close();
    }
    if (conn != null) {
     conn.close();
    }
    releaseSession(ses);
   } catch (SQLException e) {
//    e.printStackTrace();
    throw new InsigmaException("关闭数据连接出错!\n" + e.getMessage(), e);
   }
  }
 }

  public Object load(String hql) throws InsigmaException {
    Session ses = getSession();
    Query q = ses.createQuery(hql);
    return q.uniqueResult();
  }

 /* (non-Javadoc)
  * @see com.insigma.common.dao.HibernateBaseDao#findObjs(org.hibernate.criterion.DetachedCriteria)
  */
 public List findObjs(DetachedCriteria criteria) throws InsigmaException {
  // TODO Auto-generated method stub
  List list = getHibernateTemplate().findByCriteria(criteria);
  return list;
 }

 /* (non-Javadoc)
  * @see com.insigma.common.dao.HibernateBaseDao#findObjs(org.hibernate.criterion.DetachedCriteria, int, int)
  */
 public List findObjs(DetachedCriteria criteria, int first, int max)
   throws InsigmaException {
  // TODO Auto-generated method stub
  List list = getHibernateTemplate().findByCriteria(criteria, first, max);
  return list;
 }
}