From f87b6aa95351b6198eb79467365fd07ad1e82313 Mon Sep 17 00:00:00 2001 From: Ning Sun Date: Sun, 17 Dec 2023 20:34:54 +0800 Subject: [PATCH] test: update example to new api --- examples/sqlite.rs | 8 -------- 1 file changed, 8 deletions(-) diff --git a/examples/sqlite.rs b/examples/sqlite.rs index 3262792..5c98a31 100644 --- a/examples/sqlite.rs +++ b/examples/sqlite.rs @@ -11,7 +11,6 @@ use pgwire::api::results::{ DataRowEncoder, DescribeResponse, FieldInfo, QueryResponse, Response, Tag, }; use pgwire::api::stmt::NoopQueryParser; -use pgwire::api::store::MemPortalStore; use pgwire::api::{ClientInfo, MakeHandler, Type}; use pgwire::error::{ErrorInfo, PgWireError, PgWireResult}; use pgwire::messages::data::DataRow; @@ -22,7 +21,6 @@ use tokio::net::TcpListener; pub struct SqliteBackend { conn: Arc>, - portal_store: Arc>, query_parser: Arc, } @@ -190,13 +188,8 @@ fn get_params(portal: &Portal) -> Vec> { #[async_trait] impl ExtendedQueryHandler for SqliteBackend { type Statement = String; - type PortalStore = MemPortalStore; type QueryParser = NoopQueryParser; - fn portal_store(&self) -> Arc { - self.portal_store.clone() - } - fn query_parser(&self) -> Arc { self.query_parser.clone() } @@ -289,7 +282,6 @@ impl MakeHandler for MakeSqliteBackend { fn make(&self) -> Self::Handler { Arc::new(SqliteBackend { conn: self.conn.clone(), - portal_store: Arc::new(MemPortalStore::new()), query_parser: self.query_parser.clone(), }) }