Revert "Use psuedo type for composite"

This reverts commit 4313e41.

Author: trueleo

datafusion-postgres/src/datatypes.rs

@@ -14,6 +14,7 @@ use pgwire::api::results::{FieldInfo, QueryResponse};
 use pgwire::api::Type;
 use pgwire::error::{ErrorInfo, PgWireError, PgWireResult};
 use pgwire::messages::data::DataRow;
+use postgres_types::Kind;
 use rust_decimal::prelude::ToPrimitive;
 use rust_decimal::Decimal;
 
@@ -65,10 +66,10 @@ pub(crate) fn into_pg_type(df_type: &DataType) -> PgWireResult<Type> {
                 DataType::Float64 => Type::FLOAT8_ARRAY,
                 DataType::Utf8 => Type::VARCHAR_ARRAY,
                 DataType::LargeUtf8 => Type::TEXT_ARRAY,
-                DataType::Struct(_) => Type::new(
+                struct_type @ DataType::Struct(_) => Type::new(
                     Type::RECORD_ARRAY.name().into(),
                     Type::RECORD_ARRAY.oid(),
-                    Type::RECORD_ARRAY.kind().clone(),
+                    Kind::Array(into_pg_type(struct_type)?),
                     Type::RECORD_ARRAY.schema().into(),
                 ),
                 list_type => {
@@ -89,12 +90,16 @@ pub(crate) fn into_pg_type(df_type: &DataType) -> PgWireResult<Type> {
                 .reduce(|a, b| a + ", " + &b)
                 .map(|x| format!("({x})"))
                 .unwrap_or("()".to_string());
-            Type::new(
-                name,
-                Type::RECORD.oid(),
-                Type::RECORD.kind().clone(),
-                Type::RECORD.schema().into(),
-            )
+            let kind = Kind::Composite(
+                fields
+                    .iter()
+                    .map(|x| {
+                        into_pg_type(x.data_type())
+                            .map(|_type| postgres_types::Field::new(x.name().clone(), _type))
+                    })
+                    .collect::<Result<Vec<_>, PgWireError>>()?,
+            );
+            Type::new(name, Type::RECORD.oid(), kind, Type::RECORD.schema().into())
         }
         _ => {
             return Err(PgWireError::UserError(Box::new(ErrorInfo::new(