db2selectsql.java

羽量级数据持久层开发框架

// $Id: DB2SelectSQL.java $Date: 2007-10-22 上午09:01:28 $ 
// $Id: DB2SelectSQL.java $Date: 2007-10-22 上午09:01:28 $ 
package org.speedframework.sql.db2;

import org.speedframework.entity.Pagination;
import org.speedframework.sql.AbstractSelectSQL;

/**
 * Class DB2SelectSQL
 * 
 * @author <a href="mailto:[e-mail]"> lizf </a>
 * @version $Revision:1.0.0, $Date: 2007-10-22 上午09:01:28 $
 */
public class DB2SelectSQL extends AbstractSelectSQL {

	public String getLimitSQL(String sql) {
		StringBuffer stringBuffer = new StringBuffer();
		stringBuffer
				.append("select * from( select rownumber() over() as rownum_ ,a1.* from ( ");

		stringBuffer.append(sql);

		stringBuffer.append(" ) a1) a2 where a2.rownum_ between ? and ? ");
		return stringBuffer.toString();
	}

	public Object[] getQueryLimitParam(Object[] params, Pagination pagination) {
		int length = params.length;
		Object[] new_param = new Object[length + 2];

		for (int i = 0; i < length; i++) {
			new_param[i] = params[i];
		}
		new_param[length] = new Integer((pagination.getPage() - 1)
				* pagination.getCount() + 1);
		new_param[length + 1] = new Integer(pagination.getCount()
				* pagination.getPage());
		return new_param;
	}

}