Создайте фрейм данных polars из postgres sql в общем виде

Привет, я пытаюсь читать из postgres в полярную рамку в общем виде.

Я прочитал сообщение здесь Rust: Чтение фрейма данных в полярах из mysql

о чтении из mysql и хочу изменить это, чтобы мне не нужно было обрабатывать столбцы для каждого нового запроса.

Я планировал сначала сохранить все значения в большом векторе, упорядоченном по столбцам. Хранение каждого типа в перечислении.

У меня есть следующий код.

let rows = client.query(&select_sql, &[]).await?;

  #[derive(Clone, Debug)]
  enum GenericValue {
    String(String),
    Bool(bool),
    DateTime(DateTime<Utc>),
    Int32(i32),
    UInt(u32),
  }

  let number_of_rows = rows.len();
  let number_of_columns = rows.first().expect("expected one row").columns().len();

  println!("Number of columns: {:?}", number_of_columns);
  println!("Number of rows: {:?}", number_of_rows);

  let mut data: Vec<Option<GenericValue>> = vec![None; number_of_columns * number_of_rows]; 

  for (row_index, row) in rows.iter().enumerate() {

    for (col_index, column) in row.columns().iter().enumerate() {
        let colType: String = column.type_().to_string();
        
        let index = col_index * number_of_columns + row_index;

        if colType == "int4" { 
            data[index] = Some(GenericValue::Int32(row.get(col_index)));
        }
        else if colType == "text" {
            data[index] = Some(GenericValue::String(row.get(col_index)));
        }
        else if colType == "varchar" {
          data[index] = Some(GenericValue::String(row.get(col_index)));
        }
        else if colType == "bool" {
            data[index] = Some(GenericValue::Bool(row.get(col_index)));
        }
        else if colType == "timestamptz" {
          data[index] = Some(GenericValue::DateTime(row.get(col_index)));
        }
        else {
            panic!("{}", &colType);
        }
    }

   for c in 0 .. number_of_columns {

      let start_index = c * number_of_columns;
      let slice = data[start_index .. start_index + number_of_rows];

      let first: Option<GenericValue> = data[start_index];

      let chunked_data: Utf8Chunked = slice.iter().map(|v| v.unwrap()).collect();

      println!("{:?}", chunked_data);


      // let ca_country: Utf8Chunked = values.iter().map(|v| &*v.country).collect();

   }

Проблема в том, что мне нужно реализовать трейт PolarsAsRef<str> дляGenericValue что я не уверен, как это сделать, и как эти фрагментированные данные будут обрабатывать NULLS? Как я могу создать здесь правильные фрагментированные данные для каждой серии?

Обратите внимание, что это сделано для того, чтобы отойти от коннектора, поскольку он все еще кажется привязанным к очень старым полярам. и в любом случае я не получаю от этого большого выигрыша в производительности, поскольку использую секционированные таблицы postgres, которые, похоже, нарушают параллелизм коннектора.

Спасибо