Struct DfSessionService

pub struct DfSessionService { /* private fields */ }

Implementations

impl DfSessionService

pub fn new( session_context: SessionContext, catalog_name: Option<String>, ) -> DfSessionService

Trait Implementations

impl ExtendedQueryHandler for DfSessionService

type Statement = LogicalPlan

type QueryParser = Parser

fn query_parser(&self) -> Arc<Self::QueryParser>

Get a reference to associated QueryParser implementation

fn do_describe_statement<'life0, 'life1, 'life2, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, target: &'life2 StoredStatement<Self::Statement>, ) -> Pin<Box<dyn Future<Output = PgWireResult<DescribeStatementResponse>> + Send + 'async_trait>>

where C: ClientInfo + Unpin + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Return resultset metadata without actually executing statement

fn do_describe_portal<'life0, 'life1, 'life2, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, target: &'life2 Portal<Self::Statement>, ) -> Pin<Box<dyn Future<Output = PgWireResult<DescribePortalResponse>> + Send + 'async_trait>>

where C: ClientInfo + Unpin + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Return resultset metadata without actually executing portal

fn do_query<'a, 'life0, 'life1, 'life2, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, portal: &'life2 Portal<Self::Statement>, _max_rows: usize, ) -> Pin<Box<dyn Future<Output = PgWireResult<Response<'a>>> + Send + 'async_trait>>

where C: ClientInfo + Unpin + Send + Sync + 'async_trait, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

This is the main implementation for query execution. Context has been provided:

fn on_parse<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Parse, ) -> Pin<Box<dyn Future<Output = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as ClientPortalStore>::PortalStore: PortalStore<Statement = Self::Statement>, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait,

Called when client sends parse command.

fn on_bind<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Bind, ) -> Pin<Box<dyn Future<Output = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as ClientPortalStore>::PortalStore: PortalStore<Statement = Self::Statement>, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait,

Called when client sends bind command.

fn on_execute<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Execute, ) -> Pin<Box<dyn Future<Output = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as ClientPortalStore>::PortalStore: PortalStore<Statement = Self::Statement>, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait,

Called when client sends execute command.

fn on_describe<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Describe, ) -> Pin<Box<dyn Future<Output = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as ClientPortalStore>::PortalStore: PortalStore<Statement = Self::Statement>, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait,

Called when client sends describe command.

fn on_flush<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, _message: Flush, ) -> Pin<Box<dyn Future<Output = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait,

Called when client sends flush command.

fn on_sync<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, _message: Sync, ) -> Pin<Box<dyn Future<Output = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait,

Called when client sends sync command.

fn on_close<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Close, ) -> Pin<Box<dyn Future<Output = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as ClientPortalStore>::PortalStore: PortalStore<Statement = Self::Statement>, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait,

Called when client sends close command.

impl NoopStartupHandler for DfSessionService

fn post_startup<'life0, 'life1, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, _message: PgWireFrontendMessage, ) -> Pin<Box<dyn Future<Output = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + 'async_trait, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: Sync + 'async_trait,

impl SimpleQueryHandler for DfSessionService

fn do_query<'a, 'life0, 'life1, 'life2, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, query: &'life2 str, ) -> Pin<Box<dyn Future<Output = PgWireResult<Vec<Response<'a>>>> + Send + 'async_trait>>

where C: ClientInfo + Unpin + Send + Sync + 'async_trait, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Provide your query implementation using the incoming query string.

fn on_query<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, query: Query, ) -> Pin<Box<dyn Future<Output = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait,

Executed on Query request arrived. This is how postgres respond to simple query. The default implementation calls do_query with the incoming query string.