Improves error

sanpii · Jan 15, 2025 · 4b1ad12 · 4b1ad12
1 parent f35fe2b
commit 4b1ad12
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 12 deletions.
diff --git a/src/connection/_async.rs b/src/connection/_async.rs
@@ -256,7 +256,7 @@ impl Connection {
         let status = unsafe { pq_sys::PQsetnonblocking(self.into(), non_blocking as i32) };
 
         if status < 0 {
-            Err(crate::errors::Error::Unknow)
+            self.error()
         } else {
             Ok(())
         }
@@ -285,7 +285,7 @@ impl Connection {
         if status == 0 {
             Ok(())
         } else {
-            Err(crate::errors::Error::Unknow)
+            self.error()
         }
     }
 
@@ -305,7 +305,7 @@ impl Connection {
         if status == 0 {
             Ok(())
         } else {
-            Err(crate::errors::Error::Unknow)
+            self.error()
         }
     }
 
@@ -326,7 +326,7 @@ impl Connection {
         if status == 1 {
             Ok(())
         } else {
-            Err(crate::errors::Error::Unknow)
+            self.error()
         }
     }
 }
diff --git a/src/connection/_copy.rs b/src/connection/_copy.rs
@@ -24,7 +24,7 @@ impl Connection {
             -1 => self.error(),
             0 => Err(crate::errors::Error::Backend("Full buffers".to_string())),
             1 => Ok(()),
-            _ => Err(crate::errors::Error::Unknow),
+            _ => self.error(),
         }
     }
 
@@ -50,7 +50,7 @@ impl Connection {
             -1 => self.error(),
             0 => Err(crate::errors::Error::Backend("Full buffers".to_string())),
             1 => Ok(()),
-            _ => Err(crate::errors::Error::Unknow),
+            _ => self.error(),
         }
     }
 

diff --git a/src/connection/_single_row_mode.rs b/src/connection/_single_row_mode.rs
@@ -16,7 +16,7 @@ impl Connection {
         if success == 1 {
             Ok(())
         } else {
-            Err(crate::errors::Error::Unknow)
+            self.error()
         }
     }
 

diff --git a/src/connection/_status.rs b/src/connection/_status.rs
@@ -169,7 +169,7 @@ impl Connection {
         let socket = unsafe { pq_sys::PQsocket(self.into()) };
 
         if socket < 0 {
-            Err(crate::errors::Error::Unknow)
+            self.error()
         } else {
             Ok(socket)
         }

diff --git a/src/pipeline.rs b/src/pipeline.rs
@@ -37,7 +37,7 @@ pub fn enter(conn: &crate::Connection) -> crate::errors::Result {
     if success == 1 {
         Ok(())
     } else {
-        Err(crate::errors::Error::Unknow)
+        conn.error()
     }
 }
 
@@ -56,7 +56,7 @@ pub fn exit(conn: &crate::Connection) -> crate::errors::Result {
     if success == 1 {
         Ok(())
     } else {
-        Err(crate::errors::Error::Unknow)
+        conn.error()
     }
 }
 
@@ -85,7 +85,7 @@ pub fn sync(conn: &crate::Connection) -> crate::errors::Result {
     if success == 1 {
         Ok(())
     } else {
-        Err(crate::errors::Error::Unknow)
+        conn.error()
     }
 }
 
@@ -101,7 +101,7 @@ pub fn flush_request(conn: &crate::Connection) -> crate::errors::Result {
     if success == 1 {
         Ok(())
     } else {
-        Err(crate::errors::Error::Unknow)
+        conn.error()
     }
 }