ibatis实现分页技术

package com.common.ibatis; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import java.util.Map; import javax.servlet.http.HttpServletRequest; import org.springframework.orm.ibatis.SqlMapClientCallback; import org.springframework.orm.ibatis.SqlMapClientTemplate; import org.springframework.transaction.interceptor.TransactionAspectSupport; import com.common.ibatis.sqlMap.XSqlMapClientDaoSupport; import com.common.util.Reflection; import com.ibatis.sqlmap.client.SqlMapExecutor; public class CommonDBImpl extends XSqlMapClientDaoSupport implements CommonDBInte { private SqlMapClientTemplate sqlMapClient = this.getSqlMapClientTemplate(); public List queryForList(String sqlMap, Object obj){ List list = sqlMapClient.queryForList(sqlMap, obj); if (list.size() != 0) { return list; } return null; } public List queryForList(String sqlMap, Object obj, int size){ List list = sqlMapClient.queryForList(sqlMap, obj, 0, size); if (list.size() != 0) { return list; } return null; } public Object queryForObject(String sqlMap, Object obj){ return sqlMapClient.queryForObject(sqlMap, obj); } public Object insert(String sqlMap, Object obj) { return sqlMapClient.insert(sqlMap, obj); } public int update(String sqlMap, Object obj) { return sqlMapClient.update(sqlMap, obj); } public int delete(String sqlMap, Object obj) { return sqlMapClient.delete(sqlMap, obj); } public void flushDataCache(){ sqlMapClient.getSqlMapClient().flushDataCache(); } public void flushDataCache(String cacheId){ sqlMapClient.getSqlMapClient().flushDataCache(cacheId); } /** * 批处理 3个集合的长度必须一致 只支持增删改 * * @param sqlMap * sqlMap集合 * @param sqlType 操作类型 CommonDBInte.INSERT,CommonDBInte.UPDATE,CommonDBInte.DELETE * @param obj * 参数集合 * @return true or false */ public boolean transactionBatch(final String[] sqlMap, final int[] sqlType, final Object[] obj) { return (Boolean) sqlMapClient.execute(new SqlMapClientCallback() { public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException { try { executor.startBatch(); for (int i = 0; i < sqlMap.length; i++) { if (sqlType[i]==SQL_TYPE_INSERT) { executor.insert(sqlMap[i], obj[i]); } if (sqlType[i]==SQL_TYPE_UPDATE) { executor.update(sqlMap[i], obj[i]); } if (sqlType[i]==SQL_TYPE_DELETE) { executor.delete(sqlMap[i], obj[i]); } } executor.executeBatch(); return Boolean.valueOf(true); } catch (Exception e) { try { TransactionAspectSupport.currentTransactionStatus() .setRollbackOnly(); } catch (Exception ex) { ex.printStackTrace(); } e.printStackTrace(); throw new SQLException(e.getMessage()); } //return Boolean.valueOf(false); } }); } /** * 批处理 集合的长度必须一致 只支持增删改 * @param sqlMap sqlMap集合 * @param sqlType 操作类型 CommonDBInte.INSERT,CommonDBInte.UPDATE,CommonDBInte.DELETE * @param obj 参数集合 * @return true or false */ public boolean transactionBatch(final String[] sqlMap, final int sqlType, final Object[] obj){ return (Boolean) sqlMapClient.execute(new SqlMapClientCallback() { public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException { try { executor.startBatch(); for (int i = 0; i < sqlMap.length; i++) { if (sqlType==SQL_TYPE_INSERT) { executor.insert(sqlMap[i], obj[i]); } if (sqlType==SQL_TYPE_UPDATE) { executor.update(sqlMap[i], obj[i]); } if (sqlType==SQL_TYPE_DELETE) { executor.delete(sqlMap[i], obj[i]); } } executor.executeBatch(); return Boolean.valueOf(true); } catch (Exception e) { try { TransactionAspectSupport.currentTransactionStatus() .setRollbackOnly(); } catch (Exception ex) { ex.printStackTrace(); } e.printStackTrace(); throw new SQLException(e.getMessage()); } //return Boolean.valueOf(false); } }); } /** * 批处理 集合的长度必须一致 只支持增删改 * @param sqlMap sqlMap集合 * @param sqlType 操作类型 CommonDBInte.INSERT,CommonDBInte.UPDATE,CommonDBInte.DELETE * @param obj 参数集合 * @return true or false */ public boolean transactionBatch(final String sqlMap, final int sqlType, final Object[] obj){ return (Boolean) sqlMapClient.execute(new SqlMapClientCallback() { public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException { try { executor.startBatch(); for (int i = 0; i < obj.length; i++) { if (sqlType==SQL_TYPE_INSERT) { executor.insert(sqlMap, obj[i]); } if (sqlType==SQL_TYPE_UPDATE) { executor.update(sqlMap, obj[i]); } if (sqlType==SQL_TYPE_DELETE) { executor.delete(sqlMap, obj[i]); } } executor.executeBatch(); return Boolean.valueOf(true); } catch (Exception e) { try { TransactionAspectSupport.currentTransactionStatus() .setRollbackOnly(); } catch (Exception ex) { ex.printStackTrace(); } e.printStackTrace(); throw new SQLException(e.getMessage()); } //return Boolean.valueOf(false); } }); } /** * 批处理 只支持增删改 * @param sqlMap sqlMap集合 * @param sqlType 操作类型 CommonDBInte.INSERT,CommonDBInte.UPDATE,CommonDBInte.DELETE * @param obj 参数集合 * @return true or false */ public boolean transactionBatch(final String[] sqlMap, final int sqlType, final Object obj){ return (Boolean) sqlMapClient.execute(new SqlMapClientCallback() { public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException { try { executor.startBatch(); for (int i = 0; i < sqlMap.length; i++) { if (sqlType==SQL_TYPE_INSERT) { executor.insert(sqlMap[i], obj); } if (sqlType==SQL_TYPE_UPDATE) { executor.update(sqlMap[i], obj); } if (sqlType==SQL_TYPE_DELETE) { executor.delete(sqlMap[i], obj); } } executor.executeBatch(); return Boolean.valueOf(true); } catch (Exception e) { try { TransactionAspectSupport.currentTransactionStatus() .setRollbackOnly(); } catch (Exception ex) { ex.printStackTrace(); } e.printStackTrace(); throw new SQLException(e.getMessage()); } //return Boolean.valueOf(false); } }); } /** * 事务处理 3个集合的长度必须一致 只支持增删改 * * @param sqlMap * sqlMap集合 * @param sqlType 操作类型 CommonDBInte.INSERT,CommonDBInte.UPDATE,CommonDBInte.DELETE * @param obj * 参数集合 * @return true or false */ public boolean transactionSQL(final String[] sqlMap, final int[] sqlType, final Object[] obj) { try { for (int i = 0; i < sqlMap.length; i++) { if (sqlType[i]==SQL_TYPE_INSERT) { sqlMapClient.insert(sqlMap[i], obj[i]); } if (sqlType[i]==SQL_TYPE_UPDATE) { sqlMapClient.update(sqlMap[i], obj[i]); } if (sqlType[i]==SQL_TYPE_DELETE) { sqlMapClient.delete(sqlMap[i], obj[i]); } } return true; } catch (Exception e) { try { TransactionAspectSupport.currentTransactionStatus() .setRollbackOnly(); } catch (Exception ex) { ex.printStackTrace(); } e.printStackTrace(); } return false; } /** * 事务处理 2个集合的长度必须一致 只支持增删改 * @param sqlMap sqlMap集合 * @param sqlType 操作类型 CommonDBInte