OmniSciDatabaseMetaData.java

Go to the documentation of this file.

/*
 * Copyright 2018 MapD Technologies, Inc.
 *
 * Licensed 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 com.omnisci.jdbc;

import com.omnisci.thrift.server.TColumn;
import com.omnisci.thrift.server.TColumnData;
import com.omnisci.thrift.server.TColumnType;
import com.omnisci.thrift.server.TDBInfo;
import com.omnisci.thrift.server.TDBObject;
import com.omnisci.thrift.server.TDBObjectType;
import com.omnisci.thrift.server.TDatumType;
import com.omnisci.thrift.server.TEncodingType;
import com.omnisci.thrift.server.TQueryResult;
import com.omnisci.thrift.server.TRowSet;
import com.omnisci.thrift.server.TTableDetails;
import com.omnisci.thrift.server.TTablePermissions;
import com.omnisci.thrift.server.TTypeInfo;

import org.apache.thrift.TException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.ResultSet;
import java.sql.RowIdLifetime;
import java.sql.SQLException;
import java.util.*;

class OmniSciDatabaseMetaData implements DatabaseMetaData {
  final static Logger MAPDLOGGER = LoggerFactory.getLogger(OmniSciDatabaseMetaData.class);

  OmniSciConnection con = null;
  int databaseMajorVersion = 0;
  int databaseMinorVersion = 0;
  String databaseVersion = null;

  public OmniSciDatabaseMetaData(OmniSciConnection connection) throws SQLException {
    this.con = connection;

    try {
      databaseVersion = con.client.get_version();
    } catch (TException ex) {
      throw new SQLException("Failed to get DB version " + ex.toString());
    }
    String vers[] = databaseVersion.split("\\.");
    try {
      databaseMajorVersion = Integer.parseInt(vers[0]);
      databaseMinorVersion = Integer.parseInt(vers[1]);
    } catch (NumberFormatException ex) {
      throw new SQLException(
              "Non-numeric version returned from OmniSci server: " + ex.getMessage());
    }
  }

  @Override
  public boolean allProceduresAreCallable() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean allTablesAreSelectable() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public String getURL() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return con.url;
  }

  @Override
  public String getUserName() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return (String) con.cP.get(Options.user);
  }

  @Override
  public boolean isReadOnly() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean nullsAreSortedHigh() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean nullsAreSortedLow() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean nullsAreSortedAtStart() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean nullsAreSortedAtEnd() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public String getDatabaseProductName() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return "OmniSciDB";
  }

  @Override
  public String getDatabaseProductVersion()
          throws SQLException { // logger.debug("Entered");
    MAPDLOGGER.debug("Entered");
    return this.databaseVersion;
  }

  @Override
  public String getDriverName() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return "OmniSciDB JDBC Driver";
  }

  @Override
  public String getDriverVersion() throws SQLException { // logger.debug("Entered");
    MAPDLOGGER.debug("Entered");
    return OmniSciDriver.DriverVersion;
  }

  @Override
  public int getDriverMajorVersion() {
    return OmniSciDriver.DriverMajorVersion;
  }

  @Override
  public int getDriverMinorVersion() {
    return OmniSciDriver.DriverMinorVersion;
  }

  @Override
  public boolean usesLocalFiles() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean usesLocalFilePerTable() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsMixedCaseIdentifiers() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean storesUpperCaseIdentifiers() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean storesLowerCaseIdentifiers() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean storesMixedCaseIdentifiers() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsMixedCaseQuotedIdentifiers() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean storesUpperCaseQuotedIdentifiers() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean storesLowerCaseQuotedIdentifiers() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean storesMixedCaseQuotedIdentifiers() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public String getIdentifierQuoteString() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return " ";
  }

  @Override
  public String getSQLKeywords() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return "";
  }

  @Override
  public String getNumericFunctions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return "ACOS(float), ACOS(number), ASIN, ATAN2, CEIL, COS, COT, DEGREES, EXP, FLOOR, LN, LOG, PI(), POWER, SQRT"
            + ", RADIANS, ROUND, SIN, TAN, ATAN, ABS, MOD SIGN, TRUNCATE";
  }

  @Override
  public String getStringFunctions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return "CHAR_LENGTH, CHAR, KEY_FOR_STRING";
  }

  @Override
  public String getSystemFunctions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return "";
  }

  @Override
  public String getTimeDateFunctions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    // return "NOW,CURDATE,SECOND,HOUR,YEAR,EXTRACT,QUARTER,WEEK,MONTH,DATETRUNC";
    return "DATE_TRUNC, NOW, EXTRACT";
  }

  @Override
  public String getSearchStringEscape() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return "\\";
  }

  @Override
  public String getExtraNameCharacters() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return "";
  }

  @Override
  public boolean supportsAlterTableWithAddColumn() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsAlterTableWithDropColumn() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsColumnAliasing() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean nullPlusNonNullIsNull() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsConvert() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsConvert(int fromType, int toType) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsTableCorrelationNames() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsDifferentTableCorrelationNames() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsExpressionsInOrderBy() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsOrderByUnrelated() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsGroupBy() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsGroupByUnrelated() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsGroupByBeyondSelect() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsLikeEscapeClause() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsMultipleResultSets() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsMultipleTransactions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsNonNullableColumns() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsMinimumSQLGrammar() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsCoreSQLGrammar() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsExtendedSQLGrammar() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsANSI92EntryLevelSQL() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsANSI92IntermediateSQL() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsANSI92FullSQL() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsIntegrityEnhancementFacility() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsOuterJoins() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsFullOuterJoins() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsLimitedOuterJoins() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public String getSchemaTerm() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return "Database";
  }

  @Override
  public String getProcedureTerm() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return "N/A";
  }

  @Override
  public String getCatalogTerm() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return "N/A";
  }

  @Override
  public boolean isCatalogAtStart() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public String getCatalogSeparator() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return ".";
  }

  @Override
  public boolean supportsSchemasInDataManipulation() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsSchemasInProcedureCalls() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsSchemasInTableDefinitions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsSchemasInIndexDefinitions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsSchemasInPrivilegeDefinitions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsCatalogsInDataManipulation() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsCatalogsInProcedureCalls() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsCatalogsInTableDefinitions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsCatalogsInIndexDefinitions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsCatalogsInPrivilegeDefinitions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsPositionedDelete() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsPositionedUpdate() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsSelectForUpdate() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsStoredProcedures() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsSubqueriesInComparisons() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsSubqueriesInExists() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsSubqueriesInIns() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsSubqueriesInQuantifieds() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public boolean supportsCorrelatedSubqueries() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsUnion() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsUnionAll() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsOpenCursorsAcrossCommit() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsOpenCursorsAcrossRollback() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsOpenStatementsAcrossCommit() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsOpenStatementsAcrossRollback() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public int getMaxBinaryLiteralLength() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxCharLiteralLength() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxColumnNameLength() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxColumnsInGroupBy() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxColumnsInIndex() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxColumnsInOrderBy() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxColumnsInSelect() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxColumnsInTable() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxConnections() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxCursorNameLength() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxIndexLength() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxSchemaNameLength() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxProcedureNameLength() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxCatalogNameLength() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxRowSize() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public boolean doesMaxRowSizeIncludeBlobs() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public int getMaxStatementLength() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxStatements() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxTableNameLength() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxTablesInSelect() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getMaxUserNameLength() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getDefaultTransactionIsolation() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return Connection.TRANSACTION_NONE;
  }

  @Override
  public boolean supportsTransactions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsTransactionIsolationLevel(int level) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsDataDefinitionAndDataManipulationTransactions()
          throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsDataManipulationTransactionsOnly() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean dataDefinitionCausesTransactionCommit() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean dataDefinitionIgnoredInTransactions() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public ResultSet getProcedures(
          String catalog, String schemaPattern, String procedureNamePattern)
          throws SQLException {
    MAPDLOGGER.debug("Entered");
    return null;
    //    throw new UnsupportedOperationException("Not supported yet," + " line:" + new
    //    Throwable().getStackTrace()[0].
    //            getLineNumber() + " class:" + new
    //            Throwable().getStackTrace()[0].getClassName() + " method:" + new
    //            Throwable(). getStackTrace()[0].getMethodName());
  }

  @Override
  public ResultSet getProcedureColumns(String catalog,
          String schemaPattern,
          String procedureNamePattern,
          String columnNamePattern) throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  /*
   * Wrappers for creating new TColumnType. Required so that the Thrift struct
   * can be modified without breaking code.
   */
  public TColumnType createTColumnType(String colName, TTypeInfo colType) {
    return createTColumnType(colName, colType, false);
  }

  public TColumnType createTColumnType(String colName, TTypeInfo colType, Boolean irk) {
    TColumnType ct = new TColumnType();
    ct.col_name = colName;
    ct.col_type = colType;
    ct.is_reserved_keyword = irk;
    ct.is_system = false;
    ct.is_physical = false;
    return ct;
  }

  /*
Retrieves a description of the tables available in the given catalog. Only table
descriptions matching the catalog, schema, table name and type criteria are returned. They
are ordered by TABLE_TYPE, TABLE_CAT, TABLE_SCHEM and TABLE_NAME. Each table description
has the following columns:

TABLE_CAT String => table catalog (may be null)
TABLE_SCHEM String => table schema (may be null)
TABLE_NAME String => table name
TABLE_TYPE String => table type. Typical types are "TABLE", "VIEW", "SYSTEM TABLE",
"GLOBAL TEMPORARY", "LOCAL TEMPORARY", "ALIAS", "SYNONYM". REMARKS String => explanatory
comment on the table TYPE_CAT String => the types catalog (may be null) TYPE_SCHEM String
=> the types schema (may be null) TYPE_NAME String => type name (may be null)
SELF_REFERENCING_COL_NAME String => name of the designated "identifier" column of a typed
table (may be null) REF_GENERATION String => specifies how values in
SELF_REFERENCING_COL_NAME are created. Values are "SYSTEM", "USER", "DERIVED". (may be
null) Note: Some databases may not return information for all tables.

Parameters:
catalog - a catalog name; must match the catalog name as it is stored in the database; ""
retrieves those without a catalog; null means that the catalog name should not be used to
narrow the search schemaPattern - a schema name pattern; must match the schema name as it
is stored in the database; "" retrieves those without a schema; null means that the schema
name should not be used to narrow the search tableNamePattern - a table name pattern; must
match the table name as it is stored in the database types - a list of table types, which
must be from the list of table types returned from getTableTypes(),to include; null
returns all types Returns: ResultSet - each row is a table description Throws:
SQLException - if a database access error occurs
   */
  @Override
  public ResultSet getTables(
          String catalog, String schemaPattern, String tableNamePattern, String[] types)
          throws SQLException {
    MAPDLOGGER.debug("Entered");

    List<String> tables;
    try {
      tables = con.client.get_tables(con.session);
    } catch (TException ex) {
      throw new SQLException("get_tables failed " + ex.toString());
    }

    List<String> views;
    try {
      views = con.client.get_views(con.session);
    } catch (TException ex) {
      throw new SQLException("get_views failed " + ex.toString());
    }

    TTypeInfo strTTI =
            new TTypeInfo(TDatumType.STR, TEncodingType.NONE, false, false, 0, 0, 0);
    TColumnType columns[] = {createTColumnType("TABLE_CAT", new TTypeInfo(strTTI)),
            createTColumnType("TABLE_SCHEM", new TTypeInfo(strTTI)),
            createTColumnType("TABLE_NAME", new TTypeInfo(strTTI)),
            createTColumnType("TABLE_TYPE", new TTypeInfo(strTTI)),
            createTColumnType("REMARKS", new TTypeInfo(strTTI)),
            createTColumnType("TYPE_CAT", new TTypeInfo(strTTI)),
            createTColumnType("TYPE_SCHEM", new TTypeInfo(strTTI)),
            createTColumnType("TYPE_NAME", new TTypeInfo(strTTI)),
            createTColumnType("SELF_REFERENCING_COL_NAME", new TTypeInfo(strTTI)),
            createTColumnType("REF_GENERATION", new TTypeInfo(strTTI))};

    Map<String, ArrayList<String>> dataMap = new HashMap(columns.length);
    Map<String, ArrayList<Boolean>> nullMap = new HashMap(columns.length);

    // create component to contain the meta data for the rows
    // and create  a container to store the data and the nul indicators
    List<TColumnType> rowDesc = new ArrayList(columns.length);
    for (TColumnType col : columns) {
      rowDesc.add(col);
      dataMap.put(col.col_name, new ArrayList());
      nullMap.put(col.col_name, new ArrayList());
    }
    if (schemaPattern == null
            || schemaPattern.toLowerCase().equals(con.getCatalog().toLowerCase())) {
      // Now add some actual details for table name
      for (String x : tables) {
        dataMap.get("TABLE_NAME").add(x);
        nullMap.get("TABLE_NAME").add(false);
        nullMap.get("TABLE_SCHEM").add(true);
        nullMap.get("TABLE_CAT").add(true);
        if (views.contains(x) == true) {
          dataMap.get("TABLE_TYPE").add("VIEW");
        } else {
          dataMap.get("TABLE_TYPE").add("TABLE");
        }
        nullMap.get("TABLE_TYPE").add(false);
        nullMap.get("REMARKS").add(true);
        nullMap.get("TYPE_CAT").add(true);
        nullMap.get("TYPE_SCHEM").add(true);
        nullMap.get("TYPE_NAME").add(true);
        nullMap.get("SELF_REFERENCING_COL_NAME").add(true);
        nullMap.get("REF_GENERATION").add(true);
      }
    }
    List<TColumn> columnsList = new ArrayList(columns.length);

    for (TColumnType col : columns) {
      TColumn schemaCol =
              createTColumnData(dataMap.get(col.col_name), nullMap.get(col.col_name));
      columnsList.add(schemaCol);
    }

    // create a rowset for the result
    TRowSet rowSet = new TRowSet(rowDesc, null, columnsList, true);

    TQueryResult result = new TQueryResult(
            rowSet, 0, 0, null, null, true, com.omnisci.thrift.server.TQueryType.UNKNOWN);

    OmniSciResultSet tab = new OmniSciResultSet(result, "GetTables");
    return tab;
  }

  // need to add type to this currently only does str type
  private TColumn createTColumnData(Object data, List<Boolean> nullsList) {
    TColumnData colData = new TColumnData();
    colData.setStr_col((List<String>) data);

    TColumn col = new TColumn(colData, nullsList);
    return col;
  }

  @Override
  public ResultSet getSchemas() throws SQLException {
    MAPDLOGGER.debug("Entered");

    List<TDBInfo> databases = null;

    try {
      databases = con.client.get_databases(con.session);
    } catch (TException ex) {
      throw new SQLException("get_database failed " + ex.toString());
    }

    // process info from databses into the resultset, then place in regular return from
    // MapD
    TTypeInfo strTTI =
            new TTypeInfo(TDatumType.STR, TEncodingType.NONE, false, false, 0, 0, 0);
    TColumnType columns[] = {createTColumnType("TABLE_SCHEM", new TTypeInfo(strTTI)),
            createTColumnType("TABLE_CATALOG", new TTypeInfo(strTTI))};
    // create component to contain the meta data for the rows
    List<TColumnType> rowDesc = new ArrayList();
    for (TColumnType col : columns) {
      rowDesc.add(col);
    }

    // Now add some actual details for schema name
    List<String> schemaList = new ArrayList();
    List<Boolean> nullList = new ArrayList();
    List<Boolean> catalogNullList = new ArrayList();

    for (TDBInfo x : databases) {
      schemaList.add(x.db_name);
      nullList.add(false);
      catalogNullList.add(true);
    }

    TColumnData colData = new TColumnData();
    colData.setStr_col(schemaList);

    TColumn schemaCol = new TColumn(colData, nullList);
    TColumn catalogCol = new TColumn(null, catalogNullList);

    List<TColumn> columnsList = new ArrayList();
    columnsList.add(schemaCol);
    columnsList.add(catalogCol);

    // create a rowset for the result
    TRowSet rowSet = new TRowSet(rowDesc, null, columnsList, true);

    TQueryResult result = new TQueryResult(
            rowSet, 0, 0, null, null, true, com.omnisci.thrift.server.TQueryType.UNKNOWN);

    OmniSciResultSet schemas = new OmniSciResultSet(result, "getSchemas");
    return schemas;
  }

  @Override
  public ResultSet getCatalogs() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return getSchemas();
  }

  @Override
  public ResultSet getTableTypes() throws SQLException {
    MAPDLOGGER.debug("Entered");

    TTypeInfo strTTI =
            new TTypeInfo(TDatumType.STR, TEncodingType.NONE, false, false, 0, 0, 0);
    TColumnType columns[] = {createTColumnType("TABLE_TYPE", new TTypeInfo(strTTI))};

    Map<String, OmniSciData> dataMap = new HashMap(columns.length);

    // create component to contain the meta data for the rows
    // and create  a container to store the data and the nul indicators
    List<TColumnType> rowDesc = new ArrayList(columns.length);
    for (TColumnType col : columns) {
      rowDesc.add(col);
      dataMap.put(col.col_name, new OmniSciData(col.col_type.type));
    }

    // Now add some actual details for table name
    dataMap.get("TABLE_TYPE").add("TABLE");
    dataMap.get("TABLE_TYPE").add("VIEW");

    List<TColumn> columnsList = new ArrayList(columns.length);

    for (TColumnType col : columns) {
      TColumn schemaCol = dataMap.get(col.col_name).getTColumn();
      columnsList.add(schemaCol);
    }

    // create a rowset for the result
    TRowSet rowSet = new TRowSet(rowDesc, null, columnsList, true);

    TQueryResult result = new TQueryResult(
            rowSet, 0, 0, null, null, true, com.omnisci.thrift.server.TQueryType.UNKNOWN);

    OmniSciResultSet tab = new OmniSciResultSet(result, "getTableTypes");

    // logger.info("Dump result "+ result.toString());
    return tab;
  }

  /*
  Retrieves a description of table columns available in the specified catalog.
Only column descriptions matching the catalog, schema, table and column name criteria are
returned. They are ordered by TABLE_CAT,TABLE_SCHEM, TABLE_NAME, and ORDINAL_POSITION.

Each column description has the following columns:

TABLE_CAT String => table catalog (may be null)
TABLE_SCHEM String => table schema (may be null)
TABLE_NAME String => table name
COLUMN_NAME String => column name
DATA_TYPE int => SQL type from java.sql.Types
TYPE_NAME String => Data source dependent type name, for a UDT the type name is fully
qualified COLUMN_SIZE int => column size. BUFFER_LENGTH is not used. DECIMAL_DIGITS int =>
the number of fractional digits. Null is returned for data types where DECIMAL_DIGITS is
not applicable. NUM_PREC_RADIX int => Radix (typically either 10 or 2) NULLABLE int => is
NULL allowed. columnNoNulls - might not allow NULL values columnNullable - definitely
allows NULL values columnNullableUnknown - nullability unknown REMARKS String => comment
describing column (may be null) COLUMN_DEF String => default value for the column, which
should be interpreted as a string when the value is enclosed in single quotes (may be
null) SQL_DATA_TYPE int => unused SQL_DATETIME_SUB int => unused CHAR_OCTET_LENGTH int =>
for char types the maximum number of bytes in the column ORDINAL_POSITION int => index of
column in table (starting at 1) IS_NULLABLE String => ISO rules are used to determine the
nullability for a column. YES --- if the column can include NULLs NO --- if the column
cannot include NULLs empty string --- if the nullability for the column is unknown
SCOPE_CATALOG String => catalog of table that is the scope of a reference attribute (null
if DATA_TYPE isn't REF) SCOPE_SCHEMA String => schema of table that is the scope of a
reference attribute (null if the DATA_TYPE isn't REF) SCOPE_TABLE String => table name
that this the scope of a reference attribute (null if the DATA_TYPE isn't REF)
SOURCE_DATA_TYPE short => source type of a distinct type or user-generated Ref type, SQL
type from java.sql.Types (null if DATA_TYPE isn't DISTINCT or user-generated REF)
IS_AUTOINCREMENT String => Indicates whether this column is auto incremented
YES --- if the column is auto incremented
NO --- if the column is not auto incremented
empty string --- if it cannot be determined whether the column is auto incremented
IS_GENERATEDCOLUMN String => Indicates whether this is a generated column
YES --- if this a generated column
NO --- if this not a generated column
empty string --- if it cannot be determined whether this is a generated column
The COLUMN_SIZE column specifies the column size for the given column. For numeric data,
this is the maximum precision. For character data, this is the length in characters. For
datetime datatypes, this is the length in characters of the String representation
(assuming the maximum allowed precision of the fractional seconds component). For binary
data, this is the length in bytes. For the ROWID datatype, this is the length in bytes.
Null is returned for data types where the column size is not applicable.

Parameters:
catalog - a catalog name; must match the catalog name as it is stored in the database; ""
retrieves those without a catalog; null means that the catalog name should not be used to
narrow the search schemaPattern - a schema name pattern; must match the schema name as it
is stored in the database; "" retrieves those without a schema; null means that the schema
name should not be used to narrow the search tableNamePattern - a table name pattern; must
match the table name as it is stored in the database columnNamePattern - a column name
pattern; must match the column name as it is stored in the database Returns: ResultSet -
each row is a column description Throws: SQLException - if a database access error occurs
   */
  @Override
  public ResultSet getColumns(String catalog,
          String schemaPattern,
          String tableNamePattern,
          String columnNamePattern) throws SQLException {
    MAPDLOGGER.debug("Entered");
    MAPDLOGGER.debug("TablePattern " + tableNamePattern + " columnNamePattern "
            + columnNamePattern);
    String modifiedTablePattern = tableNamePattern.replaceAll("%", ".*");
    String modifiedColumnPattern =
            (columnNamePattern == null) ? null : columnNamePattern.replaceAll("%", ".*");

    MAPDLOGGER.debug("TablePattern " + tableNamePattern + " modifiedColumnPattern "
            + modifiedColumnPattern);

    // declare the columns in the result set
    TTypeInfo strTTI =
            new TTypeInfo(TDatumType.STR, TEncodingType.NONE, false, false, 0, 0, 0);
    TTypeInfo intTTI =
            new TTypeInfo(TDatumType.INT, TEncodingType.NONE, false, false, 0, 0, 0);
    TTypeInfo smallIntTTI =
            new TTypeInfo(TDatumType.SMALLINT, TEncodingType.NONE, false, false, 0, 0, 0);
    TColumnType columns[] = {createTColumnType("TABLE_CAT", new TTypeInfo(strTTI)),
            createTColumnType("TABLE_SCHEM", new TTypeInfo(strTTI)),
            createTColumnType("TABLE_NAME", new TTypeInfo(strTTI)),
            createTColumnType("COLUMN_NAME", new TTypeInfo(strTTI)),
            createTColumnType("DATA_TYPE", new TTypeInfo(intTTI)),
            createTColumnType("TYPE_NAME", new TTypeInfo(strTTI)),
            createTColumnType("COLUMN_SIZE", new TTypeInfo(intTTI)),
            createTColumnType("BUFFER_LENGTH", new TTypeInfo(strTTI)),
            createTColumnType("DECIMAL_DIGITS", new TTypeInfo(intTTI)),
            createTColumnType("NUM_PREC_RADIX", new TTypeInfo(intTTI)),
            createTColumnType("NULLABLE", new TTypeInfo(intTTI)),
            createTColumnType("REMARKS", new TTypeInfo(strTTI)),
            createTColumnType("COLUMN_DEF", new TTypeInfo(strTTI)),
            createTColumnType("SQL_DATA_TYPE", new TTypeInfo(intTTI)),
            createTColumnType("SQL_DATETIME_SUB", new TTypeInfo(intTTI)),
            createTColumnType("CHAR_OCTET_LENGTH", new TTypeInfo(intTTI)),
            createTColumnType("ORDINAL_POSITION", new TTypeInfo(intTTI)),
            createTColumnType("IS_NULLABLE", new TTypeInfo(strTTI)),
            createTColumnType("SCOPE_CATALOG", new TTypeInfo(strTTI)),
            createTColumnType("SCOPE_SCHEMA", new TTypeInfo(strTTI)),
            createTColumnType("SCOPE_TABLE", new TTypeInfo(strTTI)),
            createTColumnType("SOURCE_DATA_TYPE", new TTypeInfo(smallIntTTI)),
            createTColumnType("IS_AUTOINCREMENT", new TTypeInfo(strTTI)),
            createTColumnType("IS_GENERATEDCOLUMN", new TTypeInfo(strTTI))};

    Map<String, OmniSciData> dataMap = new HashMap(columns.length);

    // create component to contain the meta data for the rows
    // and create  a container to store the data and the nul indicators
    List<TColumnType> rowDesc = new ArrayList(columns.length);
    for (TColumnType col : columns) {
      rowDesc.add(col);
      dataMap.put(col.col_name, new OmniSciData(col.col_type.type));
    }

    // Now add some actual details for table name
    List<String> tables;
    try {
      tables = con.client.get_tables(con.session);

      for (String tableName : tables) {
        // check if the table matches the input pattern
        if (tableNamePattern == null || tableNamePattern.equals(tableName)) {
          // grab meta data for table
          TTableDetails tableDetails =
                  con.client.get_table_details(con.session, tableName);

          int ordinal = 0;
          // iterate through the columns
          for (TColumnType value : tableDetails.row_desc) {
            ordinal++;
            if (columnNamePattern == null
                    || value.col_name.matches(modifiedColumnPattern)) {
              dataMap.get("TABLE_CAT").setNull(true);
              dataMap.get("TABLE_SCHEM").setNull(true);
              dataMap.get("TABLE_NAME").add(tableName);
              dataMap.get("COLUMN_NAME").add(value.col_name);
              dataMap.get("DATA_TYPE").add(OmniSciType.toJava(value.col_type.type));
              dataMap.get("TYPE_NAME")
                      .add((value.col_type.type.name()
                              + (value.col_type.is_array ? "[]" : "")));
              if (value.col_type.type == TDatumType.DECIMAL) {
                dataMap.get("COLUMN_SIZE").add(value.col_type.precision);
              } else {
                dataMap.get("COLUMN_SIZE").add(100);
              }
              dataMap.get("BUFFER_LENGTH").setNull(true);
              if (value.col_type.type == TDatumType.DECIMAL) {
                dataMap.get("DECIMAL_DIGITS").add(value.col_type.scale);
              } else {
                dataMap.get("DECIMAL_DIGITS").setNull(true);
              }
              dataMap.get("NUM_PREC_RADIX").add(10);
              dataMap.get("NULLABLE")
                      .add(value.col_type.nullable ? DatabaseMetaData.columnNullable
                                                   : DatabaseMetaData.columnNoNulls);
              dataMap.get("REMARKS").add(" ");
              dataMap.get("COLUMN_DEF").setNull(true);
              dataMap.get("SQL_DATA_TYPE").add(0);
              dataMap.get("SQL_DATETIME_SUB").setNull(true);
              dataMap.get("CHAR_OCTET_LENGTH").add(0);
              dataMap.get("ORDINAL_POSITION").add(ordinal);
              dataMap.get("IS_NULLABLE").add(value.col_type.nullable ? "YES" : "NO");
              dataMap.get("SCOPE_CATALOG").setNull(true);
              dataMap.get("SCOPE_SCHEMA").setNull(true);
              dataMap.get("SCOPE_TABLE").setNull(true);
              dataMap.get("SOURCE_DATA_TYPE")
                      .add(OmniSciType.toJava(value.col_type.type));
              dataMap.get("IS_AUTOINCREMENT").add("NO");
              dataMap.get("IS_GENERATEDCOLUMN").add("NO");
            }
          }
        }
      }
    } catch (TException ex) {
      throw new SQLException("get_tables failed " + ex.toString());
    }

    List<TColumn> columnsList = new ArrayList(columns.length);

    for (TColumnType col : columns) {
      TColumn schemaCol = dataMap.get(col.col_name).getTColumn();
      // logger.info("Tcolumn is "+ schemaCol.toString());
      columnsList.add(schemaCol);
    }

    // create a rowset for the result
    TRowSet rowSet = new TRowSet(rowDesc, null, columnsList, true);

    TQueryResult result = new TQueryResult(
            rowSet, 0, 0, null, null, true, com.omnisci.thrift.server.TQueryType.UNKNOWN);

    OmniSciResultSet cols = new OmniSciResultSet(result, "getColumns");
    return cols;
  }

  @Override
  public ResultSet getColumnPrivileges(
          String catalog, String schema, String table, String columnNamePattern)
          throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  public ResultSet getEmptyResultSet() {
    return new OmniSciResultSet();
  }

  // this method is needed to build an empty resultset with columns names and datatypes
  public ResultSet getEmptyResultSetWithDesc(TColumnType columns[])
          throws SQLException { // for compatibility and future
    Map<String, OmniSciData> dataMap = new HashMap(columns.length);
    List<TColumnType> rowDesc = new ArrayList(columns.length);
    for (TColumnType col : columns) {
      rowDesc.add(col);
      dataMap.put(col.col_name, new OmniSciData(col.col_type.type));
    }
    List<TColumn> columnsList = new ArrayList(columns.length);
    for (TColumnType col : columns) {
      TColumn schemaCol = dataMap.get(col.col_name).getTColumn();
      columnsList.add(schemaCol);
    }
    TRowSet rowSet = new TRowSet(rowDesc, null, columnsList, true);
    TQueryResult result = new TQueryResult(
            rowSet, 0, 0, null, null, true, com.omnisci.thrift.server.TQueryType.UNKNOWN);
    OmniSciResultSet cols = new OmniSciResultSet(result, "getColumns");
    return cols;
  }

  private void tablePermProcess(
          List<String> tables, Map<String, OmniSciData> dataMap, String tableNamePattern)
          throws TException {
    for (String table : tables) {
      if (tableNamePattern != null && !table.matches(tableNamePattern)) {
        continue;
      }
      List<TDBObject> db_objects = con.client.get_db_object_privs(
              con.session, table, TDBObjectType.TableDBObjectType);

      // check if the table matches the input pattern
      for (TDBObject db_object : db_objects) {
        //  If the user is a super user then the  objectName will be super
        //  and needs to be changed to the table name.
        if (db_object.objectName.equalsIgnoreCase("super")) {
          db_object.objectName = table;
        }
        // A bunch of db objects come back.  Any with a different name throw away
        if (!db_object.objectName.equalsIgnoreCase(table)) {
          continue;
        }

        // Create  set of table permissions based ont he db_object.  This seems to
        // be the only way - though being hardwired on the number of privs is not great.
        TTablePermissions tt = new TTablePermissions(db_object.privs.get(0),
                db_object.privs.get(1),
                db_object.privs.get(2),
                db_object.privs.get(3),
                db_object.privs.get(4),
                db_object.privs.get(5),
                db_object.privs.get(6),
                db_object.privs.get(7));

        int ordinal = 1;
        for (TTablePermissions._Fields field = tt.fieldForId(ordinal); field != null;
                field = tt.fieldForId(++ordinal)) {
          Boolean x = (Boolean) tt.getFieldValue(field);
          if (x == false) {
            continue;
          }
          // standardise the fieldName upper case and remove trailing '_'.  create_ =>
          // CREATE
          dataMap.get("PRIVILEGE")
                  .add(field.getFieldName().toUpperCase().replace("_", ""));
          dataMap.get("TABLE_CAT").setNull(true);
          dataMap.get("TABLE_SCHEM").setNull(true);
          dataMap.get("TABLE_NAME").add(db_object.objectName);
          dataMap.get("GRANTOR").setNull(true);
          dataMap.get("GRANTEE").add(db_object.grantee);
          dataMap.get("IS_GRANTABLE").add("NO");
        }
      }
    }
  }

  @Override
  public ResultSet getTablePrivileges(
          String catalog, String schemaPattern, String tableNamePattern)
          throws SQLException {
    MAPDLOGGER.debug("Entered");

    String modifiedTablePattern =
            (tableNamePattern == null) ? null : tableNamePattern.replaceAll("%", ".*");

    MAPDLOGGER.debug("TablePattern " + tableNamePattern + " modifiedTableNamePattern "
            + modifiedTablePattern);

    // declare the columns in the result set
    final TTypeInfo strTTI =
            new TTypeInfo(TDatumType.STR, TEncodingType.NONE, false, false, 0, 0, 0);
    final TDatumType datumType = strTTI.type;

    Map<String, OmniSciData> dataMap = new HashMap() {
      {
        put("TABLE_CAT", new OmniSciData(datumType));
        put("TABLE_SCHEM", new OmniSciData(datumType));
        put("TABLE_NAME", new OmniSciData(datumType));
        put("GRANTOR", new OmniSciData(datumType));
        put("GRANTEE", new OmniSciData(datumType));
        put("PRIVILEGE", new OmniSciData(datumType));
        put("IS_GRANTABLE", new OmniSciData(datumType));
      }
    };

    try {
      // Get all the tables and then pattern match them in tablePermProcess
      List<String> tables = con.client.get_tables(con.session);
      tablePermProcess(tables, dataMap, modifiedTablePattern);
    } catch (TException ex) {
      throw new SQLException("get_privileges failed " + ex.toString());
    }

    // create component to contain the meta data for the rows
    // and create  a container to store the data and the nul indicators
    // List<TColumnType> rowDesc = new ArrayList(columns.length);

    List<TColumnType> rowDesc = new ArrayList(dataMap.size());
    List<TColumn> columnsList = new ArrayList(dataMap.size());

    for (Map.Entry<String, OmniSciData> pair : dataMap.entrySet()) {
      columnsList.add(pair.getValue().getTColumn());
      rowDesc.add(createTColumnType(pair.getKey(), new TTypeInfo(strTTI)));
    }

    // create a rowset for the result
    TRowSet rowSet = new TRowSet(rowDesc, null, columnsList, true);

    TQueryResult result = new TQueryResult(
            rowSet, 0, 0, null, null, true, com.omnisci.thrift.server.TQueryType.UNKNOWN);

    OmniSciResultSet cols = new OmniSciResultSet(result, "getPrivileges");
    return cols;
  }

  @Override
  public ResultSet getBestRowIdentifier(
          String catalog, String schema, String table, int scope, boolean nullable)
          throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  @Override
  public ResultSet getVersionColumns(String catalog, String schema, String table)
          throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  @Override
  public ResultSet getPrimaryKeys(String catalog, String schema, String table)
          throws SQLException {
    MAPDLOGGER.debug("Entered");

    TTypeInfo strTTI =
            new TTypeInfo(TDatumType.STR, TEncodingType.NONE, false, false, 0, 0, 0);
    TTypeInfo intTTI =
            new TTypeInfo(TDatumType.INT, TEncodingType.NONE, false, false, 0, 0, 0);
    TTypeInfo smallIntTTI =
            new TTypeInfo(TDatumType.SMALLINT, TEncodingType.NONE, false, false, 0, 0, 0);
    TColumnType columns[] = {createTColumnType("TABLE_CAT", new TTypeInfo(strTTI)),
            createTColumnType("TABLE_SCHEM", new TTypeInfo(strTTI)),
            createTColumnType("TABLE_NAME", new TTypeInfo(strTTI)),
            createTColumnType("COLUMN_NAME", new TTypeInfo(strTTI)),
            createTColumnType("KEY_SEQ", new TTypeInfo(smallIntTTI)),
            createTColumnType("PK_NAME", new TTypeInfo(strTTI))};

    return getEmptyResultSetWithDesc(columns);
  }

  @Override
  public ResultSet getImportedKeys(String catalog, String schema, String table)
          throws SQLException {
    MAPDLOGGER.debug("Entered");

    TTypeInfo strTTI =
            new TTypeInfo(TDatumType.STR, TEncodingType.NONE, false, false, 0, 0, 0);
    TTypeInfo intTTI =
            new TTypeInfo(TDatumType.INT, TEncodingType.NONE, false, false, 0, 0, 0);
    TTypeInfo smallIntTTI =
            new TTypeInfo(TDatumType.SMALLINT, TEncodingType.NONE, false, false, 0, 0, 0);
    TColumnType columns[] = {createTColumnType("PKTABLE_CAT", new TTypeInfo(strTTI)),
            createTColumnType("PKTABLE_SCHEM", new TTypeInfo(strTTI)),
            createTColumnType("PKTABLE_NAME", new TTypeInfo(strTTI)),
            createTColumnType("PKCOLUMN_NAME", new TTypeInfo(strTTI)),
            createTColumnType("FKTABLE_CAT", new TTypeInfo(strTTI)),
            createTColumnType("FKTABLE_SCHEM", new TTypeInfo(strTTI)),
            createTColumnType("FKTABLE_NAME", new TTypeInfo(strTTI)),
            createTColumnType("FKCOLUMN_NAME", new TTypeInfo(strTTI)),
            createTColumnType("KEY_SEQ", new TTypeInfo(smallIntTTI)),
            createTColumnType("UPDATE_RULE", new TTypeInfo(smallIntTTI)),
            createTColumnType("DELETE_RULE", new TTypeInfo(smallIntTTI)),
            createTColumnType("FK_NAME", new TTypeInfo(strTTI)),
            createTColumnType("PK_NAME", new TTypeInfo(strTTI)),
            createTColumnType("DEFERRABILITY", new TTypeInfo(smallIntTTI))};

    return getEmptyResultSetWithDesc(columns);
  }

  @Override
  public ResultSet getExportedKeys(String catalog, String schema, String table)
          throws SQLException {
    MAPDLOGGER.debug("Entered");

    TTypeInfo strTTI =
            new TTypeInfo(TDatumType.STR, TEncodingType.NONE, false, false, 0, 0, 0);
    TTypeInfo intTTI =
            new TTypeInfo(TDatumType.INT, TEncodingType.NONE, false, false, 0, 0, 0);
    TTypeInfo smallIntTTI =
            new TTypeInfo(TDatumType.SMALLINT, TEncodingType.NONE, false, false, 0, 0, 0);
    TColumnType columns[] = {createTColumnType("FKTABLE_CAT", new TTypeInfo(strTTI)),
            createTColumnType("FKTABLE_SCHEM", new TTypeInfo(strTTI)),
            createTColumnType("FKTABLE_NAME", new TTypeInfo(strTTI)),
            createTColumnType("FKCOLUMN_NAME", new TTypeInfo(strTTI)),
            createTColumnType("PKTABLE_CAT", new TTypeInfo(strTTI)),
            createTColumnType("PKTABLE_SCHEM", new TTypeInfo(strTTI)),
            createTColumnType("PKTABLE_NAME", new TTypeInfo(strTTI)),
            createTColumnType("PKCOLUMN_NAME", new TTypeInfo(strTTI)),
            createTColumnType("KEY_SEQ", new TTypeInfo(smallIntTTI)),
            createTColumnType("UPDATE_RULE", new TTypeInfo(smallIntTTI)),
            createTColumnType("DELETE_RULE", new TTypeInfo(smallIntTTI)),
            createTColumnType("PK_NAME", new TTypeInfo(strTTI)),
            createTColumnType("FK_NAME", new TTypeInfo(strTTI)),
            createTColumnType("DEFERRABILITY", new TTypeInfo(smallIntTTI))};

    return getEmptyResultSetWithDesc(columns);
  }

  @Override
  public ResultSet getCrossReference(String parentCatalog,
          String parentSchema,
          String parentTable,
          String foreignCatalog,
          String foreignSchema,
          String foreignTable) throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  /*
  Retrieves a description of all the data types supported by this database. They are
ordered by DATA_TYPE and then by how closely the data type maps to the corresponding JDBC
SQL type. If the database supports SQL distinct types, then getTypeInfo() will return a
single row with a TYPE_NAME of DISTINCT and a DATA_TYPE of Types.DISTINCT. If the database
supports SQL structured types, then getTypeInfo() will return a single row with a
TYPE_NAME of STRUCT and a DATA_TYPE of Types.STRUCT.

If SQL distinct or structured types are supported, then information on the individual
types may be obtained from the getUDTs() method.

Each type description has the following columns:

TYPE_NAME String => Type name
DATA_TYPE int => SQL data type from java.sql.Types
PRECISION int => maximum precision
LITERAL_PREFIX String => prefix used to quote a literal (may be null)
LITERAL_SUFFIX String => suffix used to quote a literal (may be null)
CREATE_PARAMS String => parameters used in creating the type (may be null)
NULLABLE short => can you use NULL for this type.
typeNoNulls - does not allow NULL values
typeNullable - allows NULL values
typeNullableUnknown - nullability unknown
CASE_SENSITIVE boolean=> is it case sensitive.
SEARCHABLE short => can you use "WHERE" based on this type:
typePredNone - No support
typePredChar - Only supported with WHERE .. LIKE
typePredBasic - Supported except for WHERE .. LIKE
typeSearchable - Supported for all WHERE ..
UNSIGNED_ATTRIBUTE boolean => is it unsigned.
FIXED_PREC_SCALE boolean => can it be a money value.
AUTO_INCREMENT boolean => can it be used for an auto-increment value.
LOCAL_TYPE_NAME String => localized version of type name (may be null)
MINIMUM_SCALE short => minimum scale supported
MAXIMUM_SCALE short => maximum scale supported
SQL_DATA_TYPE int => unused
SQL_DATETIME_SUB int => unused
NUM_PREC_RADIX int => usually 2 or 10
The PRECISION column represents the maximum column size that the server supports for the
given datatype. For numeric data, this is the maximum precision. For character data, this
is the length in characters. For datetime datatypes, this is the length in characters of
the String representation (assuming the maximum allowed precision of the fractional
seconds component). For binary data, this is the length in bytes. For the ROWID datatype,
this is the length in bytes. Null is returned for data types where the column size is not
applicable.

Returns:
a ResultSet object in which each row is an SQL type description
Throws:
SQLException - if a database access error occurs
   */
  @Override
  public ResultSet getTypeInfo() throws SQLException {
    MAPDLOGGER.debug("Entered");

    // declare the columns in the result set
    TTypeInfo strTTI =
            new TTypeInfo(TDatumType.STR, TEncodingType.NONE, false, false, 0, 0, 0);
    TTypeInfo intTTI =
            new TTypeInfo(TDatumType.INT, TEncodingType.NONE, false, false, 0, 0, 0);
    TTypeInfo smallIntTTI =
            new TTypeInfo(TDatumType.SMALLINT, TEncodingType.NONE, false, false, 0, 0, 0);
    TTypeInfo boolTTI =
            new TTypeInfo(TDatumType.BOOL, TEncodingType.NONE, false, false, 0, 0, 0);
    TColumnType columns[] = {createTColumnType("TYPE_NAME", new TTypeInfo(strTTI)),
            createTColumnType("DATA_TYPE", new TTypeInfo(intTTI)),
            createTColumnType("PRECISION", new TTypeInfo(intTTI)),
            createTColumnType("LITERAL_PREFIX", new TTypeInfo(strTTI)),
            createTColumnType("LITERAL_SUFFIX", new TTypeInfo(strTTI)),
            createTColumnType("CREATE_PARAMS", new TTypeInfo(strTTI)),
            createTColumnType("NULLABLE", new TTypeInfo(smallIntTTI)),
            createTColumnType("CASE_SENSITIVE", new TTypeInfo(boolTTI)),
            createTColumnType("SEARCHABLE", new TTypeInfo(smallIntTTI)),
            createTColumnType("UNSIGNED_ATTRIBUTE", new TTypeInfo(boolTTI)),
            createTColumnType("FIXED_PREC_SCALE", new TTypeInfo(boolTTI)),
            createTColumnType("AUTO_INCREMENT", new TTypeInfo(boolTTI)),
            createTColumnType("LOCAL_TYPE_NAME", new TTypeInfo(strTTI)),
            createTColumnType("MINIMUM_SCALE", new TTypeInfo(smallIntTTI)),
            createTColumnType("MAXIMUM_SCALE", new TTypeInfo(smallIntTTI)),
            createTColumnType("SQL_DATA_TYPE", new TTypeInfo(intTTI)),
            createTColumnType("SQL_DATETIME_SUB", new TTypeInfo(intTTI)),
            createTColumnType("NUM_PREC_RADIX", new TTypeInfo(intTTI))};

    Map<String, OmniSciData> dataMap = new HashMap(columns.length);

    // create component to contain the meta data for the rows
    // and create  a container to store the data and the nul indicators
    List<TColumnType> rowDesc = new ArrayList(columns.length);
    for (TColumnType col : columns) {
      rowDesc.add(col);
      dataMap.put(col.col_name, new OmniSciData(col.col_type.type));
    }
    // TODO this is currently a work in progress need to add actual details here
    // Now add some actual details for table name
    dataMap.get("TYPE_NAME").setNull(true); // String => Type name
    dataMap.get("DATA_TYPE").setNull(true); // int => SQL data type from java.sql.Types
    dataMap.get("PRECISION").setNull(true); // int => maximum precision
    dataMap.get("LITERAL_PREFIX").setNull(true); //.setNull(true);// String => prefix used
                                                 // to quote a literal (may be null)
    dataMap.get("LITERAL_SUFFIX").setNull(true); //.setNull(true);// String => suffix used
                                                 // to quote a literal (may be null)
    dataMap.get("CREATE_PARAMS")
            .setNull(
                    true); // String => parameters used in creating the type (may be null)
    dataMap.get("NULLABLE").setNull(true); // short => can you use NULL for this type.
    // typeNoNulls - does not allow NULL values
    // typeNullable - allows NULL values
    // typeNullableUnknown - nullability unknown
    dataMap.get("CASE_SENSITIVE").setNull(true); // boolean=> is it case sensitive.
    dataMap.get("SEARCHABLE")
            .setNull(true); // short => can you use "WHERE" based on this type:
    // typePredNone - No support
    // typePredChar - Only supported with WHERE .. LIKE
    // typePredBasic - Supported except for WHERE .. LIKE
    // typeSearchable - Supported for all WHERE ..
    dataMap.get("UNSIGNED_ATTRIBUTE").setNull(true); // boolean => is it unsigned.
    dataMap.get("FIXED_PREC_SCALE").setNull(true); // boolean => can it be a money value.
    dataMap.get("AUTO_INCREMENT")
            .setNull(false); // boolean => can it be used for an auto-increment value.
    dataMap.get("LOCAL_TYPE_NAME")
            .setNull(true); // String => localized version of type name (may be null)
    dataMap.get("MINIMUM_SCALE").setNull(true); // short => minimum scale supported
    dataMap.get("MAXIMUM_SCALE").setNull(true); // short => maximum scale supported
    dataMap.get("SQL_DATA_TYPE").setNull(true); // int => unused
    dataMap.get("SQL_DATETIME_SUB").setNull(true); // int => unused
    dataMap.get("NUM_PREC_RADIX").setNull(true); //

    List<TColumn> columnsList = new ArrayList(columns.length);

    for (TColumnType col : columns) {
      TColumn schemaCol = dataMap.get(col.col_name).getTColumn();
      // logger.info("Tcolumn is "+ schemaCol.toString());
      columnsList.add(schemaCol);
    }

    // create a rowset for the result
    TRowSet rowSet = new TRowSet(rowDesc, null, columnsList, true);

    TQueryResult result = new TQueryResult(
            rowSet, 0, 0, null, null, true, com.omnisci.thrift.server.TQueryType.UNKNOWN);

    OmniSciResultSet cols = new OmniSciResultSet(result, "getTypeInfo");
    return cols;
  }

  @Override
  public ResultSet getIndexInfo(String catalog,
          String schema,
          String table,
          boolean unique,
          boolean approximate) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return getEmptyResultSet();
  }

  @Override
  public boolean supportsResultSetType(int type) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsResultSetConcurrency(int type, int concurrency)
          throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean ownUpdatesAreVisible(int type) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean ownDeletesAreVisible(int type) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean ownInsertsAreVisible(int type) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean othersUpdatesAreVisible(int type) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean othersDeletesAreVisible(int type) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean othersInsertsAreVisible(int type) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean updatesAreDetected(int type) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean deletesAreDetected(int type) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean insertsAreDetected(int type) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsBatchUpdates() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return true;
  }

  @Override
  public ResultSet getUDTs(
          String catalog, String schemaPattern, String typeNamePattern, int[] types)
          throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  @Override
  public Connection getConnection() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return con;
  }

  @Override
  public boolean supportsSavepoints() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsNamedParameters() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsMultipleOpenResults() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsGetGeneratedKeys() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public ResultSet getSuperTypes(
          String catalog, String schemaPattern, String typeNamePattern)
          throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  @Override
  public ResultSet getSuperTables(
          String catalog, String schemaPattern, String tableNamePattern)
          throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  @Override
  public ResultSet getAttributes(String catalog,
          String schemaPattern,
          String typeNamePattern,
          String attributeNamePattern) throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  @Override
  public boolean supportsResultSetHoldability(int holdability) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public int getResultSetHoldability() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return ResultSet.CLOSE_CURSORS_AT_COMMIT;
  }

  @Override
  public int getDatabaseMajorVersion() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return this.databaseMajorVersion;
  }

  @Override
  public int getDatabaseMinorVersion() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return this.databaseMinorVersion;
  }

  @Override
  public int getJDBCMajorVersion() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getJDBCMinorVersion() throws SQLException { // logger.debug("Entered");
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public int getSQLStateType() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return 0;
  }

  @Override
  public boolean locatorsUpdateCopy() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean supportsStatementPooling() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public RowIdLifetime getRowIdLifetime() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return RowIdLifetime.ROWID_VALID_OTHER;
  }

  @Override
  public ResultSet getSchemas(String catalog, String schemaPattern) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return getSchemas();
  }

  @Override
  public boolean supportsStoredFunctionsUsingCallSyntax() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public boolean autoCommitFailureClosesAllResultSets() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public ResultSet getClientInfoProperties() throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  @Override
  public ResultSet getFunctions(
          String catalog, String schemaPattern, String functionNamePattern)
          throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  @Override
  public ResultSet getFunctionColumns(String catalog,
          String schemaPattern,
          String functionNamePattern,
          String columnNamePattern) throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  @Override
  public ResultSet getPseudoColumns(String catalog,
          String schemaPattern,
          String tableNamePattern,
          String columnNamePattern) throws SQLException {
    MAPDLOGGER.debug("Entered");
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

  @Override
  public boolean generatedKeyAlwaysReturned() throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }

  @Override
  public <T> T unwrap(Class<T> iface) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return null;
  }

  @Override
  public boolean isWrapperFor(Class<?> iface) throws SQLException {
    MAPDLOGGER.debug("Entered");
    return false;
  }
}