public class ConnectionIO extends Object
通信方式: 采用针对面向流的连接套接字的可选择通道SocketChannel
| 限定符和类型 | 字段和说明 |
|---|---|
protected static org.slf4j.Logger |
logback |
protected static boolean |
logError
logback日志对象
|
LogWriter |
lw
调试日志记录对象
|
long |
recvStartT
debug日志记录命令接收开始、结束时间
|
protected int |
serverProtocolVersion
服务器协议版本号(201老协议,301新协议)
|
long |
serverStartT
debug日志记录命令执行开始、结束时间
|
| 限定符和类型 | 方法和说明 |
|---|---|
protected void |
checkSqlLen(String sql) |
void |
endStream()
终止流式迁移
|
protected long |
getCurIdGen()
互斥取得游标(recv_mode=2)的编号
|
protected int |
getErr_Code(String str)
错误消息中提取错误码
|
protected static ScheduledThreadPoolExecutor |
getExecutorStatic()
静态返回定时作业对象
|
boolean |
getIsClosed()
2008-5-26 cao 添加判断连接是否断开的方法
|
protected int |
getNetworkTimeout() |
byte[] |
getPublic_key() |
String |
getServerIp() |
int |
getServerPort() |
protected int |
getServerProtocolVersion()
获取、设置当前连接服务器协议版本号
|
protected long |
getStIdGen()
互斥取得PreparedStatement编号
|
protected String |
getStringWithCharactor(byte[] bytes) |
byte[] |
getTrail_key() |
protected void |
reSizeBuffer()
将驱动缓存改动大4M(4*1024*1024)
|
void |
resumeConnectState()
从新和服务器建立连接够,在执行语句之前,要将连接状态复位到0
|
void |
sendBuffer(ByteBuffer buff) |
void |
sendFile(String filename) |
void |
sendLob(Parameter paramLob) |
void |
setExecuteSQL(String executeSQL) |
protected void |
setIOAutoCommit(boolean autoCommitFlag) |
protected void |
setNetworkTimeout(int sockeTimeOut) |
protected void |
setServerProtocolVersion(int serverProtocolVersion) |
public LogWriter lw
protected static boolean logError
protected static org.slf4j.Logger logback
public long serverStartT
public long recvStartT
protected int serverProtocolVersion
public void setExecuteSQL(String executeSQL)
executeSQL - the executeSQL to setpublic String getServerIp()
public int getServerPort()
public boolean getIsClosed()
public void sendLob(Parameter paramLob)
public void endStream()
throws SQLException
SQLExceptionprotected void setIOAutoCommit(boolean autoCommitFlag)
public void resumeConnectState()
public byte[] getPublic_key()
public byte[] getTrail_key()
public void sendBuffer(ByteBuffer buff) throws IOException
IOExceptionprotected long getStIdGen()
protected long getCurIdGen()
protected void reSizeBuffer()
protected static ScheduledThreadPoolExecutor getExecutorStatic()
protected int getServerProtocolVersion()
protected void setServerProtocolVersion(int serverProtocolVersion)
protected int getErr_Code(String str)
protected String getStringWithCharactor(byte[] bytes) throws SQLException
SQLExceptionprotected void setNetworkTimeout(int sockeTimeOut)
protected int getNetworkTimeout()
protected void checkSqlLen(String sql)
public void sendFile(String filename)
Copyright © 2025. All rights reserved.