| /*========================================================================= |
| * 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. |
| *========================================================================= |
| */ |
| /* |
| * Created on Dec 12, 2005 |
| * |
| * TODO To change the template for this generated file go to |
| * Window - Preferences - Java - Code Style - Code Templates |
| */ |
| package com.gemstone.gemfire.cache.query.internal; |
| |
| import static org.junit.Assert.assertTrue; |
| import static org.junit.Assert.fail; |
| |
| import java.util.Collection; |
| import java.util.HashSet; |
| 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.data.Address; |
| import com.gemstone.gemfire.cache.query.data.Employee; |
| import com.gemstone.gemfire.cache.query.data.Portfolio; |
| import com.gemstone.gemfire.cache.query.internal.index.IndexManager; |
| import com.gemstone.gemfire.internal.cache.LocalRegion; |
| import com.gemstone.gemfire.test.junit.categories.IntegrationTest; |
| |
| /** |
| * @author ashahid |
| * |
| * |
| */ |
| @Category(IntegrationTest.class) |
| public class QueryObserverCallbackJUnitTest{ |
| |
| Region region; |
| QueryService qs; |
| |
| @Before |
| public void setUp() throws Exception { |
| CacheUtils.startCache(); |
| region = CacheUtils.createRegion("portfolio",Portfolio.class); |
| region.put("0",new Portfolio(0)); |
| region.put("1",new Portfolio(1)); |
| region.put("2",new Portfolio(2)); |
| region.put("3",new Portfolio(3)); |
| |
| qs = CacheUtils.getQueryService(); |
| |
| } |
| |
| @After |
| public void tearDown() throws Exception { |
| CacheUtils.closeCache(); |
| IndexManager indexManager = ((LocalRegion)region).getIndexManager(); |
| if(indexManager != null ) |
| indexManager.destroy(); |
| } |
| |
| @Test |
| public void testBeforeAndAfterCartesianOfGroupJunctionsInAnAllGroupJunctionOfType_AND() { |
| try { |
| Region r3 = CacheUtils.createRegion("employees", Employee.class); |
| Set add1 = new HashSet(); |
| add1.add(new Address("411045", "Baner")); |
| add1.add(new Address("411001", "DholePatilRd")); |
| for (int i = 0; i < 4; i++) { |
| r3.put(i + "", new Employee("empName", (20 + i), i, "Mr.", (5000 + i), |
| add1)); |
| } |
| Region r4 = CacheUtils.createRegion("portfolio1", Portfolio.class); |
| for (int i = 0; i < 4; i++) { |
| r4.put(i + "", new Portfolio(i)); |
| } |
| Query query = qs.newQuery("select distinct * from /portfolio p, p.positions,/employees e, /portfolio1 p1 where p.ID = 1 and p1.ID = 2 and e.empId = 1"); |
| qs.createIndex("statusIndex", IndexType.FUNCTIONAL, "status", |
| "/portfolio"); |
| qs.createIndex("idIndex", IndexType.FUNCTIONAL, "ID", "/portfolio"); |
| qs.createIndex("idIndex1", IndexType.FUNCTIONAL, "ID", "/portfolio1"); |
| qs.createIndex("empidIndex", IndexType.FUNCTIONAL, "empId", "/employees"); |
| MyQueryObserverImpl inst = new MyQueryObserverImpl(); |
| QueryObserverHolder.setInstance(inst); |
| query.execute(); |
| assertTrue("beforeCartesianOfGroupJunctionsInAnAllGroupJunctionOfType_AND callbak not received",inst.bfrCartesianOfGroupJunctionsInAnAllGroupJunctionOfType_AND); |
| assertTrue("afterCartesianOfGroupJunctionsInAnAllGroupJunctionOfType_AND callbak not received",inst.aftCartesianOfGroupJunctionsInAnAllGroupJunctionOfType_AND); |
| |
| }catch(Exception e) { |
| e.printStackTrace(); |
| fail(e.toString()); |
| } |
| } |
| |
| @Test |
| public void testBeforeAndAfterCartesianOfCompositeGroupJunctionsInAnAllGroupJunctionOfType_AND() { |
| try { |
| Region r3 = CacheUtils.createRegion("employees", Employee.class); |
| Set add1 = new HashSet(); |
| add1.add(new Address("411045", "Baner")); |
| add1.add(new Address("411001", "DholePatilRd")); |
| for (int i = 0; i < 4; i++) { |
| r3.put(i + "", new Employee("empName", (20 + i), i, "Mr.", (5000 + i), |
| add1)); |
| } |
| Region r4 = CacheUtils.createRegion("portfolio1", Portfolio.class); |
| for (int i = 0; i < 4; i++) { |
| r4.put(i + "", new Portfolio(i)); |
| } |
| Query query = qs.newQuery("select distinct * from /portfolio p, p.positions,/employees e, /portfolio1 p1 where p.ID =p1.ID and e.empId = 1 and p1.status = 'active' and p.status='active' "); |
| qs.createIndex("statusIndex1", IndexType.FUNCTIONAL, "status", |
| "/portfolio"); |
| qs.createIndex("statusIndex2", IndexType.FUNCTIONAL, "status", |
| "/portfolio1"); |
| qs.createIndex("idIndex", IndexType.FUNCTIONAL, "ID", "/portfolio"); |
| qs.createIndex("idIndex1", IndexType.FUNCTIONAL, "ID", "/portfolio1"); |
| qs.createIndex("empidIndex", IndexType.FUNCTIONAL, "empId", "/employees"); |
| MyQueryObserverImpl inst = new MyQueryObserverImpl(); |
| QueryObserverHolder.setInstance(inst); |
| query.execute(); |
| assertTrue("beforeCartesianOfCompositeGroupJunctionsInAnAllGroupJunctionOfType_AND callbak not received",inst.bfrCartesianOfGroupJunctionsInCompositeGroupJunctionOfType_AND); |
| assertTrue("afterCartesianOfCompositeGroupJunctionsInAnAllGroupJunctionOfType_AND callbak not received",inst.aftCartesianOfGroupJunctionsInCompositeGroupJunctionOfType_AND); |
| |
| }catch(Exception e) { |
| e.printStackTrace(); |
| fail(e.toString()); |
| } |
| } |
| @Test |
| public void testBeforeAndAfterCutDownAndExpansionOfSingleIndexResult( ){ |
| try { |
| Query query = qs.newQuery("select distinct * from /portfolio p, p.positions where p.ID = 1 "); |
| qs.createIndex("idIndex", IndexType.FUNCTIONAL, "ID", "/portfolio"); |
| MyQueryObserverImpl inst = new MyQueryObserverImpl(); |
| QueryObserverHolder.setInstance(inst); |
| query.execute(); |
| assertTrue("beforeCutDownAndExpansionOfSingleIndexResult callbak not received",inst.bfrCutDownAndExpansionOfSingleIndexResult); |
| assertTrue("afterCutDownAndExpansionOfSingleIndexResult callbak not received",inst.aftCutDownAndExpansionOfSingleIndexResult); |
| }catch(Exception e) { |
| e.printStackTrace(); |
| fail(e.toString()); |
| } |
| } |
| |
| @Test |
| public void testBeforeAndAfterMergeJoinOfDoubleIndexResults() { |
| try { |
| Region r3 = CacheUtils.createRegion("employees", Employee.class); |
| Set add1 = new HashSet(); |
| add1.add(new Address("411045", "Baner")); |
| add1.add(new Address("411001", "DholePatilRd")); |
| for (int i = 0; i < 4; i++) { |
| r3.put(i + "", new Employee("empName", (20 + i), i, "Mr.", (5000 + i), |
| add1)); |
| } |
| |
| Query query = qs.newQuery("select distinct * from /portfolio p, p.positions,/employees e where p.ID = e.empId "); |
| qs.createIndex("idIndex", IndexType.FUNCTIONAL, "ID", "/portfolio"); |
| qs.createIndex("empidIndex", IndexType.FUNCTIONAL, "empId", "/employees"); |
| MyQueryObserverImpl inst = new MyQueryObserverImpl(); |
| QueryObserverHolder.setInstance(inst); |
| query.execute(); |
| assertTrue("beforeMergeJoinOfDoubleIndexResults callbak not received",inst.bfrMergeJoinOfDoubleIndexResults); |
| assertTrue("afterMergeJoinOfDoubleIndexResults callbak not received",inst.aftMergeJoinOfDoubleIndexResults); |
| |
| }catch(Exception e) { |
| e.printStackTrace(); |
| fail(e.toString()); |
| } |
| } |
| @Test |
| public void testBeforeAndAfterIterJoinOfSingleIndexResults() { |
| try { |
| Region r3 = CacheUtils.createRegion("employees", Employee.class); |
| Set add1 = new HashSet(); |
| add1.add(new Address("411045", "Baner")); |
| add1.add(new Address("411001", "DholePatilRd")); |
| for (int i = 0; i < 4; i++) { |
| r3.put(i + "", new Employee("empName", (20 + i), i, "Mr.", (5000 + i), |
| add1)); |
| } |
| Region r4 = CacheUtils.createRegion("portfolio1", Portfolio.class); |
| for (int i = 0; i < 4; i++) { |
| r4.put(i + "", new Portfolio(i)); |
| } |
| Query query = qs.newQuery("select distinct * from /portfolio p, p.positions,/employees e, /portfolio1 p1 where p.ID =p1.ID and e.empId = p1.ID "); |
| |
| qs.createIndex("idIndex", IndexType.FUNCTIONAL, "ID", "/portfolio"); |
| qs.createIndex("idIndex1", IndexType.FUNCTIONAL, "ID", "/portfolio1"); |
| qs.createIndex("empidIndex", IndexType.FUNCTIONAL, "empId", "/employees"); |
| MyQueryObserverImpl inst = new MyQueryObserverImpl(); |
| QueryObserverHolder.setInstance(inst); |
| query.execute(); |
| assertTrue("beforeIterJoinOfSingleIndexResults callbak not received",inst.bfrIterJoinOfSingleIndexResults); |
| assertTrue("afterIterJoinOfSingleIndexResults callbak not received",inst.aftIterJoinOfSingleIndexResults); |
| assertTrue("Validate callback of Indexes",inst.dbIndx[2] == inst.usedIndx); |
| assertTrue("Validate callback of Indexes",inst.unusedIndx == inst.dbIndx[0] || inst.unusedIndx == inst.dbIndx[1]); |
| |
| }catch(Exception e) { |
| e.printStackTrace(); |
| fail(e.toString()); |
| } |
| } |
| |
| @Test |
| public void testBeforeRangeJunctionDoubleConditionLookup() { |
| try { |
| Region r3 = CacheUtils.createRegion("employees", Employee.class); |
| Set add1 = new HashSet(); |
| add1.add(new Address("411045", "Baner")); |
| add1.add(new Address("411001", "DholePatilRd")); |
| for (int i = 0; i < 4; i++) { |
| r3.put(i + "", new Employee("empName", (20 + i), i, "Mr.", (5000 + i), |
| add1)); |
| } |
| Region r4 = CacheUtils.createRegion("portfolio1", Portfolio.class); |
| for (int i = 0; i < 4; i++) { |
| r4.put(i + "", new Portfolio(i)); |
| } |
| Query query = qs.newQuery("select distinct * from /portfolio p where p.ID > 1 and p.ID < 3 "); |
| |
| qs.createIndex("idIndex", IndexType.FUNCTIONAL, "ID", "/portfolio"); |
| qs.createIndex("idIndex1", IndexType.FUNCTIONAL, "ID", "/portfolio1"); |
| qs.createIndex("empidIndex", IndexType.FUNCTIONAL, "empId", "/employees"); |
| MyQueryObserverImpl inst = new MyQueryObserverImpl(); |
| QueryObserverHolder.setInstance(inst); |
| query.execute(); |
| assertTrue("beforeIndexLookup For RangeJunction.DoubleCondnRangeJunctionEvaluator not invoked",inst.beforeRangeJunctionDoubleCondnIndexLookup); |
| |
| }catch(Exception e) { |
| e.printStackTrace(); |
| fail(e.toString()); |
| } |
| } |
| class MyQueryObserverImpl implements QueryObserver { |
| |
| boolean aftCartesianOfGroupJunctionsInAnAllGroupJunctionOfType_AND = false; |
| boolean bfrCartesianOfGroupJunctionsInAnAllGroupJunctionOfType_AND = false; |
| boolean bfrCartesianOfGroupJunctionsInCompositeGroupJunctionOfType_AND = false; |
| boolean aftCartesianOfGroupJunctionsInCompositeGroupJunctionOfType_AND = false; |
| boolean bfrCutDownAndExpansionOfSingleIndexResult = false; |
| boolean aftCutDownAndExpansionOfSingleIndexResult = false; |
| boolean bfrMergeJoinOfDoubleIndexResults = false; |
| boolean aftMergeJoinOfDoubleIndexResults = false; |
| boolean bfrIterJoinOfSingleIndexResults = false; |
| boolean aftIterJoinOfSingleIndexResults = false; |
| boolean beforeRangeJunctionDoubleCondnIndexLookup = false; |
| Index usedIndx = null; |
| Index unusedIndx = null; |
| int j= 0; |
| Index[] dbIndx= new Index[3]; |
| |
| public void beforeIndexLookup(Index index, int oper, Object key) { |
| dbIndx[j++ ] = index; |
| if(j == 3)j = 0; |
| } |
| |
| |
| public void startQuery(Query query) { |
| |
| |
| } |
| |
| public void beforeQueryEvaluation(CompiledValue expression, ExecutionContext context) { |
| |
| |
| } |
| |
| |
| public void startIteration(Collection collection, CompiledValue whereClause) { |
| |
| } |
| |
| public void beforeIterationEvaluation(CompiledValue executer, Object currentObject) { |
| |
| |
| } |
| |
| public void afterIterationEvaluation(Object result) { |
| |
| |
| } |
| |
| public void endIteration(SelectResults results) { |
| |
| } |
| |
| public void afterIndexLookup(Collection results) { |
| |
| } |
| |
| public void afterQueryEvaluation(Object result) { |
| |
| } |
| |
| public void endQuery() { |
| |
| } |
| |
| |
| public void beforeRerunningIndexCreationQuery() { |
| |
| |
| } |
| |
| |
| public void beforeCartesianOfGroupJunctionsInAnAllGroupJunctionOfType_AND(Collection[] grpResults) { |
| bfrCartesianOfGroupJunctionsInAnAllGroupJunctionOfType_AND = true; |
| |
| } |
| |
| |
| public void afterCartesianOfGroupJunctionsInAnAllGroupJunctionOfType_AND() { |
| aftCartesianOfGroupJunctionsInAnAllGroupJunctionOfType_AND = true; |
| |
| } |
| |
| |
| public void beforeCartesianOfGroupJunctionsInCompositeGroupJunctionOfType_AND(Collection[] grpResults) { |
| bfrCartesianOfGroupJunctionsInCompositeGroupJunctionOfType_AND = true; |
| |
| } |
| |
| |
| public void afterCartesianOfGroupJunctionsInCompositeGroupJunctionOfType_AND() { |
| aftCartesianOfGroupJunctionsInCompositeGroupJunctionOfType_AND = true; |
| |
| } |
| |
| |
| public void beforeCutDownAndExpansionOfSingleIndexResult(Index index, Collection initialResult) { |
| bfrCutDownAndExpansionOfSingleIndexResult = true; |
| |
| } |
| |
| |
| public void afterCutDownAndExpansionOfSingleIndexResult(Collection finalResult) { |
| aftCutDownAndExpansionOfSingleIndexResult= true; |
| |
| } |
| |
| |
| public void beforeMergeJoinOfDoubleIndexResults(Index index1, Index index2, Collection initialResult) { |
| bfrMergeJoinOfDoubleIndexResults= true; |
| |
| } |
| |
| |
| public void afterMergeJoinOfDoubleIndexResults(Collection finalResult) { |
| aftMergeJoinOfDoubleIndexResults = true; |
| |
| } |
| |
| |
| public void beforeIterJoinOfSingleIndexResults(Index usedIndex, Index unusedIndex) { |
| bfrIterJoinOfSingleIndexResults = true; |
| this.usedIndx = usedIndex; |
| this.unusedIndx = unusedIndex; |
| |
| } |
| |
| |
| public void afterIterJoinOfSingleIndexResults(Collection finalResult) { |
| aftIterJoinOfSingleIndexResults = true; |
| |
| } |
| |
| |
| /* (non-Javadoc) |
| * @see com.gemstone.gemfire.cache.query.internal.QueryObserver#beforeIndexLookup(com.gemstone.gemfire.cache.query.Index, int, java.lang.Object, int, java.lang.Object, java.util.Set) |
| */ |
| public void beforeIndexLookup(Index index, int lowerBoundOperator, |
| Object lowerBoundKey, int upperBoundOperator, Object upperBoundKey, |
| Set NotEqualKeys) { |
| beforeRangeJunctionDoubleCondnIndexLookup = true; |
| } |
| |
| |
| public void beforeApplyingProjectionOnFilterEvaluatedResults(Object preProjectionAppliedResult) |
| { |
| |
| } |
| |
| |
| public void invokedQueryUtilsIntersection(SelectResults sr1, SelectResults sr2) |
| { |
| } |
| |
| |
| public void invokedQueryUtilsUnion(SelectResults sr1, SelectResults sr2) |
| { |
| } |
| |
| public void limitAppliedAtIndexLevel(Index index, int limit , Collection indexResult) |
| { |
| } |
| |
| public void orderByColumnsEqual() { |
| |
| } |
| |
| } |
| } |
