OmniSciDB  a987f07e93
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
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().

454  {
455  this.url = url;
456  this.cP = new Connection_properties(url, base_properties);
457  try {
458  TProtocol protocol = manageConnection();
459  client = new Heavy.Client(protocol);
460  setSession(this.cP.getProperty(Options.pkiauth));
461  catalog = (String) this.cP.getProperty(Options.db_name);
462  } catch (TTransportException ex) {
463  throw new SQLException("Thrift transport connection failed - "
464  + HeavyAIExceptionText.getExceptionDetail(ex),
465  ex);
466  } catch (TDBException ex) {
467  throw new SQLException("HEAVY.AI connection failed - "
468  + HeavyAIExceptionText.getExceptionDetail(ex),
469  ex);
470  } catch (TException ex) {
471  throw new SQLException(
472  "Thrift failed - " + HeavyAIExceptionText.getExceptionDetail(ex), ex);
473  } catch (java.lang.Exception ex) {
474  throw new SQLException(
475  "Connection failed - " + HeavyAIExceptionText.getExceptionDetail(ex), ex);
476  }
477  }

+ 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.

904  { // logger.debug("Entered");
905  throw new UnsupportedOperationException("Not supported yet,"
906  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
907  + " class:" + new Throwable().getStackTrace()[0].getClassName()
908  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
909  }
void ai.heavy.jdbc.HeavyAIConnection.clearWarnings ( ) throws SQLException
inline

Definition at line 621 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.warnings.

621  { // logger.debug("Entered");
622  warnings = null;
623  }
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__().

532  { // logger.debug("Entered");
533  try {
534  logger.debug("Session at close is " + session);
535  if (session != null) {
536  client.disconnect(session);
537  }
538  closeConnection();
539  } catch (TDBException ex) {
540  throw new SQLException("disconnect failed." + ex.getError_msg());
541  } catch (TException ex) {
542  throw new SQLException("disconnect failed." + ex.toString());
543  }
544  }

+ 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().

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

+ 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.

519  { // logger.debug("Entered");
520  // noop
521  }
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().

858  { // logger.debug("Entered");
859  TDatumType type;
860  try {
861  type = TDatumType.valueOf(typeName.toUpperCase());
862  } catch (IllegalArgumentException ex) {
863  throw new SQLException("No matching heavyDB type for " + typeName);
864  }
865  return new HeavyAIArray(type, elements);
866  }
std::string typeName(const T *v)
Definition: toString.h:103

+ 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.

786  { // logger.debug("Entered");
787  throw new UnsupportedOperationException("Not supported yet,"
788  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
789  + " class:" + new Throwable().getStackTrace()[0].getClassName()
790  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
791  }
Clob ai.heavy.jdbc.HeavyAIConnection.createClob ( ) throws SQLException
inline

Definition at line 778 of file HeavyAIConnection.java.

778  { // logger.debug("Entered");
779  throw new UnsupportedOperationException("Not supported yet,"
780  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
781  + " class:" + new Throwable().getStackTrace()[0].getClassName()
782  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
783  }
NClob ai.heavy.jdbc.HeavyAIConnection.createNClob ( ) throws SQLException
inline

Definition at line 794 of file HeavyAIConnection.java.

794  { // logger.debug("Entered");
795  throw new UnsupportedOperationException("Not supported yet,"
796  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
797  + " class:" + new Throwable().getStackTrace()[0].getClassName()
798  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
799  }
SQLXML ai.heavy.jdbc.HeavyAIConnection.createSQLXML ( ) throws SQLException
inline

Definition at line 802 of file HeavyAIConnection.java.

802  { // logger.debug("Entered");
803  throw new UnsupportedOperationException("Not supported yet,"
804  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
805  + " class:" + new Throwable().getStackTrace()[0].getClassName()
806  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
807  }
Statement ai.heavy.jdbc.HeavyAIConnection.createStatement ( ) throws SQLException
inline

Definition at line 480 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

480  { // logger.debug("Entered");
481  return new HeavyAIStatement(session, this);
482  }
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.

627  { // logger.debug("Entered");
628  return new HeavyAIStatement(session, this);
629  }
Statement ai.heavy.jdbc.HeavyAIConnection.createStatement ( int  resultSetType,
int  resultSetConcurrency,
int  resultSetHoldability 
) throws SQLException
inline

Definition at line 719 of file HeavyAIConnection.java.

721  { // logger.debug("Entered");
722  throw new UnsupportedOperationException("Not supported yet,"
723  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
724  + " class:" + new Throwable().getStackTrace()[0].getClassName()
725  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
726  }
Struct ai.heavy.jdbc.HeavyAIConnection.createStruct ( String  typeName,
Object[]  attributes 
) throws SQLException
inline

Definition at line 869 of file HeavyAIConnection.java.

870  { // logger.debug("Entered");
871  throw new UnsupportedOperationException("Not supported yet,"
872  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
873  + " class:" + new Throwable().getStackTrace()[0].getClassName()
874  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
875  }
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().

341  {
342  // Clones the orignal java connection object, and then reconnects
343  // at the thrift layer - doesn't re-authenticate at the application
344  // level. Instead reuses the orignal connections session number.
345  logger.debug("HeavyAIConnection clone");
346  HeavyAIConnection dbConnection = null;
347  try {
348  dbConnection = (HeavyAIConnection) super.clone();
349  } catch (CloneNotSupportedException eE) {
350  throw new SQLException(
351  "Error cloning connection [" + HeavyAIExceptionText.getExceptionDetail(eE),
352  eE);
353  }
354  // Now over write the old connection.
355  try {
356  TProtocol protocol = dbConnection.manageConnection();
357  dbConnection.client = new Heavy.Client(protocol);
358  } catch (java.lang.Exception jE) {
359  throw new SQLException("Error creating new connection "
360  + HeavyAIExceptionText.getExceptionDetail(jE),
361  jE);
362  }
363  return dbConnection;
364  }
HeavyAIConnection(String url, Properties base_properties)

+ 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.

514  { // logger.debug("Entered");
515  return true;
516  }
String ai.heavy.jdbc.HeavyAIConnection.getCatalog ( ) throws SQLException
inline

Definition at line 601 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.catalog.

601  { // logger.debug("Entered");
602  return catalog;
603  }
String ai.heavy.jdbc.HeavyAIConnection.getClientInfo ( String  name) throws SQLException
inline

Definition at line 840 of file HeavyAIConnection.java.

841  { // logger.debug("Entered");
842  throw new UnsupportedOperationException("Not supported yet,"
843  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
844  + " class:" + new Throwable().getStackTrace()[0].getClassName()
845  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
846  }
Properties ai.heavy.jdbc.HeavyAIConnection.getClientInfo ( ) throws SQLException
inline

Definition at line 849 of file HeavyAIConnection.java.

849  { // logger.debug("Entered");
850  throw new UnsupportedOperationException("Not supported yet,"
851  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
852  + " class:" + new Throwable().getStackTrace()[0].getClassName()
853  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
854  }
int ai.heavy.jdbc.HeavyAIConnection.getHoldability ( ) throws SQLException
inline

Definition at line 676 of file HeavyAIConnection.java.

676  { // logger.debug("Entered");
677  throw new UnsupportedOperationException("Not supported yet,"
678  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
679  + " class:" + new Throwable().getStackTrace()[0].getClassName()
680  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
681  }
DatabaseMetaData ai.heavy.jdbc.HeavyAIConnection.getMetaData ( ) throws SQLException
inline

Definition at line 561 of file HeavyAIConnection.java.

561  { // logger.debug("Entered");
562  DatabaseMetaData dbMetaData = new HeavyAIDatabaseMetaData(this);
563 
564  return dbMetaData;
565  }
int ai.heavy.jdbc.HeavyAIConnection.getNetworkTimeout ( ) throws SQLException
inline

Definition at line 921 of file HeavyAIConnection.java.

921  { // logger.debug("Entered");
922  throw new UnsupportedOperationException("Not supported yet,"
923  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
924  + " class:" + new Throwable().getStackTrace()[0].getClassName()
925  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
926  }
String ai.heavy.jdbc.HeavyAIConnection.getSchema ( ) throws SQLException
inline

Definition at line 896 of file HeavyAIConnection.java.

896  { // logger.debug("Entered");
897  throw new UnsupportedOperationException("Not supported yet,"
898  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
899  + " class:" + new Throwable().getStackTrace()[0].getClassName()
900  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
901  }
int ai.heavy.jdbc.HeavyAIConnection.getTransactionIsolation ( ) throws SQLException
inline

Definition at line 611 of file HeavyAIConnection.java.

611  { // logger.debug("Entered");
612  return Connection.TRANSACTION_NONE;
613  }
Map<String, Class<?> > ai.heavy.jdbc.HeavyAIConnection.getTypeMap ( ) throws SQLException
inline

Definition at line 649 of file HeavyAIConnection.java.

650  { // logger.debug("Entered");
651  throw new UnsupportedOperationException("Not supported yet,"
652  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
653  + " class:" + new Throwable().getStackTrace()[0].getClassName()
654  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
655  }
SQLWarning ai.heavy.jdbc.HeavyAIConnection.getWarnings ( ) throws SQLException
inline

Definition at line 616 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.warnings.

616  { // logger.debug("Entered");
617  return warnings;
618  }
boolean ai.heavy.jdbc.HeavyAIConnection.isClosed ( ) throws SQLException
inline

Definition at line 553 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

553  { // logger.debug("Entered");
554  if (session == null) {
555  return true;
556  }
557  return false;
558  }
boolean ai.heavy.jdbc.HeavyAIConnection.isReadOnly ( ) throws SQLException
inline

Definition at line 575 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

575  { // logger.debug("Entered");
576  try {
577  if (session != null) {
578  TServerStatus server_status = client.get_server_status(session);
579  return server_status.read_only;
580  }
581  } catch (TDBException ex) {
582  throw new SQLException(
583  "get_server_status failed during isReadOnly check." + ex.getError_msg());
584  } catch (TException ex) {
585  throw new SQLException(
586  "get_server_status failed during isReadOnly check." + ex.toString());
587  }
588  // never should get here
589  return true;
590  }
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.

810  { // logger.debug("Entered");
811  try {
812  client.get_server_status(session);
813  } catch (TTransportException ex) {
814  throw new SQLException("Connection failed - " + ex.toString());
815  } catch (TDBException ex) {
816  throw new SQLException("Connection failed - " + ex.getError_msg());
817  } catch (TException ex) {
818  throw new SQLException("Connection failed - " + ex.toString());
819  }
820  return true;
821  }
boolean ai.heavy.jdbc.HeavyAIConnection.isWrapperFor ( Class<?>  iface) throws SQLException
inline

Definition at line 937 of file HeavyAIConnection.java.

938  { // logger.debug("Entered");
939  throw new UnsupportedOperationException("Not supported yet,"
940  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
941  + " class:" + new Throwable().getStackTrace()[0].getClassName()
942  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
943  }
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().

368  {
369  SockTransportProperties skT = null;
370  String trust_store = null;
371  if (cP.getProperty(Options.server_trust_store) != null
372  && !cP.getProperty(Options.server_trust_store).isEmpty()) {
373  trust_store = cP.getProperty(Options.server_trust_store);
374  }
375  String trust_store_pwd = null;
376  if (cP.getProperty(Options.server_trust_store_pwd) != null
377  && !cP.getProperty(Options.server_trust_store_pwd).isEmpty()) {
378  trust_store_pwd = cP.getProperty(Options.server_trust_store_pwd);
379  }
380 
381  TProtocol protocol = null;
382  if (this.cP.isHttpProtocol()) {
383  // HTTP
384  skT = SockTransportProperties.getUnencryptedClient();
385 
386  transport = skT.openHttpClientTransport(this.cP.getProperty(Options.host_name),
387  Integer.parseInt(this.cP.getProperty(Options.port_num)));
388  transport.open();
389  protocol = new TJSONProtocol(transport);
390 
391  } else if (this.cP.isBinary()) {
392  skT = SockTransportProperties.getUnencryptedClient();
393  transport = skT.openClientTransport(this.cP.getProperty(Options.host_name),
394  Integer.parseInt(this.cP.getProperty(Options.port_num)));
395  if (!transport.isOpen()) transport.open();
396  protocol = new TBinaryProtocol(transport);
397 
398  } else if (this.cP.isHttpsProtocol() || this.cP.isHttpsProtocol_insecure()) {
399  if (trust_store == null) {
400  skT = SockTransportProperties.getEncryptedClientDefaultTrustStore(
401  !this.cP.isHttpsProtocol_insecure());
402  } else {
403  skT = SockTransportProperties.getEncryptedClientSpecifiedTrustStore(
404  trust_store, trust_store_pwd, !this.cP.isHttpsProtocol_insecure());
405  }
406  transport = skT.openHttpsClientTransport(this.cP.getProperty(Options.host_name),
407  Integer.parseInt(this.cP.getProperty(Options.port_num)));
408  transport.open();
409  protocol = new TJSONProtocol(transport);
410 
411  } else if (cP.isBinary_tls()) {
412  if (trust_store == null) {
413  skT = SockTransportProperties.getEncryptedClientDefaultTrustStore(false);
414  } else {
415  skT = SockTransportProperties.getEncryptedClientSpecifiedTrustStore(
416  trust_store, trust_store_pwd, false);
417  }
418  transport = skT.openClientTransport(this.cP.getProperty(Options.host_name),
419  Integer.parseInt(this.cP.getProperty(Options.port_num)));
420 
421  if (!transport.isOpen()) transport.open();
422  protocol = new TBinaryProtocol(transport);
423  } else {
424  throw new SQLException("Invalid protocol supplied");
425  }
426  return protocol;
427  }
static String server_trust_store_pwd
static String server_trust_store

+ 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.

500  { // logger.debug("Entered");
501  throw new UnsupportedOperationException("Not supported yet,"
502  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
503  + " class:" + new Throwable().getStackTrace()[0].getClassName()
504  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
505  }
CallableStatement ai.heavy.jdbc.HeavyAIConnection.prepareCall ( String  sql) throws SQLException
inline

Definition at line 491 of file HeavyAIConnection.java.

492  { // logger.debug("Entered");
493  throw new UnsupportedOperationException("Not supported yet,"
494  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
495  + " class:" + new Throwable().getStackTrace()[0].getClassName()
496  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
497  }
CallableStatement ai.heavy.jdbc.HeavyAIConnection.prepareCall ( String  sql,
int  resultSetType,
int  resultSetConcurrency 
) throws SQLException
inline

Definition at line 639 of file HeavyAIConnection.java.

641  { // logger.debug("Entered");
642  throw new UnsupportedOperationException("Not supported yet,"
643  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
644  + " class:" + new Throwable().getStackTrace()[0].getClassName()
645  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
646  }
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.

743  { // logger.debug("Entered");
744  throw new UnsupportedOperationException("Not supported yet,"
745  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
746  + " class:" + new Throwable().getStackTrace()[0].getClassName()
747  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
748  }
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.

486  { // logger.debug("Entered");
487  return new HeavyAIPreparedStatement(sql, session, this);
488  }
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.

634  { // logger.debug("Entered");
635  return new HeavyAIPreparedStatement(sql, session, this);
636  }
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.

732  { // logger.debug("Entered");
733  throw new UnsupportedOperationException("Not supported yet,"
734  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
735  + " class:" + new Throwable().getStackTrace()[0].getClassName()
736  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
737  }
PreparedStatement ai.heavy.jdbc.HeavyAIConnection.prepareStatement ( String  sql,
int  autoGeneratedKeys 
) throws SQLException
inline

Definition at line 751 of file HeavyAIConnection.java.

752  { // logger.debug("Entered");
753  throw new UnsupportedOperationException("Not supported yet,"
754  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
755  + " class:" + new Throwable().getStackTrace()[0].getClassName()
756  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
757  }
PreparedStatement ai.heavy.jdbc.HeavyAIConnection.prepareStatement ( String  sql,
int[]  columnIndexes 
) throws SQLException
inline

Definition at line 760 of file HeavyAIConnection.java.

761  { // logger.debug("Entered");
762  throw new UnsupportedOperationException("Not supported yet,"
763  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
764  + " class:" + new Throwable().getStackTrace()[0].getClassName()
765  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
766  }
PreparedStatement ai.heavy.jdbc.HeavyAIConnection.prepareStatement ( String  sql,
String[]  columnNames 
) throws SQLException
inline

Definition at line 769 of file HeavyAIConnection.java.

770  { // logger.debug("Entered");
771  throw new UnsupportedOperationException("Not supported yet,"
772  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
773  + " class:" + new Throwable().getStackTrace()[0].getClassName()
774  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
775  }
void ai.heavy.jdbc.HeavyAIConnection.releaseSavepoint ( Savepoint  savepoint) throws SQLException
inline

Definition at line 710 of file HeavyAIConnection.java.

711  { // logger.debug("Entered");
712  throw new UnsupportedOperationException("Not supported yet,"
713  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
714  + " class:" + new Throwable().getStackTrace()[0].getClassName()
715  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
716  }
void ai.heavy.jdbc.HeavyAIConnection.rollback ( ) throws SQLException
inline

Definition at line 524 of file HeavyAIConnection.java.

524  { // logger.debug("Entered");
525  throw new UnsupportedOperationException("Not supported yet,"
526  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
527  + " class:" + new Throwable().getStackTrace()[0].getClassName()
528  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
529  }
void ai.heavy.jdbc.HeavyAIConnection.rollback ( Savepoint  savepoint) throws SQLException
inline

Definition at line 701 of file HeavyAIConnection.java.

702  { // logger.debug("Entered");
703  throw new UnsupportedOperationException("Not supported yet,"
704  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
705  + " class:" + new Throwable().getStackTrace()[0].getClassName()
706  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
707  }
void ai.heavy.jdbc.HeavyAIConnection.setAutoCommit ( boolean  autoCommit) throws SQLException
inline

Definition at line 508 of file HeavyAIConnection.java.

509  { // logger.debug("Entered");
510  // we always autocommit per statement
511  }
void ai.heavy.jdbc.HeavyAIConnection.setCatalog ( String  catalog) throws SQLException
inline

Definition at line 593 of file HeavyAIConnection.java.

593  { // logger.debug("Entered");
594  throw new UnsupportedOperationException("Not supported yet,"
595  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
596  + " class:" + new Throwable().getStackTrace()[0].getClassName()
597  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
598  }
void ai.heavy.jdbc.HeavyAIConnection.setClientInfo ( String  name,
String  value 
) throws SQLClientInfoException
inline

Definition at line 824 of file HeavyAIConnection.java.

824  {
825  throw new UnsupportedOperationException("Not supported yet,"
826  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
827  + " class:" + new Throwable().getStackTrace()[0].getClassName()
828  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
829  }
void ai.heavy.jdbc.HeavyAIConnection.setClientInfo ( Properties  properties) throws SQLClientInfoException
inline

Definition at line 832 of file HeavyAIConnection.java.

832  {
833  throw new UnsupportedOperationException("Not supported yet,"
834  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
835  + " class:" + new Throwable().getStackTrace()[0].getClassName()
836  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
837  }
void ai.heavy.jdbc.HeavyAIConnection.setHoldability ( int  holdability) throws SQLException
inline

Definition at line 667 of file HeavyAIConnection.java.

668  { // logger.debug("Entered");
669  throw new UnsupportedOperationException("Not supported yet,"
670  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
671  + " class:" + new Throwable().getStackTrace()[0].getClassName()
672  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
673  }
void ai.heavy.jdbc.HeavyAIConnection.setNetworkTimeout ( Executor  executor,
int  milliseconds 
) throws SQLException
inline

Definition at line 912 of file HeavyAIConnection.java.

913  { // logger.debug("Entered");
914  throw new UnsupportedOperationException("Not supported yet,"
915  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
916  + " class:" + new Throwable().getStackTrace()[0].getClassName()
917  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
918  }
void ai.heavy.jdbc.HeavyAIConnection.setReadOnly ( boolean  readOnly) throws SQLException
inline

Definition at line 568 of file HeavyAIConnection.java.

569  { // logger.debug("Entered");
570  // TODO MAT we can't push the readonly upstream currently
571  // but we could make JDBC obey this command
572  }
Savepoint ai.heavy.jdbc.HeavyAIConnection.setSavepoint ( ) throws SQLException
inline

Definition at line 684 of file HeavyAIConnection.java.

684  { // logger.debug("Entered");
685  throw new UnsupportedOperationException("Not supported yet,"
686  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
687  + " class:" + new Throwable().getStackTrace()[0].getClassName()
688  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
689  }
Savepoint ai.heavy.jdbc.HeavyAIConnection.setSavepoint ( String  name) throws SQLException
inline

Definition at line 692 of file HeavyAIConnection.java.

693  { // logger.debug("Entered");
694  throw new UnsupportedOperationException("Not supported yet,"
695  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
696  + " class:" + new Throwable().getStackTrace()[0].getClassName()
697  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
698  }
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.

878  { // logger.debug("Entered");
879  // Setting setSchema to be a NOOP allows integration with third party products
880  // that require a successful call to setSchema to work.
881  Object db_name = this.cP.getProperty(Options.db_name);
882  if (db_name == null) {
883  throw new SQLException("db name not set, "
884  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
885  + " class:" + new Throwable().getStackTrace()[0].getClassName()
886  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
887  }
888  if (!schema.equals(db_name.toString())) {
889  logger.warn("Connected to schema [" + schema + "] differs from db name [" + db_name
890  + "].");
891  }
892  return;
893  }
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().

429  {
430  KeyLoader.S_struct s_struct = null;
431  // If pki aut then stuff public cert into password.
432  if (pki_auth != null && pki_auth.toString().equalsIgnoreCase("true")) {
433  s_struct = KeyLoader.getDetails_pkcs12(this.cP.getProperty(Options.sslcert),
434  this.cP.getProperty(Options.sslkey_password));
435  this.cP.setProperty(Options.password, s_struct.cert);
436  }
437 
438  // Get the seesion for all connectioms
439  session = client.connect((String) this.cP.getProperty(Options.user),
440  (String) this.cP.getProperty(Options.password),
441  (String) this.cP.getProperty(Options.db_name));
442 
443  // if pki auth the session will be encoded.
444  if (pki_auth != null && pki_auth.toString().equalsIgnoreCase("true")) {
445  Cipher cipher = Cipher.getInstance(s_struct.key.getAlgorithm());
446  cipher.init(Cipher.DECRYPT_MODE, s_struct.key);
447  // session is encrypted and encoded in b64
448  byte[] decodedBytes = Base64.getDecoder().decode(session);
449  byte[] decoded_bytes = cipher.doFinal(decodedBytes);
450  session = new String(decoded_bytes, "UTF-8");
451  }
452  }

+ 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.

607  { // logger.debug("Entered");
608  }
void ai.heavy.jdbc.HeavyAIConnection.setTypeMap ( Map< String, Class<?>>  map) throws SQLException
inline

Definition at line 658 of file HeavyAIConnection.java.

659  { // logger.debug("Entered");
660  throw new UnsupportedOperationException("Not supported yet,"
661  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
662  + " class:" + new Throwable().getStackTrace()[0].getClassName()
663  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
664  }
public<T> T ai.heavy.jdbc.HeavyAIConnection.unwrap ( Class< T >  iface) throws SQLException
inlinepackage

Definition at line 929 of file HeavyAIConnection.java.

929  { // logger.debug("Entered");
930  throw new UnsupportedOperationException("Not supported yet,"
931  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
932  + " class:" + new Throwable().getStackTrace()[0].getClassName()
933  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
934  }

Member Data Documentation

String ai.heavy.jdbc.HeavyAIConnection.catalog
protected
Heavy.Client ai.heavy.jdbc.HeavyAIConnection.client = null
protected
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_columnar_polys_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_columnar_polys_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
String ai.heavy.jdbc.HeavyAIConnection.url
protected
SQLWarning ai.heavy.jdbc.HeavyAIConnection.warnings
protected

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