package org.apache.rya.indexing.accumulo.entity;

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 * 
 *   http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

import java.util.Collection;
import java.util.List;
import java.util.Map;

import org.apache.accumulo.core.client.BatchWriter;
import org.apache.accumulo.core.client.Connector;
import org.apache.accumulo.core.client.mock.MockInstance;
import org.apache.accumulo.core.client.security.tokens.PasswordToken;
import org.apache.accumulo.core.data.Mutation;
import org.apache.hadoop.conf.Configuration;
import org.apache.rya.accumulo.AccumuloRdfConfiguration;
import org.apache.rya.accumulo.RyaTableMutationsFactory;
import org.apache.rya.api.RdfCloudTripleStoreConstants;
import org.apache.rya.api.domain.RyaStatement;
import org.apache.rya.api.domain.RyaType;
import org.apache.rya.api.domain.RyaURI;
import org.apache.rya.api.resolver.RyaToRdfConversions;
import org.apache.rya.api.resolver.RyaTripleContext;
import org.apache.rya.indexing.accumulo.ConfigUtils;
import org.eclipse.rdf4j.common.iteration.CloseableIteration;
import org.eclipse.rdf4j.model.Value;
import org.eclipse.rdf4j.model.ValueFactory;
import org.eclipse.rdf4j.model.impl.SimpleValueFactory;
import org.eclipse.rdf4j.model.vocabulary.XMLSchema;
import org.eclipse.rdf4j.query.BindingSet;
import org.eclipse.rdf4j.query.QueryEvaluationException;
import org.eclipse.rdf4j.query.algebra.StatementPattern;
import org.eclipse.rdf4j.query.algebra.TupleExpr;
import org.eclipse.rdf4j.query.algebra.evaluation.QueryBindingSet;
import org.eclipse.rdf4j.query.algebra.helpers.StatementPatternCollector;
import org.eclipse.rdf4j.query.parser.ParsedQuery;
import org.eclipse.rdf4j.query.parser.sparql.SPARQLParser;
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;

import com.google.common.collect.Lists;

public class AccumuloDocIndexerTest {

    private MockInstance mockInstance;
    private Connector accCon;
    AccumuloRdfConfiguration conf = new AccumuloRdfConfiguration();
    ValueFactory vf = SimpleValueFactory.getInstance();
    
    private String tableName;
    
    
    @Before
    public void init() throws Exception {
        final String INSTANCE = "instance";
        Configuration config = new Configuration();
        config.set(ConfigUtils.CLOUDBASE_AUTHS, "U");
        config.set(ConfigUtils.CLOUDBASE_INSTANCE, INSTANCE);
        config.set(ConfigUtils.CLOUDBASE_USER, "root");
        config.set(ConfigUtils.CLOUDBASE_PASSWORD, "");
       
        conf = new AccumuloRdfConfiguration(config);
        conf.set(ConfigUtils.USE_MOCK_INSTANCE, "true");
        conf.setAdditionalIndexers(EntityCentricIndex.class);
        conf.setTablePrefix("EntityCentric_");
        tableName =  EntityCentricIndex.getTableName(conf);

        // Access the accumulo instance.  If you assign a name, it persists statically, but otherwise, can't get it by name.
        accCon = new MockInstance(INSTANCE).getConnector("root", new PasswordToken(""));
        if(accCon.tableOperations().exists(tableName)) {
                throw new Exception("New mock accumulo already has a table!  Should be deleted in AfterTest.");
        } 
        // This should happen in the index initialization, but some tests need it before: 
        accCon.tableOperations().create(tableName);
    }

    @After
    public void afterTest() throws Exception {
        if (accCon.tableOperations().exists(tableName)) {
            accCon.tableOperations().delete(tableName);
        }
    }

    @Test
    public void testNoContext1()  throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));

          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);
         
          
          for (int i = 0; i < 20; i++) {
                      
              
                    RyaStatement rs1 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaType(XMLSchema.STRING, "cq1"));
                    RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"));
                    RyaStatement rs3 = null;
                    RyaStatement rs4 = null;
                   
                    if(i == 5 || i == 15) {
                        rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)));
                        rs4 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.STRING,Integer.toString(i)));
                    }
        
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize4 = null;
                    
                    if(rs3 != null) {
                        serialize3 = rtm.serialize(rs3);
                    }
                    
                    if(rs4 != null) {
                        serialize4 = rtm.serialize(rs4);
                    }
                    
                    
                    Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
                    for (Mutation m : m1) {
                        bw.addMutation(m);
                    }
                    Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
                    for (Mutation m : m2) {
                        bw.addMutation(m);
                    }
                    if (serialize3 != null) {
                        Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                        for (Mutation m : m3) {
                            bw.addMutation(m);
                        }
                    }
                    if (serialize4 != null) {
                        Collection<Mutation> m4 = EntityCentricIndex.createMutations(rs4);
                        for (Mutation m : m4) {
                            bw.addMutation(m);
                        }
                    }
         
                    
          }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 " //
                  + "{"//
                  +  "?X <uri:cf1> ?Y1 ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> 5 ."//
                  +  "}";
          
          
          String q2 = "" //
                  + "SELECT ?X ?Y1 ?Y2 " //
                  + "{"//
                  +  "?X <uri:cf1> ?Y1  ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> \"15\" ."//
                  +  "}";
          
               
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);
                ParsedQuery pq2 = parser.parseQuery(q2, null);

                TupleExpr te1 = pq1.getTupleExpr();
                TupleExpr te2 = pq2.getTupleExpr();

                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                List<StatementPattern> spList2 = StatementPatternCollector.process(te2);

                StarQuery sq1 = new StarQuery(spList1);
                StarQuery sq2 = new StarQuery(spList2);
                
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                List<BindingSet> bsList = Lists.newArrayList();
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                CloseableIteration<BindingSet, QueryEvaluationException> sol2 = adi.queryDocIndex(sq2, bsList);
                
                System.out.println("******************Test 1************************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(1, results);
                
                System.out.println("************************************************");
                results = 0;
                while(sol2.hasNext()) {
                    System.out.println(sol2.next());
                    results++;
                }
                
                Assert.assertEquals(1, results);
                
                
                adi.close();
                
                
    }
    
    
    @Test
    public void testNoContext2() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));


          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);
          
          for (int i = 0; i < 30; i++) {
                      
              
                    RyaStatement rs1 = new RyaStatement(new RyaURI("uri:cq1"), new RyaURI("uri:cf1"), new RyaURI("uri:" + i ));
                    RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"));
                    RyaStatement rs3 = null;
                  
                   
                    if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                        rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)));
                    }
        
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
                   
                    
                    if(rs3 != null) {
                        serialize3 = rtm.serialize(rs3);
                    }
                    
                    
                    Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
                    for (Mutation m : m1) {
                        bw.addMutation(m);
                    }
                    Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
                    for (Mutation m : m2) {
                        bw.addMutation(m);
                    }
                    if (serialize3 != null) {
                        Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                        for (Mutation m : m3) {
                            bw.addMutation(m);
                        }
                    }
                    
                    
          }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  +  "?Y1 <uri:cf1> ?X ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
                
                List<BindingSet> bsList = Lists.newArrayList();
//                QueryBindingSet b1 = (new QueryBindingSet());
//                b1.addBinding("X", vf.createIRI("uri:5"));
//                QueryBindingSet b2 = (new QueryBindingSet());
//                b2.addBinding("X", vf.createIRI("uri:15"));
//                QueryBindingSet b3 = (new QueryBindingSet());
//                b3.addBinding("X", vf.createIRI("uri:25"));
//                bsList.add(b1);
//                bsList.add(b2);
//                bsList.add(b3);
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 2***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(5, results);
                
                
                adi.close();
                   

    }
    
    
    @Test
    public void testNoContextCommonVarBs() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));


          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);

         
          for (int i = 0; i < 30; i++) {
                      
              
                    RyaStatement rs1 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaType(XMLSchema.STRING, "cq1"));
                    RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"));
                    RyaStatement rs3 = null;
                  
                   
                    if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                        rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)));
                    }
        
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
                   
                    
                    if(rs3 != null) {
                        serialize3 = rtm.serialize(rs3);
                    }
                    
                    
                    Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
                    for (Mutation m : m1) {
                        bw.addMutation(m);
                    }
                    Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
                    for (Mutation m : m2) {
                        bw.addMutation(m);
                    }
                    if (serialize3 != null) {
                        Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                        for (Mutation m : m3) {
                            bw.addMutation(m);
                        }
                    }
                    
                    
          }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 " //
                  + "{"//
                  +  "?X <uri:cf1> ?Y1 ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
                
                List<BindingSet> bsList = Lists.newArrayList();
                QueryBindingSet b1 = (new QueryBindingSet());
                b1.addBinding("X", vf.createIRI("uri:5"));
                QueryBindingSet b2 = (new QueryBindingSet());
                b2.addBinding("X", vf.createIRI("uri:15"));
                QueryBindingSet b3 = (new QueryBindingSet());
                b3.addBinding("X", vf.createIRI("uri:25"));
                bsList.add(b1);
                bsList.add(b2);
                bsList.add(b3);
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 3***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(3, results);
                
                
                adi.close();
                   

    }
    

    @Test
    public void testNoContextUnCommonVarBs() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));


          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);

         
          for (int i = 0; i < 30; i++) {
                      
              
                    RyaStatement rs1 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaType(XMLSchema.STRING, "cq1"));
                    RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"));
                    RyaStatement rs3 = null;
                    
                   
                    if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                        rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)));
                    }
        
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
                   
                    
                    if(rs3 != null) {
                        serialize3 = rtm.serialize(rs3);
                    }
                    
                    
                    Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
                    for (Mutation m : m1) {
                        bw.addMutation(m);
                    }
                    Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
                    for (Mutation m : m2) {
                        bw.addMutation(m);
                    }
                    if (serialize3 != null) {
                        Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                        for (Mutation m : m3) {
                            bw.addMutation(m);
                        }
                    }
                    
                    
          }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 " //
                  + "{"//
                  +  "?X <uri:cf1> ?Y1 ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
                Value v1 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(5)));
                Value v2 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(25)));
                
                List<BindingSet> bsList = Lists.newArrayList();
                QueryBindingSet b1 = (new QueryBindingSet());
                b1.addBinding("Y3", v1);
                QueryBindingSet b2 = (new QueryBindingSet());
                b2.addBinding("Y3", v2);
                bsList.add(b1);
                bsList.add(b2);
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 4***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(2, results);
                
                
                adi.close();
                   

    }
    
    
    @Test
    public void testNoContextCommonVarBs2() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));


          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);

         
          for (int i = 0; i < 30; i++) {
                      
              
                    RyaStatement rs1 = new RyaStatement(new RyaURI("uri:cq1"), new RyaURI("uri:cf1"), new RyaURI("uri:" + i ));
                    RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"));
                    RyaStatement rs3 = null;
                  
                   
                    if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                        rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)));
                    }
        
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
                   
                    
                    if(rs3 != null) {
                        serialize3 = rtm.serialize(rs3);
                    }
                    
                    
                    Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
                    for (Mutation m : m1) {
                        bw.addMutation(m);
                    }
                    Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
                    for (Mutation m : m2) {
                        bw.addMutation(m);
                    }
                    if (serialize3 != null) {
                        Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                        for (Mutation m : m3) {
                            bw.addMutation(m);
                        }
                    }
                    
                    
          }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  +  "?Y1 <uri:cf1> ?X ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
                
                List<BindingSet> bsList = Lists.newArrayList();
                QueryBindingSet b1 = (new QueryBindingSet());
                b1.addBinding("X", vf.createIRI("uri:5"));
                QueryBindingSet b2 = (new QueryBindingSet());
                b2.addBinding("X", vf.createIRI("uri:15"));
                QueryBindingSet b3 = (new QueryBindingSet());
                b3.addBinding("X", vf.createIRI("uri:25"));
                bsList.add(b1);
                bsList.add(b2);
                bsList.add(b3);
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 5***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(3, results);
                
                
                adi.close();
                   

    }
    
    
    @Test
    public void testNoContextUnCommonVarBs2() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));


          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);

         
          for (int i = 0; i < 30; i++) {
                      
              
                    RyaStatement rs1 = new RyaStatement(new RyaURI("uri:cq1"), new RyaURI("uri:cf1"), new RyaURI("uri:" + i ));
                    RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"));
                    RyaStatement rs3 = null;
                  
                   
                    if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                        rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)));
                    }
        
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
                   
                    
                    if(rs3 != null) {
                        serialize3 = rtm.serialize(rs3);
                    }
                    
                    
                    Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
                    for (Mutation m : m1) {
                        bw.addMutation(m);
                    }
                    Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
                    for (Mutation m : m2) {
                        bw.addMutation(m);
                    }
                    if (serialize3 != null) {
                        Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                        for (Mutation m : m3) {
                            bw.addMutation(m);
                        }
                    }
                    
                    
          }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  +  "?Y1 <uri:cf1> ?X ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
                
                List<BindingSet> bsList = Lists.newArrayList();
                QueryBindingSet b1 = (new QueryBindingSet());
                b1.addBinding("X", vf.createIRI("uri:5"));
                QueryBindingSet b2 = (new QueryBindingSet());
                b2.addBinding("X", vf.createIRI("uri:15"));
                QueryBindingSet b3 = (new QueryBindingSet());
                b3.addBinding("X", vf.createIRI("uri:25"));
                bsList.add(b1);
                bsList.add(b2);
                bsList.add(b3);
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 6***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(3, results);
                
                
                adi.close();
                   

    }
    
    
    @Test
    public void testContext2() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));


          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);

         
          for (int i = 0; i < 30; i++) {
                      
              
                    RyaStatement rs1 = new RyaStatement(new RyaURI("uri:cq1"), new RyaURI("uri:cf1"), new RyaURI("uri:" + i ), new RyaURI("uri:joe"));
                    RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:joe"));
                    RyaStatement rs3 = null;
                    
                    RyaStatement rs4 = new RyaStatement(new RyaURI("uri:cq1"), new RyaURI("uri:cf1"), new RyaURI("uri:" + i ), new RyaURI("uri:hank"));
                    RyaStatement rs5 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:hank"));
                    RyaStatement rs6 = null;
                  
                   
                    if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                        rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:joe"));
                        rs6 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:hank"));
                    }
        
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize4 = rtm.serialize(rs4);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize5 = rtm.serialize(rs5);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize6 = null;
                   
                    
                    if(rs3 != null) {
                        serialize3 = rtm.serialize(rs3);
                    }
                    
                    if(rs6 != null) {
                        serialize6 = rtm.serialize(rs6);
                    }
                    
                    
                    Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
                    for (Mutation m : m1) {
                        bw.addMutation(m);
                    }
                    Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
                    for (Mutation m : m2) {
                        bw.addMutation(m);
                    }
                    if (serialize3 != null) {
                        Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                        for (Mutation m : m3) {
                            bw.addMutation(m);
                        }
                    }
                    
                    Collection<Mutation> m4 = EntityCentricIndex.createMutations(rs4);
                    for (Mutation m : m4) {
                        bw.addMutation(m);
                    }
                    Collection<Mutation> m5 = EntityCentricIndex.createMutations(rs5);
                    for (Mutation m : m5) {
                        bw.addMutation(m);
                    }
                    if (serialize3 != null) {
                        Collection<Mutation> m6 = EntityCentricIndex.createMutations(rs6);
                        for (Mutation m : m6) {
                            bw.addMutation(m);
                        }
                    }
                    
                    
          }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  + " GRAPH <uri:joe> { " //
                  +  "?Y1 <uri:cf1> ?X ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  + " } "//
                  +  "}";
          
          
          String q2 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  +  "?Y1 <uri:cf1> ?X ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
                
                List<BindingSet> bsList = Lists.newArrayList();
//                QueryBindingSet b1 = (new QueryBindingSet());
//                b1.addBinding("X", vf.createIRI("uri:5"));
//                QueryBindingSet b2 = (new QueryBindingSet());
//                b2.addBinding("X", vf.createIRI("uri:15"));
//                QueryBindingSet b3 = (new QueryBindingSet());
//                b3.addBinding("X", vf.createIRI("uri:25"));
//                bsList.add(b1);
//                bsList.add(b2);
//                bsList.add(b3);
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 7***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(5, results);
                
                
                ParsedQuery pq2 = parser.parseQuery(q2, null);

                TupleExpr te2 = pq2.getTupleExpr();
                
                List<StatementPattern> spList2 = StatementPatternCollector.process(te2);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList2));
               
                StarQuery sq2 = new StarQuery(spList2);
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol2 = adi.queryDocIndex(sq2, bsList);
                
                System.out.println("**********************TEST 7***********************");
                results = 0;
                while(sol2.hasNext()) {
                    System.out.println(sol2.next());
                    results++;
                }
                Assert.assertEquals(10, results);
                
                
                adi.close();
                   

    }
    
    
    @Test
    public void testContextUnCommonVarBs2() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));


          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);

         
          for (int i = 0; i < 30; i++) {
                      
              
                    RyaStatement rs1 = new RyaStatement(new RyaURI("uri:cq1"), new RyaURI("uri:cf1"), new RyaURI("uri:" + i ), new RyaURI("uri:joe"));
                    RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:joe"));
                    RyaStatement rs3 = null;
                    
                    RyaStatement rs4 = new RyaStatement(new RyaURI("uri:cq1"), new RyaURI("uri:cf1"), new RyaURI("uri:" + i ), new RyaURI("uri:hank"));
                    RyaStatement rs5 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:hank"));
                    RyaStatement rs6 = null;
                  
                   
                    if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                        rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:joe"));
                        rs6 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:hank"));
                    }
        
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize4 = rtm.serialize(rs4);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize5 = rtm.serialize(rs5);
                    Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize6 = null;
                   
                    
                    if(rs3 != null) {
                        serialize3 = rtm.serialize(rs3);
                    }
                    
                    if(rs6 != null) {
                        serialize6 = rtm.serialize(rs6);
                    }
                    
                    
                    Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
                    for (Mutation m : m1) {
                        bw.addMutation(m);
                    }
                    Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
                    for (Mutation m : m2) {
                        bw.addMutation(m);
                    }
                    if (serialize3 != null) {
                        Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                        for (Mutation m : m3) {
                            bw.addMutation(m);
                        }
                    }
                    
                    Collection<Mutation> m4 = EntityCentricIndex.createMutations(rs4);
                    for (Mutation m : m4) {
                        bw.addMutation(m);
                    }
                    Collection<Mutation> m5 = EntityCentricIndex.createMutations(rs5);
                    for (Mutation m : m5) {
                        bw.addMutation(m);
                    }
                    if (serialize3 != null) {
                        Collection<Mutation> m6 = EntityCentricIndex.createMutations(rs6);
                        for (Mutation m : m6) {
                            bw.addMutation(m);
                        }
                    }
                    
                    
          }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  + " GRAPH <uri:joe> { " //
                  +  "?Y1 <uri:cf1> ?X ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  + " } "//
                  +  "}";
          
          
          String q2 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  +  "?Y1 <uri:cf1> ?X ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
                
                List<BindingSet> bsList = Lists.newArrayList();
                QueryBindingSet b1 = (new QueryBindingSet());
                b1.addBinding("X", vf.createIRI("uri:5"));
                QueryBindingSet b2 = (new QueryBindingSet());
                b2.addBinding("X", vf.createIRI("uri:15"));
                QueryBindingSet b3 = (new QueryBindingSet());
                b3.addBinding("X", vf.createIRI("uri:25"));
                bsList.add(b1);
                bsList.add(b2);
                bsList.add(b3);
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 8***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(3, results);
                
                
                ParsedQuery pq2 = parser.parseQuery(q2, null);

                TupleExpr te2 = pq2.getTupleExpr();
                
                List<StatementPattern> spList2 = StatementPatternCollector.process(te2);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList2));
               
                StarQuery sq2 = new StarQuery(spList2);
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol2 = adi.queryDocIndex(sq2, bsList);
                
                System.out.println("**********************TEST 8***********************");
                results = 0;
                while(sol2.hasNext()) {
                    System.out.println(sol2.next());
                    results++;
                }
                Assert.assertEquals(6, results);
                
                
                adi.close();
                   

    }
    
    
    @Test
    public void testContext1() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));


          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);

         
          for (int i = 0; i < 30; i++) {
              
              
              RyaStatement rs1 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaURI("uri:cq1"),  new RyaURI("uri:joe"));
              RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:joe"));
              RyaStatement rs3 = null;
              
              RyaStatement rs4 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaURI("uri:cq1"), new RyaURI("uri:hank"));
              RyaStatement rs5 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:hank"));
              RyaStatement rs6 = null;
            
             
              if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                  rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:joe"));
                  rs6 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:hank"));
              }
  
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize4 = rtm.serialize(rs4);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize5 = rtm.serialize(rs5);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize6 = null;
             
              
              if(rs3 != null) {
                  serialize3 = rtm.serialize(rs3);
              }
              
              if(rs6 != null) {
                  serialize6 = rtm.serialize(rs6);
              }
              
              
              Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
              for (Mutation m : m1) {
                  bw.addMutation(m);
              }
              Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
              for (Mutation m : m2) {
                  bw.addMutation(m);
              }
              if (serialize3 != null) {
                  Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                  for (Mutation m : m3) {
                      bw.addMutation(m);
                  }
              }
              
              Collection<Mutation> m4 = EntityCentricIndex.createMutations(rs4);
              for (Mutation m : m4) {
                  bw.addMutation(m);
              }
              Collection<Mutation> m5 = EntityCentricIndex.createMutations(rs5);
              for (Mutation m : m5) {
                  bw.addMutation(m);
              }
              if (serialize6 != null) {
                  Collection<Mutation> m6 = EntityCentricIndex.createMutations(rs6);
                  for (Mutation m : m6) {
                      bw.addMutation(m);
                  }
              }
              
              
    }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 " //
                  + "{"//
                  +  "?X <uri:cf1> ?Y1 ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
          String q2 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  + " GRAPH <uri:hank> { " //
                  +  "?X <uri:cf1> ?Y1 ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  + " } "//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
//                Value v1 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(5)));
//                Value v2 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(25)));
                
                List<BindingSet> bsList = Lists.newArrayList();
//                QueryBindingSet b1 = (new QueryBindingSet());
//                b1.addBinding("Y3", v1);
//                QueryBindingSet b2 = (new QueryBindingSet());
//                b2.addBinding("Y3", v2);
//                bsList.add(b1);
//                bsList.add(b2);
//                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 10***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(10, results);
                
                
                ParsedQuery pq2 = parser.parseQuery(q2, null);

                TupleExpr te2 = pq2.getTupleExpr();
                
                List<StatementPattern> spList2 = StatementPatternCollector.process(te2);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList2));
               
                StarQuery sq2 = new StarQuery(spList2);
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol2 = adi.queryDocIndex(sq2, bsList);
                
                System.out.println("**********************TEST 10***********************");
                results = 0;
                while(sol2.hasNext()) {
                    System.out.println(sol2.next());
                    results++;
                }
                Assert.assertEquals(5, results);
                
                
                adi.close();
                   

    }
    
    
    @Test
    public void testContextUnCommonVarBs1() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));


          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);

         
          for (int i = 0; i < 30; i++) {
              
              
              RyaStatement rs1 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaURI("uri:cq1"),  new RyaURI("uri:joe"));
              RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:joe"));
              RyaStatement rs3 = null;
              
              RyaStatement rs4 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaURI("uri:cq1"), new RyaURI("uri:hank"));
              RyaStatement rs5 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:hank"));
              RyaStatement rs6 = null;
            
             
              if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                  rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:joe"));
                  rs6 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:hank"));
              }
  
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize4 = rtm.serialize(rs4);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize5 = rtm.serialize(rs5);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize6 = null;
             
              
              if(rs3 != null) {
                  serialize3 = rtm.serialize(rs3);
              }
              
              if(rs6 != null) {
                  serialize6 = rtm.serialize(rs6);
              }
              
              
              Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
              for (Mutation m : m1) {
                  bw.addMutation(m);
              }
              Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
              for (Mutation m : m2) {
                  bw.addMutation(m);
              }
              if (serialize3 != null) {
                  Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                  for (Mutation m : m3) {
                      bw.addMutation(m);
                  }
              }
              
              Collection<Mutation> m4 = EntityCentricIndex.createMutations(rs4);
              for (Mutation m : m4) {
                  bw.addMutation(m);
              }
              Collection<Mutation> m5 = EntityCentricIndex.createMutations(rs5);
              for (Mutation m : m5) {
                  bw.addMutation(m);
              }
              if (serialize6 != null) {
                  Collection<Mutation> m6 = EntityCentricIndex.createMutations(rs6);
                  for (Mutation m : m6) {
                      bw.addMutation(m);
                  }
              }
              
              
    }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  +  "?X <uri:cf1> ?Y1 ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
          String q2 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  + " GRAPH <uri:hank> { " //
                  +  "?X <uri:cf1> ?Y1 ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  + " } "//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
                Value v1 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(5)));
                Value v2 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(25)));
                
                List<BindingSet> bsList = Lists.newArrayList();
                QueryBindingSet b1 = (new QueryBindingSet());
                b1.addBinding("Y3", v1);
                QueryBindingSet b2 = (new QueryBindingSet());
                b2.addBinding("Y3", v2);
                bsList.add(b1);
                bsList.add(b2);
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 11***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(4, results);
                
                
                ParsedQuery pq2 = parser.parseQuery(q2, null);

                TupleExpr te2 = pq2.getTupleExpr();
                
                List<StatementPattern> spList2 = StatementPatternCollector.process(te2);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList2));
               
                StarQuery sq2 = new StarQuery(spList2);
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol2 = adi.queryDocIndex(sq2, bsList);
                
                System.out.println("**********************TEST 11***********************");
                results = 0;
                while(sol2.hasNext()) {
                    System.out.println(sol2.next());
                    results++;
                }
                Assert.assertEquals(2, results);
                
                
                adi.close();
                   

    }
    
    
    @Test
    public void testContextCommonVarBs1() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));


          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);

         
          for (int i = 0; i < 30; i++) {
              
              
              RyaStatement rs1 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaURI("uri:cq1"),  new RyaURI("uri:joe"));
              RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:joe"));
              RyaStatement rs3 = null;
              
              RyaStatement rs4 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaURI("uri:cq1"), new RyaURI("uri:hank"));
              RyaStatement rs5 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:hank"));
              RyaStatement rs6 = null;
            
             
              if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                  rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:joe"));
                  rs6 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:hank"));
              }
  
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize4 = rtm.serialize(rs4);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize5 = rtm.serialize(rs5);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize6 = null;
             
              
              if(rs3 != null) {
                  serialize3 = rtm.serialize(rs3);
              }
              
              if(rs6 != null) {
                  serialize6 = rtm.serialize(rs6);
              }
              
              
              Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
              for (Mutation m : m1) {
                  bw.addMutation(m);
              }
              Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
              for (Mutation m : m2) {
                  bw.addMutation(m);
              }
              if (serialize3 != null) {
                  Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                  for (Mutation m : m3) {
                      bw.addMutation(m);
                  }
              }
              
              Collection<Mutation> m4 = EntityCentricIndex.createMutations(rs4);
              for (Mutation m : m4) {
                  bw.addMutation(m);
              }
              Collection<Mutation> m5 = EntityCentricIndex.createMutations(rs5);
              for (Mutation m : m5) {
                  bw.addMutation(m);
              }
              if (serialize6 != null) {
                  Collection<Mutation> m6 = EntityCentricIndex.createMutations(rs6);
                  for (Mutation m : m6) {
                      bw.addMutation(m);
                  }
              }
              
              
    }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  +  "?X <uri:cf1> ?Y1 ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
          String q2 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  + " GRAPH <uri:hank> { " //
                  +  "?X <uri:cf1> ?Y1 ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  + " } "//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
                Value v1 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(5)));
                Value v2 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(25)));
                
                List<BindingSet> bsList = Lists.newArrayList();
                QueryBindingSet b1 = (new QueryBindingSet());
                b1.addBinding("X", vf.createIRI("uri:5"));
                QueryBindingSet b2 = (new QueryBindingSet());
                b2.addBinding("X", vf.createIRI("uri:15"));
                QueryBindingSet b3 = (new QueryBindingSet());
                b3.addBinding("X", vf.createIRI("uri:25"));
                bsList.add(b1);
                bsList.add(b2);
                bsList.add(b3);
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 12***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(6, results);
                
                
                ParsedQuery pq2 = parser.parseQuery(q2, null);

                TupleExpr te2 = pq2.getTupleExpr();
                
                List<StatementPattern> spList2 = StatementPatternCollector.process(te2);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList2));
               
                StarQuery sq2 = new StarQuery(spList2);
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol2 = adi.queryDocIndex(sq2, bsList);
                
                System.out.println("**********************TEST 12***********************");
                results = 0;
                while(sol2.hasNext()) {
                    System.out.println(sol2.next());
                    results++;
                }
                Assert.assertEquals(3, results);
                
                
                adi.close();
                   

    }
    
    
    @Test
    public void testContextCommonAndUnCommonVarBs1() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));


          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);

         
          for (int i = 0; i < 30; i++) {
              
              
              RyaStatement rs1 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaURI("uri:cq1"),  new RyaURI("uri:joe"));
              RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:joe"));
              RyaStatement rs3 = null;
              
              RyaStatement rs4 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaURI("uri:cq1"), new RyaURI("uri:hank"));
              RyaStatement rs5 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:hank"));
              RyaStatement rs6 = null;
              
              RyaStatement rs7 = null;
              RyaStatement rs8 = null;
            
             
              if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                  rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:joe"));
                  rs6 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:hank"));
                  rs7 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(100+i)), new RyaURI("uri:joe"));
                  rs8 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(100+i)), new RyaURI("uri:hank"));
              }
  
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize4 = rtm.serialize(rs4);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize5 = rtm.serialize(rs5);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize6 = null;
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize7 = null;
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize8 = null;
              
              if(rs3 != null) {
                  serialize3 = rtm.serialize(rs3);
              }
              
              if(rs6 != null) {
                  serialize6 = rtm.serialize(rs6);
              }
              
              if(rs7 != null) {
                  serialize7 = rtm.serialize(rs7);
              }
              
              if(rs8 != null) {
                  serialize8 = rtm.serialize(rs8);
              }
              
              
              Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
              for (Mutation m : m1) {
                  bw.addMutation(m);
              }
              Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
              for (Mutation m : m2) {
                  bw.addMutation(m);
              }
              if (serialize3 != null) {
                  Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                  for (Mutation m : m3) {
                      bw.addMutation(m);
                  }
              }
              
              Collection<Mutation> m4 = EntityCentricIndex.createMutations(rs4);
              for (Mutation m : m4) {
                  bw.addMutation(m);
              }
              Collection<Mutation> m5 = EntityCentricIndex.createMutations(rs5);
              for (Mutation m : m5) {
                  bw.addMutation(m);
              }
              if (serialize6 != null) {
                  Collection<Mutation> m6 = EntityCentricIndex.createMutations(rs6);
                  for (Mutation m : m6) {
                      bw.addMutation(m);
                  }
              }
              
              if (serialize7 != null) {
                  Collection<Mutation> m7 = EntityCentricIndex.createMutations(rs7);
                  for (Mutation m : m7) {
                      bw.addMutation(m);
                  }
              }
              if (serialize8 != null) {
                  Collection<Mutation> m8 = EntityCentricIndex.createMutations(rs8);
                  for (Mutation m : m8) {
                      bw.addMutation(m);
                  }
              }
                   

    }
         
          String q1 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  +  "?X <uri:cf1> ?Y1 ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
          String q2 = "" //
                  + "SELECT ?X ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  + " GRAPH <uri:hank> { " //
                  +  "?X <uri:cf1> ?Y1 ."//
                  +  "?X <uri:cf2> ?Y2 ."//
                  +  "?X <uri:cf3> ?Y3 ."//
                  + " } "//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
                Value v1 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(105)));
                Value v2 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(125)));
                
                List<BindingSet> bsList = Lists.newArrayList();
                QueryBindingSet b1 = new QueryBindingSet();
                b1.addBinding("X", vf.createIRI("uri:5"));
                b1.addBinding("Y3", v1);
                QueryBindingSet b2 = new QueryBindingSet();
                b2.addBinding("X", vf.createIRI("uri:25"));
                b2.addBinding("Y3", v2);
                bsList.add(b1);
                bsList.add(b2);
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 13***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(4, results);
                
                
                ParsedQuery pq2 = parser.parseQuery(q2, null);

                TupleExpr te2 = pq2.getTupleExpr();
                
                List<StatementPattern> spList2 = StatementPatternCollector.process(te2);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList2));
               
                StarQuery sq2 = new StarQuery(spList2);
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol2 = adi.queryDocIndex(sq2, bsList);
                
                System.out.println("**********************TEST 13***********************");
                results = 0;
                while(sol2.hasNext()) {
                    System.out.println(sol2.next());
                    results++;
                }
                Assert.assertEquals(2, results);
                
                
                adi.close();
                   

    }
    
    
    @Test
    public void testContextConstantCommonVar() throws Exception {

      BatchWriter bw = null;
      RyaTableMutationsFactory rtm = new RyaTableMutationsFactory(RyaTripleContext.getInstance(conf));
      

          bw = accCon.createBatchWriter(tableName, 500L * 1024L * 1024L, Long.MAX_VALUE, 30);

         
          for (int i = 0; i < 30; i++) {
              
              
              RyaStatement rs1 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaURI("uri:cq1"),  new RyaURI("uri:joe"));
              RyaStatement rs2 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:joe"));
              RyaStatement rs3 = null;
              
              RyaStatement rs4 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf1"), new RyaURI("uri:cq1"), new RyaURI("uri:hank"));
              RyaStatement rs5 = new RyaStatement(new RyaURI("uri:" + i ), new RyaURI("uri:cf2"), new RyaType(XMLSchema.STRING, "cq2"), new RyaURI("uri:hank"));
              RyaStatement rs6 = null;
            
             
              if(i == 5 || i == 10 || i == 15 || i == 20 || i == 25) {
                  rs3 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:joe"));
                  rs6 = new RyaStatement(new RyaURI("uri:" +i ), new RyaURI("uri:cf3"), new RyaType(XMLSchema.INTEGER,Integer.toString(i)), new RyaURI("uri:hank"));
              }
  
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize1 = rtm.serialize(rs1);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize2 = rtm.serialize(rs2);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize3 = null;
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize4 = rtm.serialize(rs4);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize5 = rtm.serialize(rs5);
              Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, Collection<Mutation>> serialize6 = null;
             
              
              if(rs3 != null) {
                  serialize3 = rtm.serialize(rs3);
              }
              
              if(rs6 != null) {
                  serialize6 = rtm.serialize(rs6);
              }
              
              
              Collection<Mutation> m1 = EntityCentricIndex.createMutations(rs1);
              for (Mutation m : m1) {
                  bw.addMutation(m);
              }
              Collection<Mutation> m2 = EntityCentricIndex.createMutations(rs2);
              for (Mutation m : m2) {
                  bw.addMutation(m);
              }
              if (serialize3 != null) {
                  Collection<Mutation> m3 = EntityCentricIndex.createMutations(rs3);
                  for (Mutation m : m3) {
                      bw.addMutation(m);
                  }
              }
              
              Collection<Mutation> m4 = EntityCentricIndex.createMutations(rs4);
              for (Mutation m : m4) {
                  bw.addMutation(m);
              }
              Collection<Mutation> m5 = EntityCentricIndex.createMutations(rs5);
              for (Mutation m : m5) {
                  bw.addMutation(m);
              }
              if (serialize6 != null) {
                  Collection<Mutation> m6 = EntityCentricIndex.createMutations(rs6);
                  for (Mutation m : m6) {
                      bw.addMutation(m);
                  }
              }
              
              
    }
         
          String q1 = "" //
                  + "SELECT ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  +  "<uri:5> <uri:cf1> ?Y1 ."//
                  +  "<uri:5> <uri:cf2> ?Y2 ."//
                  +  "<uri:5> <uri:cf3> ?Y3 ."//
                  +  "}";
          
          
          String q2 = "" //
                  + "SELECT ?Y1 ?Y2 ?Y3 " //
                  + "{"//
                  + " GRAPH <uri:hank> { " //
                  +  "<uri:5> <uri:cf1> ?Y1 ."//
                  +  "<uri:5> <uri:cf2> ?Y2 ."//
                  +  "<uri:5> <uri:cf3> ?Y3 ."//
                  + " } "//
                  +  "}";
          
          
                SPARQLParser parser = new SPARQLParser();

                ParsedQuery pq1 = parser.parseQuery(q1, null);

                TupleExpr te1 = pq1.getTupleExpr();
                
                List<StatementPattern> spList1 = StatementPatternCollector.process(te1);
                
                String rowString = spList1.get(0).getSubjectVar().getValue().stringValue();
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList1));
               
                StarQuery sq1 = new StarQuery(spList1);
               
                AccumuloDocIdIndexer adi = new AccumuloDocIdIndexer(conf);
                
//                Value v1 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(5)));
//                Value v2 = RyaToRdfConversions.convertValue(new RyaType(XMLSchema.INTEGER,Integer.toString(25)));
                
                List<BindingSet> bsList = Lists.newArrayList();
//                QueryBindingSet b1 = (new QueryBindingSet());
//                b1.addBinding("X", vf.createIRI("uri:5"));
//                QueryBindingSet b2 = (new QueryBindingSet());
//                b2.addBinding("X", vf.createIRI("uri:15"));
//                QueryBindingSet b3 = (new QueryBindingSet());
//                b3.addBinding("X", vf.createIRI("uri:25"));
//                bsList.add(b1);
//                bsList.add(b2);
//                bsList.add(b3);
                
                
//                BatchScanner bs = accCon.createBatchScanner(tablename + "doc_partitioned_index", new Authorizations("U"), 15);
//                bs.setRanges(Collections.singleton(new Range(rowString)));
//                Iterator<Entry<Key,org.apache.accumulo.core.data.Value>> bsIt = bs.iterator();
//                while(bsIt.hasNext()) {
//                    String otherRowString = bsIt.next().getKey().getRow().toString();
//                    if(rowString.equals(otherRowString)) {
//                        System.out.println(otherRowString);
//                    }
//                    
//                }
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol1 = adi.queryDocIndex(sq1, bsList);
                
                System.out.println("**********************TEST 14***********************");
                int results = 0;
                while(sol1.hasNext()) {
                    System.out.println(sol1.next());
                    results++;
                }
                Assert.assertEquals(2, results);
                
                
                ParsedQuery pq2 = parser.parseQuery(q2, null);

                TupleExpr te2 = pq2.getTupleExpr();
                
                List<StatementPattern> spList2 = StatementPatternCollector.process(te2);
                
                Assert.assertTrue(StarQuery.isValidStarQuery(spList2));
               
                StarQuery sq2 = new StarQuery(spList2);
                
                
                CloseableIteration<BindingSet, QueryEvaluationException> sol2 = adi.queryDocIndex(sq2, bsList);
                
                System.out.println("**********************TEST 14***********************");
                results = 0;
                while(sol2.hasNext()) {
                    System.out.println(sol2.next());
                    results++;
                }
                Assert.assertEquals(1, results);
                
                
                adi.close();
                   

    }
    
    
}