Use psuedo type for composite

Author: trueleo

datafusion-postgres/src/datatypes.rs

@@ -66,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,
-                struct_type @ DataType::Struct(_) => Type::new(
+                DataType::Struct(_) => Type::new(
                     Type::RECORD_ARRAY.name().into(),
                     Type::RECORD_ARRAY.oid(),
-                    Kind::Array(into_pg_type(struct_type)?),
+                    Type::RECORD_ARRAY.kind().clone(),
                     Type::RECORD_ARRAY.schema().into(),
                 ),
                 list_type => {
@@ -90,16 +90,12 @@ pub(crate) fn into_pg_type(df_type: &DataType) -> PgWireResult<Type> {
                 .reduce(|a, b| a + ", " + &b)
                 .map(|x| format!("({x})"))
                 .unwrap_or("()".to_string());
-            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())
+            Type::new(
+                name,
+                Type::RECORD.oid(),
+                Type::RECORD.kind().clone(),
+                Type::RECORD.schema().into(),
+            )
         }
         _ => {
             return Err(PgWireError::UserError(Box::new(ErrorInfo::new(