com.impossibl.postgres.protocol.v30

Class ProtocolImpl

java.lang.Object

com.impossibl.postgres.protocol.v30.ProtocolImpl

All Implemented Interfaces:

Protocol

public class ProtocolImpl
extends Object
implements Protocol

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ProtocolImpl.ExecutionTimerTask

Method Summary

Methods

Modifier and Type	Method and Description
void	abort(Executor executor)
protected void	beginMessage(io.netty.buffer.ByteBuf msg, byte msgId)
protected void	beginMessage(io.netty.buffer.ByteBuf msg, byte msgId, int length)
void	cancelExecutionTimer()
BindExecCommand	createBindExec(String portalName, String statementName, List<Type> parameterTypes, List<Object> parameterValues, List<ResultField> resultFields)
CloseCommand	createClose(ServerObjectType objectType, String objectName)
FunctionCallCommand	createFunctionCall(String functionName, List<Type> parameterTypes, List<Object> parameterValues)
PrepareCommand	createPrepare(String statementName, String sqlText, List<Type> parameterTypes)
QueryCommand	createQuery(String sqlText)
SSLRequestCommand	createSSLRequest()
StartupCommand	createStartup(Map<String,Object> settings)
void	dispatch(ResponseMessage msg)
void	dispatchException(Throwable cause)
void	enableExecutionTimer(ProtocolImpl.ExecutionTimerTask task, long timeout)
protected void	endMessage(io.netty.buffer.ByteBuf msg)
void	execute(Command cmd)
BasicContext	getContext()
Throwable	getLastException()
TransactionStatus	getTransactionStatus()
boolean	isConnected()
protected void	loadParams(io.netty.buffer.ByteBuf buffer, List<Type> paramTypes, List<Object> paramValues, Context context)
protected void	receiveNotification(io.netty.buffer.ByteBuf buffer)
void	send(io.netty.buffer.ByteBuf msg)
void	shutdown()
void	writeBind(io.netty.buffer.ByteBuf msg, String portalName, String stmtName, List<Type> parameterTypes, List<Object> parameterValues, List<ResultField.Format> resultFieldFormats)
void	writeClose(io.netty.buffer.ByteBuf msg, ServerObjectType target, String targetName)
void	writeDescribe(io.netty.buffer.ByteBuf msg, ServerObjectType target, String targetName)
void	writeExecute(io.netty.buffer.ByteBuf msg, String portalName, int maxRows)
void	writeFlush(io.netty.buffer.ByteBuf msg)
void	writeFunctionCall(io.netty.buffer.ByteBuf msg, int functionId, List<Type> paramTypes, List<Object> paramValues)
protected void	writeMessage(io.netty.buffer.ByteBuf msg, byte msgId)
void	writeParse(io.netty.buffer.ByteBuf msg, String stmtName, String query, List<Type> paramTypes)
void	writePassword(io.netty.buffer.ByteBuf msg, String password)
void	writeQuery(io.netty.buffer.ByteBuf msg, String query)
void	writeSSLRequest(io.netty.buffer.ByteBuf msg)
void	writeStartup(io.netty.buffer.ByteBuf msg, Map<String,Object> params)
void	writeSync(io.netty.buffer.ByteBuf msg)
void	writeTerminate(io.netty.buffer.ByteBuf msg)

Methods inherited from class java.lang.Object

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

Method Detail

getContext

public BasicContext getContext()

getLastException

public Throwable getLastException()

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Protocol

shutdown

public void shutdown()

Specified by:

shutdown in interface Protocol

abort

public void abort(Executor executor)

Specified by:

abort in interface Protocol

createSSLRequest

public SSLRequestCommand createSSLRequest()

Specified by:

createSSLRequest in interface Protocol

createStartup

public StartupCommand createStartup(Map<String,Object> settings)

Specified by:

createStartup in interface Protocol

createPrepare

public PrepareCommand createPrepare(String statementName,
                           String sqlText,
                           List<Type> parameterTypes)

Specified by:

createPrepare in interface Protocol

createBindExec

public BindExecCommand createBindExec(String portalName,
                             String statementName,
                             List<Type> parameterTypes,
                             List<Object> parameterValues,
                             List<ResultField> resultFields)

Specified by:

createBindExec in interface Protocol

createQuery

public QueryCommand createQuery(String sqlText)

Specified by:

createQuery in interface Protocol

createFunctionCall

public FunctionCallCommand createFunctionCall(String functionName,
                                     List<Type> parameterTypes,
                                     List<Object> parameterValues)

Specified by:

createFunctionCall in interface Protocol

createClose

public CloseCommand createClose(ServerObjectType objectType,
                       String objectName)

Specified by:

createClose in interface Protocol

enableExecutionTimer

public void enableExecutionTimer(ProtocolImpl.ExecutionTimerTask task,
                        long timeout)

cancelExecutionTimer

public void cancelExecutionTimer()

execute

public void execute(Command cmd)
             throws IOException

Specified by:

execute in interface Protocol

Throws:

IOException

getTransactionStatus

public TransactionStatus getTransactionStatus()

Specified by:

getTransactionStatus in interface Protocol

writeSSLRequest

public void writeSSLRequest(io.netty.buffer.ByteBuf msg)
                     throws IOException

Throws:

IOException

writeStartup

public void writeStartup(io.netty.buffer.ByteBuf msg,
                Map<String,Object> params)
                  throws IOException

Throws:

IOException

writePassword

public void writePassword(io.netty.buffer.ByteBuf msg,
                 String password)
                   throws IOException

Throws:

IOException

writeQuery

public void writeQuery(io.netty.buffer.ByteBuf msg,
              String query)
                throws IOException

Throws:

IOException

writeParse

public void writeParse(io.netty.buffer.ByteBuf msg,
              String stmtName,
              String query,
              List<Type> paramTypes)
                throws IOException

Throws:

IOException

writeBind

public void writeBind(io.netty.buffer.ByteBuf msg,
             String portalName,
             String stmtName,
             List<Type> parameterTypes,
             List<Object> parameterValues,
             List<ResultField.Format> resultFieldFormats)
               throws IOException

Throws:

IOException

writeDescribe

public void writeDescribe(io.netty.buffer.ByteBuf msg,
                 ServerObjectType target,
                 String targetName)
                   throws IOException

Throws:

IOException

writeExecute

public void writeExecute(io.netty.buffer.ByteBuf msg,
                String portalName,
                int maxRows)
                  throws IOException

Throws:

IOException

writeFunctionCall

public void writeFunctionCall(io.netty.buffer.ByteBuf msg,
                     int functionId,
                     List<Type> paramTypes,
                     List<Object> paramValues)
                       throws IOException

Throws:

IOException

writeClose

public void writeClose(io.netty.buffer.ByteBuf msg,
              ServerObjectType target,
              String targetName)
                throws IOException

Throws:

IOException

writeFlush

public void writeFlush(io.netty.buffer.ByteBuf msg)
                throws IOException

Throws:

IOException

writeSync

public void writeSync(io.netty.buffer.ByteBuf msg)
               throws IOException

Throws:

IOException

writeTerminate

public void writeTerminate(io.netty.buffer.ByteBuf msg)
                    throws IOException

Throws:

IOException

send

public void send(io.netty.buffer.ByteBuf msg)
          throws IOException

Throws:

IOException

loadParams

protected void loadParams(io.netty.buffer.ByteBuf buffer,
              List<Type> paramTypes,
              List<Object> paramValues,
              Context context)
                   throws IOException

Throws:

IOException

writeMessage

protected void writeMessage(io.netty.buffer.ByteBuf msg,
                byte msgId)
                     throws IOException

Throws:

IOException

beginMessage

protected void beginMessage(io.netty.buffer.ByteBuf msg,
                byte msgId)

beginMessage

protected void beginMessage(io.netty.buffer.ByteBuf msg,
                byte msgId,
                int length)

endMessage

protected void endMessage(io.netty.buffer.ByteBuf msg)
                   throws IOException

Throws:

IOException

dispatch

public void dispatch(ResponseMessage msg)
              throws IOException

Throws:

IOException

dispatchException

public void dispatchException(Throwable cause)
                       throws IOException

Throws:

IOException

receiveNotification

protected void receiveNotification(io.netty.buffer.ByteBuf buffer)
                            throws IOException

Throws:

IOException