io.deephaven.jdbc.DeephavenConnection

All Implemented Interfaces:: AutoCloseable, Connection, Wrapper

public class DeephavenConnection
extends Object
implements Connection

An implementation of JDBC Connection that authenticates if needed, creates and attaches to a Deephaven worker. The worker should have the same lifetime as the Connection, and will be used to execute any Statement or PreparedStatements created through this connection. This is not thread-safe.

Field Summary

Fields inherited from interface java.sql.Connection
TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.sql.Connection

beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid

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

Class DeephavenConnection

Field Summary

Fields inherited from interface java.sql.Connection

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface java.sql.Connection

Method Details