OmniSciDB  1dac507f6e
 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
 

Static Package Attributes

static final Logger logger = LoggerFactory.getLogger(OmniSciConnection.class)
 

Detailed Description

Definition at line 82 of file OmniSciConnection.java.

Constructor & Destructor Documentation

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

Definition at line 213 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.isHttpProtocol(), com.omnisci.jdbc.OmniSciConnection.Connection_properties.isHttpsProtocol(), com.omnisci.jdbc.OmniSciConnection.Connection_properties.isHttpsProtocol_insecure(), com.omnisci.jdbc.Connection_enums.key_store, com.omnisci.jdbc.Connection_enums.key_store_pwd, com.omnisci.jdbc.Connection_enums.port_num, com.omnisci.jdbc.OmniSciConnection.session, 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.

214  { // logger.debug("Entered");
215  this.url = url;
216  this.cP = new Connection_properties(info, url);
217  SockTransportProperties skT = null;
218  String key_store = null;
219  if (cP.get(Connection_enums.key_store) != null
220  && !cP.get(Connection_enums.key_store).toString().isEmpty()) {
221  key_store = cP.get(Connection_enums.key_store).toString();
222  }
223  String key_store_pwd = null;
224  if (cP.get(Connection_enums.key_store_pwd) != null
225  && !cP.get(Connection_enums.key_store_pwd).toString().isEmpty()) {
226  key_store_pwd = cP.get(Connection_enums.key_store_pwd).toString();
227  }
228  try {
229  // cP extends hashtable. hashtable get returns null when the
230  // key isn't present. If key_store and keys_store_pwd are not present
231  // skT should then load the default java certs file ca-cert.
232  TProtocol protocol = null;
233  if (this.cP.isHttpProtocol()) {
234  // HTTP
235  boolean load_trustinfo = false;
236  skT = new SockTransportProperties(load_trustinfo);
237  transport = skT.openHttpClientTransport(
238  (String) this.cP.get(Connection_enums.host_name),
239  ((Integer) this.cP.get(Connection_enums.port_num)).intValue());
240  transport.open();
241  protocol = new TJSONProtocol(transport);
242  } else if (this.cP.isHttpsProtocol()) {
243  // HTTPS - use CA cert to validate server cert and validate server name
244  skT = new SockTransportProperties(key_store, key_store_pwd);
245  transport = skT.openHttpsClientTransport(
246  (String) this.cP.get(Connection_enums.host_name),
247  ((Integer) this.cP.get(Connection_enums.port_num)).intValue());
248  transport.open();
249  protocol = new TJSONProtocol(transport);
250  } else if (this.cP.isHttpsProtocol_insecure()) {
251  // HTTPS_INSECURE - trust all server names and certs but still encrypt pipe
252  boolean load_trustinfo = false;
253  skT = new SockTransportProperties(load_trustinfo);
254  transport = skT.openHttpsClientTransport(
255  (String) this.cP.get(Connection_enums.host_name),
256  ((Integer) this.cP.get(Connection_enums.port_num)).intValue());
257  transport.open();
258  protocol = new TJSONProtocol(transport);
259  } else if (cP.isBinary()) {
260  // jdbc binary was implmented first. It will currently look for a
261  // specified trust file, but doesn't look
262  // for any of the default java trust stores
263  if (key_store == null || key_store.isEmpty()) {
264  // un encryoted
265  boolean load_trustinfo = false;
266  skT = new SockTransportProperties(load_trustinfo);
267  transport = skT.openClientTransport(
268  (String) this.cP.get(Connection_enums.host_name),
269  ((Integer) this.cP.get(Connection_enums.port_num)).intValue());
270  } else {
271  // encryoted
272  skT = new SockTransportProperties(key_store, key_store_pwd);
273  transport = skT.openClientTransportEncrypted(
274  (String) this.cP.get(Connection_enums.host_name),
275  ((Integer) this.cP.get(Connection_enums.port_num)).intValue());
276  }
277  if (!transport.isOpen()) transport.open();
278  protocol = new TBinaryProtocol(transport);
279  } else {
280  throw new RuntimeException("Invalid protocol supplied");
281  }
282 
283  client = new MapD.Client(protocol);
284  session = client.connect((String) this.cP.get(Connection_enums.user),
285  (String) this.cP.get(Connection_enums.user_passwd),
286  (String) this.cP.get(Connection_enums.db_name));
287 
288  catalog = (String) this.cP.get(Connection_enums.db_name);
289  logger.debug("Connected session is " + session);
290 
291  } catch (TTransportException ex) {
292  throw new SQLException("Connection failed - " + ex.toString());
293  } catch (TMapDException ex) {
294  throw new SQLException("Connection failed - " + ex.toString());
295  } catch (TException ex) {
296  throw new SQLException("Connection failed - " + ex.toString());
297  } catch (java.lang.Exception ex) {
298  throw new SQLException("Connection failed - " + ex.toString());
299  }
300  }

+ 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 709 of file OmniSciConnection.java.

709  { // logger.debug("Entered");
710  throw new UnsupportedOperationException("Not supported yet,"
711  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
712  + " class:" + new Throwable().getStackTrace()[0].getClassName()
713  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
714  }
void com.omnisci.jdbc.OmniSciConnection.clearWarnings ( ) throws SQLException
inline

Definition at line 439 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.warnings.

439  { // logger.debug("Entered");
440  warnings = null;
441  }
void com.omnisci.jdbc.OmniSciConnection.close ( ) throws SQLException
inline

Definition at line 355 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.session.

355  { // logger.debug("Entered");
356  try {
357  logger.debug("Session at close is " + session);
358  if (session != null) {
359  client.disconnect(session);
360  }
361  session = null;
362  transport.close();
363  } catch (TMapDException ex) {
364  throw new SQLException("disconnect failed." + ex.toString());
365  } catch (TException ex) {
366  throw new SQLException("disconnect failed." + ex.toString());
367  }
368  }
void com.omnisci.jdbc.OmniSciConnection.commit ( ) throws SQLException
inline

Definition at line 342 of file OmniSciConnection.java.

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

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

Definition at line 604 of file OmniSciConnection.java.

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

Definition at line 596 of file OmniSciConnection.java.

596  { // logger.debug("Entered");
597  throw new UnsupportedOperationException("Not supported yet,"
598  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
599  + " class:" + new Throwable().getStackTrace()[0].getClassName()
600  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
601  }
NClob com.omnisci.jdbc.OmniSciConnection.createNClob ( ) throws SQLException
inline

Definition at line 612 of file OmniSciConnection.java.

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

Definition at line 620 of file OmniSciConnection.java.

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

Definition at line 303 of file OmniSciConnection.java.

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

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

Definition at line 444 of file OmniSciConnection.java.

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

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

Definition at line 537 of file OmniSciConnection.java.

539  { // logger.debug("Entered");
540  throw new UnsupportedOperationException("Not supported yet,"
541  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
542  + " class:" + new Throwable().getStackTrace()[0].getClassName()
543  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
544  }
Struct com.omnisci.jdbc.OmniSciConnection.createStruct ( String  typeName,
Object[]  attributes 
) throws SQLException
inline

Definition at line 684 of file OmniSciConnection.java.

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

Definition at line 337 of file OmniSciConnection.java.

337  { // logger.debug("Entered");
338  return true;
339  }
String com.omnisci.jdbc.OmniSciConnection.getCatalog ( ) throws SQLException
inline

Definition at line 419 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.catalog.

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

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

Definition at line 667 of file OmniSciConnection.java.

667  { // logger.debug("Entered");
668  throw new UnsupportedOperationException("Not supported yet,"
669  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
670  + " class:" + new Throwable().getStackTrace()[0].getClassName()
671  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
672  }
int com.omnisci.jdbc.OmniSciConnection.getHoldability ( ) throws SQLException
inline

Definition at line 494 of file OmniSciConnection.java.

494  { // logger.debug("Entered");
495  throw new UnsupportedOperationException("Not supported yet,"
496  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
497  + " class:" + new Throwable().getStackTrace()[0].getClassName()
498  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
499  }
DatabaseMetaData com.omnisci.jdbc.OmniSciConnection.getMetaData ( ) throws SQLException
inline

Definition at line 379 of file OmniSciConnection.java.

379  { // logger.debug("Entered");
380  DatabaseMetaData mapDMetaData = new OmniSciDatabaseMetaData(this);
381 
382  return mapDMetaData;
383  }
int com.omnisci.jdbc.OmniSciConnection.getNetworkTimeout ( ) throws SQLException
inline

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

Definition at line 701 of file OmniSciConnection.java.

701  { // logger.debug("Entered");
702  throw new UnsupportedOperationException("Not supported yet,"
703  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
704  + " class:" + new Throwable().getStackTrace()[0].getClassName()
705  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
706  }
int com.omnisci.jdbc.OmniSciConnection.getTransactionIsolation ( ) throws SQLException
inline

Definition at line 429 of file OmniSciConnection.java.

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

Definition at line 467 of file OmniSciConnection.java.

468  { // logger.debug("Entered");
469  throw new UnsupportedOperationException("Not supported yet,"
470  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
471  + " class:" + new Throwable().getStackTrace()[0].getClassName()
472  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
473  }
SQLWarning com.omnisci.jdbc.OmniSciConnection.getWarnings ( ) throws SQLException
inline

Definition at line 434 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.warnings.

434  { // logger.debug("Entered");
435  return warnings;
436  }
boolean com.omnisci.jdbc.OmniSciConnection.isClosed ( ) throws SQLException
inline

Definition at line 371 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.session.

371  { // logger.debug("Entered");
372  if (session == null) {
373  return true;
374  }
375  return false;
376  }
boolean com.omnisci.jdbc.OmniSciConnection.isReadOnly ( ) throws SQLException
inline

Definition at line 393 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.session.

393  { // logger.debug("Entered");
394  try {
395  if (session != null) {
396  TServerStatus server_status = client.get_server_status(session);
397  return server_status.read_only;
398  }
399  } catch (TMapDException ex) {
400  throw new SQLException(
401  "get_server_status failed during isReadOnly check." + ex.toString());
402  } catch (TException ex) {
403  throw new SQLException(
404  "get_server_status failed during isReadOnly check." + ex.toString());
405  }
406  // never should get here
407  return true;
408  }
boolean com.omnisci.jdbc.OmniSciConnection.isValid ( int  timeout) throws SQLException
inline

Definition at line 628 of file OmniSciConnection.java.

References com.omnisci.jdbc.OmniSciConnection.session.

628  { // logger.debug("Entered");
629  try {
630  client.get_server_status(session);
631  } catch (TTransportException ex) {
632  throw new SQLException("Connection failed - " + ex.toString());
633  } catch (TMapDException ex) {
634  throw new SQLException("Connection failed - " + ex.toString());
635  } catch (TException ex) {
636  throw new SQLException("Connection failed - " + ex.toString());
637  }
638  return true;
639  }
boolean com.omnisci.jdbc.OmniSciConnection.isWrapperFor ( Class<?>  iface) throws SQLException
inline

Definition at line 742 of file OmniSciConnection.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  }
String com.omnisci.jdbc.OmniSciConnection.nativeSQL ( String  sql) throws SQLException
inline

Definition at line 323 of file OmniSciConnection.java.

323  { // logger.debug("Entered");
324  throw new UnsupportedOperationException("Not supported yet,"
325  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
326  + " class:" + new Throwable().getStackTrace()[0].getClassName()
327  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
328  }
CallableStatement com.omnisci.jdbc.OmniSciConnection.prepareCall ( String  sql) throws SQLException
inline

Definition at line 314 of file OmniSciConnection.java.

315  { // logger.debug("Entered");
316  throw new UnsupportedOperationException("Not supported yet,"
317  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
318  + " class:" + new Throwable().getStackTrace()[0].getClassName()
319  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
320  }
CallableStatement com.omnisci.jdbc.OmniSciConnection.prepareCall ( String  sql,
int  resultSetType,
int  resultSetConcurrency 
) throws SQLException
inline

Definition at line 457 of file OmniSciConnection.java.

459  { // logger.debug("Entered");
460  throw new UnsupportedOperationException("Not supported yet,"
461  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
462  + " class:" + new Throwable().getStackTrace()[0].getClassName()
463  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
464  }
CallableStatement com.omnisci.jdbc.OmniSciConnection.prepareCall ( String  sql,
int  resultSetType,
int  resultSetConcurrency,
int  resultSetHoldability 
) throws SQLException
inline

Definition at line 558 of file OmniSciConnection.java.

561  { // logger.debug("Entered");
562  throw new UnsupportedOperationException("Not supported yet,"
563  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
564  + " class:" + new Throwable().getStackTrace()[0].getClassName()
565  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
566  }
PreparedStatement com.omnisci.jdbc.OmniSciConnection.prepareStatement ( String  sql) throws SQLException
inline

Definition at line 308 of file OmniSciConnection.java.

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

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

Definition at line 450 of file OmniSciConnection.java.

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

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

Definition at line 547 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  }
PreparedStatement com.omnisci.jdbc.OmniSciConnection.prepareStatement ( String  sql,
int  autoGeneratedKeys 
) throws SQLException
inline

Definition at line 569 of file OmniSciConnection.java.

570  { // logger.debug("Entered");
571  throw new UnsupportedOperationException("Not supported yet,"
572  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
573  + " class:" + new Throwable().getStackTrace()[0].getClassName()
574  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
575  }
PreparedStatement com.omnisci.jdbc.OmniSciConnection.prepareStatement ( String  sql,
int[]  columnIndexes 
) throws SQLException
inline

Definition at line 578 of file OmniSciConnection.java.

579  { // logger.debug("Entered");
580  throw new UnsupportedOperationException("Not supported yet,"
581  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
582  + " class:" + new Throwable().getStackTrace()[0].getClassName()
583  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
584  }
PreparedStatement com.omnisci.jdbc.OmniSciConnection.prepareStatement ( String  sql,
String[]  columnNames 
) throws SQLException
inline

Definition at line 587 of file OmniSciConnection.java.

588  { // logger.debug("Entered");
589  throw new UnsupportedOperationException("Not supported yet,"
590  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
591  + " class:" + new Throwable().getStackTrace()[0].getClassName()
592  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
593  }
void com.omnisci.jdbc.OmniSciConnection.releaseSavepoint ( Savepoint  savepoint) throws SQLException
inline

Definition at line 528 of file OmniSciConnection.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 com.omnisci.jdbc.OmniSciConnection.rollback ( ) throws SQLException
inline

Definition at line 347 of file OmniSciConnection.java.

347  { // logger.debug("Entered");
348  throw new UnsupportedOperationException("Not supported yet,"
349  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
350  + " class:" + new Throwable().getStackTrace()[0].getClassName()
351  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
352  }
void com.omnisci.jdbc.OmniSciConnection.rollback ( Savepoint  savepoint) throws SQLException
inline

Definition at line 519 of file OmniSciConnection.java.

520  { // logger.debug("Entered");
521  throw new UnsupportedOperationException("Not supported yet,"
522  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
523  + " class:" + new Throwable().getStackTrace()[0].getClassName()
524  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
525  }
void com.omnisci.jdbc.OmniSciConnection.setAutoCommit ( boolean  autoCommit) throws SQLException
inline

Definition at line 331 of file OmniSciConnection.java.

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

Definition at line 411 of file OmniSciConnection.java.

411  { // logger.debug("Entered");
412  throw new UnsupportedOperationException("Not supported yet,"
413  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
414  + " class:" + new Throwable().getStackTrace()[0].getClassName()
415  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
416  }
void com.omnisci.jdbc.OmniSciConnection.setClientInfo ( String  name,
String  value 
) throws SQLClientInfoException
inline

Definition at line 642 of file OmniSciConnection.java.

642  {
643  throw new UnsupportedOperationException("Not supported yet,"
644  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
645  + " class:" + new Throwable().getStackTrace()[0].getClassName()
646  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
647  }
void com.omnisci.jdbc.OmniSciConnection.setClientInfo ( Properties  properties) throws SQLClientInfoException
inline

Definition at line 650 of file OmniSciConnection.java.

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

Definition at line 485 of file OmniSciConnection.java.

486  { // logger.debug("Entered");
487  throw new UnsupportedOperationException("Not supported yet,"
488  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
489  + " class:" + new Throwable().getStackTrace()[0].getClassName()
490  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
491  }
void com.omnisci.jdbc.OmniSciConnection.setNetworkTimeout ( Executor  executor,
int  milliseconds 
) throws SQLException
inline

Definition at line 717 of file OmniSciConnection.java.

718  { // logger.debug("Entered");
719  throw new UnsupportedOperationException("Not supported yet,"
720  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
721  + " class:" + new Throwable().getStackTrace()[0].getClassName()
722  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
723  }
void com.omnisci.jdbc.OmniSciConnection.setReadOnly ( boolean  readOnly) throws SQLException
inline

Definition at line 386 of file OmniSciConnection.java.

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

Definition at line 502 of file OmniSciConnection.java.

502  { // logger.debug("Entered");
503  throw new UnsupportedOperationException("Not supported yet,"
504  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
505  + " class:" + new Throwable().getStackTrace()[0].getClassName()
506  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
507  }
Savepoint com.omnisci.jdbc.OmniSciConnection.setSavepoint ( String  name) throws SQLException
inline

Definition at line 510 of file OmniSciConnection.java.

511  { // logger.debug("Entered");
512  throw new UnsupportedOperationException("Not supported yet,"
513  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
514  + " class:" + new Throwable().getStackTrace()[0].getClassName()
515  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
516  }
void com.omnisci.jdbc.OmniSciConnection.setSchema ( String  schema) throws SQLException
inline

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

Definition at line 424 of file OmniSciConnection.java.

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

Definition at line 476 of file OmniSciConnection.java.

477  { // logger.debug("Entered");
478  throw new UnsupportedOperationException("Not supported yet,"
479  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
480  + " class:" + new Throwable().getStackTrace()[0].getClassName()
481  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
482  }
public<T> T com.omnisci.jdbc.OmniSciConnection.unwrap ( Class< T >  iface) throws SQLException
inlinepackage

Definition at line 734 of file OmniSciConnection.java.

734  { // logger.debug("Entered");
735  throw new UnsupportedOperationException("Not supported yet,"
736  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
737  + " class:" + new Throwable().getStackTrace()[0].getClassName()
738  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
739  }

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 83 of file OmniSciConnection.java.

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: