Contents

# frozen_string_literal: true

module TableSync::NamingResolver
  class Sequel
    def initialize(table_name:, db:)
      @table_name = table_name
      @db = db
    end

    def table
      table_name.is_a?(::Sequel::SQL::QualifiedIdentifier) ? table_name.column : table_name
    end

    def schema
      return table_name.table if table_name.is_a?(::Sequel::SQL::QualifiedIdentifier)
      db.get(Sequel.function("current_schema")) rescue "public"
    end

    private

    attr_reader :table_name, :db
  end
end

Version data entries

28 entries across 28 versions & 1 rubygems

Version	Path
table_sync-2.3.0	lib/table_sync/naming_resolver/sequel.rb
table_sync-2.2.0	lib/table_sync/naming_resolver/sequel.rb
table_sync-2.1.0	lib/table_sync/naming_resolver/sequel.rb
table_sync-2.0.0	lib/table_sync/naming_resolver/sequel.rb
table_sync-1.13.1	lib/table_sync/naming_resolver/sequel.rb
table_sync-1.13.0	lib/table_sync/naming_resolver/sequel.rb
table_sync-1.12.1	lib/table_sync/naming_resolver/sequel.rb
table_sync-1.12.0	lib/table_sync/naming_resolver/sequel.rb