class Multiwoven::Integrations::Destination::Postgresql::Client

def group_by_table(records)
  records.group_by { |entry| entry["table_name"] }.map do |table_name, columns|
    {
      tablename: table_name,
      columns: columns.map do |column|
        {
          column_name: column["column_name"],
          type: column["data_type"],
          optional: column["is_nullable"] == "YES"
        }
      end
    }
  end
end