Class ExtendedQueryProtocolHandler (0.15.0)
Stay organized with collections
Save and categorize content based on your preferences.
publicclass ExtendedQueryProtocolHandlerHandles the message flow for the extended query protocol. Wire-protocol messages are buffered in memory until a flush/sync is received.
Inherited Members
Constructors
ExtendedQueryProtocolHandler(ConnectionHandler connectionHandler)
publicExtendedQueryProtocolHandler(ConnectionHandlerconnectionHandler)Creates an ExtendedQueryProtocolHandler for the given connection.
ExtendedQueryProtocolHandler(ConnectionHandler connectionHandler, BackendConnection backendConnection)
publicExtendedQueryProtocolHandler(ConnectionHandlerconnectionHandler,BackendConnectionbackendConnection)Constructor only intended for testing.
Methods
buffer(AbstractQueryProtocolMessage message)
publicvoidbuffer(AbstractQueryProtocolMessagemessage)Buffer an extended query protocol message for execution when the next flush/sync message is received.
flush()
publicvoidflush()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).
This method will execute a #sync() if it determines that the next message in the buffer is a Sync message.
getBackendConnection()
publicBackendConnectiongetBackendConnection()Returns the backend PG connection for this query handler.
sync()
publicvoidsync()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.