public class AltibaseConnection
extends java.lang.Object
implements java.sql.Connection
| Modifier and Type | Field and Description |
|---|---|
static byte |
EXPLAIN_PLAN_OFF |
static byte |
EXPLAIN_PLAN_ON |
static byte |
EXPLAIN_PLAN_ONLY |
protected CmChannel |
mChannel |
protected java.util.Properties |
mClientInfo |
protected CmProtocolContextConnect |
mContext |
protected boolean |
mIsClosed |
protected java.util.logging.Logger |
mLogger |
protected AltibaseProperties |
mProp |
static java.lang.String |
PROP_APPLICATION_NAME |
| Constructor and Description |
|---|
AltibaseConnection(java.util.Properties aProp,
AltibaseDataSource aDataSource) |
AltibaseConnection(java.util.Properties aProp,
AltibaseDataSource aDataSource,
AltibaseShardingConnection aMetaConn) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
canReUseResultSet() |
protected void |
clearAsyncPrefetchStatement()
Asynchronous fetch ±â´ÉÀÌ µ¿ÀÛ ÁßÀÎ statement ¸¦ ÀúÀåÇÑ´Ù.
|
void |
clearStatements4STF()
STF¸¦ ¼öÇàÇϱâ Àü¿¡, ¹«È¿ÈµÈ StatementÀÇ »óŸ¦ Á¤¸®Çϱâ À§Çؼ ¼öÇàÇÑ´Ù.
|
void |
clearWarnings() |
void |
close() |
void |
commit() |
java.sql.Statement |
createStatement() |
java.sql.Statement |
createStatement(int aResultSetType,
int aResultSetConcurrency) |
java.sql.Statement |
createStatement(int aResultSetType,
int aResultSetConcurrency,
int aResultSetHoldability) |
void |
deregisterFailoverCallback() |
AltibaseFailoverContext |
failoverContext() |
protected boolean |
forceClobBind() |
boolean |
getAllowLobNullSelect() |
protected AltibaseStatement |
getAsyncPrefetchStatement()
Asynchronous fetch ±â´ÉÀÌ µ¿ÀÛ ÁßÀÎ statement ¸¦ ¾ò´Â´Ù.
|
boolean |
getAutoCommit() |
boolean |
getBatchSetBytesUseLob() |
java.lang.String |
getCatalog() |
java.lang.String[] |
getCipherSuiteList()
PROJ-2474 °¡´ÉÇÑ ciphersuite ¸®½ºÆ®¸¦ µ¹·ÁÁØ´Ù.
|
java.lang.String |
getDatabaseVersion()
¿¬°áµÈ DBÀÇ ÆÐŰÁö ¹öÀüÀ» ¾ò´Â´Ù.
|
java.lang.String |
getDbTimeZone()
¼¹ö¿¡ ¼³Á¤µÈ TimeZoneÀ» ¾ò´Â´Ù.
|
int |
getHoldability() |
AltibaseShardingConnection |
getMetaConnection() |
java.sql.DatabaseMetaData |
getMetaData() |
java.lang.String |
getNodeName() |
int |
getPort() |
boolean |
getProceduresReturnFunctions() |
AltibaseProperties |
getProp() |
java.lang.String |
getServer() |
java.lang.String |
getServerCharacterSet() |
int |
getSessionId() |
java.lang.String |
getSessionTimeZone()
Session¿¡ ¼³Á¤µÈ TimeZoneÀ» ¾ò´Â´Ù.
|
int |
getTransactionIsolation() |
int |
getTransTimeout() |
java.util.Map |
getTypeMap() |
java.lang.String |
getURL() |
static java.lang.String |
getURL(java.util.Properties aProps)
DB ¿¬°á Á¤º¸°¡ ´ã±ä Properties¸¦ ÀÌ¿ëÇØ URL stringÀ» ¾ò´Â´Ù.
|
java.lang.String |
getUserName() |
java.sql.SQLWarning |
getWarnings() |
boolean |
isClientSideAutoCommit() |
boolean |
isClosed() |
protected boolean |
isDeferredPrepare() |
boolean |
isMetaConnection() |
boolean |
isNodeConnection() |
boolean |
isReadOnly() |
boolean |
isShardConnection()
¸ÞŸĿ³Ø¼ÇÀ̳ª ³ëµåÄ¿³Ø¼ÇÀÎÁö ¿©ºÎ¸¦ üũÇÑ´Ù.
|
java.lang.String |
nativeSQL(java.lang.String aSql) |
void |
ping()
BUG-39149 handshake ÇÁ·ÎÅäÄÝÀ» ÀÌ¿ëÇØ Ä¿³Ø¼ÇÀÌ À¯È¿ÇÑÁö üũÇÑ´Ù.
|
java.sql.CallableStatement |
prepareCall(java.lang.String aSql) |
java.sql.CallableStatement |
prepareCall(java.lang.String aSql,
int aResultSetType,
int aResultSetConcurrency) |
java.sql.CallableStatement |
prepareCall(java.lang.String aSql,
int aResultSetType,
int aResultSetConcurrency,
int aResultSetHoldability) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String aSql) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String aSql,
int aAutoGeneratedKeys) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String aSql,
int[] aColumnIndexes) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String aSql,
int aResultSetType,
int aResultSetConcurrency) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String aSql,
int aResultSetType,
int aResultSetConcurrency,
int aResultSetHoldability) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String aSql,
java.lang.String[] aColumnNames) |
protected void |
putAppInfoToClientInfoMap(java.lang.String aValue) |
protected void |
quietClose()
ConnectionÀ» ´Ý´Â´Ù.
|
void |
registerFailoverCallback(AltibaseFailoverCallback aFailoverCallback,
java.lang.Object aAppContext) |
void |
registerMessageCallback(AltibaseMessageCallback aMessageCallback)
DB Message ÇÁ·ÎÅäÄÝÀ» ó¸®ÇÒ ÄݹéÀ» µî·ÏÇÑ´Ù.
|
void |
releaseSavepoint(java.sql.Savepoint aSavepoint) |
void |
rollback() |
void |
rollback(java.sql.Savepoint aSavepoint) |
void |
sendSMNProperty(long aNewSMN) |
protected boolean |
setAsyncPrefetchStatement(AltibaseStatement aStatement)
Asynchronous fetch ±â´ÉÀÌ µ¿ÀÛ ÁßÀÎ statement ¸¦ ÀúÀåÇÑ´Ù.
|
void |
setAutoCommit(boolean aAutoCommit) |
void |
setCatalog(java.lang.String aCatalog) |
void |
setClosed(boolean aClosed) |
void |
setExplainPlan(boolean aUseExplainPlan)
Deprecated.
Replaced by
setExplainPlan(byte) |
void |
setExplainPlan(byte aExplainPlanMode)
Explain Plan Mode¸¦ ¼³Á¤ÇÑ´Ù.
|
void |
setHoldability(int aHoldability) |
void |
setReadOnly(boolean aReadOnly) |
java.sql.Savepoint |
setSavepoint() |
java.sql.Savepoint |
setSavepoint(java.lang.String aName) |
void |
setSessionTimeZone(java.lang.String aTimeZone)
Session TimeZoneÀ» ¹Ù²Û´Ù.
|
void |
setTransactionIsolation(int aLevel) |
void |
setTransTimeout(int aTimeoutSec) |
void |
setTypeMap(java.util.Map map) |
protected void |
throwErrorForClosed() |
java.lang.String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitpublic static final byte EXPLAIN_PLAN_OFF
public static final byte EXPLAIN_PLAN_ON
public static final byte EXPLAIN_PLAN_ONLY
public static final java.lang.String PROP_APPLICATION_NAME
protected CmChannel mChannel
protected CmProtocolContextConnect mContext
protected boolean mIsClosed
protected AltibaseProperties mProp
protected java.util.Properties mClientInfo
protected transient java.util.logging.Logger mLogger
public AltibaseConnection(java.util.Properties aProp,
AltibaseDataSource aDataSource,
AltibaseShardingConnection aMetaConn)
throws java.sql.SQLException
java.sql.SQLExceptionpublic AltibaseConnection(java.util.Properties aProp,
AltibaseDataSource aDataSource)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.lang.String getNodeName()
public boolean isShardConnection()
public void ping()
throws java.sql.SQLException
java.sql.SQLExceptionprotected void putAppInfoToClientInfoMap(java.lang.String aValue)
public java.lang.String getURL()
public static java.lang.String getURL(java.util.Properties aProps)
aProps - DB ¿¬°á Á¤º¸°¡ ´ã±ä Propertiespublic void clearWarnings()
throws java.sql.SQLException
clearWarnings in interface java.sql.Connectionjava.sql.SQLExceptionpublic void close()
throws java.sql.SQLException
close in interface java.lang.AutoCloseableclose in interface java.sql.Connectionjava.sql.SQLExceptionpublic int getSessionId()
protected void quietClose()
public void commit()
throws java.sql.SQLException
commit in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.Statement createStatement()
throws java.sql.SQLException
createStatement in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.Statement createStatement(int aResultSetType,
int aResultSetConcurrency)
throws java.sql.SQLException
createStatement in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.Statement createStatement(int aResultSetType,
int aResultSetConcurrency,
int aResultSetHoldability)
throws java.sql.SQLException
createStatement in interface java.sql.Connectionjava.sql.SQLExceptionpublic boolean getAutoCommit()
throws java.sql.SQLException
getAutoCommit in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.lang.String getCatalog()
throws java.sql.SQLException
getCatalog in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.lang.String getUserName()
throws java.sql.SQLException
java.sql.SQLExceptionpublic int getHoldability()
throws java.sql.SQLException
getHoldability in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.DatabaseMetaData getMetaData()
throws java.sql.SQLException
getMetaData in interface java.sql.Connectionjava.sql.SQLExceptionpublic int getTransactionIsolation()
throws java.sql.SQLException
getTransactionIsolation in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.util.Map getTypeMap()
throws java.sql.SQLException
getTypeMap in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.SQLWarning getWarnings()
throws java.sql.SQLException
getWarnings in interface java.sql.Connectionjava.sql.SQLExceptionpublic boolean isClosed()
throws java.sql.SQLException
isClosed in interface java.sql.Connectionjava.sql.SQLExceptionpublic boolean isReadOnly()
throws java.sql.SQLException
isReadOnly in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.lang.String nativeSQL(java.lang.String aSql)
throws java.sql.SQLException
nativeSQL in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.CallableStatement prepareCall(java.lang.String aSql,
int aResultSetType,
int aResultSetConcurrency,
int aResultSetHoldability)
throws java.sql.SQLException
prepareCall in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.CallableStatement prepareCall(java.lang.String aSql,
int aResultSetType,
int aResultSetConcurrency)
throws java.sql.SQLException
prepareCall in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.CallableStatement prepareCall(java.lang.String aSql)
throws java.sql.SQLException
prepareCall in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.PreparedStatement prepareStatement(java.lang.String aSql,
int aResultSetType,
int aResultSetConcurrency)
throws java.sql.SQLException
prepareStatement in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.PreparedStatement prepareStatement(java.lang.String aSql,
int aResultSetType,
int aResultSetConcurrency,
int aResultSetHoldability)
throws java.sql.SQLException
prepareStatement in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.PreparedStatement prepareStatement(java.lang.String aSql,
int aAutoGeneratedKeys)
throws java.sql.SQLException
prepareStatement in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.PreparedStatement prepareStatement(java.lang.String aSql,
int[] aColumnIndexes)
throws java.sql.SQLException
prepareStatement in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.PreparedStatement prepareStatement(java.lang.String aSql,
java.lang.String[] aColumnNames)
throws java.sql.SQLException
prepareStatement in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.PreparedStatement prepareStatement(java.lang.String aSql)
throws java.sql.SQLException
prepareStatement in interface java.sql.Connectionjava.sql.SQLExceptionpublic void releaseSavepoint(java.sql.Savepoint aSavepoint)
throws java.sql.SQLException
releaseSavepoint in interface java.sql.Connectionjava.sql.SQLExceptionpublic void rollback()
throws java.sql.SQLException
rollback in interface java.sql.Connectionjava.sql.SQLExceptionpublic void rollback(java.sql.Savepoint aSavepoint)
throws java.sql.SQLException
rollback in interface java.sql.Connectionjava.sql.SQLExceptionpublic void setAutoCommit(boolean aAutoCommit)
throws java.sql.SQLException
setAutoCommit in interface java.sql.Connectionjava.sql.SQLExceptionpublic void setCatalog(java.lang.String aCatalog)
throws java.sql.SQLException
setCatalog in interface java.sql.Connectionjava.sql.SQLExceptionpublic void setHoldability(int aHoldability)
throws java.sql.SQLException
setHoldability in interface java.sql.Connectionjava.sql.SQLExceptionpublic void setReadOnly(boolean aReadOnly)
throws java.sql.SQLException
setReadOnly in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.Savepoint setSavepoint()
throws java.sql.SQLException
setSavepoint in interface java.sql.Connectionjava.sql.SQLExceptionpublic java.sql.Savepoint setSavepoint(java.lang.String aName)
throws java.sql.SQLException
setSavepoint in interface java.sql.Connectionjava.sql.SQLExceptionpublic void setTransactionIsolation(int aLevel)
throws java.sql.SQLException
setTransactionIsolation in interface java.sql.Connectionjava.sql.SQLExceptionpublic void setTypeMap(java.util.Map map)
throws java.sql.SQLException
setTypeMap in interface java.sql.Connectionjava.sql.SQLExceptionpublic boolean isClientSideAutoCommit()
protected boolean isDeferredPrepare()
protected boolean forceClobBind()
public java.lang.String getDatabaseVersion()
throws java.sql.SQLException
java.sql.SQLException - ÆÐŰÁö ¹öÀü ¹®ÀÚ¿À» ¾ò´Âµ¥ ½ÇÆÐÇßÀ» °æ¿ìpublic int getTransTimeout()
throws java.sql.SQLException
java.sql.SQLExceptionpublic void setTransTimeout(int aTimeoutSec)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.lang.String getDbTimeZone()
throws java.sql.SQLException
java.sql.SQLException - DB TimeZoneÀ» ¾ò´Âµ¥ ½ÇÆÐÇßÀ» °æ¿ìpublic java.lang.String getSessionTimeZone()
throws java.sql.SQLException
java.sql.SQLException - Session TimeZoneÀ» ¾ò´Âµ¥ ½ÇÆÐÇßÀ» °æ¿ìpublic void setSessionTimeZone(java.lang.String aTimeZone)
throws java.sql.SQLException
aTimeZone - ¹Ù²Ü TimeZone °ªjava.sql.SQLException - TimeZoneÀ» ¹Ù²Ù´Âµ¥ ½ÇÆÐÇßÀ» °æ¿ìpublic void setExplainPlan(byte aExplainPlanMode)
throws java.sql.SQLException
aExplainPlanMode - Explain Plan Mode. ´ÙÀ½ °ª Áß Çϳª:
EXPLAIN_PLAN_OFF,
EXPLAIN_PLAN_ON,
EXPLAIN_PLAN_ONLYjava.lang.IllegalArgumentException - Explain Plan Mode°¡ ¿Ã¹Ù¸£Áö ¾ÊÀ» °æ¿ìjava.sql.SQLException - Explain Plan ¼Ó¼º ¼³Á¤¿¡ ½ÇÆÐÇÑ °æ¿ìpublic void setExplainPlan(boolean aUseExplainPlan)
throws java.sql.SQLException
setExplainPlan(byte)aUseExplainPlan - ExplainPlanÀ» »ç¿ëÇÒÁö ¿©ºÎjava.sql.SQLException - Explain Plan ¼Ó¼º ¼³Á¤¿¡ ½ÇÆÐÇÑ °æ¿ìpublic void registerFailoverCallback(AltibaseFailoverCallback aFailoverCallback, java.lang.Object aAppContext) throws java.sql.SQLException
java.sql.SQLExceptionpublic void deregisterFailoverCallback()
throws java.sql.SQLException
java.sql.SQLExceptionpublic void registerMessageCallback(AltibaseMessageCallback aMessageCallback) throws java.sql.SQLException
aMessageCallback - ÄÝ¹é °´Ã¼java.sql.SQLExceptionpublic java.lang.String[] getCipherSuiteList()
public AltibaseFailoverContext failoverContext()
public void clearStatements4STF()
protected void throwErrorForClosed()
throws java.sql.SQLException
java.sql.SQLExceptionprotected boolean setAsyncPrefetchStatement(AltibaseStatement aStatement)
protected void clearAsyncPrefetchStatement()
protected AltibaseStatement getAsyncPrefetchStatement()
public boolean isNodeConnection()
public boolean isMetaConnection()
public AltibaseShardingConnection getMetaConnection()
public java.lang.String getServerCharacterSet()
throws java.sql.SQLException
java.sql.SQLExceptionpublic AltibaseProperties getProp()
public java.lang.String toString()
toString in class java.lang.Objectpublic void sendSMNProperty(long aNewSMN)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.lang.String getServer()
public int getPort()
public void setClosed(boolean aClosed)
public boolean getAllowLobNullSelect()
public boolean canReUseResultSet()
public boolean getProceduresReturnFunctions()
public boolean getBatchSetBytesUseLob()