class Multiwoven::Integrations::Destination::MariaDB::Client

def group_by_table(records)
  result = {}
  records.each_with_index do |entry, index|
    table_name = entry[:table_name]
    column_data = {
      column_name: entry[:column_name],
      data_type: entry[:data_type],
      is_nullable: entry[:is_nullable] == "YES"
    }
    result[index] ||= {}
    result[index][:tablename] = table_name
    result[index][:columns] = [column_data]
  end
  result.values.group_by { |entry| entry[:tablename] }.transform_values do |entries|
    { tablename: entries.first[:tablename], columns: entries.flat_map { |entry| entry[:columns] } }
  end
end