/*******************************************************************************
 * Copyright (c) 2013, Salesforce.com, Inc.
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 *     Redistributions of source code must retain the above copyright notice,
 *     this list of conditions and the following disclaimer.
 *     Redistributions in binary form must reproduce the above copyright notice,
 *     this list of conditions and the following disclaimer in the documentation
 *     and/or other materials provided with the distribution.
 *     Neither the name of Salesforce.com nor the names of its contributors may
 *     be used to endorse or promote products derived from this software without
 *     specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
 * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
 * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 ******************************************************************************/
/**********************************
 *
 * Later modifications to test Trafodion instead of Phoenix were granted to ASF.
 *
 * 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.
*************************************/

package test.java.org.trafodion.phoenix.end2end;

import static org.junit.Assert.*;
import org.junit.*;
import java.math.*;
import java.sql.*;
import java.sql.Date;
import java.util.*;
import java.io.*;
import java.lang.Thread.*;

import com.google.common.collect.ImmutableMap;

public abstract class BaseTest {

    // target is phoenix, TRAF, or SQ?
    protected enum TargetType {PHOENIX, TRAF, SQ};
    protected static TargetType targetType = TargetType.TRAF; 
    protected static void setTgtPH() { targetType = TargetType.PHOENIX; }
    protected static void setTgtTR() { targetType = TargetType.TRAF; }
    protected static void setTgtSQ() { targetType = TargetType.SQ; }

    protected static boolean tgtPH() { return targetType == TargetType.PHOENIX; }
    protected static boolean tgtTR() { return targetType == TargetType.TRAF; }
    protected static boolean tgtSQ() { return targetType == TargetType.SQ; }

    // Do you want to print the test info while Junit runs?
    private final boolean print_testinfo = false;

    private static String my_catalog = null;
    private static String my_schema = null;

    protected static Connection conn = null;
    /* List all of the object names being used in this entire class.
     * The objects are dropped with errors ignored, so it is OK if the
     * object does not exist for a particular test.
     */
    protected static ArrayList<String> objDropList = null;

    // This is really a @BeforeClass, but the child needs to initialize
    // objDropList before we can call this function, so the acutal
    // @BeforeClass is defined in the child and then it calls this
    // one after objDropList is defined.
    protected static void doBaseTestSuiteSetup() throws Exception {
        if (tgtSQ())
           createCatalogIfNotExist();
        createSchemaIfNotExist();

        String name = Thread.currentThread().getStackTrace()[2].toString();
        name = name.substring(0, name.indexOf(".doTestSuiteSetup")); 
        System.out.println(name);
    }

    @AfterClass
    public static void doBaseTestSuiteCleanup() throws Exception {
        dropSchemaIfExist();
        if (tgtSQ())
           dropCatalogIfExist();
    }

    @Before
    public void doBaseTestSetup() throws Exception {
        conn = getConnection();
    }

    @After
    public void doBaseTestCleanup() throws Exception {
        conn.close();
        dropTestObjects();
    }

    private static Connection baseConn = null;

    // For SQ only, create catalog if it does not exist
    private static void createCatalogIfNotExist() throws Exception {
        // Use our own conn.  Who knows what the tests have been doing with
        // auto commit of the conn that it has been using.
        if (baseConn == null)
            baseConn = getConnection();
         
        try {
            baseConn.createStatement().execute("create catalog " + my_catalog);
        } catch (Exception e) {
            // Do nothing, the catalog may already exist.
        }
    }

    // create schema if it does exist.
    private static void createSchemaIfNotExist() throws Exception {
        // Use our own conn.  Who knows what the tests have been doing with
        // auto commit of the conn that it has been using.
        if (baseConn == null)
            baseConn = getConnection();

        try {
            baseConn.createStatement().execute("create schema " + my_catalog + "." + my_schema);
        } catch (Exception e) {
            // Do nothing, the schema may already exist.
        }
    }

    // For SQ only, drop catalog if it exists
    private static void dropCatalogIfExist() throws Exception {
        // Use our own conn.  Who knows what the tests have been doing with
        // auto commit of the conn that it has been using.
        if (baseConn == null)
            baseConn = getConnection();

        try {
            baseConn.createStatement().execute("drop catalog " + my_catalog);
        } catch (Exception e) {
            // failure is OK. The 'cascade' option is not used here, so if 
            // the catalog has some other schemas other than the one that
            // Phoenix tests use, this will certainly fail.
        }
    }

    private static void dropSchemaIfExist() throws Exception {
        // Use our own conn.  Who knows what the tests have been doing with
        // auto commit of the conn that it has been using.
        if (baseConn == null)
            baseConn = getConnection();

        try {
            baseConn.createStatement().execute("drop schema " + my_catalog + "." + my_schema + " cascade");
        } catch (Exception e) {
            // Do nothing, the schema may not exist.  
        }
    }

    protected static void dropTestObjects() throws Exception {

        // Use our own conn.  Who knows what the tests have been doing with
        // auto commit of the conn that it has been using.
        if (baseConn == null)
            baseConn = getConnection();

        if (objDropList == null)
            return;

        for (String objname : objDropList) {
            for (int i = 0; i < 3; i++) {
                try {
                    // shouldn't make any difference, but some people
                    // insist dropping object should use executeUpdate()
                    // instead of execute()
                    baseConn.createStatement().executeUpdate("drop " + objname + " cascade");
                    break; // no execption, break out here
                } catch (Exception e) {
                    String msg = e.getMessage();
                    if ((msg.contains("ERROR[1002]") &&
                         msg.contains("does not exist")) ||
                        (msg.contains("ERROR[1003]") && 
                         msg.contains("does not exist")) ||
                        (msg.contains("ERROR[1004]") &&
                         msg.contains("does not exist"))) {
                        // ERROR[1002]: catalog does not exist in SQ, 
                        // ERROR[1003]: schema does not exist in SQ,
                        // ERROR[1004]: schema does not exist in SQ,
                        // we are done these cases.
                        break;
                    } 
                    else if (msg.contains("ERROR[1389]") &&
                        msg.contains("does not exist")) {
                        // object does not exist in TRAF, we are done.
                        break;
                    }
                    else if (i < 2 &&
                        msg.contains("ERROR[1183]") &&
                        msg.contains("Error 73")) {
                        // error 73 should be reried up to 3 times.
                        Thread.sleep(2000); // 2 secs
                        System.out.println("see error 73, retrying...");
                    } else {
                        // all rest are bad.
                        System.out.println(msg);
                        fail("Failed to drop object: " + objname);
                    }
                }
            }
        }
    }


    protected static final String tenantId = "TRAF";

    protected static final String CF_NAME = "a";
    // protected static final byte[] CF = Bytes.toBytes(CF_NAME);

    protected static final String CF2_NAME = "b";

    protected final static String A_VALUE = "a";
    // protected final static byte[] A = Bytes.toBytes(A_VALUE);
    protected final static String B_VALUE = "b";
    // protected final static byte[] B = Bytes.toBytes(B_VALUE);
    protected final static String C_VALUE = "c";
    // protected final static byte[] C = Bytes.toBytes(C_VALUE);
    protected final static String D_VALUE = "d";
    // protected final static byte[] D = Bytes.toBytes(D_VALUE);
    protected final static String E_VALUE = "e";
    // protected final static byte[] E = Bytes.toBytes(E_VALUE);

    protected final static String ROW1 = "00A123122312312";
    protected final static String ROW2 = "00A223122312312";
    protected final static String ROW3 = "00A323122312312";
    protected final static String ROW4 = "00A423122312312";
    protected final static String ROW5 = "00B523122312312";
    protected final static String ROW6 = "00B623122312312";
    protected final static String ROW7 = "00B723122312312";
    protected final static String ROW8 = "00B823122312312";
    protected final static String ROW9 = "00C923122312312";

    protected static final long MILLIS_IN_DAY = 1000 * 60 * 60 * 24;

    protected static final String ATABLE_NAME = "ATABLE";
    protected static final String SUM_DOUBLE_NAME = "SumDoubleTest";
    protected static final String ATABLE_SCHEMA_NAME = "";
    protected static final String BTABLE_NAME = "BTABLE";
    protected static final String STABLE_NAME = "STABLE";
    protected static final String STABLE_SCHEMA_NAME = "";
    protected static final String GROUPBYTEST_NAME = "GROUPBYTEST";
    protected static final String CUSTOM_ENTITY_DATA_FULL_NAME = "CUSTOM_ENTITY_DATA";
    protected static final String CUSTOM_ENTITY_DATA_NAME = "CUSTOM_ENTITY_DATA";
    protected static final String CUSTOM_ENTITY_DATA_SCHEMA_NAME = "CORE";
    protected static final String HBASE_NATIVE = "HBASE_NATIVE";
    protected static final String HBASE_DYNAMIC_COLUMNS = "HBASE_DYNAMIC_COLUMNS";
    protected static final String PRODUCT_METRICS_NAME = "PRODUCT_METRICS";
    protected static final String PTSDB_NAME = "PTSDB";
    protected static final String PTSDB2_NAME = "PTSDB2";
    protected static final String PTSDB3_NAME = "PTSDB3";
    protected static final String PTSDB_SCHEMA_NAME = "";
    protected static final String FUNKY_NAME = "FUNKY_NAMES";
    protected static final String MULTI_CF_NAME = "MULTI_CF";
    protected static final String MDTEST_NAME = "MDTEST";
    protected static final String KEYONLY_NAME = "KEYONLY";
    protected static final String TABLE_WITH_SALTING = "TABLE_WITH_SALTING";
    protected static final String INDEX_DATA_SCHEMA = "INDEX_TEST";
    protected static final String INDEX_DATA_TABLE = "INDEX_DATA_TABLE";

    protected static final String NAME_SEPARATOR = ".";

    private static final Map<String,String> tableDDLMap_PH;
    private static final Map<String,String> tableDDLMap_TR;
    private static final Map<String,String> tableDDLMap_SQ;
    static {
        ImmutableMap.Builder<String,String> builder_PH = ImmutableMap.builder();
        ImmutableMap.Builder<String,String> builder_TR = ImmutableMap.builder();
        ImmutableMap.Builder<String,String> builder_SQ = ImmutableMap.builder();

        builder_PH.put(ATABLE_NAME,"create table " + ATABLE_NAME +
                "   (organization_id char(15) not null, \n" +
                "    entity_id char(15) not null,\n" +
                "    a_string varchar(100),\n" +
                "    b_string varchar(100),\n" +
                "    a_integer integer,\n" +
                "    a_date date,\n" +
                "    a_time time,\n" +
                "    a_timestamp timestamp,\n" +
                "    x_decimal decimal(31,10),\n" +
                "    x_long bigint,\n" +
                "    x_integer integer,\n" +
                "    y_integer integer,\n" +
                "    a_byte tinyint,\n" +
                "    a_short smallint,\n" +
                "    a_float float,\n" +
                "    a_double double,\n" +
                "    a_unsigned_float unsigned_float,\n" +
                "    a_unsigned_double unsigned_double\n" +
                "    CONSTRAINT pk PRIMARY KEY (organization_id, entity_id)\n" +
                ")");
        builder_TR.put(ATABLE_NAME,"create table " + ATABLE_NAME +
                "   (organization_id char(15) not null, \n" +
                "    entity_id char(15) not null,\n" +
                "    a_string varchar(100),\n" +
                "    b_string varchar(100),\n" +
                "    a_integer integer,\n" +
                "    a_date date,\n" +
                "    a_time time,\n" +
                "    a_timestamp timestamp,\n" +
/* TRAF */      "    x_decimal decimal(18,10),\n" +
                "    x_long bigint,\n" +
                "    x_integer integer,\n" +
                "    y_integer integer,\n" +
                "    a_byte tinyint,\n" +
                "    a_short smallint,\n" +
                "    a_float float,\n" +
/* TRAF */      "    a_double double precision,\n" +
/* TRAF */      "    a_unsigned_float float,\n" +
/* TRAF */      "    a_unsigned_double double precision\n" +
                "    , CONSTRAINT pk_atable PRIMARY KEY (organization_id, entity_id)\n" +
                ")");
        builder_SQ.put(ATABLE_NAME,"create table " + ATABLE_NAME +
                "   (organization_id char(15) not null, \n" +
                "    entity_id char(15) not null,\n" +
                "    a_string varchar(100),\n" +
                "    b_string varchar(100),\n" +
                "    a_integer integer,\n" +
                "    a_date date,\n" +
                "    a_time time,\n" +
                "    a_timestamp timestamp,\n" +
/* TRAF */      "    x_decimal decimal(18,10),\n" +
                "    x_long bigint,\n" +
                "    x_integer integer,\n" +
                "    y_integer integer,\n" +
                "    a_byte tinyint,\n" +
                "    a_short smallint,\n" +
                "    a_float float,\n" +
/* TRAF */      "    a_double double precision,\n" +
/* TRAF */      "    a_unsigned_float float,\n" +
/* TRAF */      "    a_unsigned_double double precision\n" +
                "    , CONSTRAINT pk_atable PRIMARY KEY (organization_id, entity_id)\n" +
                ")");
        builder_PH.put(BTABLE_NAME,"create table " + BTABLE_NAME +
                "   (a_string varchar not null, \n" +
                "    a_id char(3) not null,\n" +
                "    b_string varchar not null, \n" +
                "    a_integer integer not null, \n" +
                "    c_string varchar(2) null,\n" +
                "    b_integer integer,\n" +
                "    c_integer integer,\n" +
                "    d_string varchar(3),\n" +
                "    e_string char(10)\n" +
                "    CONSTRAINT my_pk PRIMARY KEY (a_string,a_id,b_string,a_integer,c_string))");
        builder_TR.put(BTABLE_NAME,"create table " + BTABLE_NAME +
/* TRAF */      "   (a_string varchar(128) not null, \n" +
                "    a_id char(3) not null,\n" +
/* TRAF */      "    b_string varchar(128) not null, \n" +
                "    a_integer integer not null, \n" +
/* TRAF */      "    c_string varchar(2) not null,\n" +
                "    b_integer integer,\n" +
                "    c_integer integer,\n" +
                "    d_string varchar(3),\n" +
                "    e_string char(10)\n" +
/* TRAF */      "   , CONSTRAINT pk_btable PRIMARY KEY (a_string,a_id,b_string,a_integer,c_string))");
        builder_SQ.put(BTABLE_NAME,"create table " + BTABLE_NAME +
/* TRAF */      "   (a_string varchar(128) not null, \n" +
                "    a_id char(3) not null,\n" +
/* TRAF */      "    b_string varchar(128) not null, \n" +
                "    a_integer integer not null, \n" +
/* TRAF */      "    c_string varchar(2) not null,\n" +
                "    b_integer integer,\n" +
                "    c_integer integer,\n" +
                "    d_string varchar(3),\n" +
                "    e_string char(10)\n" +
/* TRAF */      "   , CONSTRAINT pk_btable PRIMARY KEY (a_string,a_id,b_string,a_integer,c_string))");
        builder_PH.put(TABLE_WITH_SALTING,"create table " + TABLE_WITH_SALTING +
                "   (a_integer integer not null, \n" +
                "    a_string varchar not null, \n" +
                "    a_id char(3) not null,\n" +
                "    b_string varchar, \n" +
                "    b_integer integer \n" +
                "    CONSTRAINT pk PRIMARY KEY (a_integer, a_string, a_id))\n" +
                "    SALT_BUCKETS = 4");
        builder_TR.put(TABLE_WITH_SALTING,"create table " + TABLE_WITH_SALTING +
                "   (a_integer integer not null, \n" +
/* TRAF */      "    a_string varchar(128) not null, \n" +
                "    a_id char(3) not null,\n" +
/* TRAF */      "    b_string varchar(128), \n" +
                "    b_integer integer \n" +
/* TRAF */      "    , CONSTRAINT pk_table_with_salting PRIMARY KEY (a_integer, a_string, a_id))\n" +
/* TRAF */      "");
        builder_SQ.put(TABLE_WITH_SALTING,"create table " + TABLE_WITH_SALTING +
                "   (a_integer integer not null, \n" +
/* TRAF */      "    a_string varchar(128) not null, \n" +
                "    a_id char(3) not null,\n" +
/* TRAF */      "    b_string varchar(128), \n" +
                "    b_integer integer \n" +
/* TRAF */      "    , CONSTRAINT pk_table_with_salting PRIMARY KEY (a_integer, a_string, a_id))\n" +
// TRAF         "    SALT_BUCKETS = 4");
/* TRAF */      "");
        builder_PH.put(PTSDB_NAME,"create table " + PTSDB_NAME +
                "   (inst varchar null,\n" +
                "    host varchar null,\n" +
                "    date date not null,\n" +
                "    val decimal(31,10)\n" +
                "    CONSTRAINT pk PRIMARY KEY (inst, host, date))");
        builder_TR.put(PTSDB_NAME,"create table " + PTSDB_NAME +
/* TRAF */      "   (inst varchar(128) default null,\n" +
/* TRAF */      "    host1 varchar(128) default null,\n" +
/* TRAF */      "    date1 timestamp not null,\n" +
/* TRAF */      "    val decimal(18,10)\n" +
// TRAF: change the primary keys to clustering key.  Some of the columns allow null, which can't be used as primary keys in SQ.  date1 alone is not unique enough to be a primary key.
/* TRAF */      "    ) STORE BY (date1)");
        builder_SQ.put(PTSDB_NAME,"create table " + PTSDB_NAME +
/* TRAF */      "   (inst varchar(128) default null,\n" +
/* TRAF */      "    host1 varchar(128) default null,\n" +
/* TRAF */      "    date1 timestamp not null,\n" +
/* TRAF */      "    val decimal(18,10)\n" +
// TRAF: change the primary keys to clustering key.  Some of the columns allow null, which can't be used as primary keys in SQ.  date1 alone is not unique enough to be a primary key.
/* TRAF */      "    ) STORE BY (date1)");
        builder_PH.put(PTSDB2_NAME,"create table " + PTSDB2_NAME +
                "   (inst varchar(10) not null,\n" +
                "    date date not null,\n" +
                "    val1 decimal,\n" +
                "    val2 decimal(31,10),\n" +
                "    val3 decimal\n" +
                "    CONSTRAINT pk PRIMARY KEY (inst, date))");
        builder_TR.put(PTSDB2_NAME,"create table " + PTSDB2_NAME +
                "   (inst varchar(10) not null,\n" +
/* TRAF */      "    date1 timestamp not null,\n" +
                "    val1 decimal,\n" +
/* TRAF */      "    val2 decimal(18,10),\n" +
                "    val3 decimal\n" +
/* TRAF */      "    , CONSTRAINT pk PRIMARY KEY (inst, date1))");
        builder_SQ.put(PTSDB2_NAME,"create table " + PTSDB2_NAME +
                "   (inst varchar(10) not null,\n" +
/* TRAF */      "    date1 timestamp not null,\n" +
                "    val1 decimal,\n" +
/* TRAF */      "    val2 decimal(18,10),\n" +
                "    val3 decimal\n" +
/* TRAF */      "    , CONSTRAINT pk PRIMARY KEY (inst, date1))");
        builder_PH.put(PTSDB3_NAME,"create table " + PTSDB3_NAME +
                "   (host varchar(10) not null,\n" +
                "    date date not null,\n" +
                "    val1 decimal,\n" +
                "    val2 decimal(31,10),\n" +
                "    val3 decimal\n" +
                "    CONSTRAINT pk PRIMARY KEY (host DESC, date DESC))");
        builder_TR.put(PTSDB3_NAME,"create table " + PTSDB3_NAME +
/* TRAF */      "   (host1 varchar(10) not null,\n" +
/* TRAF */      "    date1 timestamp not null,\n" +   
                "    val1 decimal,\n" +
/* TRAF */      "    val2 decimal(18,10),\n" + 
                "    val3 decimal\n" +
/* TRAF */      "    , CONSTRAINT pk PRIMARY KEY (host1 DESC, date1 DESC))");
        builder_SQ.put(PTSDB3_NAME,"create table " + PTSDB3_NAME +
/* TRAF */      "   (host1 varchar(10) not null,\n" +
/* TRAF */      "    date1 timestamp not null,\n" +
                "    val1 decimal,\n" +
/* TRAF */      "    val2 decimal(18,10),\n" +
                "    val3 decimal\n" +
/* TRAF */      "    , CONSTRAINT pk PRIMARY KEY (host1 DESC, date1 DESC))");
        builder_PH.put(FUNKY_NAME,"create table " + FUNKY_NAME +
                "   (\"foo!\" varchar not null primary key,\n" +
                "    \"1\".\"#@$\" varchar, \n" +
                "    \"1\".\"foo.bar-bas\" varchar, \n" +
                "    \"1\".\"Value\" integer,\n" +
                "    \"1\".\"VALUE\" integer,\n" +
                "    \"1\".\"value\" integer,\n" +
                "    \"1\".\"_blah^\" varchar)"
                ); 
        builder_TR.put(FUNKY_NAME,"create table " + FUNKY_NAME +
/* TRAF */      "   (\"foo!\" varchar(128) not null primary key,\n" +
/* TRAF */      "    \"#@$\" varchar(128), \n" +
/* TRAF */      "    \"foo.bar-bas\" varchar(128), \n" +
/* TRAF */      "    \"Value\" integer,\n" +
/* TRAF */      "    \"VALUE\" integer,\n" +
/* TRAF */      "    \"value\" integer,\n" +
/* TRAF */      "    \"_blah^\" varchar(128))"
                );
        builder_SQ.put(FUNKY_NAME,"create table " + FUNKY_NAME +
/* TRAF */      "   (\"foo!\" varchar(128) not null primary key,\n" +
/* TRAF */      "    \"#@$\" varchar(128), \n" +
/* TRAF */      "    \"foo.bar-bas\" varchar(128), \n" +
/* TRAF */      "    \"Value\" integer,\n" +
/* TRAF */      "    \"VALUE\" integer,\n" +
/* TRAF */      "    \"value\" integer,\n" +
/* TRAF */      "    \"_blah^\" varchar(128))"
                );
        builder_PH.put(KEYONLY_NAME,"create table " + KEYONLY_NAME +
                "   (i1 integer not null, i2 integer not null\n" +
                "    CONSTRAINT pk PRIMARY KEY (i1,i2))");
        builder_TR.put(KEYONLY_NAME,"create table " + KEYONLY_NAME +
                "   (i1 integer not null, i2 integer not null\n" +
                "    , CONSTRAINT pk_keyonly PRIMARY KEY (i1,i2))");
        builder_SQ.put(KEYONLY_NAME,"create table " + KEYONLY_NAME +
                "   (i1 integer not null, i2 integer not null\n" +
                "    , CONSTRAINT pk_keyonly PRIMARY KEY (i1,i2))");
        builder_PH.put(MULTI_CF_NAME,"create table " + MULTI_CF_NAME +
                "   (id char(15) not null primary key,\n" +
                "    a.unique_user_count integer,\n" +
                "    b.unique_org_count integer,\n" +
                "    c.db_cpu_utilization decimal(31,10),\n" +
                "    d.transaction_count bigint,\n" +
                "    e.cpu_utilization decimal(31,10),\n" +
                "    f.response_time bigint,\n" +
                "    g.response_time bigint)");
        builder_TR.put(MULTI_CF_NAME,"create table " + MULTI_CF_NAME +
                "   (id char(15) not null primary key,\n" +
/* TRAF */      "    unique_user_count integer,\n" +
/* TRAF */      "    unique_org_count integer,\n" +
/* TRAF */      "    db_cpu_utilization decimal(18,10),\n" +
/* TRAF */      "    transaction_count bigint,\n" +
/* TRAF */      "    cpu_utilization decimal(18,10),\n" +
/* TRAF */      "    f_response_time bigint,\n" +
/* TRAF */      "    g_response_time bigint)");
        builder_SQ.put(MULTI_CF_NAME,"create table " + MULTI_CF_NAME +
                "   (id char(15) not null primary key,\n" +
/* TRAF */      "    unique_user_count integer,\n" +
/* TRAF */      "    unique_org_count integer,\n" +
/* TRAF */      "    db_cpu_utilization decimal(18,10),\n" +
/* TRAF */      "    transaction_count bigint,\n" +
/* TRAF */      "    cpu_utilization decimal(18,10),\n" +
/* TRAF */      "    f_response_time bigint,\n" +
/* TRAF */      "    g_response_time bigint)");
        builder_PH.put(GROUPBYTEST_NAME,"create table " + GROUPBYTEST_NAME +
                "   (id varchar not null primary key,\n" +
                "    uri varchar, appcpu integer)");
        builder_TR.put(GROUPBYTEST_NAME,"create table " + GROUPBYTEST_NAME +
/* TRAF */      "   (id varchar(128) not null primary key,\n" +
/* TRAF */      "    uri varchar(128), appcpu integer)");
        builder_SQ.put(GROUPBYTEST_NAME,"create table " + GROUPBYTEST_NAME +
/* TRAF */      "   (id varchar(128) not null primary key,\n" +
/* TRAF */      "    uri varchar(128), appcpu integer)");
        builder_PH.put(PRODUCT_METRICS_NAME,"create table " + PRODUCT_METRICS_NAME +
                "   (organization_id char(15) not null," +
                "    date date not null," +
                "    feature char(1) not null," +
                "    unique_users integer not null,\n" +
                "    db_utilization decimal(31,10),\n" +
                "    transactions bigint,\n" +
                "    cpu_utilization decimal(31,10),\n" +
                "    response_time bigint,\n" +
                "    io_time bigint,\n" +
                "    region varchar,\n" +
                "    unset_column decimal(31,10)\n" +
                "    CONSTRAINT pk PRIMARY KEY (organization_id, DATe, feature, UNIQUE_USERS))"); 
        builder_TR.put(PRODUCT_METRICS_NAME,"create table " + PRODUCT_METRICS_NAME +
                "   (organization_id char(15) not null," +
/* TRAF */      "    date1 timestamp not null," +
                "    feature char(1) not null," +
                "    unique_users integer not null,\n" +
/* TRAF */      "    db_utilization decimal(18,10),\n" +
                "    transactions bigint,\n" +
/* TRAF */      "    cpu_utilization decimal(18,10),\n" +
                "    response_time bigint,\n" +
                "    io_time bigint,\n" +
/* TRAF */      "    region varchar(128),\n" +
/* TRAF */      "    unset_column decimal(18,10)\n" +
/* TRAF */      "    , CONSTRAINT pk_product_matrics PRIMARY KEY (organization_id, DATe1, feature, UNIQUE_USERS))"); 
        builder_SQ.put(PRODUCT_METRICS_NAME,"create table " + PRODUCT_METRICS_NAME +
                "   (organization_id char(15) not null," +
/* TRAF */      "    date1 timestamp not null," +
                "    feature char(1) not null," +
                "    unique_users integer not null,\n" +
/* TRAF */      "    db_utilization decimal(18,10),\n" +
                "    transactions bigint,\n" +
/* TRAF */      "    cpu_utilization decimal(18,10),\n" +
                "    response_time bigint,\n" +
                "    io_time bigint,\n" +
/* TRAF */      "    region varchar(128),\n" +
/* TRAF */      "    unset_column decimal(18,10)\n" +
/* TRAF */      "    , CONSTRAINT pk_product_matrics PRIMARY KEY (organization_id, DATe1, feature, UNIQUE_USERS))");
        builder_PH.put(CUSTOM_ENTITY_DATA_FULL_NAME,"create table " + CUSTOM_ENTITY_DATA_FULL_NAME +
                "   (organization_id char(15) not null, \n" +
                "    key_prefix char(3) not null,\n" +
                "    custom_entity_data_id char(12) not null,\n" +
                "    created_by varchar,\n" +
                "    created_date date,\n" +
                "    currency_iso_code char(3),\n" +
                "    deleted char(1),\n" +
                "    division decimal(31,10),\n" +
                "    last_activity date,\n" +
                "    last_update date,\n" +
                "    last_update_by varchar,\n" +
                "    name varchar(240),\n" +
                "    owner varchar,\n" +
                "    record_type_id char(15),\n" +
                "    setup_owner varchar,\n" +
                "    system_modstamp date,\n" +
                "    b.val0 varchar,\n" +
                "    b.val1 varchar,\n" +
                "    b.val2 varchar,\n" +
                "    b.val3 varchar,\n" +
                "    b.val4 varchar,\n" +
                "    b.val5 varchar,\n" +
                "    b.val6 varchar,\n" +
                "    b.val7 varchar,\n" +
                "    b.val8 varchar,\n" +
                "    b.val9 varchar\n" +
                "    CONSTRAINT pk PRIMARY KEY (organization_id, key_prefix, custom_entity_data_id))");
        builder_TR.put(CUSTOM_ENTITY_DATA_FULL_NAME,"create table " + CUSTOM_ENTITY_DATA_FULL_NAME +
                "   (organization_id char(15) not null, \n" +
                "    key_prefix char(3) not null,\n" +
                "    custom_entity_data_id char(12) not null,\n" +
/* TRAF */      "    created_by varchar(128),\n" +
                "    created_date date,\n" +
                "    currency_iso_code char(3),\n" +
                "    deleted char(1),\n" +
/* TRAF */      "    division decimal(18,10),\n" +
                "    last_activity date,\n" +
                "    last_update date,\n" +
/* TRAF */      "    last_update_by varchar(128),\n" +
                "    name varchar(240),\n" +
/* TRAF */      "    owner varchar(128),\n" +
                "    record_type_id char(15),\n" +
/* TRAF */      "    setup_owner varchar(128),\n" +
                "    system_modstamp date,\n" +
/* TRAF */      "    val0 varchar(128),\n" +
/* TRAF */      "    val1 varchar(128),\n" +
/* TRAF */      "    val2 varchar(128),\n" +
/* TRAF */      "    val3 varchar(128),\n" +
/* TRAF */      "    val4 varchar(128),\n" +
/* TRAF */      "    val5 varchar(128),\n" +
/* TRAF */      "    val6 varchar(128),\n" +
/* TRAF */      "    val7 varchar(128),\n" +
/* TRAF */      "    val8 varchar(128),\n" +
/* TRAF */      "    val9 varchar(128)\n" +
/* TRAF */      "    , CONSTRAINT pk_custom_entity_data PRIMARY KEY (organization_id, key_prefix, custom_entity_data_id))");
        builder_SQ.put(CUSTOM_ENTITY_DATA_FULL_NAME,"create table " + CUSTOM_ENTITY_DATA_FULL_NAME +
                "   (organization_id char(15) not null, \n" +
                "    key_prefix char(3) not null,\n" +
                "    custom_entity_data_id char(12) not null,\n" +
/* TRAF */      "    created_by varchar(128),\n" +
                "    created_date date,\n" +
                "    currency_iso_code char(3),\n" +
                "    deleted char(1),\n" +
/* TRAF */      "    division decimal(18,10),\n" +
                "    last_activity date,\n" +
                "    last_update date,\n" +
/* TRAF */      "    last_update_by varchar(128),\n" +
                "    name varchar(240),\n" +
/* TRAF */      "    owner varchar(128),\n" +
                "    record_type_id char(15),\n" +
/* TRAF */      "    setup_owner varchar(128),\n" +
                "    system_modstamp date,\n" +
/* TRAF */      "    val0 varchar(128),\n" +
/* TRAF */      "    val1 varchar(128),\n" +
/* TRAF */      "    val2 varchar(128),\n" +
/* TRAF */      "    val3 varchar(128),\n" +
/* TRAF */      "    val4 varchar(128),\n" +
/* TRAF */      "    val5 varchar(128),\n" +
/* TRAF */      "    val6 varchar(128),\n" +
/* TRAF */      "    val7 varchar(128),\n" +
/* TRAF */      "    val8 varchar(128),\n" +
/* TRAF */      "    val9 varchar(128)\n" +
/* TRAF */      "    , CONSTRAINT pk_custom_entity_data PRIMARY KEY (organization_id, key_prefix, custom_entity_data_id))");
        builder_PH.put("IntKeyTest","create table IntKeyTest" +
                "   (i integer not null primary key)");
        builder_TR.put("IntKeyTest","create table IntKeyTest" +
                "   (i integer not null primary key)");
        builder_SQ.put("IntKeyTest","create table IntKeyTest" +
                "   (i integer not null primary key)");
        builder_PH.put("IntIntKeyTest","create table IntIntKeyTest" +
                "   (i integer not null primary key, j integer)");
        builder_TR.put("IntIntKeyTest","create table IntIntKeyTest" +
                "   (i integer not null primary key, j integer)");
        builder_SQ.put("IntIntKeyTest","create table IntIntKeyTest" +
                "   (i integer not null primary key, j integer)");
        builder_PH.put("LongInKeyTest","create table LongInKeyTest" +
                "   (l bigint not null primary key)");
        builder_TR.put("LongInKeyTest","create table LongInKeyTest" +
                "   (l bigint not null primary key)");
        builder_SQ.put("LongInKeyTest","create table LongInKeyTest" +
                "   (l bigint not null primary key)");
        builder_PH.put("PKIntValueTest", "create table PKIntValueTest" +
                "   (pk integer not null primary key)");
        builder_TR.put("PKIntValueTest", "create table PKIntValueTest" +
                "   (pk integer not null primary key)");
        builder_SQ.put("PKIntValueTest", "create table PKIntValueTest" +
                "   (pk integer not null primary key)");
        builder_PH.put("PKBigIntValueTest", "create table PKBigIntValueTest" +
                "   (pk bigint not null primary key)");
        builder_TR.put("PKBigIntValueTest", "create table PKBigIntValueTest" +
                "   (pk bigint not null primary key)");
        builder_SQ.put("PKBigIntValueTest", "create table PKBigIntValueTest" +
                "   (pk bigint not null primary key)");
        builder_PH.put("PKUnsignedIntValueTest", "create table PKUnsignedIntValueTest" +
                "   (pk unsigned_int not null primary key)");
        builder_TR.put("PKUnsignedIntValueTest", "create table PKUnsignedIntValueTest" +
                "   (pk unsigned_int not null primary key)");
        builder_SQ.put("PKUnsignedIntValueTest", "create table PKUnsignedIntValueTest" +
                "   (pk unsigned_int not null primary key)");
        builder_PH.put("PKUnsignedLongValueTest", "create table PKUnsignedLongValueTest" +
                "   (pk unsigned_long not null\n" +
                "    CONSTRAINT pk PRIMARY KEY (pk))");
        builder_TR.put("PKUnsignedLongValueTest", "create table PKUnsignedLongValueTest" +
                "   (pk unsigned_long not null\n" +
                "    CONSTRAINT pk PRIMARY KEY (pk))");
        builder_SQ.put("PKUnsignedLongValueTest", "create table PKUnsignedLongValueTest" +
                "   (pk unsigned_long not null\n" +
                "    CONSTRAINT pk PRIMARY KEY (pk))");
        builder_PH.put("KVIntValueTest", "create table KVIntValueTest" +
                "   (pk integer not null primary key,\n" +
                "    kv integer)\n");
        builder_TR.put("KVIntValueTest", "create table KVIntValueTest" +
                "   (pk integer not null primary key,\n" +
                "    kv integer)\n");
        builder_SQ.put("KVIntValueTest", "create table KVIntValueTest" +
                "   (pk integer not null primary key,\n" +
                "    kv integer)\n");
        builder_PH.put("KVBigIntValueTest", "create table KVBigIntValueTest" +
                "   (pk integer not null primary key,\n" +
                "    kv bigint)\n");
        builder_TR.put("KVBigIntValueTest", "create table KVBigIntValueTest" +
                "   (pk integer not null primary key,\n" +
                "    kv bigint)\n");
        builder_SQ.put("KVBigIntValueTest", "create table KVBigIntValueTest" +
                "   (pk integer not null primary key,\n" +
                "    kv bigint)\n");
        builder_PH.put(INDEX_DATA_TABLE, "create table " + INDEX_DATA_SCHEMA + NAME_SEPARATOR + INDEX_DATA_TABLE + "(" +
                "   varchar_pk VARCHAR NOT NULL, " +
                "   char_pk CHAR(5) NOT NULL, " +
                "   int_pk INTEGER NOT NULL, "+
                "   long_pk BIGINT NOT NULL, " +
                "   decimal_pk DECIMAL(31, 10) NOT NULL, " +
                "   a.varchar_col1 VARCHAR, " +
                "   a.char_col1 CHAR(5), " +
                "   a.int_col1 INTEGER, " +
                "   a.long_col1 BIGINT, " +
                "   a.decimal_col1 DECIMAL(31, 10), " +
                "   b.varchar_col2 VARCHAR, " +
                "   b.char_col2 CHAR(5), " +
                "   b.int_col2 INTEGER, " +
                "   b.long_col2 BIGINT, " +
                "   b.decimal_col2 DECIMAL(31, 10) " +
                "   CONSTRAINT pk PRIMARY KEY (varchar_pk, char_pk, int_pk, long_pk DESC, decimal_pk)) " +
                "IMMUTABLE_ROWS=true");
        builder_TR.put(INDEX_DATA_TABLE, "create table " + INDEX_DATA_TABLE + "(" +
/* TRAF */      "   varchar_pk VARCHAR(128) NOT NULL, " +
                "   char_pk CHAR(5) NOT NULL, " +
                "   int_pk INTEGER NOT NULL, "+
                "   long_pk BIGINT NOT NULL, " +
/* TRAF */      "   decimal_pk DECIMAL(18, 10) NOT NULL, " +
/* TRAF */      "   varchar_col1 VARCHAR(128), " +
/* TRAF */      "   char_col1 CHAR(5), " +
/* TRAF */      "   int_col1 INTEGER, " +
/* TRAF */      "   long_col1 BIGINT, " +
/* TRAF */      "   decimal_col1 DECIMAL(18, 10), " +
/* TRAF */      "   varchar_col2 VARCHAR(128), " +
/* TRAF */      "   char_col2 CHAR(5), " +
/* TRAF */      "   int_col2 INTEGER, " +
/* TRAF */      "   long_col2 BIGINT, " +
/* TRAF */      "   decimal_col2 DECIMAL(18, 10) " +
/* TRAF */      "   , CONSTRAINT pk PRIMARY KEY (varchar_pk, char_pk, int_pk, long_pk DESC, decimal_pk)) " +
/* TRAF */      "");
        builder_SQ.put(INDEX_DATA_TABLE, "create table " + INDEX_DATA_TABLE + "(" +
/* TRAF */      "   varchar_pk VARCHAR(128) NOT NULL, " +
                "   char_pk CHAR(5) NOT NULL, " +
                "   int_pk INTEGER NOT NULL, "+
                "   long_pk BIGINT NOT NULL, " +
/* TRAF */      "   decimal_pk DECIMAL(18, 10) NOT NULL, " +
/* TRAF */      "   varchar_col1 VARCHAR(128), " +
/* TRAF */      "   char_col1 CHAR(5), " +
/* TRAF */      "   int_col1 INTEGER, " +
/* TRAF */      "   long_col1 BIGINT, " +
/* TRAF */      "   decimal_col1 DECIMAL(18, 10), " +
/* TRAF */      "   varchar_col2 VARCHAR(128), " +
/* TRAF */      "   char_col2 CHAR(5), " +
/* TRAF */      "   int_col2 INTEGER, " +
/* TRAF */      "   long_col2 BIGINT, " +
/* TRAF */      "   decimal_col2 DECIMAL(18, 10) " +
/* TRAF */      "   , CONSTRAINT pk PRIMARY KEY (varchar_pk, char_pk, int_pk, long_pk DESC, decimal_pk)) " +
/* TRAF */      "");
        builder_PH.put("SumDoubleTest","create table SumDoubleTest" +
                "   (id varchar not null primary key, d DOUBLE, f FLOAT, ud UNSIGNED_DOUBLE, uf UNSIGNED_FLOAT, i integer, de decimal)");
        builder_TR.put("SumDoubleTest","create table SumDoubleTest" +
/* TRAF */      "   (id varchar(128) not null primary key, d DOUBLE PRECISION, f FLOAT, ud DOUBLE PRECISION, uf FLOAT, i integer, de decimal)");
        builder_SQ.put("SumDoubleTest","create table SumDoubleTest" +
/* TRAF */      "   (id varchar(128) not null primary key, d DOUBLE PRECISION, f FLOAT, ud DOUBLE PRECISION, uf FLOAT, i integer, de decimal)");
        
        tableDDLMap_PH = builder_PH.build();
        tableDDLMap_TR = builder_TR.build();
        tableDDLMap_SQ = builder_SQ.build();
    }

    protected void printTestDescription() {
        if (print_testinfo) {
            System.out.println(Thread.currentThread().getStackTrace()[2]);
        }
    }

    private static String url = null;

    protected static String getUrl() { return url; }

    private static boolean driverRegistered = false;

    private static void doConnectionSetup(Connection conn) throws Exception {
        assertNotNull(conn);

        if (tgtTR()) {
            conn.createStatement().execute("control query default mode_seabase 'on'");
        }
    }

    protected static Connection getConnection() throws Exception {
        Connection conn = null;
        try {
            String propFile = System.getProperty("trafjdbc.properties");
            assertNotNull(propFile);
            FileInputStream fs = new FileInputStream(new File(propFile));
            Properties props = new Properties();
            props.load(fs);

            url = props.getProperty("url");
            my_catalog = props.getProperty("catalog");
            my_schema = props.getProperty("schema");
            String tgtType = props.getProperty("targettype");
            assertTrue(tgtType.equals("") || tgtType.equals("SQ") || tgtType.equals("TR"));
            if (tgtType.equals("SQ"))
                setTgtSQ();
            else if (tgtType.equals("TR"))
                setTgtTR();
           
            // Reigser our JDBC driver if this is the first call.           
            if (! driverRegistered) {
                if (url.contains("t4jdbc"))
                    Class.forName("org.trafodion.jdbc.t4.T4Driver");   // T4 driver
                else
                    Class.forName("org.apache.trafodion.jdbc.t2.T2Driver"); // T2 driver
                driverRegistered = true;
            }

            // System.out.println("connecting to " + url);
            conn = DriverManager.getConnection(url, props);
        } catch (Exception e) {
            conn = null;
            fail(e.getMessage());
        }

        doConnectionSetup(conn);

        return conn;
    }

    protected void createTestTable(String tableName) {
        assertNotNull(conn);
        String ddl = null;
        if (tgtPH()) ddl = tableDDLMap_PH.get(tableName);
        else if (tgtTR()) ddl = tableDDLMap_TR.get(tableName);
        else if (tgtSQ()) ddl = tableDDLMap_SQ.get(tableName);
        assertNotNull(ddl);
        StringBuilder buf = new StringBuilder(ddl);
        ddl = buf.toString();

        try {
            conn.createStatement().execute(ddl);
        } catch (Exception e) { 
            System.out.println(e.getMessage());
            fail("Failed to create table");
        }
    }

    protected void initSumDoubleValues() throws Exception {
        assertNotNull(conn);
        createTestTable("SumDoubleTest");
        try {
            // Insert all rows at ts
            PreparedStatement stmt = null;
            if (tgtPH()||tgtTR()) stmt = conn.prepareStatement(
                    "upsert into " +
                    "SumDoubleTest(" +
                    "    id, " +
                    "    d, " +
                    "    f, " +
                    "    ud, " +
                    "    uf) " +
                    "VALUES (?, ?, ?, ?, ?)");
            else if (tgtSQ()) stmt = conn.prepareStatement(
                    "insert into " +
                    "SumDoubleTest(" +
                    "    id, " +
                    "    d, " +
                    "    f, " +
                    "    ud, " +
                    "    uf) " +
                    "VALUES (?, ?, ?, ?, ?)");
            stmt.setString(1, "1");
            stmt.setDouble(2, 0.001);
            stmt.setFloat(3, 0.01f);
            stmt.setDouble(4, 0.001);
            stmt.setFloat(5, 0.01f);
            stmt.execute();

            stmt.setString(1, "2");
            stmt.setDouble(2, 0.002);
            stmt.setFloat(3, 0.02f);
            stmt.setDouble(4, 0.002);
            stmt.setFloat(5, 0.02f);
            stmt.execute();

            stmt.setString(1, "3");
            stmt.setDouble(2, 0.003);
            stmt.setFloat(3, 0.03f);
            stmt.setDouble(4, 0.003);
            stmt.setFloat(5, 0.03f);
            stmt.execute();

            stmt.setString(1, "4");
            stmt.setDouble(2, 0.004);
            stmt.setFloat(3, 0.04f);
            stmt.setDouble(4, 0.004);
            stmt.setFloat(5, 0.04f);
            stmt.execute();

            stmt.setString(1, "5");
            stmt.setDouble(2, 0.005);
            stmt.setFloat(3, 0.05f);
            stmt.setDouble(4, 0.005);
            stmt.setFloat(5, 0.05f);
            stmt.execute();
        } finally {
        }
    }

    protected void initATableValues() throws Exception {
        initATableValues(null);
    }
 
    protected void initATableValues(Date date) throws Exception {
        assertNotNull(conn);
        createTestTable(ATABLE_NAME);
        try {
            // Insert all rows at ts
            PreparedStatement stmt = null;
            if (tgtPH()||tgtTR()) stmt = conn.prepareStatement(
                    "upsert into " +
                    "ATABLE(" +
                    "    ORGANIZATION_ID, " +
                    "    ENTITY_ID, " +
                    "    A_STRING, " +
                    "    B_STRING, " +
                    "    A_INTEGER, " +
                    "    A_DATE, " +
                    "    X_DECIMAL, " +
                    "    X_LONG, " +
                    "    X_INTEGER," +
                    "    Y_INTEGER," +
                    "    A_BYTE," +
                    "    A_SHORT," +
                    "    A_FLOAT," +
                    "    A_DOUBLE," +
                    "    A_UNSIGNED_FLOAT," +
                    "    A_UNSIGNED_DOUBLE)" +
                    "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
            else if (tgtSQ()) stmt = conn.prepareStatement(
                    "insert into " +
                    "ATABLE(" +
                    "    ORGANIZATION_ID, " +
                    "    ENTITY_ID, " +
                    "    A_STRING, " +
                    "    B_STRING, " +
                    "    A_INTEGER, " +
                    "    A_DATE, " +
                    "    X_DECIMAL, " +
                    "    X_LONG, " +
                    "    X_INTEGER," +
                    "    Y_INTEGER," +
                    "    A_BYTE," +
                    "    A_SHORT," +
                    "    A_FLOAT," +
                    "    A_DOUBLE," +
                    "    A_UNSIGNED_FLOAT," +
                    "    A_UNSIGNED_DOUBLE)" +
                    "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");

            stmt.setString(1, tenantId);
            stmt.setString(2, ROW1);
            stmt.setString(3, A_VALUE);
            stmt.setString(4, B_VALUE);
            stmt.setInt(5, 1);
            stmt.setDate(6, date);
            stmt.setBigDecimal(7, null);
            stmt.setNull(8, Types.BIGINT);
            stmt.setNull(9, Types.INTEGER);
            stmt.setNull(10, Types.INTEGER);
            stmt.setByte(11, (byte)1);
            stmt.setShort(12, (short) 128);
            stmt.setFloat(13, 0.01f);
            stmt.setDouble(14, 0.0001);
            stmt.setFloat(15, 0.01f);
            stmt.setDouble(16, 0.0001);
            stmt.execute();

            stmt.setString(1, tenantId);
            stmt.setString(2, ROW2);
            stmt.setString(3, A_VALUE);
            stmt.setString(4, C_VALUE);
            stmt.setInt(5, 2);
            stmt.setDate(6, date == null ? null : new Date(date.getTime() + MILLIS_IN_DAY * 1));
            stmt.setBigDecimal(7, null);
            stmt.setNull(8, Types.BIGINT);
            stmt.setNull(9, Types.INTEGER);
            stmt.setNull(10, Types.INTEGER);
            stmt.setByte(11, (byte)2);
            stmt.setShort(12, (short) 129);
            stmt.setFloat(13, 0.02f);
            stmt.setDouble(14, 0.0002);
            stmt.setFloat(15, 0.02f);
            stmt.setDouble(16, 0.0002);
            stmt.execute();

            stmt.setString(1, tenantId);
            stmt.setString(2, ROW3);
            stmt.setString(3, A_VALUE);
            stmt.setString(4, E_VALUE);
            stmt.setInt(5, 3);
            stmt.setDate(6, date == null ? null : new Date(date.getTime() + MILLIS_IN_DAY * 2));
            stmt.setBigDecimal(7, null);
            stmt.setNull(8, Types.BIGINT);
            stmt.setNull(9, Types.INTEGER);
            stmt.setNull(10, Types.INTEGER);
            stmt.setByte(11, (byte)3);
            stmt.setShort(12, (short) 130);
            stmt.setFloat(13, 0.03f);
            stmt.setDouble(14, 0.0003);
            stmt.setFloat(15, 0.03f);
            stmt.setDouble(16, 0.0003);
            stmt.execute();

            stmt.setString(1, tenantId);
            stmt.setString(2, ROW4);
            stmt.setString(3, A_VALUE);
            stmt.setString(4, B_VALUE);
            stmt.setInt(5, 4);
            stmt.setDate(6, date == null ? null : date);
            stmt.setBigDecimal(7, null);
            stmt.setNull(8, Types.BIGINT);
            stmt.setNull(9, Types.INTEGER);
            stmt.setNull(10, Types.INTEGER);
            stmt.setByte(11, (byte)4);
            stmt.setShort(12, (short) 131);
            stmt.setFloat(13, 0.04f);
            stmt.setDouble(14, 0.0004);
            stmt.setFloat(15, 0.04f);
            stmt.setDouble(16, 0.0004);
            stmt.execute();

            stmt.setString(1, tenantId);
            stmt.setString(2, ROW5);
            stmt.setString(3, B_VALUE);
            stmt.setString(4, C_VALUE);
            stmt.setInt(5, 5);
            stmt.setDate(6, date == null ? null : new Date(date.getTime() + MILLIS_IN_DAY * 1));
            stmt.setBigDecimal(7, null);
            stmt.setNull(8, Types.BIGINT);
            stmt.setNull(9, Types.INTEGER);
            stmt.setNull(10, Types.INTEGER);
            stmt.setByte(11, (byte)5);
            stmt.setShort(12, (short) 132);
            stmt.setFloat(13, 0.05f);
            stmt.setDouble(14, 0.0005);
            stmt.setFloat(15, 0.05f);
            stmt.setDouble(16, 0.0005);
            stmt.execute();

            stmt.setString(1, tenantId);
            stmt.setString(2, ROW6);
            stmt.setString(3, B_VALUE);
            stmt.setString(4, E_VALUE);
            stmt.setInt(5, 6);
            stmt.setDate(6, date == null ? null : new Date(date.getTime() + MILLIS_IN_DAY * 2));
            stmt.setBigDecimal(7, null);
            stmt.setNull(8, Types.BIGINT);
            stmt.setNull(9, Types.INTEGER);
            stmt.setNull(10, Types.INTEGER);
            stmt.setByte(11, (byte)6);
            stmt.setShort(12, (short) 133);
            stmt.setFloat(13, 0.06f);
            stmt.setDouble(14, 0.0006);
            stmt.setFloat(15, 0.06f);
            stmt.setDouble(16, 0.0006);
            stmt.execute();

            stmt.setString(1, tenantId);
            stmt.setString(2, ROW7);
            stmt.setString(3, B_VALUE);
            stmt.setString(4, B_VALUE);
            stmt.setInt(5, 7);
            stmt.setDate(6, date == null ? null : date);
            stmt.setBigDecimal(7, BigDecimal.valueOf(0.1));
            stmt.setLong(8, 5L);
            stmt.setInt(9, 5);
            stmt.setNull(10, Types.INTEGER);
            stmt.setByte(11, (byte)7);
            stmt.setShort(12, (short) 134);
            stmt.setFloat(13, 0.07f);
            stmt.setDouble(14, 0.0007);
            stmt.setFloat(15, 0.07f);
            stmt.setDouble(16, 0.0007);
            stmt.execute();

            stmt.setString(1, tenantId);
            stmt.setString(2, ROW8);
            stmt.setString(3, B_VALUE);
            stmt.setString(4, C_VALUE);
            stmt.setInt(5, 8);
            stmt.setDate(6, date == null ? null : new Date(date.getTime() + MILLIS_IN_DAY * 1));
            stmt.setBigDecimal(7, BigDecimal.valueOf(3.9));
            long l = Integer.MIN_VALUE - 1L;
            assert(l < Integer.MIN_VALUE);
            stmt.setLong(8, l);
            stmt.setInt(9, 4);
            stmt.setNull(10, Types.INTEGER);
            stmt.setByte(11, (byte)8);
            stmt.setShort(12, (short) 135);
            stmt.setFloat(13, 0.08f);
            stmt.setDouble(14, 0.0008);
            stmt.setFloat(15, 0.08f);
            stmt.setDouble(16, 0.0008);
            stmt.execute();

            stmt.setString(1, tenantId);
            stmt.setString(2, ROW9);
            stmt.setString(3, C_VALUE);
            stmt.setString(4, E_VALUE);
            stmt.setInt(5, 9);
            stmt.setDate(6, date == null ? null : new Date(date.getTime() + MILLIS_IN_DAY * 2));
            stmt.setBigDecimal(7, BigDecimal.valueOf(3.3));
            l = Integer.MAX_VALUE + 1L;
            assert(l > Integer.MAX_VALUE);
            stmt.setLong(8, l);
            stmt.setInt(9, 3);
            stmt.setInt(10, 300);
            stmt.setByte(11, (byte)9);
            stmt.setShort(12, (short) 0);
            stmt.setFloat(13, 0.09f);
            stmt.setDouble(14, 0.0009);
            stmt.setFloat(15, 0.09f);
            stmt.setDouble(16, 0.0009);
            stmt.execute();
        } finally {
        }
    }

    protected String getExplainPlan(ResultSet rs) throws SQLException {
        String output = "";
        try {
            while (rs.next()) {
                output += rs.getString(1);
                output += '\n';
            }
        } finally {
        }
        // System.out.println(output);
        return output;
    }
}