Added support for SQLx 0.8

Author: ankane

CHANGELOG.md

@@ -1,3 +1,8 @@
+## 0.4.0 (unreleased)
+
+- Added support for SQLx 0.8
+- Dropped support for SQLx < 0.8
+
 ## 0.3.4 (2024-07-17)
 
 - Added `Eq` trait to `Bit`

Cargo.toml

@@ -16,7 +16,7 @@ doctest = false
 bytes = { version = "1", optional = true }
 postgres-types = { version = "0.2", default-features = false, optional = true }
 diesel = { version = "2", default-features = false, features = ["postgres"], optional = true }
-sqlx = { version = ">= 0.5, < 0.8", default-features = false, features = ["postgres"], optional = true }
+sqlx = { version = "0.8", default-features = false, features = ["postgres"], optional = true }
 serde = { version = "1", features = ["derive"], optional = true }
 half = { version = "2", default-features = false, optional = true }
 

src/sqlx_ext/bit.rs

@@ -13,11 +13,11 @@ impl Type<Postgres> for Bit {
 }
 
 impl Encode<'_, Postgres> for Bit {
-    fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> IsNull {
+    fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> Result<IsNull, BoxDynError> {
         let len = self.len;
-        buf.extend(&i32::try_from(len).unwrap().to_be_bytes());
+        buf.extend(&i32::try_from(len)?.to_be_bytes());
         buf.extend(&self.data);
-        IsNull::No
+        Ok(IsNull::No)
     }
 }
 

src/sqlx_ext/halfvec.rs

@@ -13,16 +13,16 @@ impl Type<Postgres> for HalfVector {
 }
 
 impl Encode<'_, Postgres> for HalfVector {
-    fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> IsNull {
+    fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> Result<IsNull, BoxDynError> {
         let dim = self.0.len();
-        buf.extend(&u16::try_from(dim).unwrap().to_be_bytes());
+        buf.extend(&u16::try_from(dim)?.to_be_bytes());
         buf.extend(&0_u16.to_be_bytes());
 
         for v in &self.0 {
             buf.extend(&v.to_be_bytes());
         }
 
-        IsNull::No
+        Ok(IsNull::No)
     }
 }
 

src/sqlx_ext/sparsevec.rs

@@ -13,11 +13,11 @@ impl Type<Postgres> for SparseVector {
 }
 
 impl Encode<'_, Postgres> for SparseVector {
-    fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> IsNull {
+    fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> Result<IsNull, BoxDynError> {
         let dim = self.dim;
         let nnz = self.indices.len();
-        buf.extend(&i32::try_from(dim).unwrap().to_be_bytes());
-        buf.extend(&i32::try_from(nnz).unwrap().to_be_bytes());
+        buf.extend(&i32::try_from(dim)?.to_be_bytes());
+        buf.extend(&i32::try_from(nnz)?.to_be_bytes());
         buf.extend(&0_i32.to_be_bytes());
 
         for v in &self.indices {
@@ -28,7 +28,7 @@ impl Encode<'_, Postgres> for SparseVector {
             buf.extend(&v.to_be_bytes());
         }
 
-        IsNull::No
+        Ok(IsNull::No)
     }
 }
 

src/sqlx_ext/vector.rs

@@ -13,16 +13,16 @@ impl Type<Postgres> for Vector {
 }
 
 impl Encode<'_, Postgres> for Vector {
-    fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> IsNull {
+    fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> Result<IsNull, BoxDynError> {
         let dim = self.0.len();
-        buf.extend(&u16::try_from(dim).unwrap().to_be_bytes());
+        buf.extend(&u16::try_from(dim)?.to_be_bytes());
         buf.extend(&0_u16.to_be_bytes());
 
         for v in &self.0 {
             buf.extend(&v.to_be_bytes());
         }
 
-        IsNull::No
+        Ok(IsNull::No)
     }
 }