gemfire-core/src/test/java/com/gemstone/gemfire/cache/query/functional/IteratorTypeDefaultTypesJUnitTest.java

/*=========================================================================
 * 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.
 *=========================================================================
 */
/*
 * IteratorTypeDefIntegerTest_vj.java
 *
 * Created on April 12, 2005, 3:52 PM
 */

/**
 *
 * @author vikramj
 */
package com.gemstone.gemfire.cache.query.functional;

import static org.junit.Assert.fail;

import java.util.ArrayList;
import java.util.HashSet;

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

import com.gemstone.gemfire.cache.query.CacheUtils;
import com.gemstone.gemfire.cache.query.Query;
import com.gemstone.gemfire.cache.query.SelectResults;
import com.gemstone.gemfire.cache.query.Utils;
import com.gemstone.gemfire.cache.query.data.Student;
import com.gemstone.gemfire.test.junit.categories.IntegrationTest;

@Category(IntegrationTest.class)
public class IteratorTypeDefaultTypesJUnitTest {

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

  }

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

  @Test
  public void testIteratorDefIntegerArray() throws Exception{
    Integer [] a =new Integer[2];
    for (int j=0;j<2;j++){
      a[j]=new Integer(j);
    }        
    Object params[]=new Object[1];
    params[0]= a;

    String queries[] = {
        "Select distinct intValue from $1 TYPE int",
        "Select distinct intValue from (array<int>) $1 "

    };
    for(int i=0;i<queries.length;i++){
      Query q= null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        if( rs.size() < 1)
          fail("testIteratorDefIntegerArray: Query fetched zero results ");
        CacheUtils.log(Utils.printResult(rs));


      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      } 
    }  
  }

  @Test
  public void testIteratorDefIntegerArrayList() throws Exception{

    ArrayList Arlist = new ArrayList();
    Arlist.add(new Integer(11));
    Arlist.add(new Integer(12));

    Object params[]=new Object[1];
    params[0]= Arlist;

    String queries[] = {
        "Select distinct intValue from $1 TYPE int",
        "Select distinct intValue from (list<int>) $1" 
    };
    for(int i=0;i<queries.length;i++){
      Query q= null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        if( rs.size() < 1)
          fail("testIteratorDefIntegerArrayList: Query fetched zero results ");
        CacheUtils.log(Utils.printResult(rs));
      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      } 
    }  

  }
  @Test
  public void testIteratorDefString() throws Exception{
    String s1="AA";
    String s2="BB";
    HashSet C1 = new HashSet();
    C1.add(s1);
    C1.add(s2);
    Object params[]=new Object[1];
    params[0]= C1;
    String queries[] = {
        "SELECT DISTINCT intern from (set<string>) $1",
        "SELECT DISTINCT intern from $1 TYPE string"      
    };
    for(int i=0;i<queries.length;i++){
      Query q = null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        if( rs.size() < 1)
          fail("testIteratorDefString: Query fetched zero results ");
        CacheUtils.log(Utils.printResult(rs));

      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      }
    }  
  }
  @Test
  public void testIteratorDefBoolean() throws Exception{
    boolean b1= true;
    boolean b2= false;
    HashSet C1 = new HashSet();
    C1.add(new Boolean(b1));
    C1.add(new Boolean(b2));
    Object params[]=new Object[1];
    params[0]= C1;
    String queries[] = {
        "SELECT DISTINCT booleanValue from (set<boolean>) $1",
        "SELECT DISTINCT booleanValue from $1 TYPE boolean"      
    };
    for(int i=0;i<queries.length;i++){
      Query q = null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        if( rs.size() < 1)
          fail("testIteratorDefBoolean: Query fetched zero results ");
        CacheUtils.log(Utils.printResult(rs));
      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      }
    }  

  }
  @Test
  public void testIteratorDefByte() throws Exception{
    byte b1= 1;
    byte b2= 2;
    HashSet C1 = new HashSet();
    C1.add(new Byte(b1));
    C1.add(new Byte(b2));
    Object params[]=new Object[1];
    params[0]= C1;
    String queries[] = {
        "SELECT DISTINCT byteValue from (set<byte>) $1",
        "SELECT DISTINCT byteValue from $1 TYPE byte"      
    };
    for(int i=0;i<queries.length;i++){
      Query q = null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        if( rs.size() < 1)
          fail("testIteratorDefByte: Query fetched zero results ");
        CacheUtils.log(Utils.printResult(rs));
      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      }
    }
  }
  @Test
  public void testIteratorDefShort() throws Exception{
    short sh1= 11;
    short sh2= 22;
    HashSet C1 = new HashSet();
    C1.add(new Short(sh1));
    C1.add(new Short(sh2));
    Object params[]=new Object[1];
    params[0]= C1;
    String queries[] = {
        "SELECT DISTINCT shortValue from (set<short>) $1",
        "SELECT DISTINCT shortValue from $1 TYPE short"      
    };
    for(int i=0;i<queries.length;i++){
      Query q = null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        if( rs.size() < 1)
          fail("testIteratorDefShort: Query fetched zero results ");
        CacheUtils.log(Utils.printResult(rs));
      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      }
    }  
  }
  @Test
  public void testIteratorDefLong() throws Exception{
    long lg1= 111;
    long lg2= 222;
    HashSet C1 = new HashSet();
    C1.add(new Long(lg1));
    C1.add(new Long(lg2));
    Object params[]=new Object[1];
    params[0]= C1;
    String queries[] = {
        "SELECT DISTINCT longValue from (set<long>) $1",
        "SELECT DISTINCT longValue from $1 TYPE long"      
    };
    for(int i=0;i<queries.length;i++){
      Query q = null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        if( rs.size() < 1)
          fail("testIteratorDefLong: Query fetched zero results ");
        CacheUtils.log(Utils.printResult(rs));
      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      }
    }  
  }
  @Test
  public void testIteratorDefDouble() throws Exception{
    double d1= 1.11;
    double d2= 2.22;
    HashSet C1 = new HashSet();
    C1.add(new Double(d1));
    C1.add(new Double(d2));
    Object params[]=new Object[1];
    params[0]= C1;
    String queries[] = {
        "SELECT DISTINCT doubleValue from (set<double>) $1",
        "SELECT DISTINCT doubleValue from $1 TYPE double"      
    };
    for(int i=0;i<queries.length;i++){
      Query q = null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        if( rs.size() < 1)
          fail("testIteratorDefDouble: Query fetched zero results ");
        CacheUtils.log(Utils.printResult(rs));
      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      }
    }  
  }
  @Test
  public void testIteratorDefFloat() throws Exception{
    float fl1= 1;
    float fl2= 2;
    HashSet C1 = new HashSet();
    C1.add(new Float(fl1));
    C1.add(new Float(fl2));
    Object params[]=new Object[1];
    params[0]= C1;
    String queries[] = {
        "SELECT DISTINCT floatValue from (set<float>) $1",
        "SELECT DISTINCT floatValue from $1 TYPE float"      
    };
    for(int i=0;i<queries.length;i++){
      Query q = null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        if( rs.size() < 1)
          fail("testIteratorDefFloat: Query fetched zero results ");
        CacheUtils.log(Utils.printResult(rs));
      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      }
    }  
  }
  @Test
  public void testIteratorDefChar() throws Exception{
    char ch1= 'a';
    char ch2= 'z';
    HashSet C1 = new HashSet();
    C1.add(new Character(ch1));
    C1.add(new Character(ch2));
    Object params[]=new Object[1];
    params[0]= C1;
    String queries[] = {
        "SELECT DISTINCT charValue from (set<char>) $1",
        "SELECT DISTINCT charValue from $1 TYPE char"      
    };
    for(int i=0;i<queries.length;i++){
      Query q = null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        if( rs.size() < 1)
          fail("testIteratorDefChar: Query fetched zero results ");
        CacheUtils.log(Utils.printResult(rs));
      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      }
    }  
  }

  @Test
  public void testNonStaticInnerClassTypeDef () {
    Student.initializeCounter();
    ArrayList Arlist = new ArrayList();
    Arlist.add(new Student("asif"));
    Arlist.add(new Student("ketan"));

    Object params[]=new Object[1];
    params[0]= Arlist;

    String queries[] = {

        "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student;" +
            "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student$Subject;" +
            "Select distinct * from  $1 as it1 ,  it1.subjects x  type Student$Subject  where x.subject='Hindi' " ,
            "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student;" +
                "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student$Subject;" +
                "Select distinct * from  $1 as it1 ,  it1.subjects  type Student$Subject  where subject='Hindi' " ,
                "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student;" +
                    "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student$Subject;" +      
                    "Select distinct * from  $1 as it1 , (list<Student$Subject>) it1.subjects   where subject='Hindi' "
    };
    for(int i=0;i<queries.length;i++){
      Query q= null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        CacheUtils.log(Utils.printResult(rs));
        if( rs.size() != 1)
          fail("testNonStaticInnerClassTypeDef: Query fetched results with size =" + rs.size()+ " FOr Query number = "+ (i+1));

      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      } 
    }  
  }

  @Test
  public void testStaticInnerClassTypeDef () {
    Student.initializeCounter();
    ArrayList Arlist = new ArrayList();
    Arlist.add(new Student("asif"));
    Arlist.add(new Student("ketan"));

    Object params[]=new Object[1];
    params[0]= Arlist;

    String queries[] = {

        "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student;" +
            "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student$Teacher;" +
            "Select distinct * from  $1 as it1 ,  it1.teachers x  type Student$Teacher  where x.teacher='Y' " ,
            "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student;" +
                "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student$Teacher;" +
                "Select distinct * from  $1 as it1 ,  it1.teachers  type Student$Teacher  where teacher='Y' " ,
                "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student;" +
                    "IMPORT com.gemstone.gemfire.cache.\"query\".data.Student$Teacher;" +      
                    "Select distinct * from  $1 as it1 , (list<Student$Teacher>) it1.teachers  where teacher='Y' "
    };
    for(int i=0;i<queries.length;i++){
      Query q= null;
      try{
        q = CacheUtils.getQueryService().newQuery(queries[i]);
        SelectResults rs =(SelectResults) q.execute(params);
        CacheUtils.log(Utils.printResult(rs));
        if( rs.size() != 1)
          fail("testStaticInnerClassTypeDef: Query fetched results with size =" + rs.size()+ " FOr Query number = "+ (i+1));

      }
      catch (Exception e){
        e.printStackTrace();
        fail(q.getQueryString());
      } 
    }  
  }
}