I added the page parameter in both use cases.

Author: rcosnita

rdbms-reduce/src/main/java/com/rcosnita/experiments/rdbmsreduce/examples/TopDomains.java

@@ -82,18 +82,20 @@ public void execute(Connection conn) throws SQLException {
 	}
 
 	public static void main(String[] args) {
-		if(args.length != 2) {
-			throw new RuntimeException("Invalid usage... Ex: java com.rcosnita.experiments.rdbmsreduce.examples.TopDomains <account_id> <number_of_domains>");
+		if(args.length < 2) {
+			throw new RuntimeException("Invalid usage... Ex: java com.rcosnita.experiments.rdbmsreduce.examples.TopDomains <account_id> <number_of_domains> <first_page>");
 		}
 
 		int accountId = Integer.parseInt(args[0]);
 		int maxDomains = Integer.parseInt(args[1]);
 
+		int firstPage  = Integer.parseInt(args.length == 3 ? args[2] : "0") * maxDomains;
+		
 		long startTime = Calendar.getInstance().getTimeInMillis();
 
 		List<Integer> provIds = JPABuilder.getProvisioningIds(accountId);
 
-		String sql = "SELECT * FROM domains WHERE prov_id IN (%(prov_ids)) ORDER BY name ASC LIMIT 100,%(max_domains)";
+		String sql = "SELECT * FROM domains WHERE prov_id IN (%(prov_ids)) ORDER BY name ASC LIMIT " + firstPage + ",%(max_domains)";
 
 		Reductor reductor = new Reductor(14, SupportedEngines.MySQL);
 

rdbms-reduce/src/main/java/com/rcosnita/experiments/rdbmsreduce/examples/TopDomainsTld.java

@@ -22,24 +22,25 @@ public class TopDomainsTld {
 	private final static Logger logger = Logger.getLogger(TopDomainsTld.class);
 
 	public static void main(String[] args) {
-		if(args.length != 3) {
-			throw new RuntimeException("Invalid usage... Ex: java com.rcosnita.experiments.rdbmsreduce.examples.TopDomains <account_id> <number_of_domains> <tld>");
+		if(args.length < 3) {
+			throw new RuntimeException("Invalid usage... Ex: java com.rcosnita.experiments.rdbmsreduce.examples.TopDomains <account_id> <number_of_domains> <tld> <first_page>");
 		}
 
 		int accountId = Integer.parseInt(args[0]);
 		int maxDomains = Integer.parseInt(args[1]);
 		String tld = args[2];
-		
+		int firstPage  = Integer.parseInt(args.length == 4 ? args[3] : "0") * maxDomains;		
+				
 		long startTime = Calendar.getInstance().getTimeInMillis();
 
 		List<Integer> provIds = JPABuilder.getProvisioningIds(accountId);
 
-		String sql = "SELECT * FROM domains WHERE name LIKE '%%(tld)%' AND prov_id IN (%(prov_ids)) ORDER BY name ASC LIMIT 0,%(max_domains)";
+		String sql = "SELECT * FROM domains WHERE name LIKE '%%(tld)%' AND prov_id IN (%(prov_ids)) ORDER BY name ASC LIMIT " + firstPage + ",%(max_domains)";
 
 		Reductor reductor = new Reductor(14, SupportedEngines.MySQL);
 
 		Map<String, Object> sqlValues = new HashMap<String, Object>();
-		sqlValues.put("tld", ".co.uk");
+		sqlValues.put("tld", tld);
 		sqlValues.put("max_domains", maxDomains);		
 		TopDomains topDomains = new TopDomains(reductor, sql, sqlValues, maxDomains, provIds);