管理系统系列--统一动态任务管理系统.zip

package com.songwie.task.base.dao; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.util.ArrayList; import java.util.List; import java.util.Map; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; import javax.persistence.Query; import org.hibernate.engine.spi.SessionImplementor; import org.springframework.stereotype.Component; /** * 数据访问通用类（适合JPA调用） * @author sw */ @Component public class CommonDAO { @PersistenceContext transient EntityManager entityManager; public EntityManager getEntityManager() { return entityManager; } protected Connection getConnection() { SessionImplementor session = this.getEntityManager().unwrap(SessionImplementor.class); return session.connection(); }; /** * 执行查询，并按照传入实体类{@code<T>}构造实体列表{@code List<T>} * @param <T> 实体类模板 * @param strSql 查询SQL语句 * @param entityName 实体类 * @return 返回实体列表{@code List<T>} */ public <T> List<T> getEntityList(String strSql, Class<T> entityName) { return this.getEntityList(strSql, new ParaList(), entityName); } /** * 使用参数<code>paras</code>执行查询，并按照传入实体类{@code<T>}构造实体列表{@code List<T>} * @param <T> 实体类模板 * @param strSql 查询SQL语句 * @param paras 查询参数 * @param entityName 实体类 * @return 返回实体列表{@code List<T>} */ public <T> List<T> getEntityList(String strSql, List<Object> paras, Class<T> entityName) { try { Connection conn = this.getConnection(); PreparedStatement ps = null; ResultSet rs = null; try { ps = conn.prepareStatement(strSql); this.setParasToStatement(ps, paras); rs = ps.executeQuery(); List<T> list = EntityUtils.ListFromRS(rs, entityName); return list; } finally { if (ps != null) { ps.close(); ps = null; } if (rs != null) { rs.close(); rs = null; } } } catch(Exception ex) { throw new RuntimeException(ex); } } /** * 使用参数<code>paras</code>执行查询，并按照传入实体类{@code<T>}构造实体列表{@code List<T>} * @param <T> 实体类模板 * @param strSql 查询SQL语句 * @param paras 查询参数 * @param entityName 实体类 * @return 返回实体列表{@code List<T>} */ public <T> List<T> getEntityList(String strSql, Object[] paras, Class<T> entityName) { return this.getEntityList(strSql, new ParaList(paras), entityName); } /** * 设置参数 * @param ps * @param paras * @throws Exception */ protected void setParasToStatement(PreparedStatement ps, List<Object> paras) throws Exception { if (paras == null) { return; } if (paras.size() <= 0) { return; } for (int i = 0; i < paras.size(); i++) { Object para = paras.get(i); if (para.getClass().equals(String.class)) { ps.setString(i + 1, para.toString()); } else if (para.getClass().equals(int.class)) { ps.setInt(i + 1, (Integer.parseInt(para.toString()))); } else if (para.getClass().equals(Integer.class)) { ps.setInt(i + 1, ((Integer) para).intValue()); } else if (para.getClass().equals(Long.class)) { ps.setLong(i + 1, ((Long) para).longValue()); } else if (para.getClass().equals(long.class)) { ps.setLong(i + 1, (Long.parseLong(para.toString()))); } else if (para.getClass().equals(double.class)) { ps.setDouble(i + 1, (Double.parseDouble(para.toString()))); } else if (para.getClass().equals(Double.class)) { ps.setDouble(i + 1, ((Double) para).doubleValue()); } } } protected void setListParasToQuery(Query query, List<Object> paras) { for (int i = 0; i < paras.size(); i++) { query.setParameter(i + 1, paras.get(i)); } } protected void setMapParasToQuery(Query query, Map<String, Object> paras) { for (String key : paras.keySet()) { query.setParameter(key, paras.get(key)); } } /** * 查询总行数 * @param strSql 查询SQL语句 * @return 总行数 */ public int getTotal(String strSql) { return this.getTotal(strSql, new ParaList()); } /** * 使用参数<code>paras</code>执行查询总行数 * @param strSql 查询SQL语句 * @param paras 查询参数 * @return 总行数 */ public int getTotal(String strSql, List<Object> paras) { strSql = "select count(1) from (" + strSql + ") t"; return this.querySingleInteger(strSql, paras); } /** * 使用参数<code>paras</code>执行查询总行数 * @param strSql 查询SQL语句 * @param paras 查询参数 * @return 总行数 */ public int getTotal(String strSql, Object[] paras) { return this.querySingleInteger(strSql, new ParaList(paras)); } /** * 使用参数<code>paras</code>执行查询总行数 * @param strSql 查询SQL语句 * @param paras 查询参数 * @return 总行数 */ public int getTotal(String strSql, Map<String, Object> paras) { strSql = "select count(1) from (" + strSql + ") t"; return this.querySingleInteger(strSql, paras); } /** * 执行分页查询，构造实体列表{@code List<T>} * @param <T> 实体类模板 * @param strSql 查询SQL语句 * @param entityName 实体类 * @param start 开始行 * @param limit 页面行数 * @return 返回实体列表{@code List<T>} */ public <T> PageData<T> getEntityListPage(String strSql, Class<T> entityName, int start, int limit) { return this.getEntityListPage(strSql, new ParaList(), entityName, start, limit); } /** * 使用参数<code>paras</code>执行分页查询，构造实体列表{@code List<T>} * @param <T> 实体类模板 * @param strSql 查询SQL语句 * @param paras 查询参数 * @param entityName 实体类 * @param start 开始行 * @param limit 页面行数 * @return 返回实体列表{@code List<T>} */ public <T> PageData<T> getEntityListPage(String strSql, List<Object> paras, Class<T> entityName, int start, int limit) { try { Connection conn = this.getConnection(); PreparedStatement ps = null; ResultSet rs = null; try { String strSQLQuery = strSql + "limit "+start +" ," + limit; ps = conn.prepareStatement(strSQLQuery); this.setParasToStatement(ps, paras); rs = ps.executeQuery(); Lis