class Emanator::Replica
Public Class Methods
new(target, view)
click to toggle source
# File lib/emanator.rb, line 9 def initialize(target, view) @target = target @view = view parser = SQLParser::Parser.new @ast = parser.scan_str(view) end
Public Instance Methods
operate(change)
click to toggle source
# File lib/emanator.rb, line 16 def operate(change) match(@ast, DirectSelect => select(@ast.query_expression, change)) end
process(change_data)
click to toggle source
# File lib/emanator.rb, line 26 def process(change_data) [ "UPDATE emanator_progress SET txid = #{change_data.txid}" ] end
select(query, change)
click to toggle source
# File lib/emanator.rb, line 20 def select(query, change) match(query, Select => ) end