diff --git a/config/alfresco/ibatis/org.hibernate.dialect.Dialect/solr-common-SqlMap.xml b/config/alfresco/ibatis/org.hibernate.dialect.Dialect/solr-common-SqlMap.xml
index d07dbdffe5..7fdc124001 100644
--- a/config/alfresco/ibatis/org.hibernate.dialect.Dialect/solr-common-SqlMap.xml
+++ b/config/alfresco/ibatis/org.hibernate.dialect.Dialect/solr-common-SqlMap.xml
@@ -36,10 +36,15 @@
         select
             acs.id              as id,
             acs.commit_time_ms  as commit_time_ms,
-            count(acl_id) as acl_count
+            (select
+                 count(acl.id)
+             from
+                 alf_access_control_list acl
+             where
+                 acl.acl_change_set = acs.id
+            ) as acl_count
         from
             alf_acl_change_set acs
-        join alf_access_control_list acl on (acl.acl_change_set = acs.id and exists (select 1 from alf_node admnode where admnode.acl_id = acl.id))
         <where>
            <if test="fromCommitTimeInclusive != null">
                <![CDATA[acs.commit_time_ms >= #{fromCommitTimeInclusive}]]>
@@ -54,7 +59,6 @@
                and <![CDATA[acs.id < #{toIdExclusive}]]>
            </if>
         </where>
-        group by acs.commit_time_ms, acs.id
         order by acs.commit_time_ms ASC, acs.id ASC
     </select>
 
@@ -65,9 +69,8 @@
         from
             alf_access_control_list acl
         <where>
-            exists (select 1 from alf_node admnode where admnode.acl_id = acl.id)
             <if test="fromIdInclusive != null">
-               and <![CDATA[acl.id >= #{fromIdInclusive}]]>
+               <![CDATA[acl.id >= #{fromIdInclusive}]]>
             </if>
             <if test="ids != null">
                 and acl.acl_change_set in 
@@ -81,14 +84,27 @@
     </select>
 
     <select id="select_Txns" parameterType="SOLRTrackingParameters" resultMap="result_Transaction">
-       select
+        select
             txn.id              as id,
             txn.commit_time_ms  as commit_time_ms,
-            count(case when node.type_qname_id != #{deletedTypeQNameId} then 1 end) as updates,
-            count(case when node.type_qname_id = #{deletedTypeQNameId} then 1 end) as deletes
+            (select
+                 count(node.id)
+             from
+                 alf_node node
+             where
+                 txn.id = node.transaction_id and
+                 node.type_qname_id != #{deletedTypeQNameId}
+            ) as updates,
+            (select
+                 count(node.id)
+             from
+                 alf_node node
+             where
+                 txn.id = node.transaction_id and
+                 node.type_qname_id = #{deletedTypeQNameId}
+            ) as deletes
         from
             alf_transaction txn
-        join alf_node node on (txn.id = node.transaction_id)
         <where>
            <if test="fromCommitTimeInclusive != null">
                <![CDATA[txn.commit_time_ms >= #{fromCommitTimeInclusive}]]>
@@ -103,7 +119,6 @@
                and <![CDATA[txn.id < #{toIdExclusive}]]>
            </if>
         </where>
-        group by txn.commit_time_ms, txn.id
         order by txn.commit_time_ms ASC, txn.id ASC
     </select>
 
diff --git a/source/test-java/org/alfresco/repo/solr/SOLRTrackingComponentTest.java b/source/test-java/org/alfresco/repo/solr/SOLRTrackingComponentTest.java
index e59cd2466d..bd9598c73f 100644
--- a/source/test-java/org/alfresco/repo/solr/SOLRTrackingComponentTest.java
+++ b/source/test-java/org/alfresco/repo/solr/SOLRTrackingComponentTest.java
@@ -21,7 +21,6 @@ package org.alfresco.repo.solr;
 import java.io.InputStream;
 import java.io.Serializable;
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.Collection;
 import java.util.HashMap;
 import java.util.HashSet;
@@ -139,20 +138,25 @@ public class SOLRTrackingComponentTest extends TestCase
     {
         List<AclChangeSet> cs = solrTrackingComponent.getAclChangeSets(null, null, null, null, 50);
         assertTrue("Expected results to be limited in number", cs.size() <= 50);
+        List<Long> aclChangeSetIds = new ArrayList<Long>(50);
         int totalAcls = 0;
         for (AclChangeSet aclChangeSet : cs)
         {
+            aclChangeSetIds.add(aclChangeSet.getId());
             totalAcls += aclChangeSet.getAclCount();
         }
         int totalAclsCheck = 0;
-        
-        for (AclChangeSet aclChangeSet : cs)
+        Long fromAclId = null;
+        while (true)
         {
-            List<Acl> acls = solrTrackingComponent.getAcls(Arrays.asList(new Long[]{aclChangeSet.getId()}), null, 200);
-            assertEquals(aclChangeSet.getAclCount(), acls.size());
+            List<Acl> acls = solrTrackingComponent.getAcls(aclChangeSetIds, fromAclId, 2);
+            if (acls.size() == 0)
+            {
+                break;
+            }
             totalAclsCheck += acls.size();
+            fromAclId = acls.get(acls.size() - 1).getId() + 1;
         }
-        
         // Double check number of ACLs
         assertEquals("ACL count should have matched", totalAcls, totalAclsCheck);
     }