11use crate :: query:: RowStream ;
22use crate :: types:: { BorrowToSql , ToSql , Type } ;
3- use crate :: { Client , Error , Row , Statement , ToStatement , Transaction } ;
3+ use crate :: { Client , Error , Row , SimpleQueryMessage , Statement , ToStatement , Transaction } ;
44use async_trait:: async_trait;
55
66mod private{
@@ -12,25 +12,25 @@ mod private {
1212/// This trait is "sealed", and cannot be implemented outside of this crate.
1313#[ async_trait]
1414pub trait GenericClient : private:: Sealed {
15- /// Like `Client::execute`.
15+ /// Like[ `Client::execute`] .
1616async fn execute < T > ( & self , query : & T , params : & [ & ( dyn ToSql +Sync ) ] ) ->Result < u64 , Error >
1717where
1818T : ?Sized +ToStatement +Sync +Send ;
1919
20- /// Like `Client::execute_raw`.
20+ /// Like[ `Client::execute_raw`] .
2121async fn execute_raw < P , I , T > ( & self , statement : & T , params : I ) ->Result < u64 , Error >
2222where
2323T : ?Sized +ToStatement +Sync +Send ,
2424P : BorrowToSql ,
2525I : IntoIterator < Item =P > +Sync +Send ,
2626I :: IntoIter : ExactSizeIterator ;
2727
28- /// Like `Client::query`.
28+ /// Like[ `Client::query`] .
2929async fn query < T > ( & self , query : & T , params : & [ & ( dyn ToSql +Sync ) ] ) ->Result < Vec < Row > , Error >
3030where
3131T : ?Sized +ToStatement +Sync +Send ;
3232
33- /// Like `Client::query_one`.
33+ /// Like[ `Client::query_one`] .
3434async fn query_one < T > (
3535& self ,
3636statement : & T ,
@@ -39,7 +39,7 @@ pub trait GenericClient: private::Sealed {
3939where
4040T : ?Sized +ToStatement +Sync +Send ;
4141
42- /// Like `Client::query_opt`.
42+ /// Like[ `Client::query_opt`] .
4343async fn query_opt < T > (
4444& self ,
4545statement : & T ,
@@ -48,31 +48,34 @@ pub trait GenericClient: private::Sealed {
4848where
4949T : ?Sized +ToStatement +Sync +Send ;
5050
51- /// Like `Client::query_raw`.
51+ /// Like[ `Client::query_raw`] .
5252async fn query_raw < T , P , I > ( & self , statement : & T , params : I ) ->Result < RowStream , Error >
5353where
5454T : ?Sized +ToStatement +Sync +Send ,
5555P : BorrowToSql ,
5656I : IntoIterator < Item =P > +Sync +Send ,
5757I :: IntoIter : ExactSizeIterator ;
5858
59- /// Like `Client::prepare`.
59+ /// Like[ `Client::prepare`] .
6060async fn prepare ( & self , query : & str ) ->Result < Statement , Error > ;
6161
62- /// Like `Client::prepare_typed`.
62+ /// Like[ `Client::prepare_typed`] .
6363async fn prepare_typed (
6464& self ,
6565query : & str ,
6666parameter_types : & [ Type ] ,
6767) ->Result < Statement , Error > ;
6868
69- /// Like `Client::transaction`.
69+ /// Like[ `Client::transaction`] .
7070async fn transaction ( & mut self ) ->Result < Transaction < ' _ > , Error > ;
7171
72- /// Like `Client::batch_execute`.
72+ /// Like[ `Client::batch_execute`] .
7373async fn batch_execute ( & self , query : & str ) ->Result < ( ) , Error > ;
7474
75- /// Returns a reference to the underlying `Client`.
75+ /// Like [`Client::simple_query`].
76+ async fn simple_query ( & self , query : & str ) ->Result < Vec < SimpleQueryMessage > , Error > ;
77+
78+ /// Returns a reference to the underlying [`Client`].
7679fn client ( & self ) ->& Client ;
7780}
7881
@@ -156,6 +159,10 @@ impl GenericClient for Client {
156159self . batch_execute ( query) . await
157160}
158161
162+ async fn simple_query ( & self , query : & str ) ->Result < Vec < SimpleQueryMessage > , Error > {
163+ self . simple_query ( query) . await
164+ }
165+
159166fn client ( & self ) ->& Client {
160167self
161168}
@@ -243,6 +250,10 @@ impl GenericClient for Transaction<'_> {
243250self . batch_execute ( query) . await
244251}
245252
253+ async fn simple_query ( & self , query : & str ) ->Result < Vec < SimpleQueryMessage > , Error > {
254+ self . simple_query ( query) . await
255+ }
256+
246257fn client ( & self ) ->& Client {
247258self . client ( )
248259}