package com.css.common.hibernate3;
import java.io.Serializable;
import java.util.List;
import java.util.Map;
/**
* DB层的Dao-接口类 <br/>
*
* @author何青
*/
publicinterfaceGenericHibernateDao<T> {
/**
*添加一个对象
* @param t
* @throws Exception
*/
publicvoid save(T t)throws Exception;
/**
* 更新一对象
* @param t
* @throws Exception
*/
publicvoid update(T t)throws Exception;
/**
* 加载一对象
* @param id
* @return T
* @throws Exception
*/
public T load(Serializable id)throws Exception;
/**
* 获取一对象
* @param id
* @return T
* @throws Exception
*/
public T get(Serializable id)throws Exception;
/**
* 删除一个对象
* @param o
* @throws Exception
*/
publicvoid remove(Object o)throws Exception;
/**
* 将传入的游离状态的对象的属性复制到持久化对象中，并返回该持久化对象。
* 如果该session中没有关联的持久化对象，加载一个，如果传入对象未保存，保存一个副本并作为持久对象返回，传入对象依然保持游离状态
* @param entity POJO实体
* @return持久化对象
* @throws Exception
*/
public Object merge(Object entity)throws Exception;
/**
* 执行本地SQL语句
* 【注意：不能执行Select查询语句】
* @param sql
* @throws Exception
*/
publicvoid executeSQL(String sql)throws Exception;
/**
* 执行本地SQL语句
* 【注意：只能执行Select查询语句】
* @param sql
* @return List
* @throws Exception
*/
@SuppressWarnings("unchecked")
public List listSQL(String sql)throws Exception;
/**
* 执行本地SQL语句
* 【注意：只能执行Select查询语句】
* @param sql
* @param cache是否应用Hibernate的二级缓存<br/>true表示开启 false 表示不开启
* @return List
* @throws Exception
*/
@SuppressWarnings("unchecked")
public List listSQL(String sql,boolean cache)throws Exception;
/**
* 执行本地SQL语句
* 【注意：只能执行Select查询语句】
* @param sql
* @return查询指定的字段值
* @throws Exception
*/
public Object valueSQL(final String sql)throws Exception;
/**
* 删除
* @param tableName
* @param fieldName
* @param fieldValues [支持批量删除]<br/>如：id=4或id="4,5"
* @throws Exception
*/
publicvoid delete(String tableName, String fieldName, String fieldValues)throws Exception;
/**
* 删除
* @param tableName
* @param map [支持多条件组合删除]<br/>如：map.put("id",3),map.put("username","myname")
* @throws Exception
*/
@SuppressWarnings("unchecked")
publicvoid delete(String tableName, Map map)throws Exception;
/**
* 更新对象
* @param hql
* @param params指定的参数
* @throws Exception
*/
publicvoid update(String hql, Object[] params)throws Exception;
/**
* 批量更新实体
* @param tableName
* @param updateFieldName
* @param updateFieldValue
* @param updateKeyName
* @param updateKeyValue
* @return返回执行结果，-1表示失败
* @throws Exception
*/
publicvoid update(final String tableName, String updateFieldName, String updateFieldValue, String updateKeyName, String updateKeyValue)throws Exception;
/**
* 查询VO对象列表<br/>
* 如：getHibernateTemplate().find(hql, params)
* @param hql HQL语句
* @param params指定的HQL语句带的多个参数值
* @return数据集合
* @throws Exception
*/
publicList list(String hql, Object[] params) throws Exception;
/**
* 查询VO对象列表<br/>
* 如：Query query = session.createQuery(hql);query.setString(i,str);
* @param hql HQL语句
* @param values指定的HQL语句带的多个参数值
* @return数据集合
* @throws Exception
*/
publicList queryList(final String hql,final Object[] values)throws Exception;
/**
* 查询VO对象列表<br/>
* 如：Query query = session.createQuery(hql);query.setString(i,str);
* @param hql HQL语句
* @param values指定的HQL语句带的多个参数值
* @param cache是否应用Hibernate的二级缓存<br/>true表示开启 false 表示不开启
* @return数据集合
* @throws Exception
*/
publicList queryList(final String hql,final Object[] values,finalboolean cache)throws Exception;
/**
* 查询Model对象列表<br/>
* 如：Query query = session.createSQLQuery(sql);query.setString(i,str);
* @param sqlBean封装Model的SqlBean对象
* @return数据集合
* @throws Exception
*/
publicList queryList(finalSqlBean sqlBean) throws Exception;
/**
* 查询Model对象列表<br/>
* 如：Query query = session.createSQLQuery(sql);query.setString(i,str);
* @param sqlBean封装Model的SqlBean对象
* @param cache是否应用Hibernate的二级缓存<br/>true表示开启 false 表示不开启
* @return数据集合
* @throws Exception
*/
publicList queryList(finalSqlBean sqlBean,finalboolean cache)throws Exception;
/**
* 根据SQL语句进行分页查询
* @param curPage请求的当前页
* @param pageSize每页显示多少行
* @param sqlBean封装Model的SqlBean对象
* @return PageSupport封装好的分页对象
*/
publicPageSupport queryPage(int curPage,int pageSize,SqlBean sqlBean)throws Exception;
/**
* 根据SQL语句进行分页查询
* @param curPage请求的当前页
* @param pageSize每页显示多少行
* @param sqlBean封装Model的SqlBean对象
* @param cache是否应用Hibernate的二级缓存<br/>true表示开启 false 表示不开启
* @return PageSupport封装好的分页对象
*/
publicPageSupport queryPage(int curPage,int pageSize,SqlBean sqlBean,boolean cache)throws Exception;
/**
* 根据HQL语句进行分页查询
* @param curPage请求的当前页
* @param pageSize每页显示多少行
* @param hql HQL语句
* @param values指定的HQL语句带的多个参数值
* @return PageSupport封装好的分页对象
*/
publicPageSupport queryPage(finalint curPage,finalint pageSize,final String hql,final Object[] values)throws Exception;
/**
* 根据HQL语句进行分页查询
* @param curPage请求的当前页
* @param pageSize每页显示多少行
* @param hql HQL语句
* @param values指定的HQL语句带的多个参数值
* @param cache是否应用Hibernate的二级缓存<br/>true表示开启 false 表示不开启
* @return PageSupport封装好的分页对象
*/
@SuppressWarnings("unchecked")
public PageSupport queryPage(finalint curPage, finalint pageSize,final String hql,final Object[] values,finalboolean cache)throws Exception;
/**
* 获取一个对象
* @param hql HQL语句
* @param values指定的参数数组
* @return查询的唯一对象
* @throws Exception
*/
public Object queryForObject(final String hql, final Object[] values)throws Exception;
/**
* 获取一个对象
* @param hql HQL语句
* @param values指定的HQL语句带的多个参数值
* @param cache是否应用Hibernate的二级缓存<br/>true表示开启 false 表示不开启
* @return查询的唯一对象
* @throws Exception
*/
public Object queryForObject(final String hql, final Object[] values,finalboolean cache)throws Exception;
}
接口的实现类：
package com.css.common.hibernate3;
import java.io.Serializable;
import java.lang.reflect.Field;
import java.math.BigDecimal;
import java.math.BigInteger;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.orm.hibernate3.HibernateCallback;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import org.springframework.util.Assert;
/**
* DB层的Dao -实现类 <br/>
*
* @author 何青
*/
public class GenericHibernateDaoImpl<T> extends HibernateDaoSupport implements GenericHibernateDao<T> {
private Class<T> concreteClass;
public GenericHibernateDaoImpl(Class<T> concreteClass) {
this.concreteClass = concreteClass;
}
@SuppressWarnings("unchecked")
public T load(Serializable id) throws Exception {
return (T)getHibernateTemplate().load(concreteClass, id);
}
@SuppressWarnings("unchecked")
public T get(Serializable id) throws Exception {
return (T)getHibernateTemplate().get(concreteClass, id);
}
public void save(T t) throws Exception {
getHibernateTemplate().save(t);
}
public void update(T t) throws Exception {
getHibernateTemplate().update(t);
}
public void remove(Object o) throws Exception {
getHibernateTemplate().delete(o);
}
public Object merge(Object entity) throws Exception {
Assert.notNull(entity);
return getSession().merge(entity);
}
public void delete(String tableName, String fieldName, String fieldValues) throws Exception {
StringBuffer _hql = new StringBuffer();
_hql.append(" delete from ").append(tableName);
_hql.append(" where ").append(fieldName).append(" in (").append(fieldValues).append(")");
executeSQL(_hql.toString());
}
@SuppressWarnings("unchecked")
public void delete(String tableName, Map map) throws Exception {
if (map != null && map.size() > 0) {
StringBuffer _hql = new StringBuffer();
_hql.append(" delete from ");
_hql.append(tableName);
_hql.append(" where ");
Iterator iterator = map.entrySet().iterator();
while (iterator.hasNext()) {
Map.Entry entity = (Map.Entry)iterator.next();
_hql.append(entity.getKey()).append(" in (").append(entity.getValue()).append(")");
_hql.append(" and ");
}
String sql = _hql.toString();
if (sql.trim().endsWith("and")) {
sql = sql.substring(0, _hql.length() - 4);
}
executeSQL(sql);
}
}
public void update(String hql, Object[] params) throws Exception {
getHibernateTemplate().bulkUpdate(hql, params);
}
public void update(final String tableName, String updateFieldName, String updateFieldValue,
String updateKeyName, String updateKeyValue) throws Exception{
StringBuffer _hql = new StringBuffer();
_hql.append(" update ").append(tableName);
_hql.append(" set ").append(updateFieldName).append(" = ").append(updateFieldValue);
_hql.append(" where ").append(updateKeyName).append(" in (").append(updateKeyValue).append(")");
executeSQL(_hql.toString());
}
public void executeSQL(String sql) throws Exception {
getSession().createSQLQuery(sql).executeUpdate();
}
@SuppressWarnings("unchecked")
public List listSQL(String sql) throws Exception {
return listSQL(sql,false);
}
@SuppressWarnings("unchecked")
public List listSQL(String sql,boolean cache) throws Exception{
Query query = getSession().createSQLQuery(sql);
// 设置Ehcache的二级缓存
query.setCacheable(cache);
return query.list();
}
@SuppressWarnings("unchecked")
public Object valueSQL(final String sql) throws Exception {
return getHibernateTemplate().execute(
new HibernateCallback() {
public Object doInHibernate(Session sess) throws HibernateException {
Query query = sess.createSQLQuery(sql);
return query.uniqueResult();
}
}
);
}
@SuppressWarnings("unchecked")
public List list(String hql, Object[] params) throws Exception{
return getHibernateTemplate().find(hql, params);
}
public List queryList(final String hql, final Object[] values) throws Exception {
return queryList(hql,values,false);
}
@SuppressWarnings("unchecked")
public List queryList(final String hql, final Object[] values,final boolean cache) throws Exception {
return (List)getHibernateTemplate().execute(new HibernateCallback() {
public Object doInHibernate(Session sess) {
Query query = sess.createQuery(hql);
// 设置Ehcache的二级缓存
query.setCacheable(cache);
setQueryParams(values, query);
return query.list();
}
});
}
public List queryList(final SqlBean sqlBean) throws Exception {
return queryList(sqlBean,false);
}
@SuppressWarnings("unchecked")
public List queryList(final SqlBean sqlBean,final boolean cache) throws Exception {
return (List)getHibernateTemplate().execute(new HibernateCallback() {
public Object doInHibernate(Session sess) {
Query query = getSessionQuery(sqlBean.toString(), sess, "sql");
// 设置Ehcache的二级缓存
query.setCacheable(cache);
setQueryParams(sqlBean.getParams(),query);
return getModels(sqlBean.getBeanNames(),query.list(),sqlBean.getModelClass(),null);
}
});
}
public Object queryForObject(final String hql, final Object[] values) throws Exception{
return queryForObject(hql,values,false);
}
public Object queryForObject(final String hql, final Object[] values,final boolean cache) throws Exception{
return getHibernateTemplate().execute(
new HibernateCallback() {
public Object doInHibernate(Session sess) throws HibernateException {
Query query = sess.createQuery(hql);
// 设置Ehcache的二级缓存
query.setCacheable(cache);
if (values != null) {
for (int i = 0; i < values.length; i++){
query.setParameter(i, values[i]);
}
}
return query.uniqueResult();
}
}
);
}
@SuppressWarnings("unchecked")
public PageSupport queryPage(final int curPage, final int pageSize, final String hql, final Object[] values) throws Exception{
return queryPage(curPage,pageSize,hql,values,false);
}
@SuppressWarnings("unchecked")
public PageSupport queryPage(final int curPage, final int pageSize, final String hql, final Object[] values,final boolean cache) throws Exception{
return (PageSupport)getHibernateTemplate().execute(new HibernateCallback() {
public Object doInHibernate(Session sess) throws HibernateException {
PageSupport ps = new PageSupport();
ps.setCurPage(curPage);
ps.setPageSize(pageSize);
Query query = sess.createQuery(hql);
// 设置Ehcache的二级缓存
query.setCacheable(cache);
setQueryParams(values, query);
query.setFirstResult(ps.getStartIndex());
query.setMaxResults(pageSize);
setQueryTotalCount(hql, values, ps,cache,"hql");
ps.setItems(query.list());
return ps;
}
}
);
}
@SuppressWarnings("unchecked")
public PageSupport queryPage(final int curPage, final int pageSize, final SqlBean sqlBean) throws Exception {
return queryPage(curPage,pageSize,sqlBean,false);
}
public PageSupport queryPage(final int curPage, final int pageSize,final SqlBean sqlBean,final boolean cache) throws Exception {
return (PageSupport)getHibernateTemplate().execute(new HibernateCallback() {
public Object doInHibernate(Session sess) {
PageSupport ps = new PageSupport();
ps.setCurPage(curPage);
ps.setPageSize(pageSize);
Query query = getSessionQuery(sqlBean.toString(), sess, "sql");
// 设置Ehcache的二级缓存
query.setCacheable(cache);
setQueryParams(sqlBean.getParams(),query);
query.setFirstResult(ps.getStartIndex());
query.setMaxResults(pageSize);
if(sqlBean.getCountSql() != null && !sqlBean.getCountSql().equals("")){
Query countQuery = getSessionQuery(sqlBean.getCountSql(), sess, "sql");
setQueryParams(sqlBean.getCountParams(), countQuery);
Object objT = countQuery.uniqueResult();
if(objT instanceof BigDecimal){
BigDecimal obj = (BigDecimal) objT;
if (obj!=null) {
ps.setTotalCount(obj.intValue());
}else{
ps.setTotalCount(0);
}
}else if(objT instanceof BigInteger){
BigInteger obj = (BigInteger) objT;
if (obj!=null) {
ps.setTotalCount(obj.intValue());
}else{
ps.setTotalCount(0);
}
}
}else{
setQueryTotalCount(sqlBean.toString(), sqlBean.getParams(), ps,cache,"sql");
}
ps.setItems(getModels(sqlBean.getBeanNames(),query.list(),sqlBean.getModelClass(),curPage));
return ps;
}
}
);
}
@SuppressWarnings("unchecked")
private List getModels(final List<String> beanNames,final List<Object> result,final Class beanClass,final Integer curPage) {
List list=new ArrayList();
for(Object obj : result){
try {
Object bean = beanClass.newInstance();
Class type = obj.getClass();
if(type.isArray()){
Object objs[] = (Object[])obj;
int num = curPage != null && curPage > 1 ? objs.length -1: objs.length;
for(int i = 0; i < num ;i++){
Field f = getClassField(beanClass,beanNames.get(i));
f.setAccessible(true);
if(objs[i] instanceof Byte) {
Byte tempB = (Byte) objs[i];
Short tempS = tempB.shortValue();
f.set(bean, tempS !=null ? tempS:null);
}else if(objs[i] instanceof BigInteger){
BigInteger tempB = (BigInteger) objs[i];
Integer tempS = tempB.intValue();
f.set(bean, tempS !=null ? tempS:null);
}else if(objs[i] instanceof Character){
Character tempB = (Character) objs[i];
String tempS = tempB.toString();
f.set(bean, tempS !=null ? tempS:null);
}else if(objs[i] instanceof BigDecimal){
BigDecimal tempB阿2= (BigDecimal) objs[i];
Long tempS = tempB.longValue();
f.set(bean, tempS !=null ? tempS:null);
}else{
f.set(bean, objs[i] !=null ? objs[i]:null);
}
f.setAccessible(false);
}
}else{
Field f = getClassField(beanClass,beanNames.get(0));
f.setAccessible(true);
if(obj instanceof Byte) {
Byte tempB = (Byte) obj;
Short tempS = tempB.shortValue();
f.set(bean, tempS !=null ? tempS:null);
}else if(obj instanceof BigInteger){
BigInteger tempB = (BigInteger) obj;
Integer tempS = tempB.intValue();
f.set(bean, tempS !=null ? tempS:null);
}else if(obj instanceof Character){
Character tempB = (Character) obj;
String tempS = tempB.toString();
f.set(bean, tempS !=null ? tempS:null);
}else if(obj instanceof BigDecimal){
BigDecimal tempB = (BigDecimal) obj;
Long tempS = tempB.longValue();
f.set(bean, tempS !=null ? tempS:null);
}else{
f.set(bean, obj !=null ? obj:null);
}
f.setAccessible(false);
}
list.add(bean);
} catch (Exception e) {
e.printStackTrace();
}
}
return list;
}
private Field getClassField(Class aClazz, String aFieldName) {
Field[] declaredFields = aClazz.getDeclaredFields();
for (Field field : declaredFields) {
if (field.getName().equals(aFieldName)) {
return field;
}
}
Class superclass = aClazz.getSuperclass();
if (superclass != null) {//简单的递归一下
return getClassField(superclass, aFieldName);
}
return null;
}
private Query getSessionQuery(String s_hql,Session sess,String queryType){
Query query = null;
if("sql".equals(queryType)){
query = sess.createSQLQuery(s_hql);
}else if("hql".equals(queryType)) {
query = sess.createQuery(s_hql);
}else{
query = sess.createQuery(s_hql);
}
return query;
}
@SuppressWarnings("unchecked")
private void setQueryTotalCount(final String hql, final Object[] values, PageSupport ps,boolean cache,String queryType){
int ids = hql.toUpperCase().indexOf(" FROM ");
String _hql = hql;
if (ids > 0) {
_hql = hql.substring(ids);
}
Object obj = queryForObjectCount("select count(*) " + _hql, values,cache,queryType);
if (obj!=null) {
ps.setTotalCount(Integer.parseInt(String.valueOf(obj)));
}else{
ps.setTotalCount(0);
}
}
private Object queryForObjectCount(String s_hql, final Object[] values,boolean cache,String queryType){
int idx = s_hql.toUpperCase().indexOf(" ORDER ");
if (idx > 0) {
s_hql = s_hql.substring(0, idx);
}
Query query = getSessionQuery(s_hql,super.getSession(),queryType);
// 设置Ehcache的二级缓存
query.setCacheable(cache);
setQueryParams(values, query);
return query.uniqueResult();
}
private void setQueryParams(final Object[] values, Query query){
if (values != null) {
for (int i = 0; i < values.length; i++) {
if (values[i] instanceof Long) {
Long l = (Long)values[i];
query.setLong(i, l.longValue());
} else if (values[i] instanceof Integer) {
Integer l = (Integer)values[i];
query.setInteger(i, l.intValue());
} else if (values[i] instanceof String) {
String str = (String)values[i];
query.setString(i, str);
} else {
query.setParameter(i, values[i]);
}
}
}
}
}
package com.css.common.hibernate3;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import org.hibernate.cfg.Configuration;
import org.hibernate.mapping.Column;
import org.hibernate.mapping.PersistentClass;
import org.hibernate.mapping.Table;
/**
* Hibernate的辅助类,获取表名和列名 <br/>
*
* @author何青
*/
publicclassHibernateConfigUtil {
privatestatic ConfigurationhibernateConf =new Configuration();
@SuppressWarnings("unchecked")
privatestatic PersistentClass getPersistentClass(Class clazz) {
synchronized (HibernateConfigUtil.class) {
PersistentClass pc = hibernateConf.getClassMapping(clazz.getName());
if (pc ==null) {
hibernateConf =hibernateConf.addClass(clazz);
pc = hibernateConf.getClassMapping(clazz.getName());
}
return pc;
}
}
@SuppressWarnings("unchecked")
privatestatic Table getTable(Class clazz) {
returngetPersistentClass(clazz).getTable();
}
/**
* 得到表名
*
* @param clazz
* 映射到数据库的po类
* @return
*/
@SuppressWarnings("unchecked")
publicstatic String getTableName(Class clazz) {
returngetTable(clazz).getName();
}
/**
* 得到表的主键名
*
* @param clazz
* 映射到数据库的po类
* @return
*/
@SuppressWarnings("unchecked")
publicstatic String getPkColumnName(Class clazz) {
returngetTable(clazz).getPrimaryKey().getColumn(0).getName();
}
/**
* 得到指定表的列名
*
* @param clazz
* 映射到数据库的po类
* @param index
* 字段列的索引数
* @return
*/
@SuppressWarnings("unchecked")
publicstatic String getColumnName(Class clazz,int index) {
Table table = getTable(clazz);
int columnSize = table.getColumnSpan();
if (index <= columnSize) {
return table.getColumn(index).getName();
} else {
return"";
}
}
/**
* 得到表的所有列名
* @param clazz映射到数据库的po类
* @return
*/
@SuppressWarnings("unchecked")
publicstatic List<String> getColumnNames(Class clazz) {
Iterator<Column> itr = getTable(clazz).getColumnIterator();
List<String> columns = new ArrayList<String>();
while (itr.hasNext()) {
Column tmp = itr.next();
columns.add(tmp.getName());
}
return columns;
}
}
package com.css.common.hibernate3;
/**
* 1\分页处理类
* 2\JSON处理类 <br/>
*
* @author 何青
*/
import java.util.ArrayList;
import java.util.List;
public class PageSupport<T> {
/**
* 返回类型
*/
private String type;
/**
* 返回信息
*/
private String message;
/**
* 当前页记录内容集合
*/
private T items;
/**
* 总记录数
*/
private Integer totalCount = 0;
/**
* 总页数
*/
private Integer pageCount = 0 ;
/**
* 每页显示记录数
*/
private Integer pageSize = 10;
/**
* 当前页
*/
private Integer curPage = 1;
/**
* 当前页之前和之后显示的页数个数 <br/>如：假设当前页是 6 共有11页<br/>那么显示分页条会显示 1 2 3 4 5 [6] 7 8 9 10 11
*/
private Integer num = 5;
/**
* 清空分页字段信息<br/>
* 避免totalCount，pageCount，pageSize，curPage，num字段付初始值
*/
public void setNull(){
totalCount = null;
pageCount = null;
pageSize = null;
curPage = null;
num = null;
}
/**
* 计算总页数
*
* @param totalCount
*/
public void setTotalCount(Integer totalCount) {
if (totalCount > 0) {
this.totalCount = totalCount;
this.pageCount = (totalCount + pageSize - 1) / pageSize;
}
}
/**
* 获取总记录数
*
* @return
*/
public Integer getTotalCount() {
return totalCount;
}
/**
* 获取每页显示记录数
*
* @return
*/
public Integer getPageSize() {
return pageSize;
}
/**
* 设置每页显示记录数
*
* @param pageSize
*/
public void setPageSize(Integer pageSize) {
this.pageSize = pageSize;
}
/**
* 得到当前页数
*
* @return
*/
public Integer getCurPage() {
return curPage;
}
/**
* 设置当前页数
*
* @param curPage
*/
public void setCurPage(Integer curPage) {
this.curPage = curPage;
}
/**
* 获取当前页之前或之后显示的页数个数
*
* @return
*/
public Integer getNum() {
return num;
}
/**
* 设置当前页之前或之后显示的页数个数
*
* @param num
*/
public void setNum(Integer num) {
this.num = num;
}
/**
* 获取当前页记录内容集合
*
* @return
*/
public T getItems() {
return items;
}
/**
* 设置当前页记录内容集合
*
* @param items
*/
public void setItems(T items) {
this.items = items;
}
/**
* 得到总页数
*
* @return
*/
public Integer getPageCount() {
return pageCount;
}
/**
* 设置页总数
*
* @param pageCount
*/
public void setPageCount(Integer pageCount) {
this.pageCount = pageCount;
}
/**
* 判断是否有前一页
*
* @return
*/
public boolean getIsPrev() {
if (curPage > 1) {
return true;
}
return false;
}
/**
* 判断是否有后一页
*
* @return
*/
public boolean getIsNext() {
if (curPage < pageCount) {
return true;
}
return false;
}
/**
* 当前页的前num条页假设当前页是 6共有11页如：1 2 3 4 5
*
* @return
*/
public List<Integer> getPrevPages() {
List<Integer> list = new ArrayList<Integer>();
int _frontStart = 1;
if (curPage > num) {
_frontStart = curPage - num;
}
for (int i = _frontStart; i < curPage; i++) {
list.add(i);
}
return list;
}
/**
* 当前页的后num条页假设当前页是 6共有11页如：7 8 9 10 11
*
* @return
*/
public List<Integer> getNextPages() {
List<Integer> list = new ArrayList<Integer>();
int _endCount = num;
if (num < pageCount && (curPage + num) < pageCount) {
_endCount = curPage + _endCount;
} else {
_endCount = pageCount;
}
for (int i = curPage + 1; i <= _endCount; i++) {
list.add(i);
}
return list;
}
/**
* 得到起始页数据
*
* @return
*/
public Integer getStartIndex() {
if (curPage > 0) {
return (curPage - 1) * pageSize;
}
return 0;
}
/**
* 查询是否有数据
*
* @return
*/
public boolean getIsPage() {
if (this.totalCount > 0) {
return true;
} else {
return false;
}
}
/**
* 获取前一页
*
* @return
*/
public Integer getPrev() {
return curPage - 1;
}
/**
* 获取后一页
* @return
*/
public int getNext(){
return curPage+1;
}
/**
* 获取最后一页
*
* @return
*/
public Integer getLast() {
return pageCount;
}
/**
* 得到返回类型
* @return
*/
public String getType() {
return type;
}
/**
* 设置返回类型
* @param type
*/
public void setType(String type) {
this.type = type;
}
/**
* 得到返回信息
* @return
*/
public String getMessage() {
return message;
}
/**
* 设置返回信息
* @param message
*/
public void setMessage(String message) {
this.message = message;
}
}
package com.css.common.hibernate3;
import java.util.ArrayList;
import java.util.List;
/**
* SQL和实体Bean的映射处理 <br/>
*
* @author 何青
*/
public class SqlBean<T> {
private Class<T> clazz;
public SqlBean(){
}
public SqlBean(Class<T> clazz) {
this.clazz = clazz;
}
private List<String> beanNames = new ArrayList<String>();
private List<String> columnNames = new ArrayList<String>();
private String where;
private Object[] params = null;
private String countSql;
private Object[] countParams = null;
public void setColumnBeanNames(String columnName,String beanName)
{
this.columnNames.add(columnName+" as "+beanName);
this.beanNames.add(beanName);
}
public void removeColumnBeanNames(String columnName,String beanName)
{
this.columnNames.remove(columnName+" as "+beanName);
this.beanNames.remove(beanName);
}
public String getColumnNames()
{
return this.columnNames.toString().substring(1,this.columnNames.toString().length()-1);
}
public List<String> getBeanNames()
{
return this.beanNames;
}
public Class<T> getModelClass() {
return this.clazz;
}
public String getWhere() {
return where;
}
public void setWhere(String where) {
this.where = where;
}
public Object[] getParams() {
return params;
}
public void setParams(Object[] params) {
this.params = params;
}
public String getCountSql() {
return countSql;
}
public void setCountSql(String countSql) {
this.countSql = countSql;
}
public Object[] getCountParams() {
return countParams;
}
public void setCountParams(Object[] countParams) {
this.countParams = countParams;
}
@Override
public String toString()
{
return "select "+this.getColumnNames()+" "+this.getWhere();
}
}
