| /*========================================================================= |
| * 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. |
| *========================================================================= |
| */ |
| /* |
| * MiscJUnitTest.java |
| * JUnit based test |
| * |
| * Created on March 10, 2005, 6:36 PM |
| */ |
| package com.gemstone.gemfire.cache.query.functional; |
| |
| import com.gemstone.gemfire.cache.query.*; |
| import com.gemstone.gemfire.cache.AttributesFactory; |
| import com.gemstone.gemfire.cache.Cache; |
| import com.gemstone.gemfire.cache.CacheWriterException; |
| import com.gemstone.gemfire.cache.PartitionAttributes; |
| import com.gemstone.gemfire.cache.PartitionAttributesFactory; |
| import com.gemstone.gemfire.cache.Region; |
| import com.gemstone.gemfire.cache.RegionAttributes; |
| import com.gemstone.gemfire.cache.TimeoutException; |
| import com.gemstone.gemfire.cache.query.CacheUtils; |
| import com.gemstone.gemfire.cache.query.FunctionDomainException; |
| import com.gemstone.gemfire.cache.query.Index; |
| import com.gemstone.gemfire.cache.query.IndexType; |
| import com.gemstone.gemfire.cache.query.NameResolutionException; |
| import com.gemstone.gemfire.cache.query.Query; |
| import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; |
| 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.TypeMismatchException; |
| import com.gemstone.gemfire.cache.query.data.Data; |
| import com.gemstone.gemfire.cache.query.data.Portfolio; |
| |
| //import com.gemstone.gemfire.cache.query.facets.lang.Employee; |
| import com.gemstone.gemfire.cache.query.types.StructType; |
| import com.gemstone.gemfire.test.junit.categories.IntegrationTest; |
| |
| import java.util.Collection; |
| import java.util.Iterator; |
| import java.util.List; |
| |
| import org.junit.After; |
| import org.junit.Before; |
| import org.junit.Test; |
| import org.junit.experimental.categories.Category; |
| |
| import parReg.query.unittest.NewPortfolio; |
| import static org.junit.Assert.*; |
| import junit.framework.*; |
| |
| /** |
| * @author vaibhav |
| * @author Asif |
| */ |
| @Category(IntegrationTest.class) |
| public class MiscJUnitTest { |
| |
| @Before |
| public void setUp() throws java.lang.Exception { |
| CacheUtils.startCache(); |
| } |
| |
| @After |
| public void tearDown() throws java.lang.Exception { |
| CacheUtils.closeCache(); |
| } |
| |
| public void xtestNestQueryInFromClause() throws Exception { |
| Region region = CacheUtils.createRegion("Portfolios", 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)); |
| Query query = CacheUtils.getQueryService().newQuery( |
| "SELECT DISTINCT * FROM (SELECT DISTINCT * FROM /Portfolios where status = 'active') p where p.ID = 0"); |
| // DebuggerSupport.waitForJavaDebugger(CacheUtils.getLogger()); |
| Collection result = (Collection) query.execute(); |
| Portfolio p = (Portfolio) (result.iterator().next()); |
| if (!p.status.equals("active") || p.getID() != 0) fail(query.getQueryString()); |
| } |
| |
| public void xtestNestQueryInWhereClause() throws Exception { |
| Region region = CacheUtils.createRegion("Portfolios", 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)); |
| Query query = CacheUtils |
| .getQueryService() |
| .newQuery( |
| "SELECT DISTINCT * FROM /Portfolios WHERE NOT (SELECT DISTINCT * FROM positions.values p WHERE p.secId = 'IBM').isEmpty"); |
| Collection result = (Collection) query.execute(); |
| Portfolio p = (Portfolio) (result.iterator().next()); |
| if (!p.positions.containsKey("IBM")) fail(query.getQueryString()); |
| //query = CacheUtils.getQueryService().newQuery("SELECT DISTINCT * FROM |
| // /Portfolios where status = ELEMENT(SELECT DISTINCT * FROM /Portfolios p |
| // where p.ID = 0).status"); |
| //result = (Collection)query.execute(); |
| //CacheUtils.log(result); |
| //query = CacheUtils.getQueryService().newQuery("SELECT DISTINCT * FROM |
| // /Portfolios x where status = ELEMENT(SELECT DISTINCT * FROM /Portfolios |
| // p where p.ID = x.ID).status"); |
| //result = (Collection)query.execute(); |
| //SELECT DISTINCT * FROM /Portfolios where status = ELEMENT(SELECT |
| // DISTINCT * FROM /Portfolios where ID = 0).status |
| //SELECT DISTINCT * FROM /Portfolios x where status = ELEMENT(SELECT |
| // DISTINCT * FROM /Portfolios p where p.ID = x.ID).status |
| } |
| |
| public void xtestVoidMethods() throws Exception { |
| Region region = CacheUtils.createRegion("Data", Data.class); |
| region.put("0", new Data()); |
| Query query = CacheUtils.getQueryService().newQuery("SELECT DISTINCT * FROM /Data where voidMethod"); |
| Collection result = (Collection) query.execute(); |
| if (result.size() != 0) fail(query.getQueryString()); |
| query = CacheUtils.getQueryService().newQuery("SELECT DISTINCT * FROM /Data where voidMethod = null "); |
| result = (Collection) query.execute(); |
| if (result.size() != 1) fail(query.getQueryString()); |
| } |
| |
| public void xtestMiscQueries() throws Exception { |
| String testData[] = { "NULL", "UNDEFINED"}; |
| for (int i = 0; i < testData.length; i++) { |
| Query query = CacheUtils.getQueryService().newQuery("SELECT DISTINCT * FROM " + testData[i]); |
| Object result = query.execute(); |
| if (!result.equals(QueryService.UNDEFINED)) fail(query.getQueryString()); |
| } |
| } |
| |
| public void xtestBug32763() throws FunctionDomainException, TypeMismatchException, NameResolutionException, |
| QueryInvocationTargetException, TimeoutException, CacheWriterException |
| { |
| Region region = CacheUtils.createRegion("pos", 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)); |
| QueryService qs = CacheUtils.getQueryService(); |
| String qStr = "SELECT DISTINCT key: key, iD: entry.value.iD, secId: posnVal.secId FROM /pos.entries entry, entry.value.positions.values posnVal WHERE entry.value.\"type\" = 'type0' AND posnVal.secId = 'YHOO'"; |
| Query q = qs.newQuery(qStr); |
| SelectResults result = (SelectResults) q.execute(); |
| StructType type = (StructType) result.getCollectionType().getElementType(); |
| String names[] = type.getFieldNames(); |
| List list = result.asList(); |
| if (list.size() < 1) fail("Test failed as the resultset's size is zero"); |
| for (int i = 0; i < list.size(); ++i) { |
| Struct stc = (Struct) list.get(i); |
| if (!stc.get(names[2]).equals("YHOO")) { |
| fail("Test failed as the SecID value is not YHOO"); |
| } |
| } |
| } |
| |
| @Test |
| public void testBug() throws TimeoutException, CacheWriterException, |
| FunctionDomainException, TypeMismatchException, NameResolutionException, QueryInvocationTargetException, Exception { |
| Region region = CacheUtils.createRegion("portfolios", 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)); |
| QueryService qs = CacheUtils.getQueryService(); |
| /*String qStr = "Select distinct structset.sos, structset.key " + |
| "from /portfolios pfos, pfos.positions.values outerPos, " + |
| "(SELECT DISTINCT key: key, sos: pos.sharesOutstanding "+ |
| "from /portfolios.entries pf, pf.value.positions.values pos " + |
| "where outerPos.secId != 'IBM' AND " + |
| "pf.key IN (select distinct * from pf.value.collectionHolderMap['0'].arr)) structset " + |
| "where structset.sos > 2000";*/ |
| |
| String qStr = "Select distinct * from /portfolios pf, pf.positions.values where status = 'active' and secId = 'IBM'"; |
| qs.createIndex("index1", IndexType.FUNCTIONAL, "status", "/portfolios pf"); |
| |
| qs.createIndex("index4", IndexType.FUNCTIONAL, "itr", "/portfolios pf, pf.collectionHolderMap chm, chm.value.arr itr"); |
| qs.createIndex("index2", IndexType.FUNCTIONAL, "status", "/portfolios pf, positions.values pos"); |
| qs.createIndex("index3", IndexType.FUNCTIONAL, "secId", "/portfolios pf, positions.values pos"); |
| qs.createIndex("index5", IndexType.FUNCTIONAL, "pos.secId", "/portfolios pf, pf.collectionHolderMap chm, chm.value.arr, pf.positions.values pos"); |
| qs.createIndex("index6", IndexType.FUNCTIONAL, "status", "/portfolios pf, pf.collectionHolderMap chm"); |
| qs.createIndex("index7", IndexType.FUNCTIONAL, "itr", "/portfolios pf, positions.values, pf.collectionHolderMap chm, chm.value.arr itr"); |
| Query q = qs.newQuery(qStr); |
| SelectResults result = (SelectResults) q.execute(); |
| if(result.size()==0) fail("Test failed as size is zero"); |
| |
| } |
| |
| @Test |
| public void testBug37723() { |
| Region region = CacheUtils.createRegion("portfolios", 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)); |
| QueryService qs = CacheUtils.getQueryService(); |
| String qry = "select distinct getID, status from /portfolios pf where getID < 10 order by getID desc"; |
| Query q = qs.newQuery(qry); |
| try { |
| SelectResults result = (SelectResults) q.execute(); |
| Iterator itr = result.iterator(); |
| int j = 3; |
| while ( itr.hasNext()) { |
| Struct struct = (Struct)itr.next(); |
| assertEquals(j--, ((Integer)struct.get("getID")).intValue()); |
| } |
| qry = "select distinct getID, status from /portfolios pf where getID < 10 order by getID asc"; |
| q = qs.newQuery(qry); |
| result = (SelectResults) q.execute(); |
| itr = result.iterator(); |
| j = 0; |
| while ( itr.hasNext()) { |
| Struct struct = (Struct)itr.next(); |
| assertEquals(j++, ((Integer)struct.get("getID")).intValue()); |
| } |
| } |
| catch (Exception e) { |
| e.printStackTrace(); |
| fail ("Test failed because of exception="+e); |
| } |
| } |
| |
| @Test |
| public void testBug40428_1() throws Exception { |
| Object shortData1 = new Object() { |
| public short shortField = 4; |
| }; |
| Object shortData2 = new Object() { |
| public short shortField = 5; |
| }; |
| Region region = CacheUtils.createRegion("shortFieldTest", Object.class); |
| region.put("0", shortData1); |
| QueryService qs = CacheUtils.getQueryService(); |
| String qry = "select * from /shortFieldTest sf where sf.shortField < 10 "; |
| qs.createIndex("shortIndex", IndexType.FUNCTIONAL, "shortField", |
| "/shortFieldTest"); |
| region.put("1", shortData2); |
| Query query = null; |
| Object result = null; |
| |
| query = qs.newQuery(qry); |
| |
| SelectResults rs = (SelectResults)query.execute(); |
| assertEquals(rs.size(), 2); |
| } |
| |
| @Test |
| public void testBug40428_2() throws Exception { |
| Object shortData1 = new Object() { |
| public short shortField = 4; |
| }; |
| Object shortData2 = new Object() { |
| public short shortField = 5; |
| }; |
| |
| Region region = CacheUtils.createRegion("shortFieldTest", Object.class); |
| region.put("0", shortData1); |
| QueryService qs = CacheUtils.getQueryService(); |
| String qry = "select * from /shortFieldTest.entries sf where sf.value.shortField < 10 "; |
| qs.createIndex("shortIndex", IndexType.FUNCTIONAL, "value.shortField", |
| "/shortFieldTest.entries"); |
| region.put("1", shortData2); |
| Query query = null; |
| Object result = null; |
| |
| query = qs.newQuery(qry); |
| |
| SelectResults rs = (SelectResults)query.execute(); |
| assertEquals(rs.size(), 2); |
| |
| } |
| |
| |
| |
| |
| @Test |
| public void testMultipleOrderByClauses() { |
| Region region = CacheUtils.createRegion("portfolios", Portfolio.class); |
| region.put("2", new Portfolio(2)); |
| region.put("3", new Portfolio(3)); |
| region.put("4", new Portfolio(4)); |
| region.put("5", new Portfolio(5)); |
| region.put("6", new Portfolio(6)); |
| region.put("7", new Portfolio(7)); |
| QueryService qs = CacheUtils.getQueryService(); |
| String qry = "select distinct status, getID from /portfolios pf where getID < 10 order by status asc, getID desc"; |
| Query q = qs.newQuery(qry); |
| try { |
| SelectResults result = (SelectResults) q.execute(); |
| Iterator itr = result.iterator(); |
| int j = 6; |
| while ( itr.hasNext() && j >0) { |
| Struct struct = (Struct)itr.next(); |
| assertEquals("active", struct.get("status")); |
| assertEquals(j, ((Integer)struct.get("getID")).intValue()); |
| |
| j-=2; |
| } |
| j =7; |
| while ( itr.hasNext()) { |
| Struct struct = (Struct)itr.next(); |
| assertEquals(j, ((Integer)struct.get("getID")).intValue()); |
| assertEquals("inactive", struct.get("status")); |
| j-=2; |
| } |
| /* |
| qry = "select distinct getID, status from /portfolios pf where getID < 10 order by getID asc"; |
| q = qs.newQuery(qry); |
| result = (SelectResults) q.execute(); |
| itr = result.iterator(); |
| j = 0; |
| while ( itr.hasNext()) { |
| Struct struct = (Struct)itr.next(); |
| assertEquals(j++, ((Integer)struct.get("getID")).intValue()); |
| }*/ |
| } |
| catch (Exception e) { |
| e.printStackTrace(); |
| fail ("Test failed because of exception="+e); |
| } |
| } |
| |
| /** |
| * Tests the where clause formed with CompiledComparison nesting |
| * @throws Exception |
| */ |
| @Test |
| public void testBug40333_InLocalRegion_1() throws Exception { |
| CacheUtils.startCache(); |
| final Cache cache = CacheUtils.getCache(); |
| AttributesFactory attributesFactory = new AttributesFactory(); |
| RegionAttributes ra = attributesFactory.create(); |
| final Region region = cache.createRegion("new_pos", ra); |
| String queryStr = " select distinct r.name, pVal, r.\"type\" " |
| + " from /new_pos r , r.positions.values pVal where " |
| + " (r.name='name_11' OR r.name='name_12') AND pVal.mktValue >=1.00"; |
| this.bug40333Simulation(region,queryStr); |
| } |
| |
| /** |
| * Commented the test as it is for some reason causing OOM when run in the suite. |
| * It is due to presence of PR |
| * Tests the where clause formed with CompiledComparison nesting |
| * @throws Exception |
| */ |
| public void _testBug40333_InPartitionedRegion_1() throws Exception { |
| CacheUtils.startCache(); |
| final Cache cache = CacheUtils.getCache(); |
| AttributesFactory attributesFactory = new AttributesFactory(); |
| PartitionAttributesFactory paf = new PartitionAttributesFactory(); |
| paf.setTotalNumBuckets(10); |
| PartitionAttributes pa = paf.create(); |
| attributesFactory.setPartitionAttributes(pa); |
| RegionAttributes ra = attributesFactory.create(); |
| final Region region = cache.createRegion("new_pos", ra); |
| String queryStr = " select distinct r.name, pVal, r.\"type\" " |
| + " from /new_pos r , r.positions.values pVal where " |
| + " (r.name='name_11' OR r.name='name_12') AND pVal.mktValue < 1.00"; |
| this.bug40333Simulation(region,queryStr); |
| } |
| |
| /** |
| * Tests the where clause formed with CompiledComparison nesting with CompiledIN |
| * @throws Exception |
| */ |
| @Test |
| public void testBug40333_InLocalRegion_2() throws Exception { |
| CacheUtils.startCache(); |
| final Cache cache = CacheUtils.getCache(); |
| AttributesFactory attributesFactory = new AttributesFactory(); |
| RegionAttributes ra = attributesFactory.create(); |
| final Region region = cache.createRegion("new_pos", ra); |
| String queryStr = " select distinct r.name, pVal, r.\"type\" " |
| + " from /new_pos r , r.positions.values pVal where " |
| + " ( r.name IN Set('name_11' , 'name_12') OR false ) AND pVal.mktValue = 1.00"; |
| this.bug40333Simulation(region,queryStr); |
| } |
| |
| /** |
| * Commented the test as it is for some reason causing OOM when run in the suite. |
| * It is due to presence of PR |
| * Tests the where clause formed with CompiledComparison nesting with CompiledIN |
| * @throws Exception |
| */ |
| public void _testBug40333_InPartitionedRegion_2() throws Exception { |
| CacheUtils.startCache(); |
| final Cache cache = CacheUtils.getCache(); |
| AttributesFactory attributesFactory = new AttributesFactory(); |
| PartitionAttributesFactory paf = new PartitionAttributesFactory(); |
| paf.setTotalNumBuckets(10); |
| PartitionAttributes pa = paf.create(); |
| attributesFactory.setPartitionAttributes(pa); |
| RegionAttributes ra = attributesFactory.create(); |
| final Region region = cache.createRegion("new_pos", ra); |
| String queryStr = " select distinct r.name, pVal, r.\"type\" " |
| + " from /new_pos r , r.positions.values pVal where " |
| + " ( r.name IN Set('name_11' , 'name_12') OR false ) AND pVal.mktValue < 1.00"; |
| this.bug40333Simulation(region,queryStr); |
| } |
| |
| private void bug40333Simulation(final Region region, final String queryStr) throws Exception { |
| final QueryService qs = CacheUtils.getQueryService(); |
| Region rgn = CacheUtils.getRegion("/new_pos"); |
| for (int i = 1; i < 100; ++i) { |
| NewPortfolio pf = new NewPortfolio("name" + i, i); |
| rgn.put("name" + i, pf); |
| } |
| final Object lock = new Object(); |
| final boolean[] expectionOccured = new boolean[] { false }; |
| final boolean[] keepGoing = new boolean[] { true }; |
| |
| Thread indexCreatorDestroyer = new Thread(new Runnable() { |
| public void run() { |
| boolean continueRunning = true; |
| do { |
| |
| synchronized (lock) { |
| continueRunning = keepGoing[0]; |
| } |
| try { |
| Index indx1 = qs.createIndex("MarketValues", IndexType.FUNCTIONAL, |
| "itr2.mktValue", "/new_pos itr1, itr1.positions.values itr2"); |
| Index indx2 = qs.createIndex("Name", IndexType.FUNCTIONAL, |
| "itr1.name", "/new_pos itr1"); |
| Index indx3 = qs.createIndex("nameIndex", IndexType.PRIMARY_KEY, |
| "name", "/new_pos"); |
| Index indx4 = qs.createIndex("idIndex", IndexType.FUNCTIONAL, "id", |
| "/new_pos"); |
| Index indx5 = qs.createIndex("statusIndex", IndexType.FUNCTIONAL, |
| "status", "/new_pos"); |
| Index indx6 = qs.createIndex("undefinedFieldIndex", IndexType.FUNCTIONAL, |
| "undefinedTestField.toString", "/new_pos"); |
| Thread.sleep(800); |
| qs.removeIndex(indx1); |
| qs.removeIndex(indx2); |
| qs.removeIndex(indx3); |
| qs.removeIndex(indx4); |
| qs.removeIndex(indx5); |
| qs.removeIndex(indx6); |
| } catch (Throwable e) { |
| region.getCache().getLogger().error(e); |
| e.printStackTrace(); |
| synchronized (lock) { |
| expectionOccured[0] = true; |
| keepGoing[0] = false; |
| continueRunning = false; |
| } |
| |
| } |
| } while (continueRunning); |
| } |
| |
| }); |
| |
| indexCreatorDestroyer.start(); |
| final Query q = qs.newQuery(queryStr); |
| final int THREAD_COUNT = 10; |
| Thread queryThreads[] = new Thread[THREAD_COUNT]; |
| final int numTimesToRun =75; |
| for (int i = 0; i < THREAD_COUNT; ++i) { |
| queryThreads[i] = new Thread(new Runnable() { |
| public void run() { |
| boolean continueRunning = true; |
| for (int i = 0; i < numTimesToRun && continueRunning; ++i) { |
| synchronized(lock) { |
| continueRunning = keepGoing[0]; |
| } |
| try { |
| SelectResults sr = (SelectResults)q.execute(); |
| } catch (Throwable e) { |
| e.printStackTrace(); |
| region.getCache().getLogger().error(e); |
| synchronized (lock) { |
| expectionOccured[0] = true; |
| keepGoing[0] = false; |
| continueRunning = false; |
| } |
| break; |
| } |
| } |
| } |
| }); |
| } |
| synchronized (lock) { |
| assertFalse(expectionOccured[0]); |
| } |
| |
| for (int i = 0; i < THREAD_COUNT; ++i) { |
| queryThreads[i].start(); |
| } |
| |
| for (int i = 0; i < THREAD_COUNT; ++i) { |
| queryThreads[i].join(); |
| } |
| synchronized (lock) { |
| keepGoing[0] = false; |
| } |
| |
| indexCreatorDestroyer.join(); |
| synchronized (lock) { |
| assertFalse(expectionOccured[0]); |
| } |
| |
| } |
| |
| @Test |
| public void testBug40441() throws Exception { |
| CacheUtils.startCache(); |
| final Cache cache = CacheUtils.getCache(); |
| AttributesFactory attributesFactory = new AttributesFactory(); |
| RegionAttributes ra = attributesFactory.create(); |
| final Region region = cache.createRegion("new_pos", ra); |
| String queryStr1 = " select distinct r.name, pVal, r.\"type\" " |
| + " from /new_pos r , r.positions.values pVal where " |
| + " ( r.undefinedTestField.toString = UNDEFINED OR false ) ";//AND pVal.mktValue = 1.00"; |
| String queryStr2 = " select distinct r.name, pVal, r.\"type\" " |
| + " from /new_pos r , r.positions.values pVal where " |
| + " ( r.undefinedTestField.toString = UNDEFINED AND true ) AND pVal.mktValue = 1.00"; |
| final QueryService qs = CacheUtils.getQueryService(); |
| for (int i = 1; i < 100; ++i) { |
| NewPortfolio pf = new NewPortfolio("name" + i, i); |
| region.put("name" + i, pf); |
| } |
| |
| Index indx1 = qs.createIndex("MarketValues", IndexType.FUNCTIONAL, |
| "itr2.mktValue", "/new_pos itr1, itr1.positions.values itr2"); |
| Index indx2 = qs.createIndex("Name", IndexType.FUNCTIONAL, |
| "itr1.name", "/new_pos itr1"); |
| Index indx3 = qs.createIndex("nameIndex", IndexType.PRIMARY_KEY, |
| "name", "/new_pos"); |
| Index indx4 = qs.createIndex("idIndex", IndexType.FUNCTIONAL, "id", |
| "/new_pos"); |
| Index indx5 = qs.createIndex("statusIndex", IndexType.FUNCTIONAL, |
| "status", "/new_pos"); |
| Index indx6 = qs.createIndex("undefinedFieldIndex", IndexType.FUNCTIONAL, |
| "undefinedTestField.toString", "/new_pos"); |
| final Query q1 = qs.newQuery(queryStr1); |
| final Query q2 = qs.newQuery(queryStr2); |
| try { |
| SelectResults sr1 = (SelectResults)q1.execute(); |
| SelectResults sr2 = (SelectResults)q2.execute(); |
| }catch(Throwable e) { |
| e.printStackTrace(); |
| fail("Test failed due to = " +e.toString()); |
| } |
| } |
| |
| @Test |
| public void testBug37119() throws Exception { |
| Region region = CacheUtils.createRegion("portfolios", 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)); |
| region.put(Integer.MIN_VALUE+"", new Portfolio(Integer.MIN_VALUE)); |
| region.put("-1", new Portfolio(-1)); |
| QueryService qs = CacheUtils.getQueryService(); |
| |
| String qStr = "Select distinct * from /portfolios pf where pf.getID() = " + Integer.MIN_VALUE; |
| Query q = qs.newQuery(qStr); |
| SelectResults result = (SelectResults) q.execute(); |
| assertEquals(result.size(),1); |
| Portfolio pf = (Portfolio)result.iterator().next(); |
| assertEquals(pf.getID(),Integer.MIN_VALUE); |
| qStr = "Select distinct * from /portfolios pf where pf.getID() = -1"; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),1); |
| pf = (Portfolio)result.iterator().next(); |
| assertEquals(pf.getID(),-1); |
| |
| qStr = "Select distinct * from /portfolios pf where pf.getID() = 3 and pf.getLongMinValue() = " + Long.MIN_VALUE +'l'; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),1); |
| pf = (Portfolio)result.iterator().next(); |
| assertEquals(pf.getID(),3); |
| |
| qStr = "Select distinct * from /portfolios pf where pf.getID() = 3 and pf.getFloatMinValue() = " + Float.MIN_VALUE +'f'; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),1); |
| pf = (Portfolio)result.iterator().next(); |
| assertEquals(pf.getID(),3); |
| |
| qStr = "Select distinct * from /portfolios pf where pf.getID() = 3 and pf.getDoubleMinValue() = " + Double.MIN_VALUE; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),1); |
| pf = (Portfolio)result.iterator().next(); |
| assertEquals(pf.getID(),3); |
| } |
| |
| |
| /* |
| @Test |
| public void testBug37119() throws Exception { |
| Region region = CacheUtils.createRegion("portfolios", 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)); |
| QueryService qs = CacheUtils.getQueryService(); |
| |
| String qStr = "Select distinct * from /portfolios pf where pf.getID() > Integer.MIN_VALUE"; |
| Query q = qs.newQuery(qStr); |
| SelectResults result = (SelectResults) q.execute(); |
| assertEquals(result.size(),4); |
| |
| qStr = "Select distinct * from /portfolios pf where pf.getID() > Integer.MAX_VALUE"; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),0); |
| |
| qStr = "Select distinct * from /portfolios pf where pf.getID() > \"Long\".MAX_VALUE"; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),0); |
| |
| qStr = "Select distinct * from /portfolios pf where pf.getID() > \"Long\".MIN_VALUE"; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),4); |
| |
| qStr = "Select distinct * from /portfolios pf where pf.getID() > integer.MIN_VALUE"; |
| q = qs.newQuery(qStr); |
| try { |
| result = (SelectResults) q.execute(); |
| fail("Expected QueryException as integer.MIN_VALUE will not be resolved"); |
| }catch(TypeMismatchException tme) { |
| //Ok |
| } |
| |
| qStr = "Select distinct * from /portfolios pf where pf.intFunction(Integer.MIN_VALUE) = Integer.MIN_VALUE"; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),4); |
| |
| qStr = "Select distinct * from /portfolios pf where pf.intFunction(Integer.MAX_VALUE) = Integer.MAX_VALUE"; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),4); |
| |
| qStr = "Select distinct * from /portfolios pf where pf.longFunction( \"Long\".MAX_VALUE) = \"Long\".MAX_VALUE"; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),4); |
| |
| qStr = "Select distinct * from /portfolios pf where pf.longFunction(\"Long\".MIN_VALUE) = \"Long\".MIN_VALUE"; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),4); |
| |
| qStr = "Select distinct * from /portfolios pf where pf.Integer.MAX_VALUE = Integer.MAX_VALUE"; |
| q = qs.newQuery(qStr); |
| try { |
| result = (SelectResults) q.execute(); |
| fail("Query should have thrown Exception as attribute Integer.MAX_VALUE is not present"); |
| }catch(NameNotFoundException nfe) { |
| //Ok; |
| } |
| |
| qStr = "Select distinct Integer.MAX_VALUE from /portfolios pf where Integer.MAX_VALUE = Integer.MAX_VALUE"; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),1); |
| assertEquals(result.iterator().next(),Integer.valueOf(Integer.MAX_VALUE)); |
| |
| |
| } |
| |
| @Test |
| public void testBu37119_1() throws Exception { |
| Region region = CacheUtils.createRegion("tempdata",null); |
| region.put("1", new TempData1()); |
| QueryService qs = CacheUtils.getQueryService(); |
| |
| String qStr = "Select distinct * from /tempdata td where td.Integer.MAX_VALUE > Integer.MAX_VALUE"; |
| Query q = qs.newQuery(qStr); |
| SelectResults result = (SelectResults) q.execute(); |
| assertEquals(result.size(),0); |
| |
| qStr = "Select distinct * from /tempdata td where td.Integer.MAX_VALUE = 2 "; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),1); |
| |
| qStr = "Select distinct * from /tempdata td where Integer.MAX_VALUE = 2 "; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),0); |
| |
| qStr = "Select distinct * from /tempdata td where Integer.MAX_VALUE.intValue = Integer.MAX_VALUE "; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),0); |
| |
| qStr = "Select distinct * from /tempdata td where Integer.test = 'test'"; |
| q = qs.newQuery(qStr); |
| result = (SelectResults) q.execute(); |
| assertEquals(result.size(),1); |
| } |
| |
| |
| static class TempData1 { |
| public TempData2 Integer = new TempData2(); |
| |
| } |
| |
| static class TempData2 { |
| public Integer MAX_VALUE = new Integer(2); |
| public String test ="test"; |
| } */ |
| |
| } |
