OmniSciDB  085a039ca4
 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 143 of file HeavyAIConnection.java.

Constructor & Destructor Documentation

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

Definition at line 459 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().

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

+ 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 909 of file HeavyAIConnection.java.

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

Definition at line 626 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.warnings.

626  { // logger.debug("Entered");
627  warnings = null;
628  }
void ai.heavy.jdbc.HeavyAIConnection.close ( ) throws SQLException
inline

Definition at line 537 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__().

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

+ 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 552 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

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

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

+ Here is the caller graph for this function:

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

Definition at line 524 of file HeavyAIConnection.java.

524  { // logger.debug("Entered");
525  // noop
526  }
Array ai.heavy.jdbc.HeavyAIConnection.createArrayOf ( String  typeName,
Object[]  elements 
) throws SQLException
inline

Definition at line 862 of file HeavyAIConnection.java.

References run_benchmark_import.type, and typeName().

863  { // logger.debug("Entered");
864  TDatumType type;
865  try {
866  type = TDatumType.valueOf(typeName.toUpperCase());
867  } catch (IllegalArgumentException ex) {
868  throw new SQLException("No matching heavyDB type for " + typeName);
869  }
870  return new HeavyAIArray(type, elements);
871  }
std::string typeName(const T *v)
Definition: toString.h:102

+ Here is the call graph for this function:

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

Definition at line 791 of file HeavyAIConnection.java.

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

Definition at line 783 of file HeavyAIConnection.java.

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

Definition at line 799 of file HeavyAIConnection.java.

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

Definition at line 807 of file HeavyAIConnection.java.

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

Definition at line 485 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

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

Definition at line 631 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

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

Definition at line 724 of file HeavyAIConnection.java.

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

Definition at line 874 of file HeavyAIConnection.java.

875  { // logger.debug("Entered");
876  throw new UnsupportedOperationException("Not supported yet,"
877  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
878  + " class:" + new Throwable().getStackTrace()[0].getClassName()
879  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
880  }
HeavyAIConnection ai.heavy.jdbc.HeavyAIConnection.getAlternateConnection ( ) throws SQLException
inline

Definition at line 346 of file HeavyAIConnection.java.

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

346  {
347  // Clones the orignal java connection object, and then reconnects
348  // at the thrift layer - doesn't re-authenticate at the application
349  // level. Instead reuses the orignal connections session number.
350  logger.debug("HeavyAIConnection clone");
351  HeavyAIConnection dbConnection = null;
352  try {
353  dbConnection = (HeavyAIConnection) super.clone();
354  } catch (CloneNotSupportedException eE) {
355  throw new SQLException(
356  "Error cloning connection [" + HeavyAIExceptionText.getExceptionDetail(eE),
357  eE);
358  }
359  // Now over write the old connection.
360  try {
361  TProtocol protocol = dbConnection.manageConnection();
362  dbConnection.client = new Heavy.Client(protocol);
363  } catch (java.lang.Exception jE) {
364  throw new SQLException("Error creating new connection "
365  + HeavyAIExceptionText.getExceptionDetail(jE),
366  jE);
367  }
368  return dbConnection;
369  }
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 519 of file HeavyAIConnection.java.

519  { // logger.debug("Entered");
520  return true;
521  }
String ai.heavy.jdbc.HeavyAIConnection.getCatalog ( ) throws SQLException
inline

Definition at line 606 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.catalog.

606  { // logger.debug("Entered");
607  return catalog;
608  }
String ai.heavy.jdbc.HeavyAIConnection.getClientInfo ( String  name) throws SQLException
inline

Definition at line 845 of file HeavyAIConnection.java.

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

Definition at line 854 of file HeavyAIConnection.java.

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

Definition at line 681 of file HeavyAIConnection.java.

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

Definition at line 566 of file HeavyAIConnection.java.

566  { // logger.debug("Entered");
567  DatabaseMetaData dbMetaData = new HeavyAIDatabaseMetaData(this);
568 
569  return dbMetaData;
570  }
int ai.heavy.jdbc.HeavyAIConnection.getNetworkTimeout ( ) throws SQLException
inline

Definition at line 926 of file HeavyAIConnection.java.

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

Definition at line 901 of file HeavyAIConnection.java.

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

Definition at line 616 of file HeavyAIConnection.java.

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

Definition at line 654 of file HeavyAIConnection.java.

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

Definition at line 621 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.warnings.

621  { // logger.debug("Entered");
622  return warnings;
623  }
boolean ai.heavy.jdbc.HeavyAIConnection.isClosed ( ) throws SQLException
inline

Definition at line 558 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

558  { // logger.debug("Entered");
559  if (session == null) {
560  return true;
561  }
562  return false;
563  }
boolean ai.heavy.jdbc.HeavyAIConnection.isReadOnly ( ) throws SQLException
inline

Definition at line 580 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

580  { // logger.debug("Entered");
581  try {
582  if (session != null) {
583  TServerStatus server_status = client.get_server_status(session);
584  return server_status.read_only;
585  }
586  } catch (TDBException ex) {
587  throw new SQLException(
588  "get_server_status failed during isReadOnly check." + ex.getError_msg());
589  } catch (TException ex) {
590  throw new SQLException(
591  "get_server_status failed during isReadOnly check." + ex.toString());
592  }
593  // never should get here
594  return true;
595  }
boolean ai.heavy.jdbc.HeavyAIConnection.isValid ( int  timeout) throws SQLException
inline

Definition at line 815 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

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

Definition at line 942 of file HeavyAIConnection.java.

943  { // logger.debug("Entered");
944  throw new UnsupportedOperationException("Not supported yet,"
945  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
946  + " class:" + new Throwable().getStackTrace()[0].getClassName()
947  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
948  }
TProtocol ai.heavy.jdbc.HeavyAIConnection.manageConnection ( ) throws java.lang.Exception
inlineprivate

Definition at line 373 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().

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

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

Definition at line 496 of file HeavyAIConnection.java.

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

Definition at line 644 of file HeavyAIConnection.java.

646  { // logger.debug("Entered");
647  throw new UnsupportedOperationException("Not supported yet,"
648  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
649  + " class:" + new Throwable().getStackTrace()[0].getClassName()
650  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
651  }
CallableStatement ai.heavy.jdbc.HeavyAIConnection.prepareCall ( String  sql,
int  resultSetType,
int  resultSetConcurrency,
int  resultSetHoldability 
) throws SQLException
inline

Definition at line 745 of file HeavyAIConnection.java.

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

Definition at line 490 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

491  { // logger.debug("Entered");
492  return new HeavyAIPreparedStatement(sql, session, this);
493  }
PreparedStatement ai.heavy.jdbc.HeavyAIConnection.prepareStatement ( String  sql,
int  resultSetType,
int  resultSetConcurrency 
) throws SQLException
inline

Definition at line 637 of file HeavyAIConnection.java.

References ai.heavy.jdbc.HeavyAIConnection.session.

639  { // logger.debug("Entered");
640  return new HeavyAIPreparedStatement(sql, session, this);
641  }
PreparedStatement ai.heavy.jdbc.HeavyAIConnection.prepareStatement ( String  sql,
int  resultSetType,
int  resultSetConcurrency,
int  resultSetHoldability 
) throws SQLException
inline

Definition at line 734 of file HeavyAIConnection.java.

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

Definition at line 756 of file HeavyAIConnection.java.

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

Definition at line 765 of file HeavyAIConnection.java.

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

Definition at line 774 of file HeavyAIConnection.java.

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

Definition at line 715 of file HeavyAIConnection.java.

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

Definition at line 529 of file HeavyAIConnection.java.

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

Definition at line 706 of file HeavyAIConnection.java.

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

Definition at line 513 of file HeavyAIConnection.java.

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

Definition at line 598 of file HeavyAIConnection.java.

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

Definition at line 829 of file HeavyAIConnection.java.

829  {
830  throw new UnsupportedOperationException("Not supported yet,"
831  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
832  + " class:" + new Throwable().getStackTrace()[0].getClassName()
833  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
834  }
void ai.heavy.jdbc.HeavyAIConnection.setClientInfo ( Properties  properties) throws SQLClientInfoException
inline

Definition at line 837 of file HeavyAIConnection.java.

837  {
838  throw new UnsupportedOperationException("Not supported yet,"
839  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
840  + " class:" + new Throwable().getStackTrace()[0].getClassName()
841  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
842  }
void ai.heavy.jdbc.HeavyAIConnection.setHoldability ( int  holdability) throws SQLException
inline

Definition at line 672 of file HeavyAIConnection.java.

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

Definition at line 917 of file HeavyAIConnection.java.

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

Definition at line 573 of file HeavyAIConnection.java.

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

Definition at line 689 of file HeavyAIConnection.java.

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

Definition at line 697 of file HeavyAIConnection.java.

698  { // logger.debug("Entered");
699  throw new UnsupportedOperationException("Not supported yet,"
700  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
701  + " class:" + new Throwable().getStackTrace()[0].getClassName()
702  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
703  }
void ai.heavy.jdbc.HeavyAIConnection.setSchema ( String  schema) throws SQLException
inline

Definition at line 883 of file HeavyAIConnection.java.

References ai.heavy.jdbc.Options.db_name.

883  { // logger.debug("Entered");
884  // Setting setSchema to be a NOOP allows integration with third party products
885  // that require a successful call to setSchema to work.
886  Object db_name = this.cP.getProperty(Options.db_name);
887  if (db_name == null) {
888  throw new SQLException("db name not set, "
889  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
890  + " class:" + new Throwable().getStackTrace()[0].getClassName()
891  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
892  }
893  if (!schema.equals(db_name.toString())) {
894  logger.warn("Connected to schema [" + schema + "] differs from db name [" + db_name
895  + "].");
896  }
897  return;
898  }
void ai.heavy.jdbc.HeavyAIConnection.setSession ( Object  pki_auth) throws java.lang.Exception
inlineprivate

Definition at line 434 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().

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

+ Here is the caller graph for this function:

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

Definition at line 611 of file HeavyAIConnection.java.

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

Definition at line 663 of file HeavyAIConnection.java.

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

Definition at line 934 of file HeavyAIConnection.java.

934  { // logger.debug("Entered");
935  throw new UnsupportedOperationException("Not supported yet,"
936  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
937  + " class:" + new Throwable().getStackTrace()[0].getClassName()
938  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
939  }

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 144 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 146 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 338 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(), 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(), and heavydb.thrift.Heavy.get_table_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: