oracleselectsql.java

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

package org.speedframework.sql.oracle;

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

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

	/* (non-Javadoc)
	 * @see org.speedframework.sql.ISelectSQL#getLimitSQL(java.lang.String)
	 */
	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();
	}

	/* (non-Javadoc)
	 * @see org.speedframework.sql.ISelectSQL#getQueryLimitParam(java.lang.Object[], org.speedframework.entity.Pagination)
	 */
	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;
	}

//	public String getCountSQL(String sql) {
//		return "select count(1) as count_ from ( " + sql + " ) ";
//	}
}