ai.heavy.jdbc.HeavyAIConnection Class Reference

Inheritance diagram for ai.heavy.jdbc.HeavyAIConnection:

Collaboration diagram for ai.heavy.jdbc.HeavyAIConnection:

Classes
class	Connection_properties

Public Member Functions
HeavyAIConnection	getAlternateConnection () throws SQLException
	HeavyAIConnection (String url, Properties base_properties) throws SQLException
Statement	createStatement () throws SQLException
PreparedStatement	prepareStatement (String sql) throws SQLException
CallableStatement	prepareCall (String sql) throws SQLException
String	nativeSQL (String sql) throws SQLException
void	setAutoCommit (boolean autoCommit) throws SQLException
boolean	getAutoCommit () throws SQLException
void	commit () throws SQLException
void	rollback () throws SQLException
void	close () throws SQLException
boolean	isClosed () throws SQLException
DatabaseMetaData	getMetaData () throws SQLException
void	setReadOnly (boolean readOnly) throws SQLException
boolean	isReadOnly () throws SQLException
void	setCatalog (String catalog) throws SQLException
String	getCatalog () throws SQLException
void	setTransactionIsolation (int level) throws SQLException
int	getTransactionIsolation () throws SQLException
SQLWarning	getWarnings () throws SQLException
void	clearWarnings () throws SQLException
Statement	createStatement (int resultSetType, int resultSetConcurrency) throws SQLException
PreparedStatement	prepareStatement (String sql, int resultSetType, int resultSetConcurrency) throws SQLException
CallableStatement	prepareCall (String sql, int resultSetType, int resultSetConcurrency) throws SQLException
Map< String, Class<?> >	getTypeMap () throws SQLException
void	setTypeMap (Map< String, Class<?>> map) throws SQLException
void	setHoldability (int holdability) throws SQLException
int	getHoldability () throws SQLException
Savepoint	setSavepoint () throws SQLException
Savepoint	setSavepoint (String name) throws SQLException
void	rollback (Savepoint savepoint) throws SQLException
void	releaseSavepoint (Savepoint savepoint) throws SQLException
Statement	createStatement (int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
PreparedStatement	prepareStatement (String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
CallableStatement	prepareCall (String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
PreparedStatement	prepareStatement (String sql, int autoGeneratedKeys) throws SQLException
PreparedStatement	prepareStatement (String sql, int[] columnIndexes) throws SQLException
PreparedStatement	prepareStatement (String sql, String[] columnNames) throws SQLException
Clob	createClob () throws SQLException
Blob	createBlob () throws SQLException
NClob	createNClob () throws SQLException
SQLXML	createSQLXML () throws SQLException
boolean	isValid (int timeout) throws SQLException
void	setClientInfo (String name, String value) throws SQLClientInfoException
void	setClientInfo (Properties properties) throws SQLClientInfoException
String	getClientInfo (String name) throws SQLException
Properties	getClientInfo () throws SQLException
Array	createArrayOf (String typeName, Object[] elements) throws SQLException
Struct	createStruct (String typeName, Object[] attributes) throws SQLException
void	setSchema (String schema) throws SQLException
String	getSchema () throws SQLException
void	abort (Executor executor) throws SQLException
void	setNetworkTimeout (Executor executor, int milliseconds) throws SQLException
int	getNetworkTimeout () throws SQLException
boolean	isWrapperFor (Class<?> iface) throws SQLException

Protected Member Functions
void	closeConnection () throws SQLException

Protected Attributes
String	session = null
Heavy.Client	client = null
String	catalog
TTransport	transport
SQLWarning	warnings
String	url
Connection_properties	cP = null

Package Functions
public< T > T	unwrap (Class< T > iface) throws SQLException

Package Attributes
Set< String >	protocol_set

Static Package Attributes
static final Logger	logger = LoggerFactory.getLogger(HeavyAIConnection.class)

Private Member Functions
TProtocol	manageConnection () throws java.lang.Exception
void	setSession (Object pki_auth) throws java.lang.Exception

Detailed Description

Definition at line 138 of file HeavyAIConnection.java.

Constructor & Destructor Documentation

ai.heavy.jdbc.HeavyAIConnection.HeavyAIConnection ( String  url, Properties  base_properties  ) throws SQLException

inline

Definition at line 454 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.catalog, ai.heavy.jdbc.HeavyAIConnection.client, ai.heavy.jdbc.HeavyAIConnection.cP, ai.heavy.jdbc.Options.db_name, ai.heavy.jdbc.HeavyAIExceptionText.getExceptionDetail(), ai.heavy.jdbc.HeavyAIConnection.manageConnection(), ai.heavy.jdbc.Options.pkiauth, ai.heavy.jdbc.HeavyAIConnection.setSession(), and ai.heavy.jdbc.HeavyAIConnection.url.

Referenced by ai.heavy.jdbc.HeavyAIConnection.getAlternateConnection().

                                                                                       {
    this.url = url;
    this.cP = new Connection_properties(url, base_properties);
    try {
      TProtocol protocol = manageConnection();
      client = new Heavy.Client(protocol);
      setSession(this.cP.getProperty(Options.pkiauth));
      catalog = (String) this.cP.getProperty(Options.db_name);
    } catch (TTransportException ex) {
      throw new SQLException("Thrift transport connection failed - "
                      + HeavyAIExceptionText.getExceptionDetail(ex),
              ex);
    } catch (TDBException ex) {
      throw new SQLException("HEAVY.AI connection failed - "
                      + HeavyAIExceptionText.getExceptionDetail(ex),
              ex);
    } catch (TException ex) {
      throw new SQLException(
              "Thrift failed - " + HeavyAIExceptionText.getExceptionDetail(ex), ex);
    } catch (java.lang.Exception ex) {
      throw new SQLException(
              "Connection failed - " + HeavyAIExceptionText.getExceptionDetail(ex), ex);
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

void ai.heavy.jdbc.HeavyAIConnection.abort ( Executor  executor ) throws SQLException

inline

Definition at line 904 of file HeavyAIConnection.java.

                                                           { // logger.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());
  }

void ai.heavy.jdbc.HeavyAIConnection.clearWarnings ( ) throws SQLException

inline

Definition at line 621 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.warnings.

                                                  { // logger.debug("Entered");
    warnings = null;
  }

void ai.heavy.jdbc.HeavyAIConnection.close ( ) throws SQLException

inline

Definition at line 532 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.closeConnection(), and ai.heavy.jdbc.HeavyAIConnection.session.

Referenced by heavydb.connection.Connection.__del__(), heavydb.cursor.Cursor.__exit__(), and heavydb.connection.Connection.__exit__().

                                          { // logger.debug("Entered");
    try {
      logger.debug("Session at close is " + session);
      if (session != null) {
        client.disconnect(session);
      }
      closeConnection();
    } catch (TDBException ex) {
      throw new SQLException("disconnect failed." + ex.getError_msg());
    } catch (TException ex) {
      throw new SQLException("disconnect failed." + ex.toString());
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

void ai.heavy.jdbc.HeavyAIConnection.closeConnection ( ) throws SQLException

inlineprotected

Definition at line 547 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

Referenced by ai.heavy.jdbc.HeavyAIConnection.close().

                                                       { // logger.debug("Entered");
    session = null;
    transport.close();
  }

Here is the caller graph for this function:

void ai.heavy.jdbc.HeavyAIConnection.commit ( ) throws SQLException

inline

Definition at line 519 of file HeavyAIConnection.java.

                                           { // logger.debug("Entered");
    // noop
  }

Array ai.heavy.jdbc.HeavyAIConnection.createArrayOf ( String  typeName, Object[]  elements  ) throws SQLException

inline

Definition at line 857 of file HeavyAIConnection.java.

References run_benchmark_import.type, and typeName().

                              { // logger.debug("Entered");
    TDatumType type;
    try {
      type = TDatumType.valueOf(typeName.toUpperCase());
    } catch (IllegalArgumentException ex) {
      throw new SQLException("No matching heavyDB type for " + typeName);
    }
    return new HeavyAIArray(type, elements);
  }

Here is the call graph for this function:

Blob ai.heavy.jdbc.HeavyAIConnection.createBlob ( ) throws SQLException

inline

Definition at line 786 of file HeavyAIConnection.java.

                                               { // logger.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());
  }

Clob ai.heavy.jdbc.HeavyAIConnection.createClob ( ) throws SQLException

inline

Definition at line 778 of file HeavyAIConnection.java.

                                               { // logger.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());
  }

NClob ai.heavy.jdbc.HeavyAIConnection.createNClob ( ) throws SQLException

inline

Definition at line 794 of file HeavyAIConnection.java.

                                                 { // logger.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());
  }

SQLXML ai.heavy.jdbc.HeavyAIConnection.createSQLXML ( ) throws SQLException

inline

Definition at line 802 of file HeavyAIConnection.java.

                                                   { // logger.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());
  }

Statement ai.heavy.jdbc.HeavyAIConnection.createStatement ( ) throws SQLException

inline

Definition at line 480 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

                                                         { // logger.debug("Entered");
    return new HeavyAIStatement(session, this);
  }

Statement ai.heavy.jdbc.HeavyAIConnection.createStatement ( int  resultSetType, int  resultSetConcurrency  ) throws SQLException

inline

Definition at line 626 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

                              { // logger.debug("Entered");
    return new HeavyAIStatement(session, this);
  }

Statement ai.heavy.jdbc.HeavyAIConnection.createStatement ( int  resultSetType, int  resultSetConcurrency, int  resultSetHoldability  ) throws SQLException

inline

Definition at line 719 of file HeavyAIConnection.java.

                              { // logger.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());
  }

Struct ai.heavy.jdbc.HeavyAIConnection.createStruct ( String  typeName, Object[]  attributes  ) throws SQLException

inline

Definition at line 869 of file HeavyAIConnection.java.

                              { // logger.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());
  }

HeavyAIConnection ai.heavy.jdbc.HeavyAIConnection.getAlternateConnection ( ) throws SQLException

inline

Definition at line 341 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIExceptionText.getExceptionDetail(), and ai.heavy.jdbc.HeavyAIConnection.HeavyAIConnection().

                                                                        {
    // Clones the orignal java connection object, and then reconnects
    // at the thrift layer - doesn't re-authenticate at the application
    // level.  Instead reuses the orignal connections session number.
    logger.debug("HeavyAIConnection clone");
    HeavyAIConnection dbConnection = null;
    try {
      dbConnection = (HeavyAIConnection) super.clone();
    } catch (CloneNotSupportedException eE) {
      throw new SQLException(
              "Error cloning connection [" + HeavyAIExceptionText.getExceptionDetail(eE),
              eE);
    }
    // Now over write the old connection.
    try {
      TProtocol protocol = dbConnection.manageConnection();
      dbConnection.client = new Heavy.Client(protocol);
    } catch (java.lang.Exception jE) {
      throw new SQLException("Error creating new connection "
                      + HeavyAIExceptionText.getExceptionDetail(jE),
              jE);
    }
    return dbConnection;
  }

Here is the call graph for this function:

boolean ai.heavy.jdbc.HeavyAIConnection.getAutoCommit ( ) throws SQLException

inline

Definition at line 514 of file HeavyAIConnection.java.

                                                     { // logger.debug("Entered");
    return true;
  }

String ai.heavy.jdbc.HeavyAIConnection.getCatalog ( ) throws SQLException

inline

Definition at line 601 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.catalog.

                                                 { // logger.debug("Entered");
    return catalog;
  }

String ai.heavy.jdbc.HeavyAIConnection.getClientInfo ( String  name ) throws SQLException

inline

Definition at line 840 of file HeavyAIConnection.java.

                              { // logger.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());
  }

Properties ai.heavy.jdbc.HeavyAIConnection.getClientInfo ( ) throws SQLException

inline

Definition at line 849 of file HeavyAIConnection.java.

                                                        { // logger.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());
  }

int ai.heavy.jdbc.HeavyAIConnection.getHoldability ( ) throws SQLException

inline

Definition at line 676 of file HeavyAIConnection.java.

                                                  { // logger.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());
  }

DatabaseMetaData ai.heavy.jdbc.HeavyAIConnection.getMetaData ( ) throws SQLException

inline

Definition at line 561 of file HeavyAIConnection.java.

                                                            { // logger.debug("Entered");
    DatabaseMetaData dbMetaData = new HeavyAIDatabaseMetaData(this);

    return dbMetaData;
  }

int ai.heavy.jdbc.HeavyAIConnection.getNetworkTimeout ( ) throws SQLException

inline

Definition at line 921 of file HeavyAIConnection.java.

                                                     { // logger.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());
  }

String ai.heavy.jdbc.HeavyAIConnection.getSchema ( ) throws SQLException

inline

Definition at line 896 of file HeavyAIConnection.java.

                                                { // logger.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());
  }

int ai.heavy.jdbc.HeavyAIConnection.getTransactionIsolation ( ) throws SQLException

inline

Definition at line 611 of file HeavyAIConnection.java.

                                                           { // logger.debug("Entered");
    return Connection.TRANSACTION_NONE;
  }

Map<String, Class<?> > ai.heavy.jdbc.HeavyAIConnection.getTypeMap ( ) throws SQLException

inline

Definition at line 649 of file HeavyAIConnection.java.

                              { // logger.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());
  }

SQLWarning ai.heavy.jdbc.HeavyAIConnection.getWarnings ( ) throws SQLException

inline

Definition at line 616 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.warnings.

                                                      { // logger.debug("Entered");
    return warnings;
  }

boolean ai.heavy.jdbc.HeavyAIConnection.isClosed ( ) throws SQLException

inline

Definition at line 553 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

                                                { // logger.debug("Entered");
    if (session == null) {
      return true;
    }
    return false;
  }

boolean ai.heavy.jdbc.HeavyAIConnection.isReadOnly ( ) throws SQLException

inline

Definition at line 575 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

                                                  { // logger.debug("Entered");
    try {
      if (session != null) {
        TServerStatus server_status = client.get_server_status(session);
        return server_status.read_only;
      }
    } catch (TDBException ex) {
      throw new SQLException(
              "get_server_status failed during isReadOnly check." + ex.getError_msg());
    } catch (TException ex) {
      throw new SQLException(
              "get_server_status failed during isReadOnly check." + ex.toString());
    }
    // never should get here
    return true;
  }

boolean ai.heavy.jdbc.HeavyAIConnection.isValid ( int  timeout ) throws SQLException

inline

Definition at line 810 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

                                                          { // logger.debug("Entered");
    try {
      client.get_server_status(session);
    } catch (TTransportException ex) {
      throw new SQLException("Connection failed - " + ex.toString());
    } catch (TDBException ex) {
      throw new SQLException("Connection failed - " + ex.getError_msg());
    } catch (TException ex) {
      throw new SQLException("Connection failed - " + ex.toString());
    }
    return true;
  }

boolean ai.heavy.jdbc.HeavyAIConnection.isWrapperFor ( Class<?>  iface ) throws SQLException

inline

Definition at line 937 of file HeavyAIConnection.java.

                              { // logger.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());
  }

TProtocol ai.heavy.jdbc.HeavyAIConnection.manageConnection ( ) throws java.lang.Exception

inlineprivate

Definition at line 368 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.cP, ai.heavy.jdbc.Options.host_name, Integer, ai.heavy.jdbc.HeavyAIConnection.Connection_properties.isBinary(), ai.heavy.jdbc.HeavyAIConnection.Connection_properties.isBinary_tls(), ai.heavy.jdbc.HeavyAIConnection.Connection_properties.isHttpProtocol(), ai.heavy.jdbc.HeavyAIConnection.Connection_properties.isHttpsProtocol(), ai.heavy.jdbc.Options.port_num, ai.heavy.jdbc.Options.server_trust_store, ai.heavy.jdbc.Options.server_trust_store_pwd, and ai.heavy.jdbc.HeavyAIConnection.transport.

Referenced by ai.heavy.jdbc.HeavyAIConnection.HeavyAIConnection().

                                                                  {
    SockTransportProperties skT = null;
    String trust_store = null;
    if (cP.getProperty(Options.server_trust_store) != null
            && !cP.getProperty(Options.server_trust_store).isEmpty()) {
      trust_store = cP.getProperty(Options.server_trust_store);
    }
    String trust_store_pwd = null;
    if (cP.getProperty(Options.server_trust_store_pwd) != null
            && !cP.getProperty(Options.server_trust_store_pwd).isEmpty()) {
      trust_store_pwd = cP.getProperty(Options.server_trust_store_pwd);
    }

    TProtocol protocol = null;
    if (this.cP.isHttpProtocol()) {
      // HTTP
      skT = SockTransportProperties.getUnencryptedClient();

      transport = skT.openHttpClientTransport(this.cP.getProperty(Options.host_name),
              Integer.parseInt(this.cP.getProperty(Options.port_num)));
      transport.open();
      protocol = new TJSONProtocol(transport);

    } else if (this.cP.isBinary()) {
      skT = SockTransportProperties.getUnencryptedClient();
      transport = skT.openClientTransport(this.cP.getProperty(Options.host_name),
              Integer.parseInt(this.cP.getProperty(Options.port_num)));
      if (!transport.isOpen()) transport.open();
      protocol = new TBinaryProtocol(transport);

    } else if (this.cP.isHttpsProtocol() || this.cP.isHttpsProtocol_insecure()) {
      if (trust_store == null) {
        skT = SockTransportProperties.getEncryptedClientDefaultTrustStore(
                !this.cP.isHttpsProtocol_insecure());
      } else {
        skT = SockTransportProperties.getEncryptedClientSpecifiedTrustStore(
                trust_store, trust_store_pwd, !this.cP.isHttpsProtocol_insecure());
      }
      transport = skT.openHttpsClientTransport(this.cP.getProperty(Options.host_name),
              Integer.parseInt(this.cP.getProperty(Options.port_num)));
      transport.open();
      protocol = new TJSONProtocol(transport);

    } else if (cP.isBinary_tls()) {
      if (trust_store == null) {
        skT = SockTransportProperties.getEncryptedClientDefaultTrustStore(false);
      } else {
        skT = SockTransportProperties.getEncryptedClientSpecifiedTrustStore(
                trust_store, trust_store_pwd, false);
      }
      transport = skT.openClientTransport(this.cP.getProperty(Options.host_name),
              Integer.parseInt(this.cP.getProperty(Options.port_num)));

      if (!transport.isOpen()) transport.open();
      protocol = new TBinaryProtocol(transport);
    } else {
      throw new SQLException("Invalid protocol supplied");
    }
    return protocol;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

String ai.heavy.jdbc.HeavyAIConnection.nativeSQL ( String  sql ) throws SQLException

inline

Definition at line 500 of file HeavyAIConnection.java.

                                                          { // logger.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());
  }

CallableStatement ai.heavy.jdbc.HeavyAIConnection.prepareCall ( String  sql ) throws SQLException

inline

Definition at line 491 of file HeavyAIConnection.java.

                              { // logger.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());
  }

CallableStatement ai.heavy.jdbc.HeavyAIConnection.prepareCall ( String  sql, int  resultSetType, int  resultSetConcurrency  ) throws SQLException

inline

Definition at line 639 of file HeavyAIConnection.java.

                              { // logger.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());
  }

CallableStatement ai.heavy.jdbc.HeavyAIConnection.prepareCall ( String  sql, int  resultSetType, int  resultSetConcurrency, int  resultSetHoldability  ) throws SQLException

inline

Definition at line 740 of file HeavyAIConnection.java.

                                                        { // logger.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());
  }

PreparedStatement ai.heavy.jdbc.HeavyAIConnection.prepareStatement ( String  sql ) throws SQLException

inline

Definition at line 485 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

                              { // logger.debug("Entered");
    return new HeavyAIPreparedStatement(sql, session, this);
  }

PreparedStatement ai.heavy.jdbc.HeavyAIConnection.prepareStatement ( String  sql, int  resultSetType, int  resultSetConcurrency  ) throws SQLException

inline

Definition at line 632 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

                              { // logger.debug("Entered");
    return new HeavyAIPreparedStatement(sql, session, this);
  }

PreparedStatement ai.heavy.jdbc.HeavyAIConnection.prepareStatement ( String  sql, int  resultSetType, int  resultSetConcurrency, int  resultSetHoldability  ) throws SQLException

inline

Definition at line 729 of file HeavyAIConnection.java.

                                                        { // logger.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());
  }

PreparedStatement ai.heavy.jdbc.HeavyAIConnection.prepareStatement ( String  sql, int  autoGeneratedKeys  ) throws SQLException

inline

Definition at line 751 of file HeavyAIConnection.java.

                              { // logger.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());
  }

PreparedStatement ai.heavy.jdbc.HeavyAIConnection.prepareStatement ( String  sql, int[]  columnIndexes  ) throws SQLException

inline

Definition at line 760 of file HeavyAIConnection.java.

                              { // logger.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());
  }

PreparedStatement ai.heavy.jdbc.HeavyAIConnection.prepareStatement ( String  sql, String[]  columnNames  ) throws SQLException

inline

Definition at line 769 of file HeavyAIConnection.java.

                              { // logger.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());
  }

void ai.heavy.jdbc.HeavyAIConnection.releaseSavepoint ( Savepoint  savepoint ) throws SQLException

inline

Definition at line 710 of file HeavyAIConnection.java.

                              { // logger.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());
  }

void ai.heavy.jdbc.HeavyAIConnection.rollback ( ) throws SQLException

inline

Definition at line 524 of file HeavyAIConnection.java.

                                             { // logger.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());
  }

void ai.heavy.jdbc.HeavyAIConnection.rollback ( Savepoint  savepoint ) throws SQLException

inline

Definition at line 701 of file HeavyAIConnection.java.

                              { // logger.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());
  }

void ai.heavy.jdbc.HeavyAIConnection.setAutoCommit ( boolean  autoCommit ) throws SQLException

inline

Definition at line 508 of file HeavyAIConnection.java.

                              { // logger.debug("Entered");
    // we always autocommit per statement
  }

void ai.heavy.jdbc.HeavyAIConnection.setCatalog ( String  catalog ) throws SQLException

inline

Definition at line 593 of file HeavyAIConnection.java.

                                                             { // logger.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());
  }

void ai.heavy.jdbc.HeavyAIConnection.setClientInfo ( String  name, String  value  ) throws SQLClientInfoException

inline

Definition at line 824 of file HeavyAIConnection.java.

                                                                                     {
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

void ai.heavy.jdbc.HeavyAIConnection.setClientInfo ( Properties  properties ) throws SQLClientInfoException

inline

Definition at line 832 of file HeavyAIConnection.java.

                                                                                 {
    throw new UnsupportedOperationException("Not supported yet,"
            + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
            + " class:" + new Throwable().getStackTrace()[0].getClassName()
            + " method:" + new Throwable().getStackTrace()[0].getMethodName());
  }

void ai.heavy.jdbc.HeavyAIConnection.setHoldability ( int  holdability ) throws SQLException

inline

Definition at line 667 of file HeavyAIConnection.java.

                              { // logger.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());
  }

void ai.heavy.jdbc.HeavyAIConnection.setNetworkTimeout ( Executor  executor, int  milliseconds  ) throws SQLException

inline

Definition at line 912 of file HeavyAIConnection.java.

                              { // logger.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());
  }

void ai.heavy.jdbc.HeavyAIConnection.setReadOnly ( boolean  readOnly ) throws SQLException

inline

Definition at line 568 of file HeavyAIConnection.java.

                              { // logger.debug("Entered");
    // TODO MAT we can't push the readonly upstream currently
    // but we could make JDBC obey this command
  }

Savepoint ai.heavy.jdbc.HeavyAIConnection.setSavepoint ( ) throws SQLException

inline

Definition at line 684 of file HeavyAIConnection.java.

                                                      { // logger.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());
  }

Savepoint ai.heavy.jdbc.HeavyAIConnection.setSavepoint ( String  name ) throws SQLException

inline

Definition at line 692 of file HeavyAIConnection.java.

                              { // logger.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());
  }

void ai.heavy.jdbc.HeavyAIConnection.setSchema ( String  schema ) throws SQLException

inline

Definition at line 878 of file HeavyAIConnection.java.

References ai.heavy.jdbc.Options.db_name.

                                                           { // logger.debug("Entered");
    // Setting setSchema to be a NOOP allows integration with third party products
    // that require a successful call to setSchema to work.
    Object db_name = this.cP.getProperty(Options.db_name);
    if (db_name == null) {
      throw new SQLException("db name not set, "
              + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
              + " class:" + new Throwable().getStackTrace()[0].getClassName()
              + " method:" + new Throwable().getStackTrace()[0].getMethodName());
    }
    if (!schema.equals(db_name.toString())) {
      logger.warn("Connected to schema [" + schema + "] differs from db name [" + db_name
              + "].");
    }
    return;
  }

void ai.heavy.jdbc.HeavyAIConnection.setSession ( Object  pki_auth ) throws java.lang.Exception

inlineprivate

Definition at line 429 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.cP, ai.heavy.jdbc.Options.db_name, ai.heavy.jdbc.Options.password, ai.heavy.jdbc.HeavyAIConnection.session, ai.heavy.jdbc.Options.sslcert, ai.heavy.jdbc.Options.sslkey_password, and ai.heavy.jdbc.Options.user.

Referenced by ai.heavy.jdbc.HeavyAIConnection.HeavyAIConnection().

                                                                      {
    KeyLoader.S_struct s_struct = null;
    // If pki aut then stuff public cert into password.
    if (pki_auth != null && pki_auth.toString().equalsIgnoreCase("true")) {
      s_struct = KeyLoader.getDetails_pkcs12(this.cP.getProperty(Options.sslcert),
              this.cP.getProperty(Options.sslkey_password));
      this.cP.setProperty(Options.password, s_struct.cert);
    }

    // Get the seesion for all connectioms
    session = client.connect((String) this.cP.getProperty(Options.user),
            (String) this.cP.getProperty(Options.password),
            (String) this.cP.getProperty(Options.db_name));

    // if pki auth the session will be encoded.
    if (pki_auth != null && pki_auth.toString().equalsIgnoreCase("true")) {
      Cipher cipher = Cipher.getInstance(s_struct.key.getAlgorithm());
      cipher.init(Cipher.DECRYPT_MODE, s_struct.key);
      // session is encrypted and encoded in b64
      byte[] decodedBytes = Base64.getDecoder().decode(session);
      byte[] decoded_bytes = cipher.doFinal(decodedBytes);
      session = new String(decoded_bytes, "UTF-8");
    }
  }

Here is the caller graph for this function:

void ai.heavy.jdbc.HeavyAIConnection.setTransactionIsolation ( int  level ) throws SQLException

inline

Definition at line 606 of file HeavyAIConnection.java.

                              { // logger.debug("Entered");
  }

void ai.heavy.jdbc.HeavyAIConnection.setTypeMap ( Map< String, Class<?>>  map ) throws SQLException

inline

Definition at line 658 of file HeavyAIConnection.java.

                              { // logger.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<T> T ai.heavy.jdbc.HeavyAIConnection.unwrap ( Class< T >  iface ) throws SQLException

inlinepackage

Definition at line 929 of file HeavyAIConnection.java.

                                                          { // logger.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());
  }

Member Data Documentation

String ai.heavy.jdbc.HeavyAIConnection.catalog

protected

Definition at line 335 of file HeavyAIConnection.java.

Referenced by ai.heavy.jdbc.HeavyAIConnection.getCatalog(), and ai.heavy.jdbc.HeavyAIConnection.HeavyAIConnection().

Heavy.Client ai.heavy.jdbc.HeavyAIConnection.client = null

protected

Definition at line 334 of file HeavyAIConnection.java.

Referenced by ai.heavy.jdbc.HeavyAIConnection.HeavyAIConnection().

Connection_properties ai.heavy.jdbc.HeavyAIConnection.cP = null

protected

Definition at line 339 of file HeavyAIConnection.java.

Referenced by ai.heavy.jdbc.HeavyAIConnection.HeavyAIConnection(), ai.heavy.jdbc.HeavyAIConnection.manageConnection(), and ai.heavy.jdbc.HeavyAIConnection.setSession().

final Logger ai.heavy.jdbc.HeavyAIConnection.logger = LoggerFactory.getLogger(HeavyAIConnection.class)

staticpackage

Definition at line 139 of file HeavyAIConnection.java.

Set<String> ai.heavy.jdbc.HeavyAIConnection.protocol_set

package

Initial value:

= new HashSet<String>(
          Arrays.asList("binary", "binary_tls", "http", "https", "https_insecure"))

Definition at line 141 of file HeavyAIConnection.java.

Referenced by ai.heavy.jdbc.HeavyAIConnection.Connection_properties.validate_params().

String ai.heavy.jdbc.HeavyAIConnection.session = null

protected

Definition at line 333 of file HeavyAIConnection.java.

Referenced by ai.heavy.jdbc.HeavyAIConnection.close(), ai.heavy.jdbc.HeavyAIConnection.closeConnection(), ai.heavy.jdbc.HeavyAIConnection.createStatement(), ai.heavy.jdbc.HeavyAIConnection.isClosed(), ai.heavy.jdbc.HeavyAIConnection.isReadOnly(), ai.heavy.jdbc.HeavyAIConnection.isValid(), ai.heavy.jdbc.HeavyAIConnection.prepareStatement(), heavydb.thrift.Heavy.disconnect_args.read(), heavydb.thrift.Heavy.switch_database_args.read(), heavydb.thrift.Heavy.clone_session_args.read(), heavydb.thrift.Heavy.get_server_status_args.read(), heavydb.thrift.Heavy.get_status_args.read(), heavydb.thrift.Heavy.get_hardware_info_args.read(), heavydb.thrift.Heavy.get_tables_args.read(), heavydb.thrift.Heavy.get_tables_for_database_args.read(), heavydb.thrift.Heavy.get_physical_tables_args.read(), heavydb.thrift.Heavy.get_views_args.read(), heavydb.thrift.Heavy.get_tables_meta_args.read(), heavydb.thrift.Heavy.get_table_details_args.read(), heavydb.thrift.Heavy.get_table_details_for_database_args.read(), heavydb.thrift.Heavy.get_internal_table_details_args.read(), heavydb.thrift.Heavy.get_internal_table_details_for_database_args.read(), heavydb.thrift.Heavy.get_users_args.read(), heavydb.thrift.Heavy.get_databases_args.read(), heavydb.thrift.Heavy.start_heap_profile_args.read(), heavydb.thrift.Heavy.stop_heap_profile_args.read(), heavydb.thrift.Heavy.get_heap_profile_args.read(), heavydb.thrift.Heavy.get_memory_args.read(), heavydb.thrift.Heavy.clear_cpu_memory_args.read(), heavydb.thrift.Heavy.clear_gpu_memory_args.read(), heavydb.thrift.Heavy.set_table_epoch_args.read(), heavydb.thrift.Heavy.set_table_epoch_by_name_args.read(), heavydb.thrift.Heavy.get_table_epoch_args.read(), heavydb.thrift.Heavy.get_table_epoch_by_name_args.read(), heavydb.thrift.Heavy.get_table_epochs_args.read(), heavydb.thrift.Heavy.set_table_epochs_args.read(), heavydb.thrift.Heavy.get_session_info_args.read(), heavydb.thrift.Heavy.get_queries_info_args.read(), heavydb.thrift.Heavy.set_leaf_info_args.read(), heavydb.thrift.Heavy.sql_execute_args.read(), heavydb.thrift.Heavy.sql_execute_df_args.read(), heavydb.thrift.Heavy.sql_execute_gdf_args.read(), heavydb.thrift.Heavy.deallocate_df_args.read(), heavydb.thrift.Heavy.sql_validate_args.read(), heavydb.thrift.Heavy.get_completion_hints_args.read(), heavydb.thrift.Heavy.set_execution_mode_args.read(), heavydb.thrift.Heavy.render_vega_args.read(), heavydb.thrift.Heavy.get_result_row_for_pixel_args.read(), heavydb.thrift.Heavy.create_custom_expression_args.read(), heavydb.thrift.Heavy.get_custom_expressions_args.read(), heavydb.thrift.Heavy.update_custom_expression_args.read(), heavydb.thrift.Heavy.delete_custom_expressions_args.read(), heavydb.thrift.Heavy.get_dashboard_args.read(), heavydb.thrift.Heavy.get_dashboards_args.read(), heavydb.thrift.Heavy.create_dashboard_args.read(), heavydb.thrift.Heavy.replace_dashboard_args.read(), heavydb.thrift.Heavy.delete_dashboard_args.read(), heavydb.thrift.Heavy.share_dashboards_args.read(), heavydb.thrift.Heavy.delete_dashboards_args.read(), heavydb.thrift.Heavy.share_dashboard_args.read(), heavydb.thrift.Heavy.unshare_dashboard_args.read(), heavydb.thrift.Heavy.unshare_dashboards_args.read(), heavydb.thrift.Heavy.get_dashboard_grantees_args.read(), heavydb.thrift.Heavy.get_link_view_args.read(), heavydb.thrift.Heavy.create_link_args.read(), heavydb.thrift.Heavy.load_table_binary_args.read(), heavydb.thrift.Heavy.load_table_binary_columnar_args.read(), heavydb.thrift.Heavy.load_table_binary_arrow_args.read(), heavydb.thrift.Heavy.load_table_args.read(), heavydb.thrift.Heavy.detect_column_types_args.read(), heavydb.thrift.Heavy.create_table_args.read(), heavydb.thrift.Heavy.import_table_args.read(), heavydb.thrift.Heavy.import_geo_table_args.read(), heavydb.thrift.Heavy.import_table_status_args.read(), heavydb.thrift.Heavy.get_first_geo_file_in_archive_args.read(), heavydb.thrift.Heavy.get_all_files_in_archive_args.read(), heavydb.thrift.Heavy.get_layers_in_geo_file_args.read(), heavydb.thrift.Heavy.query_get_outer_fragment_count_args.read(), heavydb.thrift.Heavy.check_table_consistency_args.read(), heavydb.thrift.Heavy.start_render_query_args.read(), heavydb.thrift.Heavy.insert_data_args.read(), heavydb.thrift.Heavy.insert_chunks_args.read(), heavydb.thrift.Heavy.checkpoint_args.read(), heavydb.thrift.Heavy.get_roles_args.read(), heavydb.thrift.Heavy.get_db_objects_for_grantee_args.read(), heavydb.thrift.Heavy.get_db_object_privs_args.read(), heavydb.thrift.Heavy.get_all_roles_for_user_args.read(), heavydb.thrift.Heavy.get_all_effective_roles_for_user_args.read(), heavydb.thrift.Heavy.has_role_args.read(), heavydb.thrift.Heavy.has_object_privilege_args.read(), heavydb.thrift.Heavy.set_license_key_args.read(), heavydb.thrift.Heavy.get_license_claims_args.read(), heavydb.thrift.Heavy.get_device_parameters_args.read(), heavydb.thrift.Heavy.register_runtime_extension_functions_args.read(), heavydb.thrift.Heavy.get_table_function_names_args.read(), heavydb.thrift.Heavy.get_runtime_table_function_names_args.read(), heavydb.thrift.Heavy.get_table_function_details_args.read(), heavydb.thrift.Heavy.get_function_names_args.read(), heavydb.thrift.Heavy.get_runtime_function_names_args.read(), heavydb.thrift.Heavy.get_function_details_args.read(), ai.heavy.jdbc.HeavyAIConnection.setSession(), heavydb.thrift.Heavy.disconnect_args.write(), heavydb.thrift.Heavy.switch_database_args.write(), heavydb.thrift.Heavy.clone_session_args.write(), heavydb.thrift.Heavy.get_server_status_args.write(), heavydb.thrift.Heavy.get_status_args.write(), heavydb.thrift.Heavy.get_hardware_info_args.write(), heavydb.thrift.Heavy.get_tables_args.write(), heavydb.thrift.Heavy.get_tables_for_database_args.write(), heavydb.thrift.Heavy.get_physical_tables_args.write(), heavydb.thrift.Heavy.get_views_args.write(), heavydb.thrift.Heavy.get_tables_meta_args.write(), heavydb.thrift.Heavy.get_table_details_args.write(), heavydb.thrift.Heavy.get_table_details_for_database_args.write(), heavydb.thrift.Heavy.get_internal_table_details_args.write(), heavydb.thrift.Heavy.get_internal_table_details_for_database_args.write(), heavydb.thrift.Heavy.get_users_args.write(), heavydb.thrift.Heavy.get_databases_args.write(), heavydb.thrift.Heavy.start_heap_profile_args.write(), heavydb.thrift.Heavy.stop_heap_profile_args.write(), heavydb.thrift.Heavy.get_heap_profile_args.write(), heavydb.thrift.Heavy.get_memory_args.write(), heavydb.thrift.Heavy.clear_cpu_memory_args.write(), heavydb.thrift.Heavy.clear_gpu_memory_args.write(), heavydb.thrift.Heavy.set_table_epoch_args.write(), heavydb.thrift.Heavy.set_table_epoch_by_name_args.write(), heavydb.thrift.Heavy.get_table_epoch_args.write(), heavydb.thrift.Heavy.get_table_epoch_by_name_args.write(), heavydb.thrift.Heavy.get_table_epochs_args.write(), heavydb.thrift.Heavy.set_table_epochs_args.write(), heavydb.thrift.Heavy.get_session_info_args.write(), heavydb.thrift.Heavy.get_queries_info_args.write(), heavydb.thrift.Heavy.set_leaf_info_args.write(), heavydb.thrift.Heavy.sql_execute_args.write(), heavydb.thrift.Heavy.sql_execute_df_args.write(), heavydb.thrift.Heavy.sql_execute_gdf_args.write(), heavydb.thrift.Heavy.deallocate_df_args.write(), heavydb.thrift.Heavy.sql_validate_args.write(), heavydb.thrift.Heavy.get_completion_hints_args.write(), heavydb.thrift.Heavy.set_execution_mode_args.write(), heavydb.thrift.Heavy.render_vega_args.write(), heavydb.thrift.Heavy.get_result_row_for_pixel_args.write(), heavydb.thrift.Heavy.create_custom_expression_args.write(), heavydb.thrift.Heavy.get_custom_expressions_args.write(), heavydb.thrift.Heavy.update_custom_expression_args.write(), heavydb.thrift.Heavy.delete_custom_expressions_args.write(), heavydb.thrift.Heavy.get_dashboard_args.write(), heavydb.thrift.Heavy.get_dashboards_args.write(), heavydb.thrift.Heavy.create_dashboard_args.write(), heavydb.thrift.Heavy.replace_dashboard_args.write(), heavydb.thrift.Heavy.delete_dashboard_args.write(), heavydb.thrift.Heavy.share_dashboards_args.write(), heavydb.thrift.Heavy.delete_dashboards_args.write(), heavydb.thrift.Heavy.share_dashboard_args.write(), heavydb.thrift.Heavy.unshare_dashboard_args.write(), heavydb.thrift.Heavy.unshare_dashboards_args.write(), heavydb.thrift.Heavy.get_dashboard_grantees_args.write(), heavydb.thrift.Heavy.get_link_view_args.write(), heavydb.thrift.Heavy.create_link_args.write(), heavydb.thrift.Heavy.load_table_binary_args.write(), heavydb.thrift.Heavy.load_table_binary_columnar_args.write(), heavydb.thrift.Heavy.load_table_binary_arrow_args.write(), heavydb.thrift.Heavy.load_table_args.write(), heavydb.thrift.Heavy.detect_column_types_args.write(), heavydb.thrift.Heavy.create_table_args.write(), heavydb.thrift.Heavy.import_table_args.write(), heavydb.thrift.Heavy.import_geo_table_args.write(), heavydb.thrift.Heavy.import_table_status_args.write(), heavydb.thrift.Heavy.get_first_geo_file_in_archive_args.write(), heavydb.thrift.Heavy.get_all_files_in_archive_args.write(), heavydb.thrift.Heavy.get_layers_in_geo_file_args.write(), heavydb.thrift.Heavy.query_get_outer_fragment_count_args.write(), heavydb.thrift.Heavy.check_table_consistency_args.write(), heavydb.thrift.Heavy.start_render_query_args.write(), heavydb.thrift.Heavy.insert_data_args.write(), heavydb.thrift.Heavy.insert_chunks_args.write(), heavydb.thrift.Heavy.checkpoint_args.write(), heavydb.thrift.Heavy.get_roles_args.write(), heavydb.thrift.Heavy.get_db_objects_for_grantee_args.write(), heavydb.thrift.Heavy.get_db_object_privs_args.write(), heavydb.thrift.Heavy.get_all_roles_for_user_args.write(), heavydb.thrift.Heavy.get_all_effective_roles_for_user_args.write(), heavydb.thrift.Heavy.has_role_args.write(), heavydb.thrift.Heavy.has_object_privilege_args.write(), heavydb.thrift.Heavy.set_license_key_args.write(), heavydb.thrift.Heavy.get_license_claims_args.write(), heavydb.thrift.Heavy.get_device_parameters_args.write(), heavydb.thrift.Heavy.register_runtime_extension_functions_args.write(), heavydb.thrift.Heavy.get_table_function_names_args.write(), heavydb.thrift.Heavy.get_runtime_table_function_names_args.write(), heavydb.thrift.Heavy.get_table_function_details_args.write(), heavydb.thrift.Heavy.get_function_names_args.write(), heavydb.thrift.Heavy.get_runtime_function_names_args.write(), and heavydb.thrift.Heavy.get_function_details_args.write().

TTransport ai.heavy.jdbc.HeavyAIConnection.transport

protected

Definition at line 336 of file HeavyAIConnection.java.

Referenced by ai.heavy.jdbc.HeavyAIConnection.manageConnection().

String ai.heavy.jdbc.HeavyAIConnection.url

protected

Definition at line 338 of file HeavyAIConnection.java.

Referenced by ai.heavy.jdbc.HeavyAIConnection.HeavyAIConnection().

SQLWarning ai.heavy.jdbc.HeavyAIConnection.warnings

protected

Definition at line 337 of file HeavyAIConnection.java.

Referenced by ai.heavy.jdbc.HeavyAIConnection.clearWarnings(), and ai.heavy.jdbc.HeavyAIConnection.getWarnings().

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/java/heavyaijdbc/src/main/java/ai/heavy/jdbc/HeavyAIConnection.java