feat: update pgwire to 0.37 (#3910)

# Description of Changes

Update pgwire to 0.37

Make `DataRowEncoder` reusable as enabled in this release, make
introduce 3x performance on encoding.

# API and ABI breaking changes

N/A

# Expected complexity level and risk

N/A

# Testing

<!-- Describe any testing you've done, and any testing you'd like your
reviewers to do,
so that you're confident that all the changes work as expected! -->

- [ ] <!-- maybe a test you want to do -->
- [ ] <!-- maybe a test you want a reviewer to do, so they can check it
off when they're satisfied. -->

---------

Signed-off-by: Ning Sun <sunning@greptime.com>
Signed-off-by: joshua-spacetime <josh@clockworklabs.io>
Co-authored-by: joshua-spacetime <josh@clockworklabs.io>
Co-authored-by: Zeke Foppa <196249+bfops@users.noreply.github.com>

Author: 3 people

Cargo.lock

@@ -245,7 +245,7 @@ paste = "1.0"
 percent-encoding = "2.3"
 petgraph = { version = "0.6.5", default-features = false }
 pin-project-lite = "0.2.9"
-pgwire = { version = "0.34.2", default-features = false, features = ["server-api", "pg-ext-types"] }
+pgwire = { version = "0.37", default-features = false, features = ["server-api", "pg-ext-types"] }
 postgres-types = "0.2.5"
 pretty_assertions = { version = "1.4", features = ["unstable"] }
 proc-macro2 = "1.0"

Cargo.toml

@@ -57,7 +57,7 @@ pub(crate) fn type_of(schema: &ProductType, ty: &ProductTypeElement) -> Type {
             _ => Type::ANYARRAY,
         },
         AlgebraicType::Product(_) => match format {
-            PsqlPrintFmt::Hex => Type::BYTEA_ARRAY,
+            PsqlPrintFmt::Hex => Type::BYTEA,
             PsqlPrintFmt::Timestamp => Type::TIMESTAMP,
             PsqlPrintFmt::Duration => Type::INTERVAL,
             PsqlPrintFmt::Uuid => Type::UUID,

crates/pg/src/encoder.rs

@@ -73,9 +73,8 @@ pub(crate) fn to_rows(
     let mut results = Vec::with_capacity(stmt.rows.len());
     let ty = Typespace::EMPTY.with_type(&stmt.schema);
 
+    let mut encoder = DataRowEncoder::new(header.clone());
     for row in stmt.rows {
-        let mut encoder = DataRowEncoder::new(header.clone());
-
         for (idx, value) in ty.with_values(&row).enumerate() {
             let ty = satn::PsqlType {
                 client: PsqlClient::Postgres,
@@ -86,7 +85,7 @@ pub(crate) fn to_rows(
             let mut fmt = PsqlFormatter { encoder: &mut encoder };
             value.serialize(TypedSerializer { ty: &ty, f: &mut fmt })?;
         }
-        results.push(encoder.finish());
+        results.push(Ok(encoder.take_row()));
     }
     Ok(stream::iter(results))
 }