public class PgBackendProtocol extends io.netty.channel.ChannelOutboundHandlerAdapter implements ODBCClientRemote
ODBCClientRemote.CursorDirection
Modifier and Type | Field and Description |
---|---|
static String |
APPLICATION_NAME |
static String |
CLIENT_ENCODING |
static String |
DEFAULT_APPLICATION_NAME |
static String |
DEFAULT_ENCODING |
static String |
SSL_HANDLER_KEY |
Constructor and Description |
---|
PgBackendProtocol(int maxLobSize,
int maxBufferSize,
SSLConfiguration config,
boolean requireSecure) |
Modifier and Type | Method and Description |
---|---|
void |
authenticationGSSContinue(byte[] serviceToken) |
void |
authenticationSucess(int processId,
int screctKey) |
void |
bindComplete() |
void |
emptyQueryReceived() |
void |
errorOccurred(String msg) |
void |
errorOccurred(Throwable t) |
static void |
escapeQuote(Writer sb,
String s) |
void |
flush() |
void |
functionCallResponse(byte[] data) |
void |
functionCallResponse(int data) |
String |
getClientEncoding() |
static String |
getCompletionTag(String sql,
Integer count) |
Charset |
getEncoding() |
void |
initialized(Properties props) |
void |
prepareCompleted(String preparedName) |
void |
ready(boolean inTransaction,
boolean failedTransaction) |
boolean |
secureData() |
void |
sendCommandComplete(String sql,
Integer count) |
void |
sendParameterDescription(int[] paramType) |
void |
sendParameterStatus(String param,
String value) |
void |
sendPortalSuspended() |
void |
sendResults(String sql,
ResultSetImpl rs,
List<PGUtil.PgColInfo> cols,
ResultsFuture<Integer> result,
ODBCClientRemote.CursorDirection direction,
int rowCount,
boolean describeRows,
short[] resultColumnFormat) |
void |
sendResultSetDescription(List<PGUtil.PgColInfo> cols,
short[] resultColumnFormat) |
void |
sendSslResponse() |
void |
sendUpdateCount(String sql,
int updateCount) |
void |
setEncoding(String value,
boolean init) |
void |
statementClosed() |
void |
terminated() |
void |
useAuthenticationGSS() |
void |
useClearTextAuthentication() |
void |
write(io.netty.channel.ChannelHandlerContext ctx,
Object msg,
io.netty.channel.ChannelPromise promise) |
bind, close, connect, deregister, disconnect, flush, read
ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable
public static final String APPLICATION_NAME
public static final String DEFAULT_APPLICATION_NAME
public static final String SSL_HANDLER_KEY
public static final String DEFAULT_ENCODING
public static final String CLIENT_ENCODING
public PgBackendProtocol(int maxLobSize, int maxBufferSize, SSLConfiguration config, boolean requireSecure)
public void write(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise) throws Exception
write
in interface io.netty.channel.ChannelOutboundHandler
write
in class io.netty.channel.ChannelOutboundHandlerAdapter
Exception
public void initialized(Properties props)
initialized
in interface ODBCClientRemote
public void useClearTextAuthentication()
useClearTextAuthentication
in interface ODBCClientRemote
public void useAuthenticationGSS()
useAuthenticationGSS
in interface ODBCClientRemote
public void authenticationGSSContinue(byte[] serviceToken)
authenticationGSSContinue
in interface ODBCClientRemote
public void authenticationSucess(int processId, int screctKey)
authenticationSucess
in interface ODBCClientRemote
public void prepareCompleted(String preparedName)
prepareCompleted
in interface ODBCClientRemote
public void bindComplete()
bindComplete
in interface ODBCClientRemote
public void errorOccurred(String msg)
errorOccurred
in interface ODBCClientRemote
public void errorOccurred(Throwable t)
errorOccurred
in interface ODBCClientRemote
public void ready(boolean inTransaction, boolean failedTransaction)
ready
in interface ODBCClientRemote
public void setEncoding(String value, boolean init)
setEncoding
in interface ODBCClientRemote
public String getClientEncoding()
public Charset getEncoding()
public void sendParameterDescription(int[] paramType)
sendParameterDescription
in interface ODBCClientRemote
public void sendResultSetDescription(List<PGUtil.PgColInfo> cols, short[] resultColumnFormat)
sendResultSetDescription
in interface ODBCClientRemote
public void sendResults(String sql, ResultSetImpl rs, List<PGUtil.PgColInfo> cols, ResultsFuture<Integer> result, ODBCClientRemote.CursorDirection direction, int rowCount, boolean describeRows, short[] resultColumnFormat)
sendResults
in interface ODBCClientRemote
public void sendUpdateCount(String sql, int updateCount)
sendUpdateCount
in interface ODBCClientRemote
public void statementClosed()
statementClosed
in interface ODBCClientRemote
public void terminated()
terminated
in interface ODBCClientRemote
public void flush()
flush
in interface ODBCClientRemote
public void emptyQueryReceived()
emptyQueryReceived
in interface ODBCClientRemote
public void sendCommandComplete(String sql, Integer count)
sendCommandComplete
in interface ODBCClientRemote
public static void escapeQuote(Writer sb, String s) throws IOException
IOException
public void sendSslResponse()
sendSslResponse
in interface ODBCClientRemote
public void sendPortalSuspended()
sendPortalSuspended
in interface ODBCClientRemote
public void sendParameterStatus(String param, String value)
sendParameterStatus
in interface ODBCClientRemote
public void functionCallResponse(byte[] data)
functionCallResponse
in interface ODBCClientRemote
public void functionCallResponse(int data)
functionCallResponse
in interface ODBCClientRemote
public boolean secureData()
Copyright © 2018 JBoss by Red Hat. All rights reserved.