rbatis
diff --git a/‎rbdc-pg/Cargo.toml
Copy file name to clipboardExpand all lines: rbdc-pg/Cargo.toml
+1-1Lines changed: 1 addition & 1 deletion b/‎rbdc-pg/Cargo.toml
Copy file name to clipboardExpand all lines: rbdc-pg/Cargo.toml
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎rbdc-pg/src/connection/stream.rs
Copy file name to clipboardExpand all lines: rbdc-pg/src/connection/stream.rs
+2-1Lines changed: 2 additions & 1 deletion b/‎rbdc-pg/src/connection/stream.rs
Copy file name to clipboardExpand all lines: rbdc-pg/src/connection/stream.rs
+2-1Lines changed: 2 additions & 1 deletion
diff --git a/‎rbdc-pg/src/error.rs
Copy file name to clipboardExpand all lines: rbdc-pg/src/error.rs
+13Lines changed: 13 additions & 0 deletions b/‎rbdc-pg/src/error.rs
Copy file name to clipboardExpand all lines: rbdc-pg/src/error.rs
+13Lines changed: 13 additions & 0 deletions
@@ -1,6 +1,6 @@
 [package]
 name = "rbdc-pg"
-version = "4.5.18"
+version = "4.5.19"
 edition = "2021"
 description = "The Rust SQL Toolkit and ORM Library. An async, pure Rust SQL crate featuring compile-time Dynamic SQL"
 readme = "Readme.md"
 
@@ -13,6 +13,7 @@ use crate::options::PgConnectOptions;
 use rbdc::error::Error;
 use rbdc::io::{BufStream, Decode, Encode};
 use rbdc::net::{MaybeTlsStream, Socket};
+use crate::error::PgDatabaseError;
 // the stream is a separate type from the connection to uphold the invariant where an instantiated
 // [PgConnection] is a **valid** connection to postgres
 
@@ -101,7 +102,7 @@ impl PgStream {
                 MessageFormat::ErrorResponse => {
                     // An error returned from the database server.
                     let notice = message.decode::<Notice>()?;
-                    return Err(Error::from(format!("db:code={},message={}", notice.code(), notice.message())));
+                    return Err(PgDatabaseError::from(notice).into());
                 }
 
                 MessageFormat::NotificationResponse => {
 
@@ -158,3 +158,16 @@ impl Display for PgDatabaseError {
 }
 
 impl Error for PgDatabaseError {}
+
+
+impl From<Notice> for PgDatabaseError {
+    fn from(notice: Notice) -> Self {
+        PgDatabaseError(notice)
+    }
+}
+
+impl From<PgDatabaseError> for rbs::Error {
+    fn from(err: PgDatabaseError) -> Self {
+        rbs::Error::from(format!("{}:{}",err.code(), err.message()))
+    }
+}