Class ExtendedQueryProtocolHandler (0.5.1)

public class ExtendedQueryProtocolHandler

Handles the message flow for the extended query protocol. Wire-protocol messages are buffered in memory until a flush/sync is received.

Inheritance

java.lang.Object > ExtendedQueryProtocolHandler

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

ExtendedQueryProtocolHandler(ConnectionHandler connectionHandler)

public ExtendedQueryProtocolHandler(ConnectionHandler connectionHandler)

Creates an ExtendedQueryProtocolHandler for the given connection.

Parameter

Name	Description
connectionHandler	`ConnectionHandler`

ExtendedQueryProtocolHandler(BackendConnection backendConnection)

public ExtendedQueryProtocolHandler(BackendConnection backendConnection)

Constructor only intended for testing.

Parameter

Name	Description
backendConnection	`BackendConnection`

Methods

buffer(AbstractQueryProtocolMessage message)

public void buffer(AbstractQueryProtocolMessage message)

Buffer an extended query protocol message for execution when the next flush/sync message is received.

Parameter

Name	Description
message	`AbstractQueryProtocolMessage`

flush()

public void flush()

Flushes the current queue of messages. Any pending database statements are first executed, before sending the wire-protocol responses to the frontend. A flush does not commit the implicit transaction (if any).

Exceptions

Type	Description
Exception

getBackendConnection()

public BackendConnection getBackendConnection()

Returns the backend PG connection for this query handler.

Returns

Type	Description
BackendConnection

sync()

public void sync()

Flushes the current queue of messages and commits the implicit transaction (if any). Any pending database statements are first executed, before sending the wire-protocol responses to the frontend.

Exceptions

Type	Description
Exception