accessselectsql.java

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

package org.speedframework.sql.access;

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

/**
 * Class AccessSelectSQL
 * 
 * @author <a href="mailto:[e-mail]"> lizf </a>
 * @version $Revision:1.0.0, $Date: 2007-11-1 上午08:50:10 $
 */
public class AccessSelectSQL extends AbstractSelectSQL {

	public String getLimitSQL(String sql) {
		StringBuffer stringBuffer = new StringBuffer(10);

		stringBuffer
				.append("select * from ( select row_.*, rownum rownum_ from ( ");
		stringBuffer.append(sql);
		stringBuffer.append(" ) row_ where rownum <= ?) where rownum_ > ?");

		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] = Integer.toString(pagination.getPage()
				* pagination.getCount());
		new_param[length + 1] = new Integer((pagination.getPage() - 1)
				* pagination.getCount());

		return new_param;
	}
}