Category

Development Platform
Home > SourceCode/Document > Internet-Socket-Network > WEB(ASP,PHP,...) > View Code
CommonDAO.java~3~
Package: shihua.rar　[view]
Upload User: zghglow
Upload Date: 2022-08-09
Package Size: 27227k
Code Size: 10k
Category:

WEB(ASP,PHP,...)

Development Platform:

JavaScript

CommonDAO.java~3~：Code Content
  1. package com.chinacannel.common;
  3. import java.util.List;
  4. import java.util.ArrayList;
  5. import net.sf.hibernate.*;
  6. import net.sf.hibernate.type.Type;
  7. import org.apache.commons.logging.Log;
  8. import org.apache.commons.logging.LogFactory;
  9. import java.io.Serializable;
  11. public class CommonDAO {
  12.     private static Log log = LogFactory.getLog(CommonDAO.class);
  14.     public CommonDAO() {
  15.     }
  17.     public int getCount(Class cls) throws DAOException {
  18.         String hql = "select count(*) from " + cls.getName() + " s";
  19.         return this.getCountBySql(hql);
  20.     }
  22.     public int getCountBySql(String hql) throws DAOException {
  23.         Session session = null;
  24.         int count = 0;
  25.         try {
  26.             session = HibernateUtil.currentSession();
  27.             count = ((Integer) session.iterate(hql).next()).intValue();
  28.         } catch (HibernateException he) {
  29.             throw new DAOException("HibernateException:" + he.getMessage(), he);
  30.         }
  31.         return count;
  32.     }
  34.     public boolean createObject(Object object) throws DAOException {
  35.         boolean lpReturnValue = false;
  36.         log.debug("创建对象的实例:" + object.getClass().toString());
  37.         Session session = null;
  38.         //Transaction trans  = null;
  39.         try {
  40.             session = HibernateUtil.currentSession();
  41.             // trans = session.beginTransaction();
  42.             session.save(object);
  43.             session.flush();
  44.             // trans.commit();
  45.             lpReturnValue = true;
  46.         } catch (HibernateException he) {
  47.             throw new DAOException("HibernateException:" + he.getMessage(), he);
  48. //        } finally {
  49. //            try {
  50. //                HibernateUtil.closeSession();
  51. //            } catch (Exception ex) {
  52. //                log.error(ex.getMessage(), ex);
  53. //            }
  54.         }
  55.         return lpReturnValue;
  56.     }
  58.     public boolean updateObject(Object object) throws DAOException {
  59.         boolean lpReturnValue = false;
  61.         log.debug("更新对象的实例:" + object.getClass().toString());
  62.         Session session = null;
  63.         //Transaction trans = null;
  64.         try {
  65.             session = HibernateUtil.currentSession();
  66.             //trans = session.beginTransaction();
  67.             session.update(object);
  68.             session.flush();
  69.             //trans.commit();
  70.             lpReturnValue = true;
  71.         } catch (UnresolvableObjectException uoe) {
  72.             log.info(uoe.getMessage(), uoe);
  73.         } catch (HibernateException he) {
  74.             throw new DAOException("HibernateException:" + he.getMessage(), he);
  75. //        } finally {
  76. //            try {
  77. //                HibernateUtil.closeSession();
  78. //            } catch (Exception ex) {
  79. //                log.error(ex.getMessage(), ex);
  80. //            }
  81.         }
  82.         return lpReturnValue;
  83.     }
  85.     public boolean removeObject(Object object) throws DAOException {
  86.         boolean lpReturnValue = false;
  88.         log.debug("删除对象的实例:" + object.getClass().toString());
  89.         Session session = null;
  90.         Transaction trans = null;
  91.         try {
  92.             session = HibernateUtil.currentSession();
  93.             trans = session.beginTransaction();
  94.             session.delete(object);
  95.             trans.commit();
  96.             //session.flush();
  97.             lpReturnValue = true;
  98.         } catch (UnresolvableObjectException uoe) {
  99.             log.info(uoe.getMessage(), uoe);
  100.         } catch (HibernateException he) {
  101.             try {
  102.                 trans.rollback();
  103.             } catch (HibernateException he2) {
  104.                 //
  105.             }
  106.             throw new DAOException("HibernateException:" + he.getMessage(), he);
  107.         } catch (Exception ex) {
  108.             throw new DAOException("Exception:" + ex.getMessage(), ex);
  109. //        } finally {
  110. //            try {
  111. //                HibernateUtil.closeSession();
  112. //            } catch (Exception ex) {
  113. //                log.error(ex.getMessage(), ex);
  114. //            }
  115.         }
  116.         return lpReturnValue;
  117.     }
  119.     public Object loadObject(Serializable id, Class cls) throws
  120.             DAOException {
  121.         log.debug("获得对象的实例:" + cls.toString() + ",关键值为" + id.toString());
  122.         Object po = null;
  123.         Session session = null;
  124.         try {
  125.             session = HibernateUtil.currentSession();
  126.             po = (Object) session.load(cls, id);
  127.         } catch (UnresolvableObjectException uoe) {
  128.             log.info(uoe.getMessage(), uoe);
  129.         } catch (HibernateException he) {
  130.             throw new DAOException("HibernateException:" + he.getMessage(), he);
  131.         } catch (Exception ex) {
  132.             throw new DAOException("Exception:" + ex.getMessage(), ex);
  133. //        } finally {
  134. //            try {
  135. //                HibernateUtil.closeSession();
  136. //            } catch (Exception ex) {
  137. //                log.error(ex.getMessage(), ex);
  138. //            }
  139.         }
  140.         return po;
  141.     }
  143.     public Object loadOneObjectBySQL(String hql) throws DAOException {
  144.         List list = this.loadObjectListBySQL(hql, 0, 1);
  145.         if (list.size() > 0) {
  146.             return list.get(0);
  147.         } else {
  148.             return null;
  149.         }
  150.     }
  152.     public List loadObjectBySQL(String hql, Object[] params, Type[] types) throws
  153.             DAOException {
  154.         List ls = new ArrayList(0);
  155.         Session session = null;
  156.         try {
  157.             session = HibernateUtil.currentSession();
  158.             ls = session.find(hql, params, types);
  159.         } catch (UnresolvableObjectException uoe) {
  160.             log.info(uoe.getMessage(), uoe);
  161.         } catch (HibernateException he) {
  162.             throw new DAOException("HibernateException:" + he.getMessage(), he);
  163.         } catch (Exception ex) {
  164.             throw new DAOException("Exception:" + ex.getMessage(), ex);
  165.         }
  166.         return ls;
  167.     }
  169.     public List loadObjectListBySQL(String hql) throws DAOException {
  170.         List ls = new ArrayList(0);
  171.         Session session = null;
  172.         try {
  173.             session = HibernateUtil.currentSession();
  174.             ls = session.find(hql);
  175.         } catch (UnresolvableObjectException uoe) {
  176.             log.info(uoe.getMessage(), uoe);
  177.         } catch (HibernateException he) {
  178.             throw new DAOException("HibernateException:" + he.getMessage(), he);
  179.         } catch (Exception ex) {
  180.             throw new DAOException("Exception:" + ex.getMessage(), ex);
  181. //      }finally{
  182. //        try{
  183. //          HibernateUtil.closeSession();
  184. //        }catch(Exception ex){
  185. //          log.error(ex.getMessage(), ex);
  186. //        }
  187.         }
  188.         return ls;
  189.     }
  191.     public List loadObjectListBySQL(String hql, Object[] params, Type[] types,
  192.                                     int start, int top) throws DAOException {
  193.         List ls = new ArrayList(0);
  194.         Session session = null;
  195.         try {
  196.             session = HibernateUtil.currentSession();
  197.             Query query = session.createQuery(hql);
  198.             for (int i = 0; i < params.length; i++) {
  199.                 query.setParameter(i, params[i], types[i]);
  200.             }
  201.             query.setFirstResult(start);
  202.             query.setMaxResults(top);
  203.             ls = query.list();
  204.         } catch (UnresolvableObjectException uoe) {
  205.             log.info(uoe.getMessage(), uoe);
  206.         } catch (HibernateException he) {
  207.             throw new DAOException("HibernateException:" + he.getMessage(), he);
  208.         } catch (Exception ex) {
  209.             throw new DAOException("Exception:" + ex.getMessage(), ex);
  210. //      }finally{
  211. //        try{
  212. //          HibernateUtil.closeSession();
  213. //        }catch(Exception ex){
  214. //          log.error(ex.getMessage(), ex);
  215. //        }
  216.         }
  217.         return ls;
  218.     }
  220.     public List loadObjectListBySQL(String hql, int start, int top) throws
  221.             DAOException {
  222.         List ls = new ArrayList(0);
  223.         Session session = null;
  224.         try {
  225.             session = HibernateUtil.currentSession();
  226.             Query query = session.createQuery(hql);
  227.             query.setFirstResult(start);
  228.             query.setMaxResults(top);
  229.             ls = query.list();
  230.         } catch (UnresolvableObjectException uoe) {
  231.             log.info(uoe.getMessage(), uoe);
  232.         } catch (HibernateException he) {
  233.             throw new DAOException("HibernateException:" + he.getMessage(), he);
  234.         } catch (Exception ex) {
  235.             throw new DAOException("Exception:" + ex.getMessage(), ex);
  236. //      }finally{
  237. //        try{
  238. //          HibernateUtil.closeSession();
  239. //        }catch(Exception ex){
  240. //          log.error(ex.getMessage(), ex);
  241. //        }
  242.         }
  243.         return ls;
  244.     }
  246.     public List loadAllObjects(Class cls) throws DAOException {
  247.         List ls = null;
  248.         Session session = null;
  249.         try {
  250.             session = HibernateUtil.currentSession();
  251.             ls = session.find(getQuerySQL(cls));
  252.             if (ls == null)
  253.                 ls = new ArrayList(0);
  254.         } catch (UnresolvableObjectException uoe) {
  255.             log.info(uoe.getMessage(), uoe);
  256.         } catch (HibernateException he) {
  257.             throw new DAOException("HibernateException:" + he.getMessage(), he);
  258.         } catch (Exception ex) {
  259.             throw new DAOException("Exception:" + ex.getMessage(), ex);
  260. //        } finally {
  261. //            try {
  262. //                HibernateUtil.closeSession();
  263. //            } catch (Exception ex) {
  264. //                log.error(ex.getMessage(), ex);
  265. //            }
  266.         }
  267.         return ls;
  268.     }
  270.     public int executeDelete(String hql) throws DAOException{
  271.         Session session = null;
  272.         try {
  273.             session = HibernateUtil.currentSession();
  274.             return session.delete(hql);
  275.         } catch (UnresolvableObjectException uoe) {
  276.             log.info(uoe.getMessage(), uoe);
  277.         } catch (HibernateException he) {
  278.             throw new DAOException("HibernateException:" + he.getMessage(), he);
  279.         } catch (Exception ex) {
  280.             throw new DAOException("Exception:" + ex.getMessage(), ex);
  281.         }
  282.         return -1;
  283.     }
  285.     protected String getQuerySQL(Class cls) {
  286.         log.debug("from " + cls.getName() + " s");
  287.         return "from " + cls.getName() + " s";
  288.     }
  289. }