chore(deps): bump pgwire from 0.35.0 to 0.36.0 (#241)

* chore(deps): bump pgwire from 0.35.0 to 0.36.0

Bumps [pgwire](https://github.com/sunng87/pgwire) from 0.35.0 to 0.36.0.
- [Release notes](https://github.com/sunng87/pgwire/releases)
- [Changelog](https://github.com/sunng87/pgwire/blob/master/CHANGELOG.md)
- [Commits](sunng87/pgwire@v0.35.0...v0.36.0)

---
updated-dependencies:
- dependency-name: pgwire
  dependency-version: 0.36.0
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <[email protected]>

* fix: update pgwire and api adoption

* test: fix test by giving encoding format

---------

Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Ning Sun <[email protected]>
Co-authored-by: Ning Sun <[email protected]>

Author: dependabot[bot]

Cargo.lock

@@ -18,7 +18,7 @@ bytes = "1.11.0"
 chrono = { version = "0.4", features = ["std"] }
 datafusion = { version = "50", default-features = false }
 futures = "0.3"
-pgwire = { version = "0.35", default-features = false }
+pgwire = { version = "0.36.1", default-features = false }
 postgres-types = "0.2"
 rust_decimal = { version = "1.39", features = ["db-postgres"] }
 tokio = { version = "1", default-features = false }

Cargo.toml

@@ -64,7 +64,7 @@ where
     S: Clone,
 {
     fn get_pg_type(
-        pg_type_hint: Option<&Type>,
+        pg_type_hint: Option<Type>,
         inferenced_type: Option<&DataType>,
     ) -> PgWireResult<Type> {
         if let Some(ty) = pg_type_hint {
@@ -80,7 +80,14 @@ where
     let mut deserialized_params = Vec::with_capacity(param_len);
     for i in 0..param_len {
         let inferenced_type = inferenced_types.get(i).and_then(|v| v.to_owned());
-        let pg_type = get_pg_type(portal.statement.parameter_types.get(i), inferenced_type)?;
+        let pg_type = get_pg_type(
+            portal
+                .statement
+                .parameter_types
+                .get(i)
+                .and_then(|f| f.clone()),
+            inferenced_type,
+        )?;
         match pg_type {
             // enumerate all supported parameter types and deserialize the
             // type to ScalarValue
@@ -156,6 +163,7 @@ where
             }
             Type::TIME => {
                 let value = portal.parameter::<NaiveTime>(i, &pg_type)?;
+                dbg!(&value);
 
                 let ns = value.map(|t| {
                     t.num_seconds_from_midnight() as i64 * 1_000_000_000 + t.nanosecond() as i64
@@ -329,22 +337,22 @@ mod tests {
     use datafusion::{common::ParamValues, scalar::ScalarValue};
     use pgwire::{
         api::{portal::Portal, stmt::StoredStatement},
-        messages::extendedquery::Bind,
+        messages::{data::FORMAT_CODE_BINARY, extendedquery::Bind},
     };
     use postgres_types::Type;
 
     use crate::datatypes::df::deserialize_parameters;
 
     #[test]
     fn test_deserialise_time_params() {
-        let postgres_types = vec![Type::TIME];
+        let postgres_types = vec![Some(Type::TIME)];
 
         let us: i64 = 1_000_000; // 1 second
 
         let bind = Bind::new(
             None,
             None,
-            vec![],
+            vec![FORMAT_CODE_BINARY],
             vec![Some(Bytes::from(i64::to_be_bytes(us).to_vec()))],
             vec![],
         );

arrow-pg/src/datatypes/df.rs

@@ -651,7 +651,7 @@ impl QueryParser for Parser {
         &self,
         client: &C,
         sql: &str,
-        _types: &[Type],
+        _types: &[Option<Type>],
     ) -> PgWireResult<Self::Statement>
     where
         C: ClientInfo + Unpin + Send + Sync,