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