Sha256: c80677c16df9cfe43f9540f92f35eac4e0176a9f39120a98ef7e3a9dccd3634c

Contents?: true

Size: 1.32 KB

Versions: 1

Compression:

Stored size: 1.32 KB

Contents

# frozen_string_literal: true

require 'table_saw/connection'

module TableSaw
  module Queries
    class ForeignKeyRelationships
      QUERY = <<~SQL
        select
          tc.constraint_name,
          tc.table_name as from_table,
          tc.constraint_type,
          kcu.column_name as from_column,
          ccu.table_name as to_table,
          ccu.column_name as to_column
        from information_schema.table_constraints tc
          join information_schema.key_column_usage kcu on tc.constraint_name = kcu.constraint_name
          join information_schema.constraint_column_usage ccu on tc.constraint_name = ccu.constraint_name
        where tc.constraint_type = 'FOREIGN KEY'
      SQL

      def belongs_to
        result.each_with_object(Hash.new { |h, k| h[k] = {} }) do |row, memo|
          memo[row['from_table']][row['from_column']] = row['to_table']
        end
      end

      # rubocop:disable Naming/PredicateName
      def has_many
        @has_many ||= result.each_with_object(Hash.new { |h, k| h[k] = [] }) do |row, memo|
          memo[row['to_table']].push([row['from_table'], row['from_column']])
        end
      end
      # rubocop:enable Naming/PredicateName

      private

      def result
        @result ||= TableSaw::Connection.with do |conn|
          conn.exec(QUERY)
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
table_saw-0.1.0 lib/table_saw/queries/foreign_key_relationships.rb