gemfire-core/src/test/java/com/gemstone/gemfire/cache/query/functional/IumMultConditionJUnitTest.java - geode - Git at Google

 /*=========================================================================
  * Copyright (c) 2010-2014 Pivotal Software, Inc. All Rights Reserved.
  * This product is protected by U.S. and international copyright
  * and intellectual property laws. Pivotal products are covered by
  * one or more patents listed at http://www.pivotal.io/patents.
  *=========================================================================
  */
 /*
  * IumMultConditionJUnitTest.java
  * @author vikramj
  * Created on April 29, 2005, 2:30 PM
  *Task IUM 5 And IUM 6
  */
 // @Task IUM6: To Test Task IUM6 Comment the index2 abd run the test.
 // Presently the Test Fails for IUM6 and Exeption occurs:
 // Index not found : java.lang.IllegalArgumentException: use a StructSet
 // instead
 package com.gemstone.gemfire.cache.query.functional;

 import static org.junit.Assert.fail;

 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Iterator;
 import java.util.Set;

 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;

 import com.gemstone.gemfire.cache.Region;
 import com.gemstone.gemfire.cache.query.CacheUtils;
 import com.gemstone.gemfire.cache.query.Index;
 import com.gemstone.gemfire.cache.query.IndexType;
 import com.gemstone.gemfire.cache.query.Query;
 import com.gemstone.gemfire.cache.query.QueryService;
 import com.gemstone.gemfire.cache.query.SelectResults;
 import com.gemstone.gemfire.cache.query.Struct;
 import com.gemstone.gemfire.cache.query.data.Portfolio;
 import com.gemstone.gemfire.cache.query.data.Position;
 import com.gemstone.gemfire.cache.query.internal.QueryObserverAdapter;
 import com.gemstone.gemfire.cache.query.internal.QueryObserverHolder;
 import com.gemstone.gemfire.cache.query.types.StructType;
 import com.gemstone.gemfire.test.junit.categories.IntegrationTest;

 @Category(IntegrationTest.class)
 public class IumMultConditionJUnitTest {

   StructType resType1 = null;
   StructType resType2 = null;
   String[] strg1 = null;
   String[] strg2 = null;
   int resSize1 = 0;
   int resSize2 = 0;
   Object valPf1 = null;
   Object valPos1 = null;
   Object valPf2 = null;
   Object valPos2 = null;
   Iterator itert1 = null;
   Iterator itert2 = null;
   Set set1 = null;
   Set set2 = null;
   boolean isActive1 = false;
   boolean isActive2 = false;

   @Before
   public void setUp() throws java.lang.Exception {
     CacheUtils.startCache();
   }

   @After
   public void tearDown() throws java.lang.Exception {
     CacheUtils.closeCache();
   }

   @Test
   public void testComparisonBetnWithAndWithoutIndexCreation() throws Exception {
     Region region = CacheUtils.createRegion("pos", Portfolio.class);
     for (int i = 0; i < 4; i++) {
       region.put("" + i, new Portfolio(i));
     }
     QueryService qs;
     qs = CacheUtils.getQueryService();
     String queries[] = { "SELECT DISTINCT * FROM /pos pf,  positions.values pos where pf.status='active' and pos.secId= 'IBM' and ID = 0"};
     SelectResults sr[][] = new SelectResults[queries.length][2];

     for (int i = 0; i < queries.length; i++) {
       Query q = null;
       try {
         q = CacheUtils.getQueryService().newQuery(queries[i]);
         QueryObserverImpl observer = new QueryObserverImpl();
         QueryObserverHolder.setInstance(observer);
         sr[i][0] = (SelectResults) q.execute();

         if (!observer.isIndexesUsed) {
           CacheUtils.log("NO INDEX USED");
         }else {
           fail ("Indexes used !!!!?");
         }
         //        CacheUtils.log(Utils.printResult(r));
         resType1 = (StructType) (sr[i][0]).getCollectionType()
             .getElementType();
         resSize1 = ((sr[i][0]).size());
         //        CacheUtils.log(resType1);
         strg1 = resType1.getFieldNames();
         //        CacheUtils.log(strg1[0]);
         //        CacheUtils.log(strg1[1]);
         set1 = ((sr[i][0]).asSet());
         Iterator iter = set1.iterator();
         while (iter.hasNext()) {
           Struct stc1 = (Struct) iter.next();
           valPf1 = stc1.get(strg1[0]);
           valPos1 = stc1.get(strg1[1]);
           isActive1 = ((Portfolio) stc1.get(strg1[0])).isActive();
           //          CacheUtils.log(isActive1);
           //        CacheUtils.log(valPf1);
           //        CacheUtils.log(valPos1);
         }
       } catch (Exception e) {
         e.printStackTrace();
         fail(q.getQueryString());
       }
     }
     //  Create an Index on status and execute the same query again.
     qs = CacheUtils.getQueryService();
     qs.createIndex("statusIndex", IndexType.FUNCTIONAL,
         "pf.status", "/pos pf, pf.positions.values pos");
     //   Index index2 = (Index)qs.createIndex("secIdIndex",
     // IndexType.FUNCTIONAL,"pos.secId","/pos pf, pf.positions.values pos");
     qs.createIndex("IDIndex", IndexType.FUNCTIONAL,
         "pf.ID", "/pos pf, pf.positions.values pos");
     String queries2[] = { "SELECT DISTINCT * FROM /pos pf,  positions.values pos where pf.status='active' and pos.secId= 'IBM' and ID = 0"};
     for (int i = 0; i < queries.length; i++) {
       Query q = null;
       try {
         q = CacheUtils.getQueryService().newQuery(queries[i]);
         QueryObserverImpl observer2 = new QueryObserverImpl();
         QueryObserverHolder.setInstance(observer2);
         sr[i][1] = (SelectResults)q.execute();

         if (observer2.isIndexesUsed == true) {
           CacheUtils.log("YES INDEX IS USED!");
         } else {
           fail("Index NOT Used");
         }
         //        CacheUtils.log(Utils.printResult(r2));
         resType2 = (StructType) (sr[i][1]).getCollectionType()
             .getElementType();
         resSize2 = ((sr[i][1]).size());
         //         CacheUtils.log(resType2);
         strg2 = resType2.getFieldNames();
         //         CacheUtils.log(strg2[0]);
         //         CacheUtils.log(strg2[1]);
         set2 = ((sr[i][1]).asSet());
         Iterator iter = set2.iterator();
         while (iter.hasNext()) {
           Struct stc2 = (Struct) iter.next();
           valPf2 = stc2.get(strg2[0]);
           valPos2 = stc2.get(strg2[1]);
           isActive2 = ((Portfolio) stc2.get(strg2[0])).isActive();
           //        CacheUtils.log(valPf2);
           //        CacheUtils.log(valPos2);
         }
       } catch (Exception e) {
         e.printStackTrace();
         fail(q.getQueryString());
       }
     }
     // BUG FIXED: Types are not Equal in both the cases as when Indexes are used the
     // Iterator Names
     //       are getting Overwritten as iter1,iter2 and so on instead of the complied
     // values of the iterator names used in the Query.
     if ((resType1).equals(resType2)){
       CacheUtils.log("Both Search Results are of the same Type i.e.-->"+resType1);
     }else {
       fail("FAILED:Search result Type is different in both the cases");
     }
     if (resSize1 == resSize2 || resSize1 != 0 ) {
       CacheUtils.log("Both Search Results are Non zero and are of Same Size i.e.  Size= "
           + resSize1);
     } else {
       fail("FAILED:Search result Type is different in both the cases");
     }
     itert2 = set2.iterator();
     itert1 = set1.iterator();
     while (itert1.hasNext()) {
       Struct stc2 = (Struct) itert2.next();
       Struct stc1 = (Struct) itert1.next();
       if (stc2.get(strg2[0]) != stc1.get(strg1[0]))
         fail("FAILED: In both the Cases the first member of StructSet i.e. Portfolio are different. ");
       if (stc2.get(strg2[1]) != stc1.get(strg1[1]))
         fail("FAILED: In both the cases Positions are different");
       if (((Position) stc2.get(strg2[1])).secId != ((Position) stc1
           .get(strg1[1])).secId)
         fail("FAILED: In both the cases Positions secIds are different");
       if (((Portfolio) stc2.get(strg2[0])).isActive() != ((Portfolio) stc1
           .get(strg1[0])).isActive())
         fail("FAILED: Status of the Portfolios found are different");
       if (((Portfolio) stc2.get(strg2[0])).getID() != ((Portfolio) stc1
           .get(strg1[0])).getID())
         fail("FAILED: IDs of the Portfolios found are different");
     }
     CacheUtils.compareResultsOfWithAndWithoutIndex(sr, this);
   }

   class QueryObserverImpl extends QueryObserverAdapter {

     boolean isIndexesUsed = false;
     ArrayList indexesUsed = new ArrayList();

     public void beforeIndexLookup(Index index, int oper, Object key) {
       indexesUsed.add(index.getName());
     }

     public void afterIndexLookup(Collection results) {
       if (results != null) {
         isIndexesUsed = true;
       }
     }
   }
 }
	/*=========================================================================
	* Copyright (c) 2010-2014 Pivotal Software, Inc. All Rights Reserved.
	* This product is protected by U.S. and international copyright
	* and intellectual property laws. Pivotal products are covered by
	* one or more patents listed at http://www.pivotal.io/patents.
	*=========================================================================
	*/
	/*
	* IumMultConditionJUnitTest.java
	* @author vikramj
	* Created on April 29, 2005, 2:30 PM
	*Task IUM 5 And IUM 6
	*/
	// @Task IUM6: To Test Task IUM6 Comment the index2 abd run the test.
	// Presently the Test Fails for IUM6 and Exeption occurs:
	// Index not found : java.lang.IllegalArgumentException: use a StructSet
	// instead
	package com.gemstone.gemfire.cache.query.functional;

	import static org.junit.Assert.fail;

	import java.util.ArrayList;
	import java.util.Collection;
	import java.util.Iterator;
	import java.util.Set;

	import org.junit.After;
	import org.junit.Before;
	import org.junit.Test;
	import org.junit.experimental.categories.Category;

	import com.gemstone.gemfire.cache.Region;
	import com.gemstone.gemfire.cache.query.CacheUtils;
	import com.gemstone.gemfire.cache.query.Index;
	import com.gemstone.gemfire.cache.query.IndexType;
	import com.gemstone.gemfire.cache.query.Query;
	import com.gemstone.gemfire.cache.query.QueryService;
	import com.gemstone.gemfire.cache.query.SelectResults;
	import com.gemstone.gemfire.cache.query.Struct;
	import com.gemstone.gemfire.cache.query.data.Portfolio;
	import com.gemstone.gemfire.cache.query.data.Position;
	import com.gemstone.gemfire.cache.query.internal.QueryObserverAdapter;
	import com.gemstone.gemfire.cache.query.internal.QueryObserverHolder;
	import com.gemstone.gemfire.cache.query.types.StructType;
	import com.gemstone.gemfire.test.junit.categories.IntegrationTest;

	@Category(IntegrationTest.class)
	public class IumMultConditionJUnitTest {

	StructType resType1 = null;
	StructType resType2 = null;
	String[] strg1 = null;
	String[] strg2 = null;
	int resSize1 = 0;
	int resSize2 = 0;
	Object valPf1 = null;
	Object valPos1 = null;
	Object valPf2 = null;
	Object valPos2 = null;
	Iterator itert1 = null;
	Iterator itert2 = null;
	Set set1 = null;
	Set set2 = null;
	boolean isActive1 = false;
	boolean isActive2 = false;

	@Before
	public void setUp() throws java.lang.Exception {
	CacheUtils.startCache();
	}

	@After
	public void tearDown() throws java.lang.Exception {
	CacheUtils.closeCache();
	}

	@Test
	public void testComparisonBetnWithAndWithoutIndexCreation() throws Exception {
	Region region = CacheUtils.createRegion("pos", Portfolio.class);
	for (int i = 0; i < 4; i++) {
	region.put("" + i, new Portfolio(i));
	}
	QueryService qs;
	qs = CacheUtils.getQueryService();
	String queries[] = { "SELECT DISTINCT * FROM /pos pf, positions.values pos where pf.status='active' and pos.secId= 'IBM' and ID = 0"};
	SelectResults sr[][] = new SelectResults[queries.length][2];

	for (int i = 0; i < queries.length; i++) {
	Query q = null;
	try {
	q = CacheUtils.getQueryService().newQuery(queries[i]);
	QueryObserverImpl observer = new QueryObserverImpl();
	QueryObserverHolder.setInstance(observer);
	sr[i][0] = (SelectResults) q.execute();

	if (!observer.isIndexesUsed) {
	CacheUtils.log("NO INDEX USED");
	}else {
	fail ("Indexes used !!!!?");
	}
	// CacheUtils.log(Utils.printResult(r));
	resType1 = (StructType) (sr[i][0]).getCollectionType()
	.getElementType();
	resSize1 = ((sr[i][0]).size());
	// CacheUtils.log(resType1);
	strg1 = resType1.getFieldNames();
	// CacheUtils.log(strg1[0]);
	// CacheUtils.log(strg1[1]);
	set1 = ((sr[i][0]).asSet());
	Iterator iter = set1.iterator();
	while (iter.hasNext()) {
	Struct stc1 = (Struct) iter.next();
	valPf1 = stc1.get(strg1[0]);
	valPos1 = stc1.get(strg1[1]);
	isActive1 = ((Portfolio) stc1.get(strg1[0])).isActive();
	// CacheUtils.log(isActive1);
	// CacheUtils.log(valPf1);
	// CacheUtils.log(valPos1);
	}
	} catch (Exception e) {
	e.printStackTrace();
	fail(q.getQueryString());
	}
	}
	// Create an Index on status and execute the same query again.
	qs = CacheUtils.getQueryService();
	qs.createIndex("statusIndex", IndexType.FUNCTIONAL,
	"pf.status", "/pos pf, pf.positions.values pos");
	// Index index2 = (Index)qs.createIndex("secIdIndex",
	// IndexType.FUNCTIONAL,"pos.secId","/pos pf, pf.positions.values pos");
	qs.createIndex("IDIndex", IndexType.FUNCTIONAL,
	"pf.ID", "/pos pf, pf.positions.values pos");
	String queries2[] = { "SELECT DISTINCT * FROM /pos pf, positions.values pos where pf.status='active' and pos.secId= 'IBM' and ID = 0"};
	for (int i = 0; i < queries.length; i++) {
	Query q = null;
	try {
	q = CacheUtils.getQueryService().newQuery(queries[i]);
	QueryObserverImpl observer2 = new QueryObserverImpl();
	QueryObserverHolder.setInstance(observer2);
	sr[i][1] = (SelectResults)q.execute();

	if (observer2.isIndexesUsed == true) {
	CacheUtils.log("YES INDEX IS USED!");
	} else {
	fail("Index NOT Used");
	}
	// CacheUtils.log(Utils.printResult(r2));
	resType2 = (StructType) (sr[i][1]).getCollectionType()
	.getElementType();
	resSize2 = ((sr[i][1]).size());
	// CacheUtils.log(resType2);
	strg2 = resType2.getFieldNames();
	// CacheUtils.log(strg2[0]);
	// CacheUtils.log(strg2[1]);
	set2 = ((sr[i][1]).asSet());
	Iterator iter = set2.iterator();
	while (iter.hasNext()) {
	Struct stc2 = (Struct) iter.next();
	valPf2 = stc2.get(strg2[0]);
	valPos2 = stc2.get(strg2[1]);
	isActive2 = ((Portfolio) stc2.get(strg2[0])).isActive();
	// CacheUtils.log(valPf2);
	// CacheUtils.log(valPos2);
	}
	} catch (Exception e) {
	e.printStackTrace();
	fail(q.getQueryString());
	}
	}
	// BUG FIXED: Types are not Equal in both the cases as when Indexes are used the
	// Iterator Names
	// are getting Overwritten as iter1,iter2 and so on instead of the complied
	// values of the iterator names used in the Query.
	if ((resType1).equals(resType2)){
	CacheUtils.log("Both Search Results are of the same Type i.e.-->"+resType1);
	}else {
	fail("FAILED:Search result Type is different in both the cases");
	}
	if (resSize1 == resSize2 \|\| resSize1 != 0 ) {
	CacheUtils.log("Both Search Results are Non zero and are of Same Size i.e. Size= "
	+ resSize1);
	} else {
	fail("FAILED:Search result Type is different in both the cases");
	}
	itert2 = set2.iterator();
	itert1 = set1.iterator();
	while (itert1.hasNext()) {
	Struct stc2 = (Struct) itert2.next();
	Struct stc1 = (Struct) itert1.next();
	if (stc2.get(strg2[0]) != stc1.get(strg1[0]))
	fail("FAILED: In both the Cases the first member of StructSet i.e. Portfolio are different. ");
	if (stc2.get(strg2[1]) != stc1.get(strg1[1]))
	fail("FAILED: In both the cases Positions are different");
	if (((Position) stc2.get(strg2[1])).secId != ((Position) stc1
	.get(strg1[1])).secId)
	fail("FAILED: In both the cases Positions secIds are different");
	if (((Portfolio) stc2.get(strg2[0])).isActive() != ((Portfolio) stc1
	.get(strg1[0])).isActive())
	fail("FAILED: Status of the Portfolios found are different");
	if (((Portfolio) stc2.get(strg2[0])).getID() != ((Portfolio) stc1
	.get(strg1[0])).getID())
	fail("FAILED: IDs of the Portfolios found are different");
	}
	CacheUtils.compareResultsOfWithAndWithoutIndex(sr, this);
	}

	class QueryObserverImpl extends QueryObserverAdapter {

	boolean isIndexesUsed = false;
	ArrayList indexesUsed = new ArrayList();

	public void beforeIndexLookup(Index index, int oper, Object key) {
	indexesUsed.add(index.getName());
	}

	public void afterIndexLookup(Collection results) {
	if (results != null) {
	isIndexesUsed = true;
	}
	}
	}
	}