SSH框架调用多个数据库

package cn.com.goevent.dao.impl; import java.io.Serializable; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import java.util.List; import java.util.Map; import javax.annotation.Resource; import org.hibernate.Criteria; import org.hibernate.HibernateException; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.Transaction; import org.hibernate.criterion.DetachedCriteria; import org.hibernate.criterion.Projections; import org.hibernate.transform.Transformers; import org.springframework.orm.hibernate3.HibernateCallback; import org.springframework.orm.hibernate3.HibernateTemplate; import org.springframework.orm.hibernate3.support.HibernateDaoSupport; import cn.com.goevent.dao.BaseDao; import cn.com.goevent.dao.BaseDao1; public class BaseDaoImpl1 extends HibernateDaoSupport implements BaseDao1 { public Long getCount(final DetachedCriteria criteria) { HibernateTemplate hibernateTemplate = getHibernateTemplate(); Long count = (Long) hibernateTemplate.execute( new HibernateCallback() { public Object doInHibernate(Session session) throws HibernateException { Criteria execcriteria = criteria .getExecutableCriteria(session); execcriteria.setProjection(Projections.rowCount()); Object results = execcriteria.uniqueResult(); return results; } }); return count; } public void delete(Object o) { getHibernateTemplate().delete(o); } public void excute(final String SQL) { getHibernateTemplate().execute(new HibernateCallback() { public Object doInHibernate(Session session) throws HibernateException, SQLException { Query query = session.createQuery(SQL); query.executeUpdate(); return null; } }); } public List find(String SQL, Object param) { return getHibernateTemplate().find(SQL, param); } public List find(String SQL, Object[] param) { return getHibernateTemplate().find(SQL, param); } public void flush() { try { getSession().flush(); getSession().clear(); } catch (Exception e) { } } public List get(DetachedCriteria criteria) { return getHibernateTemplate().findByCriteria(criteria); } public Object get(Class clazz, Serializable id) { Object o = getHibernateTemplate().get(clazz, id); if (o == null) { return null; } return o; } public List get(Object obj, int from, int size) { return getHibernateTemplate().findByExample(obj, from, size); } public List get(Object obj) { return getHibernateTemplate().findByExample(obj); } public List loadAll(Class clazz) { return getHibernateTemplate().loadAll(clazz); } public List get(DetachedCriteria criteria, int from, int size) { return getHibernateTemplate().findByCriteria(criteria, from, size); } public void delete(Class clazz, Serializable id) { getHibernateTemplate().delete(get(clazz, id)); } public void save(Object o) { getHibernateTemplate().save(o); } public void saveOrUpdate(Object o) { getHibernateTemplate().saveOrUpdate(o); } public List getSQLList(String sql){ Query q = getHibernateTemplate().getSessionFactory().getCurrentSession().createSQLQuery(sql); return q.list(); } public void excuteSQL(final String sql) { getHibernateTemplate().execute(new HibernateCallback() { public Object doInHibernate(Session session) throws HibernateException, SQLException { Transaction tx = session.beginTransaction(); Connection con = session.connection(); PreparedStatement stmt= con.prepareStatement(sql); stmt.executeUpdate(); tx.commit(); return null; } }); } public List getHQLList(String hql,Integer from ,Integer size){ Query q = getHibernateTemplate().getSessionFactory().getCurrentSession().createQuery(hql).setFirstResult(from).setMaxResults(size); return q.list(); } public List getSQLList(String sql, Class clazz){ Query q = getHibernateTemplate().getSessionFactory().getCurrentSession().createSQLQuery(sql).setResultTransformer(Transformers.aliasToBean(clazz));//CheckInfo为pojo类 return q.list(); } @Override public List<Map> getResultMap(String sql) { Query query = this.getSession().createSQLQuery(sql); query.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP); List list = query.list(); if(list!=null && list.size()>0){ return list; } return null; } @Override public void update(Object obj) { this.getSession().merge(obj); } }