add test

postgres/examples/pooling.rs

@@ -8,7 +8,7 @@ use xitca_postgres::{
     dev::{ClientBorrowMut, Encode, Prepare, Query, Response},
     error::{DriverDown, Error},
     iter::AsyncLendingIterator,
-    transaction::Transaction,
+    transaction::{Transaction, TransactionBuilder},
     types::{Oid, Type},
     Client, Config, Execute, Postgres,
 };
@@ -103,7 +103,7 @@ impl ClientBorrowMut for PoolConnection {
 impl PoolConnection {
     // with above traits implements you can begin a transaction with your client new type
     pub async fn transaction(&mut self) -> Result<Transaction<Self>, Error> {
-        Transaction::<Self>::builder().begin(self).await
+        TransactionBuilder::new().begin(self).await
     }
 }
 

postgres/src/client.rs

@@ -22,7 +22,7 @@ use super::{
     query::Query,
     session::Session,
     statement::Statement,
-    transaction::Transaction,
+    transaction::{Transaction, TransactionBuilder},
     types::{Oid, Type},
 };
 
@@ -128,7 +128,7 @@ impl Client {
     /// start a transaction
     #[inline]
     pub fn transaction(&mut self) -> impl Future<Output = Result<Transaction<Self>, Error>> + Send {
-        Transaction::<Self>::builder().begin(self)
+        TransactionBuilder::new().begin(self)
     }
 
     /// Executes a `COPY FROM STDIN` statement, returning a sink used to write the copy data.

postgres/src/pool.rs

@@ -25,7 +25,7 @@ use super::{
     query::Query,
     session::Session,
     statement::{Statement, StatementNamed},
-    transaction::Transaction,
+    transaction::{Transaction, TransactionBuilder},
     types::{Oid, Type},
     BoxedFuture, Postgres,
 };
@@ -148,7 +148,7 @@ impl PoolConnection<'_> {
     /// function the same as [`Client::transaction`]
     #[inline]
     pub fn transaction(&mut self) -> impl Future<Output = Result<Transaction<Self>, Error>> + Send {
-        Transaction::<Self>::builder().begin(self)
+        TransactionBuilder::new().begin(self)
     }
 
     /// function the same as [`Client::copy_in`]

postgres/src/transaction.rs

@@ -93,10 +93,6 @@ impl<C> Transaction<'_, C>
 where
     C: Prepare + ClientBorrowMut,
 {
-    pub fn builder() -> TransactionBuilder {
-        TransactionBuilder::new()
-    }
-
     /// Binds a statement to a set of parameters, creating a [`Portal`] which can be incrementally queried.
     ///
     /// Portals only last for the duration of the transaction in which they are created, and can only be used on the

postgres/src/transaction/builder.rs

@@ -45,7 +45,7 @@ pub struct TransactionBuilder {
 }
 
 impl TransactionBuilder {
-    pub(crate) fn new() -> Self {
+    pub const fn new() -> Self {
         Self {
             isolation_level: None,
             read_only: None,

postgres/tests/runtime.rs

@@ -5,6 +5,7 @@ use xitca_postgres::{
     iter::AsyncLendingIterator,
     pipeline::Pipeline,
     statement::Statement,
+    transaction::{IsolationLevel, TransactionBuilder},
     types::Type,
     Client, Execute, Postgres,
 };
@@ -224,6 +225,32 @@ async fn query_portal() {
     assert!(stream3.try_next().await.unwrap().is_none());
 }
 
+#[tokio::test]
+async fn transaction_isolation() {
+    let mut client = connect("postgres://postgres:postgres@localhost:5432").await;
+
+    std::path::Path::new("samples/test.sql").execute(&client).await.unwrap();
+
+    let transaction = TransactionBuilder::new()
+        .isolation_level(IsolationLevel::Serializable)
+        .read_only(true)
+        .deferrable(true)
+        .begin(&mut client)
+        .await
+        .unwrap();
+
+    let stmt = Statement::named("SELECT id, name FROM foo ORDER BY id", &[])
+        .execute(&transaction)
+        .await
+        .unwrap();
+
+    let mut res = stmt.query(&transaction).await.unwrap();
+
+    let row = res.try_next().await.unwrap().unwrap();
+    assert_eq!(row.get::<i32>(0), 1);
+    assert_eq!(row.get::<&str>(1), "alice");
+}
+
 #[tokio::test]
 async fn query_unnamed_with_transaction() {
     let mut client = connect("postgres://postgres:postgres@localhost:5432").await;