Class: DatabaseValidations::Adapters::BaseAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/database_validations/lib/adapters/base_adapter.rb

Direct Known Subclasses

MysqlAdapter, PostgresqlAdapter, SqliteAdapter

Constant Summary collapse

SUPPORTED_OPTIONS =
[].freeze
ADAPTER =
:base

Instance Method Summary collapse

Constructor Details

#initialize(model) ⇒ BaseAdapter

Returns a new instance of BaseAdapter.



7
8
9
# File 'lib/database_validations/lib/adapters/base_adapter.rb', line 7

def initialize(model)
  @model = model
end

Instance Method Details

#find_foreign_key_by_column(column) ⇒ Object



37
38
39
# File 'lib/database_validations/lib/adapters/base_adapter.rb', line 37

def find_foreign_key_by_column(column)
  foreign_keys.find { |foreign_key| foreign_key.column.to_s == column.to_s }
end

#find_unique_index(columns, where) ⇒ Object

Parameters:

  • columns (Array<String>)
  • where (String)


18
19
20
# File 'lib/database_validations/lib/adapters/base_adapter.rb', line 18

def find_unique_index(columns, where)
  unique_indexes.find { |index| Array.wrap(index.columns).map(&:to_s).sort == columns && index.where == where }
end

#find_unique_index_by_name(index_name) ⇒ Object

Parameters:

  • index_name (String)


12
13
14
# File 'lib/database_validations/lib/adapters/base_adapter.rb', line 12

def find_unique_index_by_name(index_name)
  unique_indexes.find { |index| index.name == index_name }
end

#foreign_keysObject



33
34
35
# File 'lib/database_validations/lib/adapters/base_adapter.rb', line 33

def foreign_keys
  model.connection.foreign_keys(model.table_name)
end

#table_nameString

Returns:

  • (String)


42
43
44
# File 'lib/database_validations/lib/adapters/base_adapter.rb', line 42

def table_name
  model.table_name
end

#unique_indexesObject



22
23
24
25
26
27
28
29
30
31
# File 'lib/database_validations/lib/adapters/base_adapter.rb', line 22

def unique_indexes
  connection = model.connection

  if connection.schema_cache.respond_to?(:indexes)
    # Rails 6 only
    connection.schema_cache.indexes(model.table_name).select(&:unique)
  else
    connection.indexes(model.table_name).select(&:unique)
  end
end