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.ConnectionPoolingMode`
`static class`	`XGConnection.ConnectionProperty`
`static class`	`XGConnection.ConnectionPropertyGroup`
`static class`	`XGConnection.HandshakeType`
`static interface`	`XGConnection.ResponseHandler<Response>`	A response handler for response frame
`protected static class`	`XGConnection.Session`
`static class`	`XGConnection.Tls`
`static class`	`XGConnection.XGConnectionFactory`	Handles the entire XGConnection lifecycle.

Field Summary

Fields
Modifier and Type	Field	Description
`protected String`	`client`
`protected static String`	`CLIENT_VERSION`
`protected ArrayList<String>`	`cmdcomps`
`protected String`	`connectedIp`
`protected int`	`connectedPort`
`protected String`	`database`
`protected boolean`	`force`
`protected BufferedInputStream`	`in`
`Integer`	`maxRows`
`protected static boolean`	`metricsEnabled`
`protected OptionalInt`	`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 CaselessProperties`	`properties`
`protected String`	`protocolVersion`
`protected String`	`pwd`
`protected XGResultSet`	`rs`
`protected int`	`secondaryIndex`
`protected List<List<String>>`	`secondaryInterfaces`
`protected String`	`serverSessionId`
`protected String`	`serverVersion`
`protected XGConnection.Session`	`session`
`static String`	`sessionID`
`protected com.ocient.jdbc.XGConnection.Session.State`	`sessionState`
`protected OptionalLong`	`setPso`
`protected Optional<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

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()`
`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)`
`List<ClientWireProtocol.Authenticator>`	`fetchAuthenticators()`	Fetches all `ClientWireProtocol.Authenticator`s
`void`	`forceExternal(boolean force)`
`XGConnection`	`forkConnection(XGConnectionInfo.Hint hint, boolean hint_bypassLoadBalancerOnHandshakeOnly)`	Forks a new XGConnection based on the current connection, with optional hints for connection type.
`boolean`	`getAutoCommit()`
`String`	`getCatalog()`
`Properties`	`getClientInfo()`
`String`	`getClientInfo(String arg0)`
`static Set<Gauge>`	`getConnectionPoolGauges()`
`String`	`getDB()`
`static OpenIDAuthenticators.OAuthFlow`	`getDefaultOAuthFlow()`
`int`	`getHoldability()`
`XGConnectionInfo`	`getInfo()`
`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()`
`boolean`	`isClosed()`
`boolean`	`isReadOnly()`
`boolean`	`isValid(int arg0)`
`boolean`	`isWrapperFor(Class<?> iface)`
`static XGConnection`	`leaseConnection(XGConnectionInfo info)`	Leases a connection to the database specified by `info`.
`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)`
`boolean`	`setFatalException(Throwable t)`
`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)`
`int`	`setMemoryTracing(boolean memoryTracing, 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`	`setServerVersion(String version)`
`int`	`setServiceClassName(String serviceClassName, boolean reset)`
`void`	`setTimeout(int seconds)`
`void`	`setTransactionIsolation(int arg0)`
`void`	`setTypeMap(Map<String,Class<?>> arg0)`
`static XGConnection`	`TEST_createConnection(String user, String pwd, String ip, int portNum, String url, String database, String protocolVersion, XGConnection.Tls tls, CaselessProperties hint_properties)`
`String`	`toString()`
`<T> T`	`unwrap(Class<T> iface)`
`static void`	`writeOktaNativeSSOToken(Path tokenFilePath, OktaAuthenticators.OktaNativeSSOToken token)`

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, 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
- CLIENT_VERSION
  
  protected static final String CLIENT_VERSION
- in
  
  protected BufferedInputStream in
- out
  
  protected BufferedOutputStream out
- rs
  
  protected XGResultSet rs
- warnings
  
  protected ArrayList<SQLWarning> warnings
- url
  
  protected final String url
- 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
- serverVersion
  
  protected String serverVersion
- oneShotForce
  
  protected boolean oneShotForce
- cmdcomps
  
  protected ArrayList<String> cmdcomps
- secondaryInterfaces
  
  protected List<List<String>> secondaryInterfaces
- secondaryIndex
  
  protected int secondaryIndex
- networkTimeout
  
  protected OptionalInt networkTimeout
- tls
  
  protected XGConnection.Tls tls
- sessionID
  
  public static final String sessionID
- metricsEnabled
  
  protected static volatile boolean metricsEnabled
- pwd
  
  protected String pwd
- session
  
  protected XGConnection.Session session
- serverSessionId
  
  protected String serverSessionId
- sessionState
  
  protected com.ocient.jdbc.XGConnection.Session.State sessionState
- typeMap
  
  protected Map<String,Class<?>> typeMap
- properties
  
  protected CaselessProperties properties
- setSchema
  
  protected Optional<String> setSchema
- setPso
  
  protected OptionalLong setPso
- maxRows
  
  public Integer maxRows
- force
  
  protected boolean force
Method Details
- refreshSession
  
  public void refreshSession() throws SQLException
  
  Throws:
  
  SQLException
- refreshToken
  
  public void refreshToken() throws SQLException
  
  Throws:
  
  SQLException
- getConnectionPoolGauges
  
  public static Set<Gauge> getConnectionPoolGauges()
- getInfo
  
  public XGConnectionInfo getInfo()
- leaseConnection
  
  public static XGConnection leaseConnection(XGConnectionInfo info) throws SQLException
  
  Leases a connection to the database specified by info. The returned Connection will have had XGConnection.XGConnectionFactory.activateObject(XGConnectionInfo, PooledObject) called with the info passed into this method. IMPORTANT: This is the ONLY way to establish a connection to the database outside of this immediate compilation unit.
  
  Parameters:
  
  info - the XGConnectionInfo object that contains the properties for the connection
  
  Returns:
  
  an XGConnection object that is either newly created or reused from the pool
  
  Throws:
  
  Exception - if there is an error retrieving a connection from the pool
  
  SQLException
- forkConnection
  
  public XGConnection forkConnection(XGConnectionInfo.Hint hint, boolean hint_bypassLoadBalancerOnHandshakeOnly) throws SQLException
  
  Forks a new XGConnection based on the current connection, with optional hints for connection type.
  
  Parameters:
  
  hint - the hint for the type of connection to fork
  
  hint_bypassLoadBalancerOnHandshakeOnly - set to true to disable redirect on connect
  
  Returns:
  
  a new XGConnection object based on the current connection, with the specified properties
  
  Throws:
  
  Exception - if there is an error creating the new connection
  
  IllegalStateException - if an invalid hint is specified
  
  SQLException
- TEST_createConnection
  
  public static XGConnection TEST_createConnection(String user, String pwd, String ip, int portNum, String url, String database, String protocolVersion, XGConnection.Tls tls, CaselessProperties hint_properties)
- 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()
- setFatalException
  
  public boolean setFatalException(Throwable t)
- 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()
- 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()
- 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
- 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
- setServiceClassName
  
  public int setServiceClassName(String serviceClassName, boolean reset) throws SQLException
  
  Throws:
  
  SQLException
- setMemoryTracing
  
  public int setMemoryTracing(boolean memoryTracing, 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
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object

Class XGConnection