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.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 int`	`networkTimeout`
`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`	`serverVersion`
`protected long`	`setPso`
`protected String`	`setSchema`
`protected XGConnection.Tls`	`tls`
`protected Map<String,Class<?>>`	`typeMap`
`protected String`	`url`
`protected String`	`user`
`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, int portNum, String url, String database, String protocolVersion, String clientVersion, boolean force, XGConnection.Tls tls, Properties properties)`
`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()`
`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)`
`void`	`forceExternal(boolean force)`
`boolean`	`getAutoCommit()`
`String`	`getCatalog()`
`Properties`	`getClientInfo()`
`String`	`getClientInfo(String arg0)`
`String`	`getDB()`
`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.
`void`	`reconnect()`
`void`	`reconnect(boolean shouldRequestVersion)`
`void`	`redirect(String host, int port, boolean shouldRequestVersion)`
`void`	`releaseSavepoint(Savepoint arg0)`
`void`	`rollback()`
`void`	`rollback(Savepoint arg0)`
`int`	`sendParameterMessage(ClientWireProtocol.SetParameter param)`
`void`	`setAutoCommit(boolean arg0)`
`void`	`setCatalog(String arg0)`
`void`	`setClientInfo(String arg0, String arg1)`
`void`	`setClientInfo(Properties arg0)`
`int`	`setConcurrency(Integer concurrency, boolean reset)`
`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)`
`void`	`setNetworkTimeout(Executor executor, int milliseconds)`
`int`	`setPriority(Double priority, boolean reset)`
`void`	`setPSO(boolean on)`
`void`	`setPSO(long threshold)`
`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)`

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
- 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
- setSchema
  
  protected String setSchema
- defaultSchema
  
  protected String defaultSchema
- setPso
  
  protected long setPso
- maxRows
  
  public Integer maxRows
- force
  
  protected boolean force
- 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
- pwd
  
  protected String pwd
- typeMap
  
  protected Map<String,Class<?>> typeMap
Constructor Details
- XGConnection
  
  public XGConnection(String user, String pwd, int portNum, String url, String database, String protocolVersion, String clientVersion, boolean force, XGConnection.Tls tls, Properties properties)
- 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
- 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
- clearOneShotForce
  
  public void clearOneShotForce()
- clearWarnings
  
  public void clearWarnings() throws SQLException
  
  Specified by:
  
  clearWarnings in interface Connection
  
  Throws:
  
  SQLException
- 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
- equals
  
  public boolean equals(Object o)
  
  Overrides:
  
  equals in class Object
- forceExternal
  
  public void forceExternal(boolean force) throws Exception
  
  Throws:
  
  Exception
- 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
- 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)
- 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
- setConcurrency
  
  public int setConcurrency(Integer concurrency, boolean reset)
- 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)
- setMaxTempDisk
  
  public int setMaxTempDisk(Integer maxTempDisk, boolean reset)
- setMaxTime
  
  public int setMaxTime(Integer maxTime, boolean reset)
- 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)
- setPSO
  
  public void setPSO(boolean on) throws Exception
  
  Throws:
  
  Exception
- setPSO
  
  public void setPSO(long threshold) throws Exception
  
  Throws:
  
  Exception
- 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

Modifier and Type	Class	Description
`static class`	`XGConnection.HandshakeType`
`static class`	`XGConnection.Tls`

Class XGConnection

Nested Class Summary

Field Summary

Fields inherited from interface java.sql.Connection

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface java.sql.Connection

Field Details

Constructor Details

Method Details