com.ocient.jdbc.XGConnection

All Implemented Interfaces:: AutoCloseable, Connection, Wrapper

public class XGConnection
extends Object
implements Connection

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`static class`	`XGConnection.ConnectionProperty`
`static class`	`XGConnection.ConnectionPropertyGroup`
`static class`	`XGConnection.HandshakeType`
`static class`	`XGConnection.Tls`

Field Summary

Fields
Modifier and Type	Field	Description
`protected String`	`client`
`protected String`	`clientVersion`
`protected ArrayList<String>`	`cmdcomps`
`protected String`	`connectedIp`
`protected int`	`connectedPort`
`protected String`	`database`
`protected String`	`defaultSchema`
`protected boolean`	`force`
`protected BufferedInputStream`	`in`
`protected String`	`ip`
`Integer`	`maxRows`
`protected static boolean`	`metricsEnabled`
`protected int`	`networkTimeout`
`static String`	`OKTA_NATIVE_SSO_TOKEN_FILE_NAME`
`static Path`	`OKTA_NATIVE_SSO_TOKEN_FILE_PATH`
`protected boolean`	`oneShotForce`
`protected String`	`originalIp`
`protected int`	`originalPort`
`protected BufferedOutputStream`	`out`
`protected int`	`portNum`
`protected String`	`protocolVersion`
`protected String`	`pwd`
`protected XGResultSet`	`rs`
`protected int`	`secondaryIndex`
`protected ArrayList<ArrayList<String>>`	`secondaryInterfaces`
`protected String`	`serverSessionId`
`protected String`	`serverVersion`
`protected com.ocient.jdbc.XGConnection.Session`	`session`
`static String`	`sessionID`
`protected com.ocient.jdbc.XGConnection.Session.State`	`sessionState`
`protected long`	`setPso`
`protected String`	`setSchema`
`protected XGConnection.Tls`	`tls`
`protected Map<String,Class<?>>`	`typeMap`
`protected String`	`url`
`protected String`	`user`
`static Path`	`USER_HOME_PATH`
`protected ArrayList<SQLWarning>`	`warnings`

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

Constructors
Constructor	Description
`XGConnection(String user, String pwd, String ip, int portNum, String url, String database, String protocolVersion, String clientVersion, String force, XGConnection.Tls tls, Properties properties)`

Method Summary

Modifier and Type	Method	Description
`void`	`abort(Executor executor)`
`protected void`	`addTimeout(TimerTask task, long timeout)`	Schedules the task to run after the specified delay
`void`	`clearOneShotForce()`
`void`	`clearWarnings()`
`void`	`close()`
`void`	`commit()`
`void`	`connect()`
`boolean`	`connected()`
`XGConnection`	`copy()`
`XGConnection`	`copy(boolean shouldRequestVersion)`
`XGConnection`	`copy(boolean shouldRequestVersion, boolean noRedirect)`
`Array`	`createArrayOf(String arg0, Object[] arg1)`
`Blob`	`createBlob()`
`Clob`	`createClob()`
`NClob`	`createNClob()`
`static OktaAuthenticators.OktaNativeSSOToken`	`createOktaNativeSSOToken(ClientWireProtocol.OpenIDAuthenticator authenticator, Properties properties)`
`SQLXML`	`createSQLXML()`
`Statement`	`createStatement()`
`Statement`	`createStatement(int arg0, int arg1)`
`Statement`	`createStatement(int arg0, int arg1, int arg2)`
`Struct`	`createStruct(String arg0, Object[] arg1)`
`boolean`	`equals(Object o)`	Equals and hashcode should almost always be autogenerated.
`List<ClientWireProtocol.Authenticator>`	`fetchAuthenticators()`	Fetches all `ClientWireProtocol.Authenticator`s
`void`	`forceExternal(boolean force)`
`boolean`	`getAutoCommit()`
`String`	`getCatalog()`
`Properties`	`getClientInfo()`
`String`	`getClientInfo(String arg0)`
`String`	`getDB()`
`static OpenIDAuthenticators.OAuthFlow`	`getDefaultOAuthFlow()`
`int`	`getHoldability()`
`int`	`getMajorVersion()`
`DatabaseMetaData`	`getMetaData()`
`int`	`getMinorVersion()`
`int`	`getNetworkTimeout()`
`Properties`	`getProperties()`
`String`	`getSchema()`
`String`	`getSchemaLocal()`
`String`	`getServerVersion()`
`protected long`	`getTimeoutMillis()`
`int`	`getTransactionIsolation()`
`Map<String,Class<?>>`	`getTypeMap()`
`String`	`getURL()`
`String`	`getUser()`
`String`	`getVersion()`
`SQLWarning`	`getWarnings()`
`int`	`hashCode()`
`boolean`	`isClosed()`
`boolean`	`isReadOnly()`
`boolean`	`isValid(int arg0)`
`boolean`	`isWrapperFor(Class<?> iface)`
`String`	`nativeSQL(String arg0)`
`CallableStatement`	`prepareCall(String arg0)`
`CallableStatement`	`prepareCall(String arg0, int arg1, int arg2)`
`CallableStatement`	`prepareCall(String arg0, int arg1, int arg2, int arg3)`
`PreparedStatement`	`prepareStatement(String arg0)`
`PreparedStatement`	`prepareStatement(String arg0, int arg1)`
`PreparedStatement`	`prepareStatement(String arg0, int[] arg1)`
`PreparedStatement`	`prepareStatement(String arg0, int arg1, int arg2)`
`PreparedStatement`	`prepareStatement(String arg0, int arg1, int arg2, int arg3)`
`PreparedStatement`	`prepareStatement(String arg0, String[] arg1)`
`protected void`	`purgeTimeoutTasks()`	Purges all canceled tasks from the timer.
`static Optional<OktaAuthenticators.OktaNativeSSOToken>`	`readOktaNativeSSOToken(Path tokenFilePath)`
`void`	`reconnect()`
`void`	`reconnect(boolean shouldRequestVersion)`
`void`	`redirect(String host, int port, boolean shouldRequestVersion)`
`void`	`refreshSession()`
`void`	`refreshToken()`
`void`	`releaseSavepoint(Savepoint arg0)`
`static Path`	`resolveOktaNativeSSOTokenFilePath(Properties properties)`
`void`	`rollback()`
`void`	`rollback(Savepoint arg0)`
`int`	`sendParameterMessage(ClientWireProtocol.SetParameter param)`
`com.ocient.jdbc.XGConnection.Session.State`	`sendRefreshSession()`
`com.ocient.jdbc.XGConnection.Session.State`	`sendRefreshToken(com.ocient.jdbc.XGConnection.Session.State oldState)`
`void`	`setAutoCommit(boolean arg0)`
`void`	`setCatalog(String arg0)`
`void`	`setClientInfo(String arg0, String arg1)`
`void`	`setClientInfo(Properties arg0)`
`void`	`setHoldability(int arg0)`
`int`	`setMaxRows(Integer maxRows, boolean reset)`
`int`	`setMaxRowsHardLimit(Integer maxRows, boolean reset)`
`int`	`setMaxTempDisk(Integer maxTempDisk, boolean reset)`
`int`	`setMaxTime(Integer maxTime, boolean reset)`
`static void`	`setMetrics(boolean enabled)`
`void`	`setNetworkTimeout(Executor executor, int milliseconds)`
`int`	`setParallelism(Integer parallelism, boolean reset)`
`int`	`setPriority(Double priority, boolean reset)`
`int`	`setPriorityAdjustFactor(Double priorityAdjustFactor, boolean reset)`
`int`	`setPriorityAdjustTime(Integer priorityAdjustTime, boolean reset)`
`void`	`setPSO(boolean on)`
`void`	`setPSO(long threshold)`
`void`	`setPSOSeed(long seed, boolean reset)`
`void`	`setReadOnly(boolean arg0)`
`Savepoint`	`setSavepoint()`
`Savepoint`	`setSavepoint(String arg0)`
`void`	`setSchema(String schema)`
`void`	`setSchemaLocal(String newSchema)`
`void`	`setServerVersion(String version)`
`void`	`setTimeout(int seconds)`
`void`	`setTransactionIsolation(int arg0)`
`void`	`setTypeMap(Map<String,Class<?>> arg0)`
`<T> T`	`unwrap(Class<T> iface)`
`static void`	`writeOktaNativeSSOToken(Path tokenFilePath, OktaAuthenticators.OktaNativeSSOToken token)`

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Connection

beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid

Field Details
- USER_HOME_PATH
  
  public static final Path USER_HOME_PATH
- OKTA_NATIVE_SSO_TOKEN_FILE_NAME
  
  public static final String OKTA_NATIVE_SSO_TOKEN_FILE_NAME
  
  See Also:
  
  Constant Field Values
- OKTA_NATIVE_SSO_TOKEN_FILE_PATH
  
  public static final Path OKTA_NATIVE_SSO_TOKEN_FILE_PATH
- in
  
  protected BufferedInputStream in
- out
  
  protected BufferedOutputStream out
- rs
  
  protected XGResultSet rs
- portNum
  
  protected int portNum
- warnings
  
  protected ArrayList<SQLWarning> warnings
- url
  
  protected final String url
- ip
  
  protected String ip
- originalIp
  
  protected String originalIp
- connectedIp
  
  protected String connectedIp
- originalPort
  
  protected int originalPort
- connectedPort
  
  protected int connectedPort
- user
  
  protected String user
- database
  
  protected String database
- client
  
  protected String client
- protocolVersion
  
  protected String protocolVersion
- clientVersion
  
  protected String clientVersion
- serverVersion
  
  protected String serverVersion
- defaultSchema
  
  protected String defaultSchema
- oneShotForce
  
  protected boolean oneShotForce
- cmdcomps
  
  protected ArrayList<String> cmdcomps
- secondaryInterfaces
  
  protected ArrayList<ArrayList<String>> secondaryInterfaces
- secondaryIndex
  
  protected int secondaryIndex
- networkTimeout
  
  protected int networkTimeout
- tls
  
  protected XGConnection.Tls tls
- sessionID
  
  public static final String sessionID
- metricsEnabled
  
  protected static volatile boolean metricsEnabled
- pwd
  
  protected String pwd
- session
  
  protected com.ocient.jdbc.XGConnection.Session session
- serverSessionId
  
  protected String serverSessionId
- sessionState
  
  protected com.ocient.jdbc.XGConnection.Session.State sessionState
- typeMap
  
  protected Map<String,Class<?>> typeMap
- setSchema
  
  protected String setSchema
- setPso
  
  protected long setPso
- maxRows
  
  public Integer maxRows
- force
  
  protected boolean force
Constructor Details
- XGConnection
  
  public XGConnection(String user, String pwd, String ip, int portNum, String url, String database, String protocolVersion, String clientVersion, String force, XGConnection.Tls tls, Properties properties) throws Exception
  
  Throws:
  
  Exception
Method Details
- refreshSession
  
  public void refreshSession() throws SQLException
  
  Throws:
  
  SQLException
- refreshToken
  
  public void refreshToken() throws SQLException
  
  Throws:
  
  SQLException
- abort
  
  public void abort(Executor executor) throws SQLException
  
  Specified by:
  
  abort in interface Connection
  
  Throws:
  
  SQLException
- addTimeout
  
  protected void addTimeout(TimerTask task, long timeout)
  
  Schedules the task to run after the specified delay
  
  Parameters:
  
  task - the task to run
  
  timeout - delay in milliseconds
- setMetrics
  
  public static void setMetrics(boolean enabled)
- clearOneShotForce
  
  public void clearOneShotForce()
- clearWarnings
  
  public void clearWarnings() throws SQLException
  
  Specified by:
  
  clearWarnings in interface Connection
  
  Throws:
  
  SQLException
- getDefaultOAuthFlow
  
  public static OpenIDAuthenticators.OAuthFlow getDefaultOAuthFlow()
- resolveOktaNativeSSOTokenFilePath
  
  public static Path resolveOktaNativeSSOTokenFilePath(Properties properties)
- readOktaNativeSSOToken
  
  public static Optional<OktaAuthenticators.OktaNativeSSOToken> readOktaNativeSSOToken(Path tokenFilePath) throws Exception
  
  Throws:
  
  Exception
- createOktaNativeSSOToken
  
  public static OktaAuthenticators.OktaNativeSSOToken createOktaNativeSSOToken(ClientWireProtocol.OpenIDAuthenticator authenticator, Properties properties) throws Exception
  
  Throws:
  
  Exception
- writeOktaNativeSSOToken
  
  public static void writeOktaNativeSSOToken(Path tokenFilePath, OktaAuthenticators.OktaNativeSSOToken token) throws Exception
  
  Throws:
  
  Exception
- close
  
  public void close() throws SQLException
  
  Specified by:
  
  close in interface AutoCloseable
  
  Specified by:
  
  close in interface Connection
  
  Throws:
  
  SQLException
- commit
  
  public void commit() throws SQLException
  
  Specified by:
  
  commit in interface Connection
  
  Throws:
  
  SQLException
- connect
  
  public void connect() throws Exception
  
  Throws:
  
  Exception
- connected
  
  public boolean connected()
- copy
  
  public XGConnection copy() throws SQLException
  
  Throws:
  
  SQLException
- copy
  
  public XGConnection copy(boolean shouldRequestVersion) throws SQLException
  
  Throws:
  
  SQLException
- copy
  
  public XGConnection copy(boolean shouldRequestVersion, boolean noRedirect) throws SQLException
  
  Throws:
  
  SQLException
- createArrayOf
  
  public Array createArrayOf(String arg0, Object[] arg1) throws SQLException
  
  Specified by:
  
  createArrayOf in interface Connection
  
  Throws:
  
  SQLException
- createBlob
  
  public Blob createBlob() throws SQLException
  
  Specified by:
  
  createBlob in interface Connection
  
  Throws:
  
  SQLException
- createClob
  
  public Clob createClob() throws SQLException
  
  Specified by:
  
  createClob 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
- createStatement
  
  public Statement createStatement() throws SQLException
  
  Specified by:
  
  createStatement in interface Connection
  
  Throws:
  
  SQLException
- createStatement
  
  public Statement createStatement(int arg0, int arg1) throws SQLException
  
  Specified by:
  
  createStatement in interface Connection
  
  Throws:
  
  SQLException
- createStatement
  
  public Statement createStatement(int arg0, int arg1, int arg2) throws SQLException
  
  Specified by:
  
  createStatement in interface Connection
  
  Throws:
  
  SQLException
- createStruct
  
  public Struct createStruct(String arg0, Object[] arg1) throws SQLException
  
  Specified by:
  
  createStruct in interface Connection
  
  Throws:
  
  SQLException
- fetchAuthenticators
  
  public List<ClientWireProtocol.Authenticator> fetchAuthenticators() throws SQLException
  
  Fetches all ClientWireProtocol.Authenticators
  
  Returns:
  
  Throws:
  
  SQLException
- forceExternal
  
  public void forceExternal(boolean force) throws SQLException
  
  Throws:
  
  SQLException
- getAutoCommit
  
  public boolean getAutoCommit() throws SQLException
  
  Specified by:
  
  getAutoCommit in interface Connection
  
  Throws:
  
  SQLException
- getCatalog
  
  public String getCatalog() throws SQLException
  
  Specified by:
  
  getCatalog in interface Connection
  
  Throws:
  
  SQLException
- getClientInfo
  
  public Properties getClientInfo() throws SQLException
  
  Specified by:
  
  getClientInfo in interface Connection
  
  Throws:
  
  SQLException
- getClientInfo
  
  public String getClientInfo(String arg0) throws SQLException
  
  Specified by:
  
  getClientInfo in interface Connection
  
  Throws:
  
  SQLException
- getDB
  
  public String getDB()
- getProperties
  
  public Properties getProperties()
- getHoldability
  
  public int getHoldability() throws SQLException
  
  Specified by:
  
  getHoldability in interface Connection
  
  Throws:
  
  SQLException
- getMajorVersion
  
  public int getMajorVersion()
- getMetaData
  
  public DatabaseMetaData getMetaData() throws SQLException
  
  Specified by:
  
  getMetaData in interface Connection
  
  Throws:
  
  SQLException
- getMinorVersion
  
  public int getMinorVersion()
- getNetworkTimeout
  
  public int getNetworkTimeout() throws SQLException
  
  Specified by:
  
  getNetworkTimeout in interface Connection
  
  Throws:
  
  SQLException
- getSchema
  
  public String getSchema() throws SQLException
  
  Specified by:
  
  getSchema in interface Connection
  
  Throws:
  
  SQLException
- getSchemaLocal
  
  public String getSchemaLocal()
- setSchemaLocal
  
  public void setSchemaLocal(String newSchema)
- getServerVersion
  
  public String getServerVersion()
- getTimeoutMillis
  
  protected long getTimeoutMillis()
- getTransactionIsolation
  
  public int getTransactionIsolation() throws SQLException
  
  Specified by:
  
  getTransactionIsolation in interface Connection
  
  Throws:
  
  SQLException
- getTypeMap
  
  public Map<String,Class<?>> getTypeMap() throws SQLException
  
  Specified by:
  
  getTypeMap in interface Connection
  
  Throws:
  
  SQLException
- getURL
  
  public String getURL()
- getUser
  
  public String getUser()
- getVersion
  
  public String getVersion()
- getWarnings
  
  public SQLWarning getWarnings() throws SQLException
  
  Specified by:
  
  getWarnings in interface Connection
  
  Throws:
  
  SQLException
- equals
  
  public boolean equals(Object o)
  
  Equals and hashcode should almost always be autogenerated. Only roll your own if 1. have a legitimate reason to do so (very rare) 2. know what you're doing 3. write unit tests for object equality
  
  Overrides:
  
  equals in class Object
- hashCode
  
  public int hashCode()
  
  Overrides:
  
  hashCode in class Object
- isClosed
  
  public boolean isClosed() throws SQLException
  
  Specified by:
  
  isClosed in interface Connection
  
  Throws:
  
  SQLException
- isReadOnly
  
  public boolean isReadOnly() throws SQLException
  
  Specified by:
  
  isReadOnly in interface Connection
  
  Throws:
  
  SQLException
- isValid
  
  public boolean isValid(int arg0) throws SQLException
  
  Specified by:
  
  isValid in interface Connection
  
  Throws:
  
  SQLException
- isWrapperFor
  
  public boolean isWrapperFor(Class<?> iface) throws SQLException
  
  Specified by:
  
  isWrapperFor in interface Wrapper
  
  Throws:
  
  SQLException
- nativeSQL
  
  public String nativeSQL(String arg0) throws SQLException
  
  Specified by:
  
  nativeSQL in interface Connection
  
  Throws:
  
  SQLException
- prepareCall
  
  public CallableStatement prepareCall(String arg0) throws SQLException
  
  Specified by:
  
  prepareCall in interface Connection
  
  Throws:
  
  SQLException
- prepareCall
  
  public CallableStatement prepareCall(String arg0, int arg1, int arg2) throws SQLException
  
  Specified by:
  
  prepareCall in interface Connection
  
  Throws:
  
  SQLException
- prepareCall
  
  public CallableStatement prepareCall(String arg0, int arg1, int arg2, int arg3) throws SQLException
  
  Specified by:
  
  prepareCall in interface Connection
  
  Throws:
  
  SQLException
- prepareStatement
  
  public PreparedStatement prepareStatement(String arg0) throws SQLException
  
  Specified by:
  
  prepareStatement in interface Connection
  
  Throws:
  
  SQLException
- prepareStatement
  
  public PreparedStatement prepareStatement(String arg0, int arg1) throws SQLException
  
  Specified by:
  
  prepareStatement in interface Connection
  
  Throws:
  
  SQLException
- prepareStatement
  
  public PreparedStatement prepareStatement(String arg0, int arg1, int arg2) throws SQLException
  
  Specified by:
  
  prepareStatement in interface Connection
  
  Throws:
  
  SQLException
- prepareStatement
  
  public PreparedStatement prepareStatement(String arg0, int arg1, int arg2, int arg3) throws SQLException
  
  Specified by:
  
  prepareStatement in interface Connection
  
  Throws:
  
  SQLException
- prepareStatement
  
  public PreparedStatement prepareStatement(String arg0, int[] arg1) throws SQLException
  
  Specified by:
  
  prepareStatement in interface Connection
  
  Throws:
  
  SQLException
- prepareStatement
  
  public PreparedStatement prepareStatement(String arg0, String[] arg1) throws SQLException
  
  Specified by:
  
  prepareStatement in interface Connection
  
  Throws:
  
  SQLException
- purgeTimeoutTasks
  
  protected void purgeTimeoutTasks()
  
  Purges all canceled tasks from the timer.
  Note: You should only call this if you've canceled a timer. This call may create a Timer object if one does not already exist
- reconnect
  
  public void reconnect() throws IOException, SQLException
  
  Throws:
  
  IOException
  
  SQLException
- reconnect
  
  public void reconnect(boolean shouldRequestVersion) throws IOException, SQLException
  
  Throws:
  
  IOException
  
  SQLException
- redirect
  
  public void redirect(String host, int port, boolean shouldRequestVersion) throws IOException, SQLException
  
  Throws:
  
  IOException
  
  SQLException
- releaseSavepoint
  
  public void releaseSavepoint(Savepoint arg0) throws SQLException
  
  Specified by:
  
  releaseSavepoint in interface Connection
  
  Throws:
  
  SQLException
- rollback
  
  public void rollback() throws SQLException
  
  Specified by:
  
  rollback in interface Connection
  
  Throws:
  
  SQLException
- rollback
  
  public void rollback(Savepoint arg0) throws SQLException
  
  Specified by:
  
  rollback in interface Connection
  
  Throws:
  
  SQLException
- sendParameterMessage
  
  public int sendParameterMessage(ClientWireProtocol.SetParameter param) throws SQLException
  
  Throws:
  
  SQLException
- setAutoCommit
  
  public void setAutoCommit(boolean arg0) throws SQLException
  
  Specified by:
  
  setAutoCommit in interface Connection
  
  Throws:
  
  SQLException
- setCatalog
  
  public void setCatalog(String arg0) throws SQLException
  
  Specified by:
  
  setCatalog in interface Connection
  
  Throws:
  
  SQLException
- setClientInfo
  
  public void setClientInfo(Properties arg0) throws SQLClientInfoException
  
  Specified by:
  
  setClientInfo in interface Connection
  
  Throws:
  
  SQLClientInfoException
- setClientInfo
  
  public void setClientInfo(String arg0, String arg1) throws SQLClientInfoException
  
  Specified by:
  
  setClientInfo in interface Connection
  
  Throws:
  
  SQLClientInfoException
- setParallelism
  
  public int setParallelism(Integer parallelism, boolean reset) throws SQLException
  
  Throws:
  
  SQLException
- setHoldability
  
  public void setHoldability(int arg0) throws SQLException
  
  Specified by:
  
  setHoldability in interface Connection
  
  Throws:
  
  SQLException
- setMaxRows
  
  public int setMaxRows(Integer maxRows, boolean reset)
- setMaxRowsHardLimit
  
  public int setMaxRowsHardLimit(Integer maxRows, boolean reset) throws SQLException
  
  Throws:
  
  SQLException
- setMaxTempDisk
  
  public int setMaxTempDisk(Integer maxTempDisk, boolean reset) throws SQLException
  
  Throws:
  
  SQLException
- setMaxTime
  
  public int setMaxTime(Integer maxTime, boolean reset) throws SQLException
  
  Throws:
  
  SQLException
- setNetworkTimeout
  
  public void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException
  
  Specified by:
  
  setNetworkTimeout in interface Connection
  
  Throws:
  
  SQLException
- setPriority
  
  public int setPriority(Double priority, boolean reset) throws SQLException
  
  Throws:
  
  SQLException
- setPSOSeed
  
  public void setPSOSeed(long seed, boolean reset) throws Exception
  
  Throws:
  
  Exception
- setPSO
  
  public void setPSO(boolean on) throws Exception
  
  Throws:
  
  Exception
- setPSO
  
  public void setPSO(long threshold) throws Exception
  
  Throws:
  
  Exception
- setPriorityAdjustFactor
  
  public int setPriorityAdjustFactor(Double priorityAdjustFactor, boolean reset) throws SQLException
  
  Throws:
  
  SQLException
- setPriorityAdjustTime
  
  public int setPriorityAdjustTime(Integer priorityAdjustTime, boolean reset) throws SQLException
  
  Throws:
  
  SQLException
- setReadOnly
  
  public void setReadOnly(boolean arg0) throws SQLException
  
  Specified by:
  
  setReadOnly in interface Connection
  
  Throws:
  
  SQLException
- setSavepoint
  
  public Savepoint setSavepoint() throws SQLException
  
  Specified by:
  
  setSavepoint in interface Connection
  
  Throws:
  
  SQLException
- setSavepoint
  
  public Savepoint setSavepoint(String arg0) throws SQLException
  
  Specified by:
  
  setSavepoint in interface Connection
  
  Throws:
  
  SQLException
- setSchema
  
  public void setSchema(String schema) throws SQLException
  
  Specified by:
  
  setSchema in interface Connection
  
  Throws:
  
  SQLException
- setServerVersion
  
  public void setServerVersion(String version)
- setTimeout
  
  public void setTimeout(int seconds) throws SQLException
  
  Throws:
  
  SQLException
- setTransactionIsolation
  
  public void setTransactionIsolation(int arg0) throws SQLException
  
  Specified by:
  
  setTransactionIsolation in interface Connection
  
  Throws:
  
  SQLException
- setTypeMap
  
  public void setTypeMap(Map<String,Class<?>> arg0) throws SQLException
  
  Specified by:
  
  setTypeMap in interface Connection
  
  Throws:
  
  SQLException
- unwrap
  
  public <T> T unwrap(Class<T> iface) throws SQLException
  
  Specified by:
  
  unwrap in interface Wrapper
  
  Throws:
  
  SQLException
- sendRefreshSession
  
  public com.ocient.jdbc.XGConnection.Session.State sendRefreshSession() throws SQLException
  
  Throws:
  
  SQLException
- sendRefreshToken
  
  public com.ocient.jdbc.XGConnection.Session.State sendRefreshToken(com.ocient.jdbc.XGConnection.Session.State oldState) throws SQLException
  
  Throws:
  
  SQLException

Class XGConnection