Sha256: 2846eaa22380c136897a04ac51a08ff73857ab947030f3369a2734184f7d6a49
Contents?: true
Size: 1.99 KB
Versions: 42
Compression:
Stored size: 1.99 KB
Contents
module ActiveGraph
module Schema
class Operation
attr_reader :label, :property, :options
def initialize(label, property, options = default_options)
@label = if label.is_a?(ActiveGraph::Core::Label)
label
else
ActiveGraph::Core::Label.new(label)
end
@property = property.to_sym
@options = options
end
def self.incompatible_operation_classes
[]
end
def label_object
label
end
def create!
drop_incompatible!
return if exist?
schema_query(:"create_#{type}")
end
def incompatible_operation_classes
self.class.incompatible_operation_classes
end
def drop!
schema_query(:"drop_#{type}")
end
def drop_incompatible!
incompatible_operation_classes.each do |clazz|
operation = clazz.new(@label, property)
operation.drop! if operation.exist?
end
end
def exist?
fail 'Abstract class, not implemented'
end
def default_options
{}
end
def type
fail 'Abstract class, not implemented'
end
private
def schema_query(method)
label.send(method, property, options)
end
end
class ExactIndexOperation < ActiveGraph::Schema::Operation
def self.incompatible_operation_classes
[UniqueConstraintOperation]
end
def type
'index'
end
def exist?
label.index?(property)
end
end
class UniqueConstraintOperation < ActiveGraph::Schema::Operation
def self.incompatible_operation_classes
[ExactIndexOperation]
end
def type
'uniqueness_constraint'
end
def create!
return if exist?
super
end
def exist?
label.uniqueness_constraint?(property)
end
def default_options
{type: :unique}
end
end
end
end
Version data entries
42 entries across 42 versions & 1 rubygems