public class CmShardProtocol
extends java.lang.Object
| Constructor and Description |
|---|
CmShardProtocol(CmProtocolContextShardConnect aShardContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
getNodeList()
»þµùÀ» ±¸¼ºÇϰí ÀÖ´Â ³ëµå¸®½ºÆ®¸¦ ÇÁ·ÎÅäÄÝÀ» ÅëÇØ ¹Þ¾Æ¿Â´Ù.
|
void |
sendConnectionReport(CmProtocolContextShardConnect aShardContextConnect,
NodeConnectionReport aReport)
¼¹ö·Î Failover Connection Report¸¦ Àü¼ÛÇÑ´Ù.
|
void |
sendShardTransactionCommitRequest(java.util.List<DataNode> aTouchedNodeList) |
void |
setChannel(CmChannel aChannel) |
void |
shardAnalyze(CmProtocolContextShardStmt aShardContextStmt,
java.lang.String aSql,
int aStmtID) |
void |
updateNodeList()
»þµùÀ» ±¸¼ºÇϰí ÀÖ´Â ³ëµå¸®½ºÆ®¸¦ ÇÁ·ÎÅäÄÝÀ» ÅëÇØ °»½ÅÇÑ´Ù.
|
public CmShardProtocol(CmProtocolContextShardConnect aShardContext)
public void getNodeList()
throws java.sql.SQLException
java.sql.SQLExceptionpublic void updateNodeList()
throws java.sql.SQLException
java.sql.SQLExceptionpublic void shardAnalyze(CmProtocolContextShardStmt aShardContextStmt, java.lang.String aSql, int aStmtID) throws java.sql.SQLException
aShardContextStmt - shard statement context °´Ã¼aSql - sql stringaStmtID - Statement IDjava.sql.SQLExceptionpublic void sendShardTransactionCommitRequest(java.util.List<DataNode> aTouchedNodeList) throws java.sql.SQLException
java.sql.SQLExceptionpublic void sendConnectionReport(CmProtocolContextShardConnect aShardContextConnect, NodeConnectionReport aReport) throws java.sql.SQLException
aShardContextConnect - shard context connect °´Ã¼aReport - Ä¿³Ø¼Ç ·¹Æ÷Æ® °´Ã¼java.sql.SQLException - ÇÁ·ÎÅäÄÝ ¼Û/¼ö½Å µµÁß ¿¹¿Ü°¡ ¹ß»ýÇÑ °æ¿ìpublic void setChannel(CmChannel aChannel)