Altibase.jdbc.driver.cm

Class CmProtocol

java.lang.Object

Altibase.jdbc.driver.cm.CmProtocol

public class CmProtocol
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
CmProtocol()

Method Summary

Modifier and Type	Method and Description
static void	cancelStatement(CmProtocolContextDirExec aContext, int aCID)
static void	clientCommit(CmProtocolContext aContext, boolean aClientSideAutoCommit) ClientSideAutoCommitÀÌ onÀÎ °æ¿ì¿¡¸¸ ¼­¹ö·Î commit ¸Þ¼¼Áö¸¦ Àü¼ÛÇÑ´Ù.
static void	closeCursor(CmProtocolContextDirExec aContext, int aStmtID, short aResultSetID, boolean aClientSideAutoCommit)
static void	commit(CmProtocolContext aContext)
static void	connect(CmProtocolContextConnect aContext, java.lang.String aDBName, java.lang.String aUser, java.lang.String aPassword, short aConnectMode, ShardConnType aShardConnType)
static void	directExecute(CmProtocolContextDirExec aContext, int aCID, java.lang.String aSql, boolean aHoldable, boolean aForKeySetDriven, boolean aNliteralReplace, boolean aClientSideAutoCommit, boolean aShouldCloseCursor)
static void	directExecuteAndFetch(CmProtocolContextDirExec aContext, int aCID, java.lang.String aSql, int aFetchCount, long aMaxRows, int aMaxFieldSize, boolean aHoldable, boolean aForKeySetDriven, boolean aNliteralReplace, boolean aShouldCloseCursor)
static void	directExecuteBatch(CmProtocolContextDirExec aContext, int aCID, java.lang.String[] aSql, boolean aNliteralReplace, boolean aClientSideAutoCommit)
static void	disconnect(CmProtocolContextConnect aContext)
static void	fetch(CmProtocolContextDirExec aContext, int aFetchCount, long aMaxRows, int aMaxFieldSize)
static void	fetchNext(CmProtocolContextDirExec aContext, int aFetchCount)
static void	free(CmProtocolContextLob aContext)
static void	freeStatement(CmProtocolContextDirExec aContext, int aStmtID)
static void	getBlob(CmProtocolContextLob aContext, long aServerOffset, long aLength)
static void	getBytePos(CmProtocolContextLob aContext, int aCharLength)
static void	getCharLength(CmProtocolContextLob aContext)
static void	getClobBytePos(CmProtocolContextLob aContext, long aByteOffset, long aCharLength)
static void	getClobCharPos(CmProtocolContextLob aContext, long aCharOffset, long aCharLength)
static void	getLobByteLength(CmProtocolContextLob aContext)
static void	getPlan(CmProtocolContext aContext, int aStmtID, java.util.List aDeferredRequests) Statement ID¿¡ ÇØ´çÇÏ´Â Plan text¸¦ ¾ò´Â´Ù.
static void	getProperty(CmProtocolContextConnect aContext, byte aPropCode)
static void	handshake(CmProtocolContextConnect aContext)
static void	invokeDeferredRequests(java.util.List<java.util.Map<java.lang.String,java.lang.Object>> aDeferredRequests)
static void	prepare(CmProtocolContextDirExec aContext, int aCID, java.lang.String aSql, boolean aHoldable, boolean aForKeySetDriven, boolean aNliteralReplace, boolean aIsDeferred)
static void	preparedExecute(CmProtocolContextPrepExec aContext, java.util.List<Column> aParams, boolean aClientSideAutoCommit, boolean aShouldCloseCursor)
static void	preparedExecuteAndFetch(CmProtocolContextPrepExec aContext, java.util.List<Column> aParams, int aFetchCount, long aMaxRows, int aMaxFieldSize, boolean aShouldCloseCursor)
static void	preparedExecuteBatch(CmProtocolContextPrepExec aContext, java.util.List<Column> aParams, DynamicArrayRowHandle aRowHandle, int aRowCount)
static void	preparedExecuteBatchUsingList(CmProtocolContextPrepExec aContext, java.util.List<Column> aParams, ListBufferHandle aBufferHandle, int aRowCount, boolean aIsAtomic)
static void	putBlob(CmProtocolContextLob aContext, long aServerOffset, byte[] aSource, int aSourceOffset, int aSourceLength)
static void	putBlob(CmProtocolContextLob aContext, long aServerOffset, java.io.InputStream aSource, long aSourceLength)
static long	putClob(CmProtocolContextLob aContext, long aServerOffset, char[] aSrc) CLob µ¥ÀÌŸ¸¦ ¼­¹ö·Î º¸³½´Ù.
static long	putClob(CmProtocolContextLob aContext, long aServerOffset, char[] aSrc, int aSrcOffset, int aSrcLength) CLob µ¥ÀÌŸ¸¦ ¼­¹ö·Î º¸³½´Ù.
static long	putClob(CmProtocolContextLob aContext, long aServerOffset, java.io.Reader aSource, int aSourceLength) CLob µ¥ÀÌŸ¸¦ ¼­¹ö·Î º¸³½´Ù.
protected static void	readProtocolResult(CmProtocolContext aContext) ÇÁ·ÎÅäÄÝÀ» Çؼ®ÇÑ´Ù.
static void	receivefetchNextAsync(CmProtocolContextDirExec aContext) ºñµ¿±âÀûÀ¸·Î ¼Û½ÅÇÑ fetch ÇÁ·ÎÅäÄÝÀ» ¼ö½ÅÇÑ´Ù.
static void	rollback(CmProtocolContext aContext)
static void	sendFetchNextAsync(CmProtocolContextDirExec aContext, int aFetchCount) ºñµ¿±âÀûÀ¸·Î fetch ÇÁ·ÎÅäÄÝÀ» ¼Û½ÅÇÑ´Ù.
static void	sendProperties(CmProtocolContextConnect aContext)
static void	shardHandshake(CmProtocolContextConnect aContext) Meta ¼­¹ö¿Í Data ³ëµå¿¡ shard handshake ÇÁ·ÎÅäÄÝÀ» º¸³½´Ù.
static void	truncate(CmProtocolContextLob aContext, int aLength)
static void	writeGetBindParamInfo(CmProtocolContextDirExec aContext)
static void	xaClose(CmProtocolContextXA aContext)
static void	xaCommit(CmProtocolContextXA aContext, javax.transaction.xa.Xid aXid, long aFlag)
static void	xaEnd(CmProtocolContextXA aContext, javax.transaction.xa.Xid aXid, long aFlag)
static void	xaForget(CmProtocolContextXA aContext, javax.transaction.xa.Xid aXid)
static void	xaOpen(CmProtocolContextXA aContext)
static void	xaPrepare(CmProtocolContextXA aContext, javax.transaction.xa.Xid aXid)
static void	xaRecover(CmProtocolContextXA aContext, int aFlag)
static void	xaRollback(CmProtocolContextXA aContext, javax.transaction.xa.Xid aXid)
static void	xaStart(CmProtocolContextXA aContext, javax.transaction.xa.Xid aXid, long aFlag)

Methods inherited from class java.lang.Object

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

Constructor Detail

CmProtocol

public CmProtocol()

Method Detail

handshake

public static void handshake(CmProtocolContextConnect aContext)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

shardHandshake

public static void shardHandshake(CmProtocolContextConnect aContext)
                           throws java.sql.SQLException

Meta ¼­¹ö¿Í Data ³ëµå¿¡ shard handshake ÇÁ·ÎÅäÄÝÀ» º¸³½´Ù.

Parameters:

aContext - ContextConnect °´Ã¼

Throws:

java.sql.SQLException - shardHandshake µµÁß ¿¡·¯°¡ ¹ß»ýÇßÀ» ¶§

connect

public static void connect(CmProtocolContextConnect aContext,
                           java.lang.String aDBName,
                           java.lang.String aUser,
                           java.lang.String aPassword,
                           short aConnectMode,
                           ShardConnType aShardConnType)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

getProperty

public static void getProperty(CmProtocolContextConnect aContext,
                               byte aPropCode)
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

sendProperties

public static void sendProperties(CmProtocolContextConnect aContext)
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

disconnect

public static void disconnect(CmProtocolContextConnect aContext)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

commit

public static void commit(CmProtocolContext aContext)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

rollback

public static void rollback(CmProtocolContext aContext)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

directExecute

public static void directExecute(CmProtocolContextDirExec aContext,
                                 int aCID,
                                 java.lang.String aSql,
                                 boolean aHoldable,
                                 boolean aForKeySetDriven,
                                 boolean aNliteralReplace,
                                 boolean aClientSideAutoCommit,
                                 boolean aShouldCloseCursor)
                          throws java.sql.SQLException

Throws:

java.sql.SQLException

clientCommit

public static void clientCommit(CmProtocolContext aContext,
                                boolean aClientSideAutoCommit)
                         throws java.sql.SQLException

ClientSideAutoCommitÀÌ onÀÎ °æ¿ì¿¡¸¸ ¼­¹ö·Î commit ¸Þ¼¼Áö¸¦ Àü¼ÛÇÑ´Ù.

Parameters:

aContext - CmProtocolContext °´Ã¼

Throws:

java.sql.SQLException - commit½Ã ¿¡·¯°¡ ¹ß»ýÇÑ °æ¿ì

fetch

public static void fetch(CmProtocolContextDirExec aContext,
                         int aFetchCount,
                         long aMaxRows,
                         int aMaxFieldSize)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

fetchNext

public static void fetchNext(CmProtocolContextDirExec aContext,
                             int aFetchCount)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

sendFetchNextAsync

public static void sendFetchNextAsync(CmProtocolContextDirExec aContext,
                                      int aFetchCount)
                               throws java.sql.SQLException

ºñµ¿±âÀûÀ¸·Î fetch ÇÁ·ÎÅäÄÝÀ» ¼Û½ÅÇÑ´Ù.

Parameters:

aContext - Protocol context

aFetchCount - fetch ¸¦ ¿äûÇÒ row ¼ö

Throws:

java.sql.SQLException - ¼Û¼ö½Å °úÁ¤¿¡¼­ ¿¡·¯°¡ ¹ß»ýÇÏ¿´À» °æ¿ì

receivefetchNextAsync

public static void receivefetchNextAsync(CmProtocolContextDirExec aContext)
                                  throws java.sql.SQLException

ºñµ¿±âÀûÀ¸·Î ¼Û½ÅÇÑ fetch ÇÁ·ÎÅäÄÝÀ» ¼ö½ÅÇÑ´Ù.

Parameters:

aContext - Protocol context

Throws:

java.sql.SQLException - ¼Û¼ö½Å °úÁ¤¿¡¼­ ¿¡·¯°¡ ¹ß»ýÇÏ¿´À» °æ¿ì

directExecuteBatch

public static void directExecuteBatch(CmProtocolContextDirExec aContext,
                                      int aCID,
                                      java.lang.String[] aSql,
                                      boolean aNliteralReplace,
                                      boolean aClientSideAutoCommit)
                               throws java.sql.SQLException

Throws:

java.sql.SQLException

directExecuteAndFetch

public static void directExecuteAndFetch(CmProtocolContextDirExec aContext,
                                         int aCID,
                                         java.lang.String aSql,
                                         int aFetchCount,
                                         long aMaxRows,
                                         int aMaxFieldSize,
                                         boolean aHoldable,
                                         boolean aForKeySetDriven,
                                         boolean aNliteralReplace,
                                         boolean aShouldCloseCursor)
                                  throws java.sql.SQLException

Throws:

java.sql.SQLException

prepare

public static void prepare(CmProtocolContextDirExec aContext,
                           int aCID,
                           java.lang.String aSql,
                           boolean aHoldable,
                           boolean aForKeySetDriven,
                           boolean aNliteralReplace,
                           boolean aIsDeferred)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

writeGetBindParamInfo

public static void writeGetBindParamInfo(CmProtocolContextDirExec aContext)
                                  throws java.sql.SQLException

Throws:

java.sql.SQLException

preparedExecute

public static void preparedExecute(CmProtocolContextPrepExec aContext,
                                   java.util.List<Column> aParams,
                                   boolean aClientSideAutoCommit,
                                   boolean aShouldCloseCursor)
                            throws java.sql.SQLException

Throws:

java.sql.SQLException

preparedExecuteBatch

public static void preparedExecuteBatch(CmProtocolContextPrepExec aContext,
                                        java.util.List<Column> aParams,
                                        DynamicArrayRowHandle aRowHandle,
                                        int aRowCount)
                                 throws java.sql.SQLException

Throws:

java.sql.SQLException

preparedExecuteBatchUsingList

public static void preparedExecuteBatchUsingList(CmProtocolContextPrepExec aContext,
                                                 java.util.List<Column> aParams,
                                                 ListBufferHandle aBufferHandle,
                                                 int aRowCount,
                                                 boolean aIsAtomic)
                                          throws java.sql.SQLException

Throws:

java.sql.SQLException

preparedExecuteAndFetch

public static void preparedExecuteAndFetch(CmProtocolContextPrepExec aContext,
                                           java.util.List<Column> aParams,
                                           int aFetchCount,
                                           long aMaxRows,
                                           int aMaxFieldSize,
                                           boolean aShouldCloseCursor)
                                    throws java.sql.SQLException

Throws:

java.sql.SQLException

closeCursor

public static void closeCursor(CmProtocolContextDirExec aContext,
                               int aStmtID,
                               short aResultSetID,
                               boolean aClientSideAutoCommit)
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

freeStatement

public static void freeStatement(CmProtocolContextDirExec aContext,
                                 int aStmtID)
                          throws java.sql.SQLException

Throws:

java.sql.SQLException

cancelStatement

public static void cancelStatement(CmProtocolContextDirExec aContext,
                                   int aCID)
                            throws java.sql.SQLException

Throws:

java.sql.SQLException

getLobByteLength

public static void getLobByteLength(CmProtocolContextLob aContext)
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

getBlob

public static void getBlob(CmProtocolContextLob aContext,
                           long aServerOffset,
                           long aLength)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

putBlob

public static void putBlob(CmProtocolContextLob aContext,
                           long aServerOffset,
                           byte[] aSource,
                           int aSourceOffset,
                           int aSourceLength)
                    throws java.sql.SQLException,
                           java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

putBlob

public static void putBlob(CmProtocolContextLob aContext,
                           long aServerOffset,
                           java.io.InputStream aSource,
                           long aSourceLength)
                    throws java.sql.SQLException,
                           java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

truncate

public static void truncate(CmProtocolContextLob aContext,
                            int aLength)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

free

public static void free(CmProtocolContextLob aContext)
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

getCharLength

public static void getCharLength(CmProtocolContextLob aContext)
                          throws java.sql.SQLException

Throws:

java.sql.SQLException

getBytePos

public static void getBytePos(CmProtocolContextLob aContext,
                              int aCharLength)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

getClobBytePos

public static void getClobBytePos(CmProtocolContextLob aContext,
                                  long aByteOffset,
                                  long aCharLength)
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

getClobCharPos

public static void getClobCharPos(CmProtocolContextLob aContext,
                                  long aCharOffset,
                                  long aCharLength)
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

putClob

public static long putClob(CmProtocolContextLob aContext,
                           long aServerOffset,
                           char[] aSrc)
                    throws java.sql.SQLException,
                           java.io.IOException

CLob µ¥ÀÌŸ¸¦ ¼­¹ö·Î º¸³½´Ù.

Parameters:

aContext - ÇÁ·ÎÅäÄÝ ÄÁÅؽºÆ®

aServerOffset - µ¥ÀÌŸ¸¦ ¹Ý¿µÇÒ ¼­¹ö µ¥ÀÌŸÀÇ ±âÁØ À§Ä¡(byte ´ÜÀ§)

aSrc - º¸³¾ µ¥ÀÌŸ

Returns:

º¸³½ µ¥ÀÌŸ »çÀÌÁî(byte ´ÜÀ§)

Throws:

java.sql.SQLException - ÇÁ·ÎÅäÄÝÀ» ¾²´Âµ¥ ½ÇÆÐÇßÀ» °æ¿ì

java.io.IOException - µ¥ÀÌŸ¸¦ Àдµ¥ ½ÇÆÐÇßÀ» °æ¿ì

putClob

public static long putClob(CmProtocolContextLob aContext,
                           long aServerOffset,
                           char[] aSrc,
                           int aSrcOffset,
                           int aSrcLength)
                    throws java.sql.SQLException,
                           java.io.IOException

CLob µ¥ÀÌŸ¸¦ ¼­¹ö·Î º¸³½´Ù.

Parameters:

aContext - ÇÁ·ÎÅäÄÝ ÄÁÅؽºÆ®

aServerOffset - µ¥ÀÌŸ¸¦ ¹Ý¿µÇÒ ¼­¹ö µ¥ÀÌŸÀÇ ±âÁØ À§Ä¡(byte ´ÜÀ§)

aSrc - º¸³¾ µ¥ÀÌŸ

aSrcOffset - º¸³»±â ½ÃÀÛÇÒ À§Ä¡

aSrcLength - º¸³¾ ±æÀÌ

Returns:

º¸³½ µ¥ÀÌŸ »çÀÌÁî(byte ´ÜÀ§)

Throws:

java.sql.SQLException - ÇÁ·ÎÅäÄÝÀ» ¾²´Âµ¥ ½ÇÆÐÇßÀ» °æ¿ì

java.io.IOException - µ¥ÀÌŸ¸¦ Àдµ¥ ½ÇÆÐÇßÀ» °æ¿ì

putClob

public static long putClob(CmProtocolContextLob aContext,
                           long aServerOffset,
                           java.io.Reader aSource,
                           int aSourceLength)
                    throws java.sql.SQLException,
                           java.io.IOException

CLob µ¥ÀÌŸ¸¦ ¼­¹ö·Î º¸³½´Ù.

Parameters:

aContext - ÇÁ·ÎÅäÄÝ ÄÁÅؽºÆ®

aServerOffset - µ¥ÀÌŸ¸¦ ¹Ý¿µÇÒ ¼­¹ö µ¥ÀÌŸÀÇ ±âÁØ À§Ä¡(byte ´ÜÀ§)

aSource - º¸³¾ µ¥ÀÌŸ

aSourceLength - º¸³¾ µ¥ÀÌŸ ±æÀÌ

Returns:

º¸³½ µ¥ÀÌŸ »çÀÌÁî(byte ´ÜÀ§)

Throws:

java.sql.SQLException - ÇÁ·ÎÅäÄÝÀ» ¾²´Âµ¥ ½ÇÆÐÇßÀ» °æ¿ì

java.io.IOException - µ¥ÀÌŸ¸¦ Àдµ¥ ½ÇÆÐÇßÀ» °æ¿ì

xaOpen

public static void xaOpen(CmProtocolContextXA aContext)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

xaClose

public static void xaClose(CmProtocolContextXA aContext)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

xaPrepare

public static void xaPrepare(CmProtocolContextXA aContext,
                             javax.transaction.xa.Xid aXid)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

xaCommit

public static void xaCommit(CmProtocolContextXA aContext,
                            javax.transaction.xa.Xid aXid,
                            long aFlag)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

xaRollback

public static void xaRollback(CmProtocolContextXA aContext,
                              javax.transaction.xa.Xid aXid)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

xaStart

public static void xaStart(CmProtocolContextXA aContext,
                           javax.transaction.xa.Xid aXid,
                           long aFlag)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

xaEnd

public static void xaEnd(CmProtocolContextXA aContext,
                         javax.transaction.xa.Xid aXid,
                         long aFlag)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

xaForget

public static void xaForget(CmProtocolContextXA aContext,
                            javax.transaction.xa.Xid aXid)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

xaRecover

public static void xaRecover(CmProtocolContextXA aContext,
                             int aFlag)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

getPlan

public static void getPlan(CmProtocolContext aContext,
                           int aStmtID,
                           java.util.List aDeferredRequests)
                    throws java.sql.SQLException

Statement ID¿¡ ÇØ´çÇÏ´Â Plan text¸¦ ¾ò´Â´Ù.

Parameters:

aContext - Protocol context

aStmtID - Plan text¸¦ ¾òÀ» StatementÀÇ ID

aDeferredRequests - deferredµÈ prepare¿äû

Throws:

java.sql.SQLException - ¿äûÀ» º¸³»Áö ¸øÇ߰ųª, ¶Ç´Â Plan text¸¦ ¾òÀ» ¼ö ¾ø´Â °æ¿ì

readProtocolResult

protected static void readProtocolResult(CmProtocolContext aContext)
                                  throws java.sql.SQLException

ÇÁ·ÎÅäÄÝÀ» Çؼ®ÇÑ´Ù. ¸¸¾à, ºñµ¿±âÀûÀ¸·Î ¿äûÇÑ ÇÁ·ÎÅäÄÝÀÌ ÀÖ´Ù¸é ¸ÕÀú Çؼ®ÇÑ´Ù.

Parameters:

aContext - Protocol context

Throws:

java.sql.SQLException - ¼ö½Å µµÁß ¿¡·¯°¡ ¹ß»ýÇÏ¿´À» °æ¿ì

invokeDeferredRequests

public static void invokeDeferredRequests(java.util.List<java.util.Map<java.lang.String,java.lang.Object>> aDeferredRequests)