OmniSciDB  addbbd5075
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
com.omnisci.jdbc.OmniSciConnection Class Reference
+ Inheritance diagram for com.omnisci.jdbc.OmniSciConnection:
+ Collaboration diagram for com.omnisci.jdbc.OmniSciConnection:

Classes

class  Connection_properties
 

Public Member Functions

 OmniSciConnection (String url, Properties info) 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 Attributes

String session = null
 
MapD.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(OmniSciConnection.class)
 

Detailed Description

Definition at line 138 of file OmniSciConnection.java.

Constructor & Destructor Documentation

com.omnisci.jdbc.OmniSciConnection.OmniSciConnection ( String  url,
Properties  info 
) throws SQLException
inline

Definition at line 282 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.catalog, com.omnisci.jdbc.OmniSciConnection.client, com.omnisci.jdbc.OmniSciConnection.cP, com.omnisci.jdbc.Connection_enums.db_name, com.omnisci.jdbc.Connection_enums.host_name, Integer, com.omnisci.jdbc.OmniSciConnection.Connection_properties.isBinary(), com.omnisci.jdbc.OmniSciConnection.Connection_properties.isBinary_tls(), com.omnisci.jdbc.OmniSciConnection.Connection_properties.isHttpProtocol(), com.omnisci.jdbc.OmniSciConnection.Connection_properties.isHttpsProtocol(), com.omnisci.jdbc.Connection_enums.pkiauth, com.omnisci.jdbc.Connection_enums.port_num, com.omnisci.jdbc.Connection_enums.server_trust_store, com.omnisci.jdbc.Connection_enums.server_trust_store_pwd, com.omnisci.jdbc.OmniSciConnection.session, com.omnisci.jdbc.Connection_enums.sslcert, com.omnisci.jdbc.Connection_enums.sslkey_password, Experimental.String, com.omnisci.jdbc.OmniSciConnection.transport, com.omnisci.jdbc.OmniSciConnection.url, com.omnisci.jdbc.Connection_enums.user, and com.omnisci.jdbc.Connection_enums.user_passwd.

283  { // logger.debug("Entered");
284  this.url = url;
285  this.cP = new Connection_properties(info, url);
286  SockTransportProperties skT = null;
287  String trust_store = null;
288  if (cP.get(Connection_enums.server_trust_store) != null
289  && !cP.get(Connection_enums.server_trust_store).toString().isEmpty()) {
290  trust_store = cP.get(Connection_enums.server_trust_store).toString();
291  }
292  String trust_store_pwd = null;
293  if (cP.get(Connection_enums.server_trust_store_pwd) != null
294  && !cP.get(Connection_enums.server_trust_store_pwd).toString().isEmpty()) {
295  trust_store_pwd = cP.get(Connection_enums.server_trust_store_pwd).toString();
296  }
297  try {
298  // cP extends hashtable. hashtable get returns null when the
299  // key isn't present. If trust_store and keys_store_pwd are not present
300  // skT should then load the default java certs file ca-cert.
301  TProtocol protocol = null;
302  if (this.cP.isHttpProtocol()) {
303  // HTTP
304  skT = SockTransportProperties.getUnencryptedClient();
305  transport = skT.openHttpClientTransport(
306  (String) this.cP.get(Connection_enums.host_name),
307  ((Integer) this.cP.get(Connection_enums.port_num)).intValue());
308  transport.open();
309  protocol = new TJSONProtocol(transport);
310 
311  } else if (this.cP.isBinary()) {
312  skT = SockTransportProperties.getUnencryptedClient();
313  transport =
314  skT.openClientTransport((String) this.cP.get(Connection_enums.host_name),
315  ((Integer) this.cP.get(Connection_enums.port_num)).intValue());
316  if (!transport.isOpen()) transport.open();
317  protocol = new TBinaryProtocol(transport);
318 
319  } else if (this.cP.isHttpsProtocol() || this.cP.isHttpsProtocol_insecure()) {
320  if (trust_store == null) {
321  skT = SockTransportProperties.getEncryptedClientDefaultTrustStore(
322  !this.cP.isHttpsProtocol_insecure());
323  } else {
324  skT = SockTransportProperties.getEncryptedClientSpecifiedTrustStore(
325  trust_store, trust_store_pwd, !this.cP.isHttpsProtocol_insecure());
326  }
327  transport = skT.openHttpsClientTransport(
328  (String) this.cP.get(Connection_enums.host_name),
329  ((Integer) this.cP.get(Connection_enums.port_num)).intValue());
330  transport.open();
331  protocol = new TJSONProtocol(transport);
332 
333  } else if (cP.isBinary_tls()) {
334  if (trust_store == null) {
335  skT = SockTransportProperties.getEncryptedClientDefaultTrustStore(false);
336  } else {
337  skT = SockTransportProperties.getEncryptedClientSpecifiedTrustStore(
338  trust_store, trust_store_pwd, false);
339  }
340  transport =
341  skT.openClientTransport((String) this.cP.get(Connection_enums.host_name),
342  ((Integer) this.cP.get(Connection_enums.port_num)).intValue());
343 
344  if (!transport.isOpen()) transport.open();
345  protocol = new TBinaryProtocol(transport);
346  } else {
347  throw new RuntimeException("Invalid protocol supplied");
348  }
349 
350  client = new MapD.Client(protocol);
351  KeyLoader.S_struct s_struct = null;
352  Object pki_auth = this.cP.get(Connection_enums.pkiauth);
353  if (pki_auth != null && pki_auth.toString().equalsIgnoreCase("true")) {
354  s_struct = KeyLoader.getDetails_pkcs12(
355  this.cP.get(Connection_enums.sslcert).toString(),
356  this.cP.get(Connection_enums.sslkey_password).toString());
357  this.cP.put(Connection_enums.user_passwd, s_struct.cert);
358  }
359  session = client.connect((String) this.cP.get(Connection_enums.user),
360  (String) this.cP.get(Connection_enums.user_passwd),
361  (String) this.cP.get(Connection_enums.db_name));
362  if (pki_auth != null && pki_auth.toString().equalsIgnoreCase("true")) {
363  Cipher cipher = Cipher.getInstance(s_struct.key.getAlgorithm());
364  cipher.init(Cipher.DECRYPT_MODE, s_struct.key);
365  // session is encrypted and encoded in b64
366  byte[] decodedBytes = Base64.getDecoder().decode(session);
367  byte[] decoded_bytes = cipher.doFinal(decodedBytes);
368  session = new String(decoded_bytes, "UTF-8");
369  }
370  catalog = (String) this.cP.get(Connection_enums.db_name);
371  logger.debug("Connected session is " + session);
372 
373  } catch (TTransportException ex) {
374  throw new SQLException("Connection failed - " + ex.toString());
375  } catch (TMapDException ex) {
376  throw new SQLException("Connection failed - " + ex.toString());
377  } catch (TException ex) {
378  throw new SQLException("Connection failed - " + ex.toString());
379  } catch (java.lang.Exception ex) {
380  throw new SQLException("Connection failed - " + ex.toString());
381  }
382  }

+ Here is the call graph for this function:

Member Function Documentation

void com.omnisci.jdbc.OmniSciConnection.abort ( Executor  executor) throws SQLException
inline

Definition at line 791 of file OmniSciConnection.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  }
void com.omnisci.jdbc.OmniSciConnection.clearWarnings ( ) throws SQLException
inline

Definition at line 521 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.warnings.

521  { // logger.debug("Entered");
522  warnings = null;
523  }
void com.omnisci.jdbc.OmniSciConnection.close ( ) throws SQLException
inline

Definition at line 437 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.session.

437  { // logger.debug("Entered");
438  try {
439  logger.debug("Session at close is " + session);
440  if (session != null) {
441  client.disconnect(session);
442  }
443  session = null;
444  transport.close();
445  } catch (TMapDException ex) {
446  throw new SQLException("disconnect failed." + ex.toString());
447  } catch (TException ex) {
448  throw new SQLException("disconnect failed." + ex.toString());
449  }
450  }
void com.omnisci.jdbc.OmniSciConnection.commit ( ) throws SQLException
inline

Definition at line 424 of file OmniSciConnection.java.

424  { // logger.debug("Entered");
425  // noop
426  }
Array com.omnisci.jdbc.OmniSciConnection.createArrayOf ( String  typeName,
Object[]  elements 
) throws SQLException
inline

Definition at line 757 of file OmniSciConnection.java.

758  { // logger.debug("Entered");
759  throw new UnsupportedOperationException("Not supported yet,"
760  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
761  + " class:" + new Throwable().getStackTrace()[0].getClassName()
762  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
763  }
Blob com.omnisci.jdbc.OmniSciConnection.createBlob ( ) throws SQLException
inline

Definition at line 686 of file OmniSciConnection.java.

686  { // logger.debug("Entered");
687  throw new UnsupportedOperationException("Not supported yet,"
688  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
689  + " class:" + new Throwable().getStackTrace()[0].getClassName()
690  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
691  }
Clob com.omnisci.jdbc.OmniSciConnection.createClob ( ) throws SQLException
inline

Definition at line 678 of file OmniSciConnection.java.

678  { // logger.debug("Entered");
679  throw new UnsupportedOperationException("Not supported yet,"
680  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
681  + " class:" + new Throwable().getStackTrace()[0].getClassName()
682  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
683  }
NClob com.omnisci.jdbc.OmniSciConnection.createNClob ( ) throws SQLException
inline

Definition at line 694 of file OmniSciConnection.java.

694  { // logger.debug("Entered");
695  throw new UnsupportedOperationException("Not supported yet,"
696  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
697  + " class:" + new Throwable().getStackTrace()[0].getClassName()
698  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
699  }
SQLXML com.omnisci.jdbc.OmniSciConnection.createSQLXML ( ) throws SQLException
inline

Definition at line 702 of file OmniSciConnection.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  }
Statement com.omnisci.jdbc.OmniSciConnection.createStatement ( ) throws SQLException
inline

Definition at line 385 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.client, and com.omnisci.jdbc.OmniSciConnection.session.

385  { // logger.debug("Entered");
386  return new OmniSciStatement(session, client);
387  }
Statement com.omnisci.jdbc.OmniSciConnection.createStatement ( int  resultSetType,
int  resultSetConcurrency 
) throws SQLException
inline

Definition at line 526 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.client, and com.omnisci.jdbc.OmniSciConnection.session.

527  { // logger.debug("Entered");
528  return new OmniSciStatement(session, client);
529  }
Statement com.omnisci.jdbc.OmniSciConnection.createStatement ( int  resultSetType,
int  resultSetConcurrency,
int  resultSetHoldability 
) throws SQLException
inline

Definition at line 619 of file OmniSciConnection.java.

621  { // logger.debug("Entered");
622  throw new UnsupportedOperationException("Not supported yet,"
623  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
624  + " class:" + new Throwable().getStackTrace()[0].getClassName()
625  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
626  }
Struct com.omnisci.jdbc.OmniSciConnection.createStruct ( String  typeName,
Object[]  attributes 
) throws SQLException
inline

Definition at line 766 of file OmniSciConnection.java.

767  { // logger.debug("Entered");
768  throw new UnsupportedOperationException("Not supported yet,"
769  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
770  + " class:" + new Throwable().getStackTrace()[0].getClassName()
771  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
772  }
boolean com.omnisci.jdbc.OmniSciConnection.getAutoCommit ( ) throws SQLException
inline

Definition at line 419 of file OmniSciConnection.java.

419  { // logger.debug("Entered");
420  return true;
421  }
String com.omnisci.jdbc.OmniSciConnection.getCatalog ( ) throws SQLException
inline

Definition at line 501 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.catalog.

501  { // logger.debug("Entered");
502  return catalog;
503  }
String com.omnisci.jdbc.OmniSciConnection.getClientInfo ( String  name) throws SQLException
inline

Definition at line 740 of file OmniSciConnection.java.

741  { // logger.debug("Entered");
742  throw new UnsupportedOperationException("Not supported yet,"
743  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
744  + " class:" + new Throwable().getStackTrace()[0].getClassName()
745  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
746  }
Properties com.omnisci.jdbc.OmniSciConnection.getClientInfo ( ) throws SQLException
inline

Definition at line 749 of file OmniSciConnection.java.

749  { // logger.debug("Entered");
750  throw new UnsupportedOperationException("Not supported yet,"
751  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
752  + " class:" + new Throwable().getStackTrace()[0].getClassName()
753  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
754  }
int com.omnisci.jdbc.OmniSciConnection.getHoldability ( ) throws SQLException
inline

Definition at line 576 of file OmniSciConnection.java.

576  { // logger.debug("Entered");
577  throw new UnsupportedOperationException("Not supported yet,"
578  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
579  + " class:" + new Throwable().getStackTrace()[0].getClassName()
580  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
581  }
DatabaseMetaData com.omnisci.jdbc.OmniSciConnection.getMetaData ( ) throws SQLException
inline

Definition at line 461 of file OmniSciConnection.java.

461  { // logger.debug("Entered");
462  DatabaseMetaData mapDMetaData = new OmniSciDatabaseMetaData(this);
463 
464  return mapDMetaData;
465  }
int com.omnisci.jdbc.OmniSciConnection.getNetworkTimeout ( ) throws SQLException
inline

Definition at line 808 of file OmniSciConnection.java.

808  { // logger.debug("Entered");
809  throw new UnsupportedOperationException("Not supported yet,"
810  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
811  + " class:" + new Throwable().getStackTrace()[0].getClassName()
812  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
813  }
String com.omnisci.jdbc.OmniSciConnection.getSchema ( ) throws SQLException
inline

Definition at line 783 of file OmniSciConnection.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  }
int com.omnisci.jdbc.OmniSciConnection.getTransactionIsolation ( ) throws SQLException
inline

Definition at line 511 of file OmniSciConnection.java.

511  { // logger.debug("Entered");
512  return Connection.TRANSACTION_NONE;
513  }
Map<String, Class<?> > com.omnisci.jdbc.OmniSciConnection.getTypeMap ( ) throws SQLException
inline

Definition at line 549 of file OmniSciConnection.java.

550  { // logger.debug("Entered");
551  throw new UnsupportedOperationException("Not supported yet,"
552  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
553  + " class:" + new Throwable().getStackTrace()[0].getClassName()
554  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
555  }
SQLWarning com.omnisci.jdbc.OmniSciConnection.getWarnings ( ) throws SQLException
inline

Definition at line 516 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.warnings.

516  { // logger.debug("Entered");
517  return warnings;
518  }
boolean com.omnisci.jdbc.OmniSciConnection.isClosed ( ) throws SQLException
inline

Definition at line 453 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.session.

453  { // logger.debug("Entered");
454  if (session == null) {
455  return true;
456  }
457  return false;
458  }
boolean com.omnisci.jdbc.OmniSciConnection.isReadOnly ( ) throws SQLException
inline

Definition at line 475 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.session.

475  { // logger.debug("Entered");
476  try {
477  if (session != null) {
478  TServerStatus server_status = client.get_server_status(session);
479  return server_status.read_only;
480  }
481  } catch (TMapDException ex) {
482  throw new SQLException(
483  "get_server_status failed during isReadOnly check." + ex.toString());
484  } catch (TException ex) {
485  throw new SQLException(
486  "get_server_status failed during isReadOnly check." + ex.toString());
487  }
488  // never should get here
489  return true;
490  }
boolean com.omnisci.jdbc.OmniSciConnection.isValid ( int  timeout) throws SQLException
inline

Definition at line 710 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.session.

710  { // logger.debug("Entered");
711  try {
712  client.get_server_status(session);
713  } catch (TTransportException ex) {
714  throw new SQLException("Connection failed - " + ex.toString());
715  } catch (TMapDException ex) {
716  throw new SQLException("Connection failed - " + ex.toString());
717  } catch (TException ex) {
718  throw new SQLException("Connection failed - " + ex.toString());
719  }
720  return true;
721  }
boolean com.omnisci.jdbc.OmniSciConnection.isWrapperFor ( Class<?>  iface) throws SQLException
inline

Definition at line 824 of file OmniSciConnection.java.

825  { // logger.debug("Entered");
826  throw new UnsupportedOperationException("Not supported yet,"
827  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
828  + " class:" + new Throwable().getStackTrace()[0].getClassName()
829  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
830  }
String com.omnisci.jdbc.OmniSciConnection.nativeSQL ( String  sql) throws SQLException
inline

Definition at line 405 of file OmniSciConnection.java.

405  { // logger.debug("Entered");
406  throw new UnsupportedOperationException("Not supported yet,"
407  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
408  + " class:" + new Throwable().getStackTrace()[0].getClassName()
409  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
410  }
CallableStatement com.omnisci.jdbc.OmniSciConnection.prepareCall ( String  sql) throws SQLException
inline

Definition at line 396 of file OmniSciConnection.java.

397  { // logger.debug("Entered");
398  throw new UnsupportedOperationException("Not supported yet,"
399  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
400  + " class:" + new Throwable().getStackTrace()[0].getClassName()
401  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
402  }
CallableStatement com.omnisci.jdbc.OmniSciConnection.prepareCall ( String  sql,
int  resultSetType,
int  resultSetConcurrency 
) throws SQLException
inline

Definition at line 539 of file OmniSciConnection.java.

541  { // logger.debug("Entered");
542  throw new UnsupportedOperationException("Not supported yet,"
543  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
544  + " class:" + new Throwable().getStackTrace()[0].getClassName()
545  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
546  }
CallableStatement com.omnisci.jdbc.OmniSciConnection.prepareCall ( String  sql,
int  resultSetType,
int  resultSetConcurrency,
int  resultSetHoldability 
) throws SQLException
inline

Definition at line 640 of file OmniSciConnection.java.

643  { // logger.debug("Entered");
644  throw new UnsupportedOperationException("Not supported yet,"
645  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
646  + " class:" + new Throwable().getStackTrace()[0].getClassName()
647  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
648  }
PreparedStatement com.omnisci.jdbc.OmniSciConnection.prepareStatement ( String  sql) throws SQLException
inline

Definition at line 390 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.client, and com.omnisci.jdbc.OmniSciConnection.session.

391  { // logger.debug("Entered");
392  return new OmniSciPreparedStatement(sql, session, client);
393  }
PreparedStatement com.omnisci.jdbc.OmniSciConnection.prepareStatement ( String  sql,
int  resultSetType,
int  resultSetConcurrency 
) throws SQLException
inline

Definition at line 532 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.client, and com.omnisci.jdbc.OmniSciConnection.session.

534  { // logger.debug("Entered");
535  return new OmniSciPreparedStatement(sql, session, client);
536  }
PreparedStatement com.omnisci.jdbc.OmniSciConnection.prepareStatement ( String  sql,
int  resultSetType,
int  resultSetConcurrency,
int  resultSetHoldability 
) throws SQLException
inline

Definition at line 629 of file OmniSciConnection.java.

632  { // logger.debug("Entered");
633  throw new UnsupportedOperationException("Not supported yet,"
634  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
635  + " class:" + new Throwable().getStackTrace()[0].getClassName()
636  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
637  }
PreparedStatement com.omnisci.jdbc.OmniSciConnection.prepareStatement ( String  sql,
int  autoGeneratedKeys 
) throws SQLException
inline

Definition at line 651 of file OmniSciConnection.java.

652  { // logger.debug("Entered");
653  throw new UnsupportedOperationException("Not supported yet,"
654  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
655  + " class:" + new Throwable().getStackTrace()[0].getClassName()
656  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
657  }
PreparedStatement com.omnisci.jdbc.OmniSciConnection.prepareStatement ( String  sql,
int[]  columnIndexes 
) throws SQLException
inline

Definition at line 660 of file OmniSciConnection.java.

661  { // logger.debug("Entered");
662  throw new UnsupportedOperationException("Not supported yet,"
663  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
664  + " class:" + new Throwable().getStackTrace()[0].getClassName()
665  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
666  }
PreparedStatement com.omnisci.jdbc.OmniSciConnection.prepareStatement ( String  sql,
String[]  columnNames 
) throws SQLException
inline

Definition at line 669 of file OmniSciConnection.java.

670  { // logger.debug("Entered");
671  throw new UnsupportedOperationException("Not supported yet,"
672  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
673  + " class:" + new Throwable().getStackTrace()[0].getClassName()
674  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
675  }
void com.omnisci.jdbc.OmniSciConnection.releaseSavepoint ( Savepoint  savepoint) throws SQLException
inline

Definition at line 610 of file OmniSciConnection.java.

611  { // logger.debug("Entered");
612  throw new UnsupportedOperationException("Not supported yet,"
613  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
614  + " class:" + new Throwable().getStackTrace()[0].getClassName()
615  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
616  }
void com.omnisci.jdbc.OmniSciConnection.rollback ( ) throws SQLException
inline

Definition at line 429 of file OmniSciConnection.java.

429  { // logger.debug("Entered");
430  throw new UnsupportedOperationException("Not supported yet,"
431  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
432  + " class:" + new Throwable().getStackTrace()[0].getClassName()
433  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
434  }
void com.omnisci.jdbc.OmniSciConnection.rollback ( Savepoint  savepoint) throws SQLException
inline

Definition at line 601 of file OmniSciConnection.java.

602  { // logger.debug("Entered");
603  throw new UnsupportedOperationException("Not supported yet,"
604  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
605  + " class:" + new Throwable().getStackTrace()[0].getClassName()
606  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
607  }
void com.omnisci.jdbc.OmniSciConnection.setAutoCommit ( boolean  autoCommit) throws SQLException
inline

Definition at line 413 of file OmniSciConnection.java.

414  { // logger.debug("Entered");
415  // we always autocommit per statement
416  }
void com.omnisci.jdbc.OmniSciConnection.setCatalog ( String  catalog) throws SQLException
inline

Definition at line 493 of file OmniSciConnection.java.

493  { // logger.debug("Entered");
494  throw new UnsupportedOperationException("Not supported yet,"
495  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
496  + " class:" + new Throwable().getStackTrace()[0].getClassName()
497  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
498  }
void com.omnisci.jdbc.OmniSciConnection.setClientInfo ( String  name,
String  value 
) throws SQLClientInfoException
inline

Definition at line 724 of file OmniSciConnection.java.

724  {
725  throw new UnsupportedOperationException("Not supported yet,"
726  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
727  + " class:" + new Throwable().getStackTrace()[0].getClassName()
728  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
729  }
void com.omnisci.jdbc.OmniSciConnection.setClientInfo ( Properties  properties) throws SQLClientInfoException
inline

Definition at line 732 of file OmniSciConnection.java.

732  {
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  }
void com.omnisci.jdbc.OmniSciConnection.setHoldability ( int  holdability) throws SQLException
inline

Definition at line 567 of file OmniSciConnection.java.

568  { // logger.debug("Entered");
569  throw new UnsupportedOperationException("Not supported yet,"
570  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
571  + " class:" + new Throwable().getStackTrace()[0].getClassName()
572  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
573  }
void com.omnisci.jdbc.OmniSciConnection.setNetworkTimeout ( Executor  executor,
int  milliseconds 
) throws SQLException
inline

Definition at line 799 of file OmniSciConnection.java.

800  { // logger.debug("Entered");
801  throw new UnsupportedOperationException("Not supported yet,"
802  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
803  + " class:" + new Throwable().getStackTrace()[0].getClassName()
804  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
805  }
void com.omnisci.jdbc.OmniSciConnection.setReadOnly ( boolean  readOnly) throws SQLException
inline

Definition at line 468 of file OmniSciConnection.java.

469  { // logger.debug("Entered");
470  // TODO MAT we can't push the readonly upstream currently
471  // but we could make JDBC obey this command
472  }
Savepoint com.omnisci.jdbc.OmniSciConnection.setSavepoint ( ) throws SQLException
inline

Definition at line 584 of file OmniSciConnection.java.

584  { // logger.debug("Entered");
585  throw new UnsupportedOperationException("Not supported yet,"
586  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
587  + " class:" + new Throwable().getStackTrace()[0].getClassName()
588  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
589  }
Savepoint com.omnisci.jdbc.OmniSciConnection.setSavepoint ( String  name) throws SQLException
inline

Definition at line 592 of file OmniSciConnection.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 com.omnisci.jdbc.OmniSciConnection.setSchema ( String  schema) throws SQLException
inline

Definition at line 775 of file OmniSciConnection.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 com.omnisci.jdbc.OmniSciConnection.setTransactionIsolation ( int  level) throws SQLException
inline

Definition at line 506 of file OmniSciConnection.java.

507  { // logger.debug("Entered");
508  }
void com.omnisci.jdbc.OmniSciConnection.setTypeMap ( Map< String, Class<?>>  map) throws SQLException
inline

Definition at line 558 of file OmniSciConnection.java.

559  { // logger.debug("Entered");
560  throw new UnsupportedOperationException("Not supported yet,"
561  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
562  + " class:" + new Throwable().getStackTrace()[0].getClassName()
563  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
564  }
public<T> T com.omnisci.jdbc.OmniSciConnection.unwrap ( Class< T >  iface) throws SQLException
inlinepackage

Definition at line 816 of file OmniSciConnection.java.

816  { // logger.debug("Entered");
817  throw new UnsupportedOperationException("Not supported yet,"
818  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
819  + " class:" + new Throwable().getStackTrace()[0].getClassName()
820  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
821  }

Member Data Documentation

String com.omnisci.jdbc.OmniSciConnection.catalog
protected
MapD.Client com.omnisci.jdbc.OmniSciConnection.client = null
protected
Connection_properties com.omnisci.jdbc.OmniSciConnection.cP = null
protected
final Logger com.omnisci.jdbc.OmniSciConnection.logger = LoggerFactory.getLogger(OmniSciConnection.class)
staticpackage

Definition at line 139 of file OmniSciConnection.java.

Set<String> com.omnisci.jdbc.OmniSciConnection.protocol_set
package
Initial value:
= new HashSet<String>(
Arrays.asList("binary", "binary_tls", "http", "https", "https_insecure"))

Definition at line 141 of file OmniSciConnection.java.

Referenced by com.omnisci.jdbc.OmniSciConnection.Connection_properties.validate_params().

TTransport com.omnisci.jdbc.OmniSciConnection.transport
protected
String com.omnisci.jdbc.OmniSciConnection.url
protected
SQLWarning com.omnisci.jdbc.OmniSciConnection.warnings
protected

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