Package com.ocient.jdbc
Class XGConnection
- java.lang.Object
-
- com.ocient.jdbc.XGConnection
-
- All Implemented Interfaces:
AutoCloseable,Connection,Wrapper
public class XGConnection extends Object implements Connection
-
-
Field Summary
Fields Modifier and Type Field Description protected Stringclientprotected ArrayList<String>cmdcompsprotected Stringdatabaseprotected booleanforceprotected BufferedInputStreaminprotected booleanoneShotForceprotected BufferedOutputStreamoutprotected intportNumprotected Stringpwdprotected XGResultSetrsprotected StringsetSchemaprotected Stringurlprotected Stringuserprotected Stringversionprotected 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
-
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
-
-
-
-
Field Detail
-
in
protected BufferedInputStream in
-
out
protected BufferedOutputStream out
-
rs
protected XGResultSet rs
-
portNum
protected int portNum
-
warnings
protected ArrayList<SQLWarning> warnings
-
url
protected String url
-
user
protected String user
-
database
protected String database
-
client
protected String client
-
version
protected String version
-
setSchema
protected String setSchema
-
force
protected boolean force
-
oneShotForce
protected boolean oneShotForce
-
pwd
protected String pwd
-
-
Method Detail
-
abort
public void abort(Executor executor) throws SQLException
- Specified by:
abortin interfaceConnection- Throws:
SQLException
-
clearOneShotForce
public void clearOneShotForce()
-
clearWarnings
public void clearWarnings() throws SQLException- Specified by:
clearWarningsin interfaceConnection- Throws:
SQLException
-
close
public void close() throws SQLException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceConnection- Throws:
SQLException
-
commit
public void commit() throws SQLException- Specified by:
commitin interfaceConnection- Throws:
SQLException
-
createArrayOf
public Array createArrayOf(String arg0, Object[] arg1) throws SQLException
- Specified by:
createArrayOfin interfaceConnection- Throws:
SQLException
-
createBlob
public Blob createBlob() throws SQLException
- Specified by:
createBlobin interfaceConnection- Throws:
SQLException
-
createClob
public Clob createClob() throws SQLException
- Specified by:
createClobin interfaceConnection- Throws:
SQLException
-
createNClob
public NClob createNClob() throws SQLException
- Specified by:
createNClobin interfaceConnection- Throws:
SQLException
-
createSQLXML
public SQLXML createSQLXML() throws SQLException
- Specified by:
createSQLXMLin interfaceConnection- Throws:
SQLException
-
createStatement
public Statement createStatement() throws SQLException
- Specified by:
createStatementin interfaceConnection- Throws:
SQLException
-
createStatement
public Statement createStatement(int arg0, int arg1) throws SQLException
- Specified by:
createStatementin interfaceConnection- Throws:
SQLException
-
createStatement
public Statement createStatement(int arg0, int arg1, int arg2) throws SQLException
- Specified by:
createStatementin interfaceConnection- Throws:
SQLException
-
createStruct
public Struct createStruct(String arg0, Object[] arg1) throws SQLException
- Specified by:
createStructin interfaceConnection- Throws:
SQLException
-
getAutoCommit
public boolean getAutoCommit() throws SQLException- Specified by:
getAutoCommitin interfaceConnection- Throws:
SQLException
-
getCatalog
public String getCatalog() throws SQLException
- Specified by:
getCatalogin interfaceConnection- Throws:
SQLException
-
getClientInfo
public Properties getClientInfo() throws SQLException
- Specified by:
getClientInfoin interfaceConnection- Throws:
SQLException
-
getClientInfo
public String getClientInfo(String arg0) throws SQLException
- Specified by:
getClientInfoin interfaceConnection- Throws:
SQLException
-
getDB
public String getDB()
-
getHoldability
public int getHoldability() throws SQLException- Specified by:
getHoldabilityin interfaceConnection- Throws:
SQLException
-
getMajorVersion
public int getMajorVersion()
-
getMetaData
public DatabaseMetaData getMetaData() throws SQLException
- Specified by:
getMetaDatain interfaceConnection- Throws:
SQLException
-
getMinorVersion
public int getMinorVersion()
-
getNetworkTimeout
public int getNetworkTimeout() throws SQLException- Specified by:
getNetworkTimeoutin interfaceConnection- Throws:
SQLException
-
getSchema
public String getSchema() throws SQLException
- Specified by:
getSchemain interfaceConnection- Throws:
SQLException
-
getTransactionIsolation
public int getTransactionIsolation() throws SQLException- Specified by:
getTransactionIsolationin interfaceConnection- Throws:
SQLException
-
getTypeMap
public Map<String,Class<?>> getTypeMap() throws SQLException
- Specified by:
getTypeMapin interfaceConnection- Throws:
SQLException
-
getURL
public String getURL()
-
getUser
public String getUser()
-
getVersion
public String getVersion()
-
getWarnings
public SQLWarning getWarnings() throws SQLException
- Specified by:
getWarningsin interfaceConnection- Throws:
SQLException
-
isClosed
public boolean isClosed() throws SQLException- Specified by:
isClosedin interfaceConnection- Throws:
SQLException
-
isReadOnly
public boolean isReadOnly() throws SQLException- Specified by:
isReadOnlyin interfaceConnection- Throws:
SQLException
-
isValid
public boolean isValid(int arg0) throws SQLException- Specified by:
isValidin interfaceConnection- Throws:
SQLException
-
isWrapperFor
public boolean isWrapperFor(Class<?> iface) throws SQLException
- Specified by:
isWrapperForin interfaceWrapper- Throws:
SQLException
-
nativeSQL
public String nativeSQL(String arg0) throws SQLException
- Specified by:
nativeSQLin interfaceConnection- Throws:
SQLException
-
prepareCall
public CallableStatement prepareCall(String arg0) throws SQLException
- Specified by:
prepareCallin interfaceConnection- Throws:
SQLException
-
prepareCall
public CallableStatement prepareCall(String arg0, int arg1, int arg2) throws SQLException
- Specified by:
prepareCallin interfaceConnection- Throws:
SQLException
-
prepareCall
public CallableStatement prepareCall(String arg0, int arg1, int arg2, int arg3) throws SQLException
- Specified by:
prepareCallin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String arg0) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String arg0, int arg1) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String arg0, int arg1, int arg2) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String arg0, int arg1, int arg2, int arg3) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String arg0, int[] arg1) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String arg0, String[] arg1) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
connected
public boolean connected()
-
reconnect
public void reconnect() throws IOException, SQLException- Throws:
IOExceptionSQLException
-
redirect
public void redirect(String host, int port) throws IOException, SQLException
- Throws:
IOExceptionSQLException
-
releaseSavepoint
public void releaseSavepoint(Savepoint arg0) throws SQLException
- Specified by:
releaseSavepointin interfaceConnection- Throws:
SQLException
-
rollback
public void rollback() throws SQLException- Specified by:
rollbackin interfaceConnection- Throws:
SQLException
-
rollback
public void rollback(Savepoint arg0) throws SQLException
- Specified by:
rollbackin interfaceConnection- Throws:
SQLException
-
setAutoCommit
public void setAutoCommit(boolean arg0) throws SQLException- Specified by:
setAutoCommitin interfaceConnection- Throws:
SQLException
-
setCatalog
public void setCatalog(String arg0) throws SQLException
- Specified by:
setCatalogin interfaceConnection- Throws:
SQLException
-
setClientInfo
public void setClientInfo(Properties arg0) throws SQLClientInfoException
- Specified by:
setClientInfoin interfaceConnection- Throws:
SQLClientInfoException
-
setClientInfo
public void setClientInfo(String arg0, String arg1) throws SQLClientInfoException
- Specified by:
setClientInfoin interfaceConnection- Throws:
SQLClientInfoException
-
setHoldability
public void setHoldability(int arg0) throws SQLException- Specified by:
setHoldabilityin interfaceConnection- Throws:
SQLException
-
setNetworkTimeout
public void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException
- Specified by:
setNetworkTimeoutin interfaceConnection- Throws:
SQLException
-
setReadOnly
public void setReadOnly(boolean arg0) throws SQLException- Specified by:
setReadOnlyin interfaceConnection- Throws:
SQLException
-
setSavepoint
public Savepoint setSavepoint() throws SQLException
- Specified by:
setSavepointin interfaceConnection- Throws:
SQLException
-
setSavepoint
public Savepoint setSavepoint(String arg0) throws SQLException
- Specified by:
setSavepointin interfaceConnection- Throws:
SQLException
-
setSchema
public void setSchema(String schema) throws SQLException
- Specified by:
setSchemain interfaceConnection- Throws:
SQLException
-
setTransactionIsolation
public void setTransactionIsolation(int arg0) throws SQLException- Specified by:
setTransactionIsolationin interfaceConnection- Throws:
SQLException
-
setTypeMap
public void setTypeMap(Map<String,Class<?>> arg0) throws SQLException
- Specified by:
setTypeMapin interfaceConnection- Throws:
SQLException
-
unwrap
public <T> T unwrap(Class<T> iface) throws SQLException
- Specified by:
unwrapin interfaceWrapper- Throws:
SQLException
-
-