com.mapd.parser.server.test.TestDBServer Class Reference

Collaboration diagram for com.mapd.parser.server.test.TestDBServer:

Classes
class	ConnInfo

Public Member Functions
void	testThreadedCall ()

Private Member Functions
void	randomDBCall (ConnInfo conn)
ConnInfo	createDBConnection ()
void	executeQuery (ConnInfo conn, String query, int resultCount)
void	closeDBConnection (ConnInfo conn)

Private Attributes
volatile int	threadsRun = 0
volatile boolean	threadHadFailure = false
volatile AssertionError	ae

Static Private Attributes
static final Logger	HEAVYDBLOGGER = LoggerFactory.getLogger(TestDBServer.class)
static final int	TEST_THREAD_COUNT = 2
static CalciteServerWrapper	csw = null

Detailed Description

Definition at line 41 of file TestDBServer.java.

Member Function Documentation

void com.mapd.parser.server.test.TestDBServer.closeDBConnection ( ConnInfo  conn )

inlineprivate

Definition at line 141 of file TestDBServer.java.

Referenced by com.mapd.parser.server.test.TestDBServer.testThreadedCall().

                                                {
    try {
      conn.client.disconnect(conn.session);
      conn.transport.close();
    } catch (TException x) {
      fail("Exception on close occurred " + x.toString());
    }
  }

Here is the caller graph for this function:

ConnInfo com.mapd.parser.server.test.TestDBServer.createDBConnection ( )

inlineprivate

Definition at line 111 of file TestDBServer.java.

Referenced by com.mapd.parser.server.test.TestDBServer.testThreadedCall().

                                        {
    String session = null;
    TTransport transport = null;
    Heavy.Client client = null;
    try {
      transport = new TSocket("localhost", 6274);
      transport.open();
      TProtocol protocol = new TBinaryProtocol(transport);
      client = new Heavy.Client(protocol);
      session = client.connect("admin", "HyperInteractive", "omnisci");
    } catch (TException x) {
      fail("Exception on create occurred " + x.toString());
    }
    return new ConnInfo(session, transport, client);
  }

Here is the caller graph for this function:

void com.mapd.parser.server.test.TestDBServer.executeQuery ( ConnInfo  conn, String  query, int  resultCount  )

inlineprivate

Definition at line 127 of file TestDBServer.java.

References run_benchmark_import.res.

Referenced by com.mapd.parser.server.test.TestDBServer.randomDBCall().

                                                                          {
    try {
      TQueryResult res = conn.client.sql_execute(conn.session, query, true, null, -1, -1);
      if (resultCount != res.row_set.columns.get(0).nulls.size()) {
        fail("result doesn't match " + resultCount
                + " != " + res.row_set.columns.get(0).nulls.size());
      }
    } catch (TDBException x) {
      fail("Exception on EXECUTE " + x.getError_msg());
    } catch (TException x) {
      fail("Exception on EXECUTE " + x.toString());
    }
  }

Here is the caller graph for this function:

void com.mapd.parser.server.test.TestDBServer.randomDBCall ( ConnInfo  conn )

inlineprivate

Definition at line 98 of file TestDBServer.java.

References com.mapd.parser.server.test.TestDBServer.executeQuery().

Referenced by com.mapd.parser.server.test.TestDBServer.testThreadedCall().

                                           {
    Random r = new Random();
    int aliasID = r.nextInt(100000) + 1000000;
    int limit = r.nextInt(20) + 1;
    // executeQuery(conn, String.format("Select TABALIAS%d.dest_lon AS COLALIAS%d
    // from
    // flights TABALIAS%d LIMIT %d",
    // aliasID, aliasID, aliasID, limit), limit);
    executeQuery(conn,
            "SELECT date_trunc(day, arr_timestamp) as key0,CASE when carrier_name IN ('Southwest Airlines','American Airlines','Skywest Airlines','American Eagle Airlines','US Airways') then carrier_name ELSE 'other' END as key1,COUNT(*) AS val FROM flights_2008_7m WHERE (arr_timestamp >= TIMESTAMP(0) '2008-01-01 00:57:00' AND arr_timestamp < TIMESTAMP(0) '2009-01-01 18:27:00') GROUP BY key0, key1 ORDER BY key0,key1",
            2202);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

void com.mapd.parser.server.test.TestDBServer.testThreadedCall ( )

inline

Definition at line 50 of file TestDBServer.java.

References com.mapd.parser.server.test.TestDBServer.ae, com.mapd.parser.server.test.TestDBServer.closeDBConnection(), report.conn, com.mapd.parser.server.test.TestDBServer.createDBConnection(), com.mapd.parser.server.test.TestDBServer.randomDBCall(), run, com.mapd.parser.server.test.TestDBServer.TEST_THREAD_COUNT, com.mapd.parser.server.test.TestDBServer.threadHadFailure, and com.mapd.parser.server.test.TestDBServer.threadsRun.

                                 {
    final ExecutorService pool = Executors.newFixedThreadPool(TEST_THREAD_COUNT);

    Runnable r = new Runnable() {
      @Override
      public void run() {
        try {
          ConnInfo conn = createDBConnection();
          Random r = new Random();
          int calCount = r.nextInt(9) + 1;
          int calls = 0;
          for (int i = 1; i <= 100; i++) {
            // if (i%100 == 0){
            System.out.println("i is " + i);
            // }
            if (calls > calCount) {
              closeDBConnection(conn);
              conn = createDBConnection();
              calCount = r.nextInt(9) + 1;
              calls = 0;
            }
            randomDBCall(conn);
            calls++;
          }
          closeDBConnection(conn);
        } catch (AssertionError x) {
          HEAVYDBLOGGER.error("error during Runnable");
          threadHadFailure = true;
          ae = x;
        }
        threadsRun++;
        if (threadsRun >= TEST_THREAD_COUNT) {
          pool.shutdown();
        }
      }
    };

    for (int i = 0; i < TEST_THREAD_COUNT; i++) {
      pool.submit(r);
    }
    while (!pool.isShutdown()) {
      // stay alive
    }
    if (threadHadFailure) {
      throw ae;
    }
  }

Here is the call graph for this function:

Member Data Documentation

volatile AssertionError com.mapd.parser.server.test.TestDBServer.ae

private

Definition at line 46 of file TestDBServer.java.

Referenced by com.mapd.parser.server.test.TestDBServer.testThreadedCall().

CalciteServerWrapper com.mapd.parser.server.test.TestDBServer.csw = null

staticprivate

Definition at line 47 of file TestDBServer.java.

final Logger com.mapd.parser.server.test.TestDBServer.HEAVYDBLOGGER = LoggerFactory.getLogger(TestDBServer.class)

staticprivate

Definition at line 42 of file TestDBServer.java.

final int com.mapd.parser.server.test.TestDBServer.TEST_THREAD_COUNT = 2

staticprivate

Definition at line 43 of file TestDBServer.java.

Referenced by com.mapd.parser.server.test.TestDBServer.testThreadedCall().

volatile boolean com.mapd.parser.server.test.TestDBServer.threadHadFailure = false

private

Definition at line 45 of file TestDBServer.java.

Referenced by com.mapd.parser.server.test.TestDBServer.testThreadedCall().

volatile int com.mapd.parser.server.test.TestDBServer.threadsRun = 0

private

Definition at line 44 of file TestDBServer.java.

Referenced by com.mapd.parser.server.test.TestDBServer.testThreadedCall().

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/java/calcite/src/test/java/com/heavydb/parser/server/test/TestDBServer.java