mysqlselectsql.java

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

package org.speedframework.sql.mysql;

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

/**
 * Class MySQLSelectSQL
 * 
 * @author <a href="mailto:[e-mail]"> lizf </a>
 * @version $Revision:1.0.0, $Date: 2007-10-11 4:31:49 $
 */
public class MySQLSelectSQL extends AbstractSelectSQL {

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

		return new_param;
	}

	/*
	 * （非 Javadoc）
	 * 
	 * @see org.speedframework.sql.ISelectSQL#getLimitSQL(java.lang.String)
	 */
	public String getLimitSQL(String sql) {
		StringBuffer stringBuffer = new StringBuffer(10);
        stringBuffer.append("select * from ( ");
		stringBuffer.append(sql);
		stringBuffer.append(" ) rows_ limit ?,?");

		return stringBuffer.toString();
	}

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

}