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(), }) }